X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Fnamestore%2Ftest_namestore_api_lookup_private.c;h=a387720a0e2308168230029c50d102faee8f6e93;hb=d41ed82a4ea0cc8e1674b6d5d2c49fd6462610bb;hp=cf9bfc20c46d6feb0588af4d4c8c93ec2278354b;hpb=f5f5a9f680df2cebe6435ec87650cb3cb6e3ef6e;p=oweals%2Fgnunet.git diff --git a/src/namestore/test_namestore_api_lookup_private.c b/src/namestore/test_namestore_api_lookup_private.c index cf9bfc20c..a387720a0 100644 --- a/src/namestore/test_namestore_api_lookup_private.c +++ b/src/namestore/test_namestore_api_lookup_private.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_store.c * @brief testcase for namestore_api.c: store a record @@ -32,7 +32,7 @@ #define TEST_RECORD_DATA 'a' -#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 5) +#define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 5) static struct GNUNET_NAMESTORE_Handle *nsh; @@ -51,19 +51,19 @@ static const char * name = "d"; static void -cleanup () +cleanup() { if (NULL != nsh) - { - GNUNET_NAMESTORE_disconnect (nsh); - nsh = NULL; - } + { + GNUNET_NAMESTORE_disconnect(nsh); + nsh = NULL; + } if (NULL != privkey) - { - GNUNET_free (privkey); - privkey = NULL; - } - GNUNET_SCHEDULER_shutdown (); + { + GNUNET_free(privkey); + privkey = NULL; + } + GNUNET_SCHEDULER_shutdown(); } @@ -73,152 +73,152 @@ cleanup () * @param cls handle to use to re-connect. */ static void -endbadly (void *cls) +endbadly(void *cls) { endbadly_task = NULL; if (NULL != nsqe) - { - GNUNET_NAMESTORE_cancel (nsqe); - nsqe = NULL; - } - cleanup (); + { + GNUNET_NAMESTORE_cancel(nsqe); + nsqe = NULL; + } + cleanup(); res = 1; } static void -end (void *cls) +end(void *cls) { - cleanup (); + cleanup(); res = 0; } static void -lookup_it (void *cls, - const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone, - const char *label, - unsigned int rd_count, - const struct GNUNET_GNSRECORD_Data *rd) +lookup_it(void *cls, + const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone, + const char *label, + unsigned int rd_count, + const struct GNUNET_GNSRECORD_Data *rd) { nsqe = NULL; - if (0 != GNUNET_memcmp (privkey, - zone)) - { - GNUNET_break(0); - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } + if (0 != GNUNET_memcmp(privkey, + zone)) + { + GNUNET_break(0); + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } if (NULL == label) - { - GNUNET_break(0); - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } - - if (0 != strcmp (label, name)) - { - GNUNET_break(0); - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } + { + GNUNET_break(0); + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } + + if (0 != strcmp(label, name)) + { + GNUNET_break(0); + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } if (1 != rd_count) - { - GNUNET_break(0); - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } + { + GNUNET_break(0); + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } /* Done */ - GNUNET_SCHEDULER_cancel (endbadly_task); + GNUNET_SCHEDULER_cancel(endbadly_task); endbadly_task = NULL; - GNUNET_SCHEDULER_add_now (&end, NULL); + GNUNET_SCHEDULER_add_now(&end, NULL); } static void -fail_cb (void *cls) +fail_cb(void *cls) { - GNUNET_assert (0); + GNUNET_assert(0); } static void -put_cont (void *cls, - int32_t success, - const char *emsg) +put_cont(void *cls, + int32_t success, + const char *emsg) { const char *name = cls; nsqe = NULL; - GNUNET_assert (NULL != cls); - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Name store added record for `%s': %s\n", - name, - (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); + GNUNET_assert(NULL != cls); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Name store added record for `%s': %s\n", + name, + (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); if (GNUNET_OK != success) - { - GNUNET_SCHEDULER_cancel (endbadly_task); - endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); - return; - } + { + GNUNET_SCHEDULER_cancel(endbadly_task); + endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); + return; + } /* Lookup */ - nsqe = GNUNET_NAMESTORE_records_lookup (nsh, - privkey, - name, - &fail_cb, - NULL, - &lookup_it, - NULL); + nsqe = GNUNET_NAMESTORE_records_lookup(nsh, + privkey, + name, + &fail_cb, + NULL, + &lookup_it, + NULL); } 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) { struct GNUNET_GNSRECORD_Data rd; - endbadly_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, - &endbadly, - NULL); - privkey = GNUNET_CRYPTO_ecdsa_key_create (); - GNUNET_assert (privkey != NULL); - GNUNET_CRYPTO_ecdsa_key_get_public (privkey, &pubkey); + endbadly_task = GNUNET_SCHEDULER_add_delayed(TIMEOUT, + &endbadly, + NULL); + privkey = GNUNET_CRYPTO_ecdsa_key_create(); + GNUNET_assert(privkey != NULL); + GNUNET_CRYPTO_ecdsa_key_get_public(privkey, &pubkey); rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us; rd.record_type = TEST_RECORD_TYPE; rd.data_size = TEST_RECORD_DATALEN; - rd.data = GNUNET_malloc (TEST_RECORD_DATALEN); + rd.data = GNUNET_malloc(TEST_RECORD_DATALEN); rd.flags = 0; - memset ((char *) rd.data, 'a', TEST_RECORD_DATALEN); - - nsh = GNUNET_NAMESTORE_connect (cfg); - GNUNET_break (NULL != nsh); - nsqe = GNUNET_NAMESTORE_records_store (nsh, - privkey, - name, - 1, - &rd, - &put_cont, - (void *) name); + memset((char *)rd.data, 'a', TEST_RECORD_DATALEN); + + nsh = GNUNET_NAMESTORE_connect(cfg); + GNUNET_break(NULL != nsh); + nsqe = GNUNET_NAMESTORE_records_store(nsh, + privkey, + name, + 1, + &rd, + &put_cont, + (void *)name); if (NULL == nsqe) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - _("Namestore cannot store no block\n")); - } + { + GNUNET_log(GNUNET_ERROR_TYPE_ERROR, + _("Namestore cannot store no block\n")); + } - GNUNET_free ((void *)rd.data); + GNUNET_free((void *)rd.data); } @@ -226,7 +226,7 @@ run (void *cls, int -main (int argc, char *argv[]) +main(int argc, char *argv[]) { const char *plugin_name; char *cfg_name; @@ -234,16 +234,16 @@ main (int argc, char *argv[]) SETUP_CFG(plugin_name, cfg_name); res = 1; if (0 != - GNUNET_TESTING_peer_run ("test-namestore-api-lookup-private", - 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-lookup-private", + cfg_name, + &run, + NULL)) + { + res = 1; + } + GNUNET_DISK_purge_cfg_dir(cfg_name, + "GNUNET_TEST_HOME"); + GNUNET_free(cfg_name); return res; }