1 files changed, 228 insertions, 223 deletions

diff --git a/src/datastore/test_plugin_datastore.c b/src/datastore/test_plugin_datastore.c
index 2b7bf9ae4..a260e1575 100644
--- a/src/datastore/test_plugin_datastore.c
+++ b/src/datastore/test_plugin_datastore.c
@@ -16,7 +16,7 @@
      along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
      SPDX-License-Identifier: AGPL3.0-or-later
-*/
+ */
 /*
  * @file test_plugin_datastore.c
  * @brief Test database plugin directly, calling each API function once
@@ -44,8 +44,7 @@ static const char *plugin_name;
 
 static int ok;
 
-enum RunPhase
-{
+enum RunPhase {
   RP_ERROR = 0,
   RP_PUT,
   RP_GET,
@@ -57,8 +56,7 @@ enum RunPhase
 };
 
 
-struct CpsRunContext
-{
+struct CpsRunContext {
   const struct GNUNET_CONFIGURATION_Handle *cfg;
   struct GNUNET_DATASTORE_PluginFunctions *api;
   enum RunPhase phase;
@@ -76,14 +74,14 @@ struct CpsRunContext
  *        0 for "reset to empty"
  */
 static void
-disk_utilization_change_cb (void *cls, int delta)
+disk_utilization_change_cb(void *cls, int delta)
 {
   /* do nothing */
 }
 
 
 static void
-test (void *cls);
+test(void *cls);
 
 
 /**
@@ -96,47 +94,47 @@ test (void *cls);
  * @param msg error message on error
  */
 static void
-put_continuation (void *cls,
-                  const struct GNUNET_HashCode *key,
-                  uint32_t size,
-                  int status,
-                  const char *msg)
+put_continuation(void *cls,
+                 const struct GNUNET_HashCode *key,
+                 uint32_t size,
+                 int status,
+                 const char *msg)
 {
   struct CpsRunContext *crc = cls;
   static unsigned long long os;
   unsigned long long cs;
 
   if (GNUNET_OK != status)
-  {
-    fprintf (stderr,
-             "ERROR: `%s'\n",
-             msg);
-  }
+    {
+      fprintf(stderr,
+              "ERROR: `%s'\n",
+              msg);
+    }
   else
-  {
-    crc->api->estimate_size (crc->api->cls,
-                             &cs);
-    GNUNET_assert (os <= cs);
-    os = cs;
-    stored_bytes += size;
-    stored_ops++;
-    stored_entries++;
-  }
-  GNUNET_SCHEDULER_add_now (&test, crc);
+    {
+      crc->api->estimate_size(crc->api->cls,
+                              &cs);
+      GNUNET_assert(os <= cs);
+      os = cs;
+      stored_bytes += size;
+      stored_ops++;
+      stored_entries++;
+    }
+  GNUNET_SCHEDULER_add_now(&test, crc);
 }
 
 
 static void
-gen_key (int i, struct GNUNET_HashCode * key)
+gen_key(int i, struct GNUNET_HashCode * key)
 {
-  memset (key, 0, sizeof (struct GNUNET_HashCode));
-  key->bits[0] = (unsigned int) i;
-  GNUNET_CRYPTO_hash (key, sizeof (struct GNUNET_HashCode), key);
+  memset(key, 0, sizeof(struct GNUNET_HashCode));
+  key->bits[0] = (unsigned int)i;
+  GNUNET_CRYPTO_hash(key, sizeof(struct GNUNET_HashCode), key);
 }
 
 
 static void
-do_put (struct CpsRunContext *crc)
+do_put(struct CpsRunContext *crc)
 {
   char value[65536];
   size_t size;
@@ -145,45 +143,45 @@ do_put (struct CpsRunContext *crc)
   static int i;
 
   if (PUT_10 == i)
-  {
-    i = 0;
-    crc->phase++;
-    GNUNET_SCHEDULER_add_now (&test, crc);
-    return;
-  }
+    {
+      i = 0;
+      crc->phase++;
+      GNUNET_SCHEDULER_add_now(&test, crc);
+      return;
+    }
   /* most content is 32k */
   size = 32 * 1024;
 
-  if (0 != i && GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 16) == 0)   /* but some of it is less! */
-    size = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 32 * 1024);
+  if (0 != i && GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, 16) == 0)    /* but some of it is less! */
+    size = GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, 32 * 1024);
   size = size - (size & 7);     /* always multiple of 8 */
 
   /* generate random key */
-  gen_key (i, &key);
-  memset (value, i, size);
+  gen_key(i, &key);
+  memset(value, i, size);
   if (i > 255)
-    memset (value, i - 255, size / 2);
+    memset(value, i - 255, size / 2);
   value[0] = crc->i;
-  prio = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 100);
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-              "putting type %u, anon %u under key %s\n", i + 1, i,
-              GNUNET_h2s (&key));
-  crc->api->put (crc->api->cls,
-                 &key,
-                 false /* absent */,
-                 size,
-                 value, i + 1 /* type */ ,
-                 prio,
-                 i /* anonymity */ ,
-                 0 /* replication */ ,
-                 GNUNET_TIME_relative_to_absolute
-                   (GNUNET_TIME_relative_multiply
-                     (GNUNET_TIME_UNIT_MILLISECONDS,
-                      60 * 60 * 60 * 1000 +
-                      GNUNET_CRYPTO_random_u32
+  prio = GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, 100);
+  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+             "putting type %u, anon %u under key %s\n", i + 1, i,
+             GNUNET_h2s(&key));
+  crc->api->put(crc->api->cls,
+                &key,
+                false /* absent */,
+                size,
+                value, i + 1 /* type */,
+                prio,
+                i /* anonymity */,
+                0 /* replication */,
+                GNUNET_TIME_relative_to_absolute
+                  (GNUNET_TIME_relative_multiply
+                    (GNUNET_TIME_UNIT_MILLISECONDS,
+                    60 * 60 * 60 * 1000 +
+                    GNUNET_CRYPTO_random_u32
                       (GNUNET_CRYPTO_QUALITY_WEAK, 1000))),
-                 put_continuation,
-                 crc);
+                put_continuation,
+                crc);
   i++;
 }
 
@@ -192,51 +190,51 @@ static uint64_t guid;
 
 
 static int
-iterate_one_shot (void *cls,
-                  const struct GNUNET_HashCode *key,
-                  uint32_t size,
-                  const void *data,
-                  enum GNUNET_BLOCK_Type type,
-                  uint32_t priority,
-                  uint32_t anonymity,
-                  uint32_t replication,
-                  struct GNUNET_TIME_Absolute expiration,
-                  uint64_t uid)
+iterate_one_shot(void *cls,
+                 const struct GNUNET_HashCode *key,
+                 uint32_t size,
+                 const void *data,
+                 enum GNUNET_BLOCK_Type type,
+                 uint32_t priority,
+                 uint32_t anonymity,
+                 uint32_t replication,
+                 struct GNUNET_TIME_Absolute expiration,
+                 uint64_t uid)
 {
   struct CpsRunContext *crc = cls;
 
-  GNUNET_assert (NULL != key);
+  GNUNET_assert(NULL != key);
   guid = uid;
   crc->phase++;
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-              "Found result type=%u, priority=%u, size=%u, expire=%s, key %s\n",
-              (unsigned int) type,
-              (unsigned int) priority,
-              (unsigned int) size,
-              GNUNET_STRINGS_absolute_time_to_string (expiration),
-              GNUNET_h2s (key));
-  GNUNET_SCHEDULER_add_now (&test,
-                            crc);
+  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+             "Found result type=%u, priority=%u, size=%u, expire=%s, key %s\n",
+             (unsigned int)type,
+             (unsigned int)priority,
+             (unsigned int)size,
+             GNUNET_STRINGS_absolute_time_to_string(expiration),
+             GNUNET_h2s(key));
+  GNUNET_SCHEDULER_add_now(&test,
+                           crc);
   return GNUNET_OK;
 }
 
 
 static void
-remove_continuation (void *cls,
-                     const struct GNUNET_HashCode *key,
-                     uint32_t size,
-                     int status,
-                     const char *msg)
+remove_continuation(void *cls,
+                    const struct GNUNET_HashCode *key,
+                    uint32_t size,
+                    int status,
+                    const char *msg)
 {
   struct CpsRunContext *crc = cls;
 
-  GNUNET_assert (NULL != key);
-  GNUNET_assert (32768 == size);
-  GNUNET_assert (GNUNET_OK == status);
-  GNUNET_assert (NULL == msg);
+  GNUNET_assert(NULL != key);
+  GNUNET_assert(32768 == size);
+  GNUNET_assert(GNUNET_OK == status);
+  GNUNET_assert(NULL == msg);
   crc->phase++;
-  GNUNET_SCHEDULER_add_now (&test,
-                            crc);
+  GNUNET_SCHEDULER_add_now(&test,
+                           crc);
 }
 
 
@@ -248,28 +246,28 @@ remove_continuation (void *cls,
  * @param cfg configuration to use
  */
 static void
-unload_plugin (struct GNUNET_DATASTORE_PluginFunctions *api,
-               const struct GNUNET_CONFIGURATION_Handle *cfg)
+unload_plugin(struct GNUNET_DATASTORE_PluginFunctions *api,
+              const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
   char *name;
   char *libname;
 
   if (GNUNET_OK !=
-      GNUNET_CONFIGURATION_get_value_string (cfg,
-                                             "DATASTORE",
-                                             "DATABASE",
-                                             &name))
-  {
-    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
-                _("No `%s' specified for `%s' in configuration!\n"),
-                "DATABASE",
-                "DATASTORE");
-    return;
-  }
-  GNUNET_asprintf (&libname, "libgnunet_plugin_datastore_%s", name);
-  GNUNET_break (NULL == GNUNET_PLUGIN_unload (libname, api));
-  GNUNET_free (libname);
-  GNUNET_free (name);
+      GNUNET_CONFIGURATION_get_value_string(cfg,
+                                            "DATASTORE",
+                                            "DATABASE",
+                                            &name))
+    {
+      GNUNET_log(GNUNET_ERROR_TYPE_ERROR,
+                 _("No `%s' specified for `%s' in configuration!\n"),
+                 "DATABASE",
+                 "DATASTORE");
+      return;
+    }
+  GNUNET_asprintf(&libname, "libgnunet_plugin_datastore_%s", name);
+  GNUNET_break(NULL == GNUNET_PLUGIN_unload(libname, api));
+  GNUNET_free(libname);
+  GNUNET_free(name);
 }
 
 
@@ -279,92 +277,99 @@ unload_plugin (struct GNUNET_DATASTORE_PluginFunctions *api,
  * the transport and core.
  */
 static void
-cleaning_task (void *cls)
+cleaning_task(void *cls)
 {
   struct CpsRunContext *crc = cls;
 
-  unload_plugin (crc->api, crc->cfg);
-  GNUNET_free (crc);
+  unload_plugin(crc->api, crc->cfg);
+  GNUNET_free(crc);
 }
 
 
 static void
-test (void *cls)
+test(void *cls)
 {
   struct CpsRunContext *crc = cls;
   struct GNUNET_HashCode key;
 
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-              "In phase %d, iteration %u\n", crc->phase, crc->cnt);
+  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+             "In phase %d, iteration %u\n", crc->phase, crc->cnt);
   switch (crc->phase)
-  {
-  case RP_ERROR:
-    ok = 1;
-    GNUNET_break (0);
-    crc->api->drop (crc->api->cls);
-    GNUNET_SCHEDULER_add_now (&cleaning_task, crc);
-    break;
-  case RP_PUT:
-    do_put (crc);
-    break;
-  case RP_GET:
-    if (crc->cnt == 1)
     {
-      crc->cnt = 0;
-      crc->phase++;
-      GNUNET_SCHEDULER_add_now (&test, crc);
+    case RP_ERROR:
+      ok = 1;
+      GNUNET_break(0);
+      crc->api->drop(crc->api->cls);
+      GNUNET_SCHEDULER_add_now(&cleaning_task, crc);
       break;
-    }
-    gen_key (5, &key);
-    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-                "Looking for %s\n",
-                GNUNET_h2s (&key));
-    crc->api->get_key (crc->api->cls,
-                       0,
-                       false,
-                       &key,
-                       GNUNET_BLOCK_TYPE_ANY,
-                       &iterate_one_shot,
-                       crc);
-    break;
-  case RP_ITER_ZERO:
-    if (crc->cnt == 1)
-    {
-      crc->cnt = 0;
-      crc->phase++;
-      GNUNET_SCHEDULER_add_now (&test, crc);
+
+    case RP_PUT:
+      do_put(crc);
       break;
-    }
-    crc->api->get_zero_anonymity (crc->api->cls, 0, 1, &iterate_one_shot, crc);
-    break;
-  case RP_REPL_GET:
-    crc->api->get_replication (crc->api->cls, &iterate_one_shot, crc);
-    break;
-  case RP_EXPI_GET:
-    crc->api->get_expiration (crc->api->cls, &iterate_one_shot, crc);
-    break;
-  case RP_REMOVE:
+
+    case RP_GET:
+      if (crc->cnt == 1)
+        {
+          crc->cnt = 0;
+          crc->phase++;
+          GNUNET_SCHEDULER_add_now(&test, crc);
+          break;
+        }
+      gen_key(5, &key);
+      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+                 "Looking for %s\n",
+                 GNUNET_h2s(&key));
+      crc->api->get_key(crc->api->cls,
+                        0,
+                        false,
+                        &key,
+                        GNUNET_BLOCK_TYPE_ANY,
+                        &iterate_one_shot,
+                        crc);
+      break;
+
+    case RP_ITER_ZERO:
+      if (crc->cnt == 1)
+        {
+          crc->cnt = 0;
+          crc->phase++;
+          GNUNET_SCHEDULER_add_now(&test, crc);
+          break;
+        }
+      crc->api->get_zero_anonymity(crc->api->cls, 0, 1, &iterate_one_shot, crc);
+      break;
+
+    case RP_REPL_GET:
+      crc->api->get_replication(crc->api->cls, &iterate_one_shot, crc);
+      break;
+
+    case RP_EXPI_GET:
+      crc->api->get_expiration(crc->api->cls, &iterate_one_shot, crc);
+      break;
+
+    case RP_REMOVE:
     {
       struct GNUNET_HashCode key;
       uint32_t size = 32768;
       char value[size];
 
-      gen_key (0, &key);
-      memset (value, 0, size);
+      gen_key(0, &key);
+      memset(value, 0, size);
       value[0] = crc->i;
-      crc->api->remove_key (crc->api->cls,
-                            &key,
-                            size,
-                            value,
-                            &remove_continuation,
-                            crc);
+      crc->api->remove_key(crc->api->cls,
+                           &key,
+                           size,
+                           value,
+                           &remove_continuation,
+                           crc);
+      break;
+    }
+
+    case RP_DROP:
+      crc->api->drop(crc->api->cls);
+      GNUNET_SCHEDULER_add_now(&cleaning_task, crc);
       break;
     }
-  case RP_DROP:
-    crc->api->drop (crc->api->cls);
-    GNUNET_SCHEDULER_add_now (&cleaning_task, crc);
-    break;
-  }
 }
 
 
@@ -372,7 +377,7 @@ test (void *cls)
  * Load the datastore plugin.
  */
 static struct GNUNET_DATASTORE_PluginFunctions *
-load_plugin (const struct GNUNET_CONFIGURATION_Handle *cfg)
+load_plugin(const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
   static struct GNUNET_DATASTORE_PluginEnvironment env;
   struct GNUNET_DATASTORE_PluginFunctions *ret;
@@ -380,61 +385,61 @@ load_plugin (const struct GNUNET_CONFIGURATION_Handle *cfg)
   char *libname;
 
   if (GNUNET_OK !=
-      GNUNET_CONFIGURATION_get_value_string (cfg,
-                                             "DATASTORE",
-                                             "DATABASE",
-                                             &name))
-  {
-    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
-                _("No `%s' specified for `%s' in configuration!\n"),
-                "DATABASE",
-                "DATASTORE");
-    return NULL;
-  }
+      GNUNET_CONFIGURATION_get_value_string(cfg,
+                                            "DATASTORE",
+                                            "DATABASE",
+                                            &name))
+    {
+      GNUNET_log(GNUNET_ERROR_TYPE_ERROR,
+                 _("No `%s' specified for `%s' in configuration!\n"),
+                 "DATABASE",
+                 "DATASTORE");
+      return NULL;
+    }
   env.cfg = cfg;
   env.duc = &disk_utilization_change_cb;
   env.cls = NULL;
-  GNUNET_log (GNUNET_ERROR_TYPE_INFO, _("Loading `%s' datastore plugin\n"),
-              name);
-  GNUNET_asprintf (&libname, "libgnunet_plugin_datastore_%s", name);
-  if (NULL == (ret = GNUNET_PLUGIN_load (libname, &env)))
-  {
-    fprintf (stderr, "Failed to load plugin `%s'!\n", name);
-    GNUNET_free (libname);
-    GNUNET_free (name);
-    ok = 77; /* mark test as skipped */
-    return NULL;
-  }
-  GNUNET_free (libname);
-  GNUNET_free (name);
+  GNUNET_log(GNUNET_ERROR_TYPE_INFO, _("Loading `%s' datastore plugin\n"),
+             name);
+  GNUNET_asprintf(&libname, "libgnunet_plugin_datastore_%s", name);
+  if (NULL == (ret = GNUNET_PLUGIN_load(libname, &env)))
+    {
+      fprintf(stderr, "Failed to load plugin `%s'!\n", name);
+      GNUNET_free(libname);
+      GNUNET_free(name);
+      ok = 77; /* mark test as skipped */
+      return NULL;
+    }
+  GNUNET_free(libname);
+  GNUNET_free(name);
   return ret;
 }
 
 
 static void
-run (void *cls, char *const *args, const char *cfgfile,
-     const struct GNUNET_CONFIGURATION_Handle *c)
+run(void *cls, char *const *args, const char *cfgfile,
+    const struct GNUNET_CONFIGURATION_Handle *c)
 {
   struct GNUNET_DATASTORE_PluginFunctions *api;
   struct CpsRunContext *crc;
 
-  api = load_plugin (c);
+  api = load_plugin(c);
   if (api == NULL)
-  {
-    fprintf (stderr,
-             "%s", "Could not initialize plugin, assuming database not configured. Test not run!\n");
-    return;
-  }
-  crc = GNUNET_new (struct CpsRunContext);
+    {
+      fprintf(stderr,
+              "%s", "Could not initialize plugin, assuming database not configured. Test not run!\n");
+      return;
+    }
+  crc = GNUNET_new(struct CpsRunContext);
   crc->api = api;
   crc->cfg = c;
   crc->phase = RP_PUT;
-  GNUNET_SCHEDULER_add_now (&test, crc);
+  GNUNET_SCHEDULER_add_now(&test, crc);
 }
 
 
 int
-main (int argc, char *argv[])
+main(int argc, char *argv[])
 {
   char dir_name[PATH_MAX];
   char cfg_name[PATH_MAX];
@@ -449,20 +454,20 @@ main (int argc, char *argv[])
   };
 
   /* determine name of plugin to use */
-  plugin_name = GNUNET_TESTING_get_testname_from_underscore (argv[0]);
-  GNUNET_snprintf (dir_name, sizeof (dir_name),
-                   "/tmp/test-gnunet-datastore-plugin-%s", plugin_name);
-  GNUNET_DISK_directory_remove (dir_name);
-  GNUNET_log_setup ("test-plugin-datastore",
-                    "WARNING",
-                    NULL);
-  GNUNET_snprintf (cfg_name, sizeof (cfg_name),
-                   "test_plugin_datastore_data_%s.conf", plugin_name);
-  GNUNET_PROGRAM_run ((sizeof (xargv) / sizeof (char *)) - 1, xargv,
-                      "test-plugin-datastore", "nohelp", options, &run, NULL);
-  if ( (0 != ok) && (77 != ok) )
-    fprintf (stderr, "Missed some testcases: %u\n", ok);
-  GNUNET_DISK_directory_remove (dir_name);
+  plugin_name = GNUNET_TESTING_get_testname_from_underscore(argv[0]);
+  GNUNET_snprintf(dir_name, sizeof(dir_name),
+                  "/tmp/test-gnunet-datastore-plugin-%s", plugin_name);
+  GNUNET_DISK_directory_remove(dir_name);
+  GNUNET_log_setup("test-plugin-datastore",
+                   "WARNING",
+                   NULL);
+  GNUNET_snprintf(cfg_name, sizeof(cfg_name),
+                  "test_plugin_datastore_data_%s.conf", plugin_name);
+  GNUNET_PROGRAM_run((sizeof(xargv) / sizeof(char *)) - 1, xargv,
+                     "test-plugin-datastore", "nohelp", options, &run, NULL);
+  if ((0 != ok) && (77 != ok))
+    fprintf(stderr, "Missed some testcases: %u\n", ok);
+  GNUNET_DISK_directory_remove(dir_name);
   return ok;
 }