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/fs/test_fs_search_with_and.c | 285 ++++++++++++++++++++------------------- 1 file changed, 148 insertions(+), 137 deletions(-) (limited to 'src/fs/test_fs_search_with_and.c') diff --git a/src/fs/test_fs_search_with_and.c b/src/fs/test_fs_search_with_and.c index f1072a4a1..e43b8e25a 100644 --- a/src/fs/test_fs_search_with_and.c +++ b/src/fs/test_fs_search_with_and.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 fs/test_fs_search_with_and.c * @brief testcase for publishing multiple files and search with a and operator @@ -42,12 +42,12 @@ /** * How long until we give up on transmitting the message? */ -#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60) +#define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 60) /** * How long should our test-content live? */ -#define LIFETIME GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 15) +#define LIFETIME GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 15) static struct GNUNET_TIME_Absolute start; @@ -66,140 +66,150 @@ static int processed_files; static void -abort_publish_task (void *cls) +abort_publish_task(void *cls) { if (NULL != publish) - { - GNUNET_FS_publish_stop (publish); - publish = NULL; - } + { + GNUNET_FS_publish_stop(publish); + publish = NULL; + } if (NULL != timeout_task) - { - GNUNET_SCHEDULER_cancel (timeout_task); - timeout_task = NULL; - } + { + GNUNET_SCHEDULER_cancel(timeout_task); + timeout_task = NULL; + } } static void -abort_error (void *cls) +abort_error(void *cls) { - fprintf (stderr, - "Timeout\n"); + fprintf(stderr, + "Timeout\n"); timeout_task = NULL; if (NULL != search) - { - GNUNET_FS_search_stop (search); - search = NULL; - } + { + GNUNET_FS_search_stop(search); + search = NULL; + } if (NULL != publish) - { - GNUNET_FS_publish_stop (publish); - publish = NULL; - } + { + GNUNET_FS_publish_stop(publish); + publish = NULL; + } err = 1; } static void -abort_search_task (void *cls) +abort_search_task(void *cls) { if (NULL != search) - { - GNUNET_FS_search_stop (search); - search = NULL; - } + { + GNUNET_FS_search_stop(search); + search = NULL; + } } static void * -progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) +progress_cb(void *cls, const struct GNUNET_FS_ProgressInfo *event) { - struct GNUNET_FS_Uri *kuri; switch (event->status) - { - case GNUNET_FS_STATUS_PUBLISH_PROGRESS: - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Publish is progressing (%llu/%llu at level %u off %llu)...\n", - (unsigned long long) event->value.publish.completed, - (unsigned long long) event->value.publish.size, - event->value.publish.specifics.progress.depth, - (unsigned long long) event->value.publish.specifics. - progress.offset); - break; - case GNUNET_FS_STATUS_PUBLISH_PROGRESS_DIRECTORY: - break; - case GNUNET_FS_STATUS_PUBLISH_COMPLETED: - processed_files++; - if(processed_files == NUM_FILES) - { - char *emsg = NULL; - kuri = GNUNET_FS_uri_ksk_create ("+down_foo +down_bar", &emsg); - GNUNET_assert (kuri != NULL); - - start = GNUNET_TIME_absolute_get (); - search = - GNUNET_FS_search_start (fs, kuri, 1, GNUNET_FS_SEARCH_OPTION_NONE, - "search"); - GNUNET_FS_uri_destroy (kuri); - GNUNET_assert (search != NULL); - } - break; - case GNUNET_FS_STATUS_SEARCH_RESULT: - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Search complete.\n"); - GNUNET_SCHEDULER_add_now (&abort_search_task, NULL); - break; - case GNUNET_FS_STATUS_PUBLISH_ERROR: - fprintf (stderr, "Error publishing file: %s\n", - event->value.publish.specifics.error.message); - GNUNET_break (0); - GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); - break; - case GNUNET_FS_STATUS_SEARCH_ERROR: - fprintf (stderr, "Error searching file: %s\n", - event->value.search.specifics.error.message); - GNUNET_SCHEDULER_add_now (&abort_search_task, NULL); - break; - case GNUNET_FS_STATUS_PUBLISH_START: - GNUNET_assert (0 == strcmp ("publish-context", event->value.publish.cctx)); - GNUNET_assert (NULL == event->value.publish.pctx); - GNUNET_assert (FILESIZE == event->value.publish.size); - GNUNET_assert (0 == event->value.publish.completed); - GNUNET_assert (1 == event->value.publish.anonymity); - break; - case GNUNET_FS_STATUS_PUBLISH_STOPPED: - GNUNET_assert (publish == event->value.publish.pc); - GNUNET_assert (FILESIZE == event->value.publish.size); - GNUNET_assert (1 == event->value.publish.anonymity); - GNUNET_FS_stop (fs); - fs = NULL; - break; - case GNUNET_FS_STATUS_SEARCH_START: - GNUNET_assert (search == NULL); - GNUNET_assert (0 == strcmp ("search", event->value.search.cctx)); - GNUNET_assert (1 == event->value.search.anonymity); - break; - case GNUNET_FS_STATUS_SEARCH_RESULT_STOPPED: - break; - case GNUNET_FS_STATUS_SEARCH_STOPPED: - GNUNET_assert (search == event->value.search.sc); - GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); - break; - default: - fprintf (stderr, "Unexpected event: %d\n", event->status); - break; - } + { + case GNUNET_FS_STATUS_PUBLISH_PROGRESS: + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Publish is progressing (%llu/%llu at level %u off %llu)...\n", + (unsigned long long)event->value.publish.completed, + (unsigned long long)event->value.publish.size, + event->value.publish.specifics.progress.depth, + (unsigned long long)event->value.publish.specifics. + progress.offset); + break; + + case GNUNET_FS_STATUS_PUBLISH_PROGRESS_DIRECTORY: + break; + + case GNUNET_FS_STATUS_PUBLISH_COMPLETED: + processed_files++; + if (processed_files == NUM_FILES) + { + char *emsg = NULL; + kuri = GNUNET_FS_uri_ksk_create("+down_foo +down_bar", &emsg); + GNUNET_assert(kuri != NULL); + + start = GNUNET_TIME_absolute_get(); + search = + GNUNET_FS_search_start(fs, kuri, 1, GNUNET_FS_SEARCH_OPTION_NONE, + "search"); + GNUNET_FS_uri_destroy(kuri); + GNUNET_assert(search != NULL); + } + break; + + case GNUNET_FS_STATUS_SEARCH_RESULT: + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Search complete.\n"); + GNUNET_SCHEDULER_add_now(&abort_search_task, NULL); + break; + + case GNUNET_FS_STATUS_PUBLISH_ERROR: + fprintf(stderr, "Error publishing file: %s\n", + event->value.publish.specifics.error.message); + GNUNET_break(0); + GNUNET_SCHEDULER_add_now(&abort_publish_task, NULL); + break; + + case GNUNET_FS_STATUS_SEARCH_ERROR: + fprintf(stderr, "Error searching file: %s\n", + event->value.search.specifics.error.message); + GNUNET_SCHEDULER_add_now(&abort_search_task, NULL); + break; + + case GNUNET_FS_STATUS_PUBLISH_START: + GNUNET_assert(0 == strcmp("publish-context", event->value.publish.cctx)); + GNUNET_assert(NULL == event->value.publish.pctx); + GNUNET_assert(FILESIZE == event->value.publish.size); + GNUNET_assert(0 == event->value.publish.completed); + GNUNET_assert(1 == event->value.publish.anonymity); + break; + + case GNUNET_FS_STATUS_PUBLISH_STOPPED: + GNUNET_assert(publish == event->value.publish.pc); + GNUNET_assert(FILESIZE == event->value.publish.size); + GNUNET_assert(1 == event->value.publish.anonymity); + GNUNET_FS_stop(fs); + fs = NULL; + break; + + case GNUNET_FS_STATUS_SEARCH_START: + GNUNET_assert(search == NULL); + GNUNET_assert(0 == strcmp("search", event->value.search.cctx)); + GNUNET_assert(1 == event->value.search.anonymity); + break; + + case GNUNET_FS_STATUS_SEARCH_RESULT_STOPPED: + break; + + case GNUNET_FS_STATUS_SEARCH_STOPPED: + GNUNET_assert(search == event->value.search.sc); + GNUNET_SCHEDULER_add_now(&abort_publish_task, NULL); + break; + + default: + fprintf(stderr, "Unexpected event: %d\n", event->status); + break; + } return 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) { const char *keywords[] = { "down_foo", @@ -213,46 +223,47 @@ run (void *cls, size_t i; size_t j; - fs = GNUNET_FS_start (cfg, "test-fs-search", &progress_cb, NULL, - GNUNET_FS_FLAGS_NONE, GNUNET_FS_OPTIONS_END); - GNUNET_assert (NULL != fs); + fs = GNUNET_FS_start(cfg, "test-fs-search", &progress_cb, NULL, + GNUNET_FS_FLAGS_NONE, GNUNET_FS_OPTIONS_END); + GNUNET_assert(NULL != fs); processed_files = 0; - for(j = 0; j < NUM_FILES; j++){ - buf = GNUNET_malloc (FILESIZE); - for (i = 0; i < FILESIZE; i++) - buf[i] = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 256); - meta = GNUNET_CONTAINER_meta_data_create (); - kuri = GNUNET_FS_uri_ksk_create_from_args (2, keywords); - bo.content_priority = 42; - bo.anonymity_level = 1; - bo.replication_level = 0; - bo.expiration_time = GNUNET_TIME_relative_to_absolute (LIFETIME); - fi = GNUNET_FS_file_information_create_from_data (fs, "publish-context", - FILESIZE, buf, kuri, meta, - GNUNET_NO, &bo); - GNUNET_FS_uri_destroy (kuri); - GNUNET_CONTAINER_meta_data_destroy (meta); - GNUNET_assert (NULL != fi); - start = GNUNET_TIME_absolute_get (); - publish = - GNUNET_FS_publish_start (fs, fi, NULL, NULL, NULL, + for (j = 0; j < NUM_FILES; j++) + { + buf = GNUNET_malloc(FILESIZE); + for (i = 0; i < FILESIZE; i++) + buf[i] = GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, 256); + meta = GNUNET_CONTAINER_meta_data_create(); + kuri = GNUNET_FS_uri_ksk_create_from_args(2, keywords); + bo.content_priority = 42; + bo.anonymity_level = 1; + bo.replication_level = 0; + bo.expiration_time = GNUNET_TIME_relative_to_absolute(LIFETIME); + fi = GNUNET_FS_file_information_create_from_data(fs, "publish-context", + FILESIZE, buf, kuri, meta, + GNUNET_NO, &bo); + GNUNET_FS_uri_destroy(kuri); + GNUNET_CONTAINER_meta_data_destroy(meta); + GNUNET_assert(NULL != fi); + start = GNUNET_TIME_absolute_get(); + publish = + GNUNET_FS_publish_start(fs, fi, NULL, NULL, NULL, GNUNET_FS_PUBLISH_OPTION_NONE); - GNUNET_assert (publish != NULL); - } + GNUNET_assert(publish != NULL); + } - timeout_task = GNUNET_SCHEDULER_add_delayed (LIFETIME, - &abort_error, NULL); + timeout_task = GNUNET_SCHEDULER_add_delayed(LIFETIME, + &abort_error, NULL); } int -main (int argc, char *argv[]) +main(int argc, char *argv[]) { - if (0 != GNUNET_TESTING_peer_run ("test-fs-search-with-and", - "test_fs_search_data.conf", - &run, NULL)) + if (0 != GNUNET_TESTING_peer_run("test-fs-search-with-and", + "test_fs_search_data.conf", + &run, NULL)) return 1; return err; } -- cgit v1.2.3