From d41ed82a4ea0cc8e1674b6d5d2c49fd6462610bb Mon Sep 17 00:00:00 2001 From: ng0 Date: Sun, 8 Sep 2019 12:33:09 +0000 Subject: uncrustify as demanded. --- src/namestore/test_namestore_api_monitoring.c | 390 +++++++++++++------------- 1 file changed, 195 insertions(+), 195 deletions(-) (limited to 'src/namestore/test_namestore_api_monitoring.c') diff --git a/src/namestore/test_namestore_api_monitoring.c b/src/namestore/test_namestore_api_monitoring.c index 8fbeb6479..f1ee980cc 100644 --- a/src/namestore/test_namestore_api_monitoring.c +++ b/src/namestore/test_namestore_api_monitoring.c @@ -11,12 +11,12 @@ WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details. - + You should have received a copy of the GNU Affero General Public License along with this program. If not, see . SPDX-License-Identifier: AGPL3.0-or-later -*/ + */ /** * @file namestore/test_namestore_api_monitoring.c * @brief testcase for zone monitoring functionality: monitor first, then add records @@ -31,7 +31,7 @@ -#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 100) +#define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 100) static struct GNUNET_NAMESTORE_Handle * nsh; @@ -62,63 +62,63 @@ struct GNUNET_NAMESTORE_QueueEntry * ns_ops[3]; static void -do_shutdown () +do_shutdown() { if (NULL != zm) - { - GNUNET_NAMESTORE_zone_monitor_stop (zm); - zm = NULL; - } + { + GNUNET_NAMESTORE_zone_monitor_stop(zm); + zm = NULL; + } if (NULL != ns_ops[0]) - { - GNUNET_NAMESTORE_cancel(ns_ops[0]); - ns_ops[0] = NULL; - } + { + GNUNET_NAMESTORE_cancel(ns_ops[0]); + ns_ops[0] = NULL; + } if (NULL != ns_ops[1]) - { - GNUNET_NAMESTORE_cancel(ns_ops[1]); - ns_ops[1] = NULL; - } + { + GNUNET_NAMESTORE_cancel(ns_ops[1]); + ns_ops[1] = NULL; + } if (NULL != ns_ops[2]) - { - GNUNET_NAMESTORE_cancel(ns_ops[2]); - ns_ops[2] = NULL; - } + { + GNUNET_NAMESTORE_cancel(ns_ops[2]); + ns_ops[2] = NULL; + } if (NULL != nsh) - { - GNUNET_NAMESTORE_disconnect (nsh); - nsh = NULL; - } + { + GNUNET_NAMESTORE_disconnect(nsh); + nsh = NULL; + } GNUNET_free_non_null(s_name_1); GNUNET_free_non_null(s_name_2); GNUNET_free_non_null(s_name_3); if (s_rd_1 != NULL) - { - GNUNET_free ((void *)s_rd_1->data); - GNUNET_free (s_rd_1); - } + { + GNUNET_free((void *)s_rd_1->data); + GNUNET_free(s_rd_1); + } if (s_rd_2 != NULL) - { - GNUNET_free ((void *)s_rd_2->data); - GNUNET_free (s_rd_2); - } + { + GNUNET_free((void *)s_rd_2->data); + GNUNET_free(s_rd_2); + } if (s_rd_3 != NULL) - { - GNUNET_free ((void *)s_rd_3->data); - GNUNET_free (s_rd_3); - } + { + GNUNET_free((void *)s_rd_3->data); + GNUNET_free(s_rd_3); + } if (NULL != privkey) - { - GNUNET_free (privkey); - privkey = NULL; - } + { + GNUNET_free(privkey); + privkey = NULL; + } if (NULL != privkey2) - { - GNUNET_free (privkey2); - privkey2 = NULL; - } + { + GNUNET_free(privkey2); + privkey2 = NULL; + } } @@ -128,218 +128,218 @@ do_shutdown () * @param cls handle to use to re-connect. */ static void -endbadly (void *cls) +endbadly(void *cls) { - do_shutdown (); + do_shutdown(); res = 1; } static void -end (void *cls) +end(void *cls) { - do_shutdown (); + do_shutdown(); res = 0; } static void -zone_proc (void *cls, - const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone_key, - const char *name, - unsigned int rd_count, - const struct GNUNET_GNSRECORD_Data *rd) +zone_proc(void *cls, + const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone_key, + const char *name, + unsigned int rd_count, + const struct GNUNET_GNSRECORD_Data *rd) { static int returned_records; static int fail = GNUNET_NO; - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Comparing results name %s\n", - name); - if (0 != GNUNET_memcmp (zone_key, - privkey)) - { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Monitoring returned wrong zone key\n"); - GNUNET_break (0); - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } - - if (0 == strcmp (name, s_name_1)) - { - if (GNUNET_YES != GNUNET_GNSRECORD_records_cmp(rd, s_rd_1)) + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Comparing results name %s\n", + name); + if (0 != GNUNET_memcmp(zone_key, + privkey)) + { + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Monitoring returned wrong zone key\n"); + GNUNET_break(0); + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } + + if (0 == strcmp(name, s_name_1)) { - GNUNET_break (0); - fail = GNUNET_YES; + if (GNUNET_YES != GNUNET_GNSRECORD_records_cmp(rd, s_rd_1)) + { + GNUNET_break(0); + fail = GNUNET_YES; + } } - } - else if (0 == strcmp (name, s_name_2)) - { - if (GNUNET_YES != GNUNET_GNSRECORD_records_cmp(rd, s_rd_2)) + else if (0 == strcmp(name, s_name_2)) { - GNUNET_break (0); - fail = GNUNET_YES; + if (GNUNET_YES != GNUNET_GNSRECORD_records_cmp(rd, s_rd_2)) + { + GNUNET_break(0); + fail = GNUNET_YES; + } } - } else - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Invalid name %s\n", - name); - GNUNET_break (0); - fail = GNUNET_YES; - } - GNUNET_NAMESTORE_zone_monitor_next (zm, - 1); + { + GNUNET_log(GNUNET_ERROR_TYPE_ERROR, + "Invalid name %s\n", + name); + GNUNET_break(0); + fail = GNUNET_YES; + } + GNUNET_NAMESTORE_zone_monitor_next(zm, + 1); if (2 == ++returned_records) - { - if (endbadly_task != NULL) { - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = NULL; + if (endbadly_task != NULL) + { + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = NULL; + } + if (GNUNET_YES == fail) + GNUNET_SCHEDULER_add_now(&endbadly, NULL); + else + GNUNET_SCHEDULER_add_now(&end, NULL); } - if (GNUNET_YES == fail) - GNUNET_SCHEDULER_add_now (&endbadly, NULL); - else - GNUNET_SCHEDULER_add_now (&end, NULL); - } } static void -put_cont (void *cls, - int32_t success, - const char *emsg) +put_cont(void *cls, + int32_t success, + const char *emsg) { static int c = 0; char *label = cls; - if (0 == strcmp (label, s_name_1)) + if (0 == strcmp(label, s_name_1)) ns_ops[0] = NULL; - else if (0 == strcmp (label, s_name_2)) + else if (0 == strcmp(label, s_name_2)) ns_ops[1] = NULL; - else if (0 == strcmp (label, s_name_3)) + else if (0 == strcmp(label, s_name_3)) ns_ops[2] = NULL; if (success == GNUNET_OK) - { - c++; - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Created record %u: `%s'\n", - c, - label); - } + { + c++; + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Created record %u: `%s'\n", + c, + label); + } else - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Failed to create record `%s'\n", - label); - GNUNET_break (0); - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, - NULL); - } + { + GNUNET_log(GNUNET_ERROR_TYPE_ERROR, + "Failed to create record `%s'\n", + label); + GNUNET_break(0); + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, + NULL); + } } static struct GNUNET_GNSRECORD_Data * -create_record (unsigned int count) +create_record(unsigned int count) { struct GNUNET_GNSRECORD_Data *rd; - rd = GNUNET_new_array (count, - struct GNUNET_GNSRECORD_Data); + rd = GNUNET_new_array(count, + struct GNUNET_GNSRECORD_Data); for (unsigned int c = 0; c < count; c++) - { - rd[c].expiration_time = GNUNET_TIME_relative_to_absolute (GNUNET_TIME_UNIT_HOURS).abs_value_us; - rd[c].record_type = TEST_RECORD_TYPE; - rd[c].data_size = 50; - rd[c].data = GNUNET_malloc(50); - rd[c].flags = 0; - memset ((char *) rd[c].data, 'a', 50); - } + { + rd[c].expiration_time = GNUNET_TIME_relative_to_absolute(GNUNET_TIME_UNIT_HOURS).abs_value_us; + rd[c].record_type = TEST_RECORD_TYPE; + rd[c].data_size = 50; + rd[c].data = GNUNET_malloc(50); + rd[c].flags = 0; + memset((char *)rd[c].data, 'a', 50); + } return rd; } static void -fail_cb (void *cls) +fail_cb(void *cls) { - GNUNET_assert (0); + GNUNET_assert(0); } static void -sync_cb (void *cls) +sync_cb(void *cls) { /* do nothing */ } static void -run (void *cls, - const struct GNUNET_CONFIGURATION_Handle *cfg, - struct GNUNET_TESTING_Peer *peer) +run(void *cls, + const struct GNUNET_CONFIGURATION_Handle *cfg, + struct GNUNET_TESTING_Peer *peer) { res = 1; - privkey = GNUNET_CRYPTO_ecdsa_key_create (); - GNUNET_assert (privkey != NULL); + privkey = GNUNET_CRYPTO_ecdsa_key_create(); + GNUNET_assert(privkey != NULL); /* Start monitoring */ - zm = GNUNET_NAMESTORE_zone_monitor_start (cfg, - privkey, - GNUNET_YES, - &fail_cb, - NULL, - &zone_proc, - NULL, - &sync_cb, - NULL); + zm = GNUNET_NAMESTORE_zone_monitor_start(cfg, + privkey, + GNUNET_YES, + &fail_cb, + NULL, + &zone_proc, + NULL, + &sync_cb, + NULL); if (NULL == zm) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Failed to create zone monitor\n"); - GNUNET_break (0); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } - - endbadly_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &endbadly, NULL); + { + GNUNET_log(GNUNET_ERROR_TYPE_ERROR, + "Failed to create zone monitor\n"); + GNUNET_break(0); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } + + endbadly_task = GNUNET_SCHEDULER_add_delayed(TIMEOUT, &endbadly, NULL); /* Connect to namestore */ - nsh = GNUNET_NAMESTORE_connect (cfg); + nsh = GNUNET_NAMESTORE_connect(cfg); if (NULL == nsh) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Connect to namestore\n"); - GNUNET_break (0); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } + { + GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Connect to namestore\n"); + GNUNET_break(0); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } - privkey2 = GNUNET_CRYPTO_ecdsa_key_create (); - GNUNET_assert (privkey2 != NULL); + privkey2 = GNUNET_CRYPTO_ecdsa_key_create(); + GNUNET_assert(privkey2 != NULL); - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Created record 3\n"); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Created record 3\n"); /* name in different zone */ GNUNET_asprintf(&s_name_3, "dummy3"); s_rd_3 = create_record(1); - GNUNET_assert (NULL != (ns_ops[2] = - GNUNET_NAMESTORE_records_store (nsh, - privkey2, - s_name_3, - 1, - s_rd_3, - &put_cont, - s_name_3))); - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Created record 1\n"); + GNUNET_assert(NULL != (ns_ops[2] = + GNUNET_NAMESTORE_records_store(nsh, + privkey2, + s_name_3, + 1, + s_rd_3, + &put_cont, + s_name_3))); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Created record 1\n"); GNUNET_asprintf(&s_name_1, "dummy1"); s_rd_1 = create_record(1); - GNUNET_assert (NULL != (ns_ops[0] = - GNUNET_NAMESTORE_records_store (nsh, + GNUNET_assert(NULL != (ns_ops[0] = + GNUNET_NAMESTORE_records_store(nsh, privkey, s_name_1, 1, @@ -348,11 +348,11 @@ run (void *cls, s_name_1))); - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created record 2 \n"); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Created record 2 \n"); GNUNET_asprintf(&s_name_2, "dummy2"); s_rd_2 = create_record(1); - GNUNET_assert (NULL != (ns_ops[1] = - GNUNET_NAMESTORE_records_store (nsh, + GNUNET_assert(NULL != (ns_ops[1] = + GNUNET_NAMESTORE_records_store(nsh, privkey, s_name_2, 1, @@ -366,25 +366,25 @@ run (void *cls, int -main (int argc, - char *argv[]) +main(int argc, + char *argv[]) { const char *plugin_name; char *cfg_name; - SETUP_CFG (plugin_name, cfg_name); + SETUP_CFG(plugin_name, cfg_name); res = 1; if (0 != - GNUNET_TESTING_peer_run ("test-namestore-api-monitoring", - cfg_name, - &run, - NULL)) - { - res = 1; - } - GNUNET_DISK_purge_cfg_dir (cfg_name, - "GNUNET_TEST_HOME"); - GNUNET_free (cfg_name); + GNUNET_TESTING_peer_run("test-namestore-api-monitoring", + cfg_name, + &run, + NULL)) + { + res = 1; + } + GNUNET_DISK_purge_cfg_dir(cfg_name, + "GNUNET_TEST_HOME"); + GNUNET_free(cfg_name); return res; } -- cgit v1.2.3