diff options
| author | Christian Grothoff <christian@grothoff.org> | 2024-03-03 11:07:57 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2024-03-03 11:07:57 +0100 |
| commit | 311e3fb7455d3383685ff8d93a3861a6ea3f3c07 (patch) | |
| tree | 20d68e03855a8fee067a2ec3ddf3d9437c4333f3 | |
| parent | d5b3ae3b0f1d955df7a701d7f6a7546ff20cdc4d (diff) | |
| -rw-r--r-- | src/service/datastore/gnunet-service-datastore.c | 9 | ||||
| -rw-r--r-- | src/service/datastore/perf_datastore_api.c | 3 | ||||
| -rw-r--r-- | src/service/datastore/test_datastore_api_management.c | 13 |
3 files changed, 17 insertions, 8 deletions
diff --git a/src/service/datastore/gnunet-service-datastore.c b/src/service/datastore/gnunet-service-datastore.c index f45e71ee9..d42e16fe2 100644 --- a/src/service/datastore/gnunet-service-datastore.c +++ b/src/service/datastore/gnunet-service-datastore.c @@ -1078,11 +1078,13 @@ handle_remove (void *cls, const struct DataMessage *dm) * @param message the actual message */ static void -handle_drop (void *cls, const struct GNUNET_MessageHeader *message) +handle_drop (void *cls, + const struct GNUNET_MessageHeader *message) { struct GNUNET_SERVICE_Client *client = cls; - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Processing DROP request\n"); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Processing DROP request\n"); do_drop = GNUNET_YES; GNUNET_SERVICE_client_continue (client); } @@ -1330,7 +1332,8 @@ cleaning_task (void *cls) } if (GNUNET_YES == do_drop) { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Dropping database!\n"); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Dropping database!\n"); plugin->api->drop (plugin->api->cls); payload = 0; last_sync++; diff --git a/src/service/datastore/perf_datastore_api.c b/src/service/datastore/perf_datastore_api.c index f7d9fa544..3b5488168 100644 --- a/src/service/datastore/perf_datastore_api.c +++ b/src/service/datastore/perf_datastore_api.c @@ -507,7 +507,8 @@ run_continuation (void *cls) break; case RP_ERROR: - GNUNET_DATASTORE_disconnect (datastore, GNUNET_YES); + GNUNET_DATASTORE_disconnect (datastore, + GNUNET_YES); GNUNET_free (crc); ok = 1; break; diff --git a/src/service/datastore/test_datastore_api_management.c b/src/service/datastore/test_datastore_api_management.c index b9b134fbc..de99d757d 100644 --- a/src/service/datastore/test_datastore_api_management.c +++ b/src/service/datastore/test_datastore_api_management.c @@ -262,7 +262,8 @@ run_continuation (void *cls) case RP_DONE: GNUNET_assert (0 == crc->i); GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Finished, disconnecting\n"); - GNUNET_DATASTORE_disconnect (datastore, GNUNET_YES); + GNUNET_DATASTORE_disconnect (datastore, + GNUNET_YES); GNUNET_free (crc); ok = 0; } @@ -270,7 +271,9 @@ run_continuation (void *cls) static void -run_tests (void *cls, int success, struct GNUNET_TIME_Absolute min_expiration, +run_tests (void *cls, + int success, + struct GNUNET_TIME_Absolute min_expiration, const char *msg) { struct CpsRunContext *crc = cls; @@ -280,11 +283,13 @@ run_tests (void *cls, int success, struct GNUNET_TIME_Absolute min_expiration, fprintf (stderr, "Test 'put' operation failed with error `%s' database likely not setup, skipping test.\n", msg); - GNUNET_DATASTORE_disconnect (datastore, GNUNET_YES); + GNUNET_DATASTORE_disconnect (datastore, + GNUNET_YES); GNUNET_free (crc); return; } - GNUNET_SCHEDULER_add_now (&run_continuation, crc); + GNUNET_SCHEDULER_add_now (&run_continuation, + crc); } |