diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-03-07 19:10:51 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-03-07 19:10:51 +0000 |
commit | cd0ad4c559f9338eec2a152ded51d16e021eca06 (patch) | |
tree | 151c7e7b1483f4b50411e1fd30be1091cc7480bd /src/fs | |
parent | 71c9ff44f0b1b1f6c3dc72e945644e47ab5ab921 (diff) | |
download | gnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.tar.gz gnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.zip |
-indentation and comment fixes
Diffstat (limited to 'src/fs')
-rw-r--r-- | src/fs/gnunet-service-fs_lc.c | 15 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs_pr.c | 17 |
2 files changed, 21 insertions, 11 deletions
diff --git a/src/fs/gnunet-service-fs_lc.c b/src/fs/gnunet-service-fs_lc.c index 2f19e3d5d..0e68718ac 100644 --- a/src/fs/gnunet-service-fs_lc.c +++ b/src/fs/gnunet-service-fs_lc.c | |||
@@ -327,7 +327,8 @@ GSF_local_client_start_search_handler_ (struct GNUNET_SERVER_Client *client, | |||
327 | return GNUNET_SYSERR; | 327 | return GNUNET_SYSERR; |
328 | } | 328 | } |
329 | GNUNET_STATISTICS_update (GSF_stats, | 329 | GNUNET_STATISTICS_update (GSF_stats, |
330 | gettext_noop ("# client searches received"), 1, | 330 | gettext_noop ("# client searches received"), |
331 | 1, | ||
331 | GNUNET_NO); | 332 | GNUNET_NO); |
332 | sc = (msize - sizeof (struct SearchMessage)) / sizeof (struct GNUNET_HashCode); | 333 | sc = (msize - sizeof (struct SearchMessage)) / sizeof (struct GNUNET_HashCode); |
333 | sm = (const struct SearchMessage *) message; | 334 | sm = (const struct SearchMessage *) message; |
@@ -349,7 +350,9 @@ GSF_local_client_start_search_handler_ (struct GNUNET_SERVER_Client *client, | |||
349 | (SEARCH_MESSAGE_OPTION_CONTINUED was always set) and that have a | 350 | (SEARCH_MESSAGE_OPTION_CONTINUED was always set) and that have a |
350 | matching query and type */ | 351 | matching query and type */ |
351 | if ((GNUNET_YES != prd->has_started) && | 352 | if ((GNUNET_YES != prd->has_started) && |
352 | (0 != memcmp (&prd->query, &sm->query, sizeof (struct GNUNET_HashCode))) && | 353 | (0 != memcmp (&prd->query, |
354 | &sm->query, | ||
355 | sizeof (struct GNUNET_HashCode))) && | ||
353 | (prd->type == type)) | 356 | (prd->type == type)) |
354 | break; | 357 | break; |
355 | cr = cr->next; | 358 | cr = cr->next; |
@@ -359,7 +362,9 @@ GSF_local_client_start_search_handler_ (struct GNUNET_SERVER_Client *client, | |||
359 | { | 362 | { |
360 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 363 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
361 | "Have existing request, merging content-seen lists.\n"); | 364 | "Have existing request, merging content-seen lists.\n"); |
362 | GSF_pending_request_update_ (cr->pr, (const struct GNUNET_HashCode *) &sm[1], sc); | 365 | GSF_pending_request_update_ (cr->pr, |
366 | (const struct GNUNET_HashCode *) &sm[1], | ||
367 | sc); | ||
363 | GNUNET_STATISTICS_update (GSF_stats, | 368 | GNUNET_STATISTICS_update (GSF_stats, |
364 | gettext_noop | 369 | gettext_noop |
365 | ("# client searches updated (merged content seen list)"), | 370 | ("# client searches updated (merged content seen list)"), |
@@ -372,7 +377,9 @@ GSF_local_client_start_search_handler_ (struct GNUNET_SERVER_Client *client, | |||
372 | GNUNET_NO); | 377 | GNUNET_NO); |
373 | cr = GNUNET_new (struct ClientRequest); | 378 | cr = GNUNET_new (struct ClientRequest); |
374 | cr->lc = lc; | 379 | cr->lc = lc; |
375 | GNUNET_CONTAINER_DLL_insert (lc->cr_head, lc->cr_tail, cr); | 380 | GNUNET_CONTAINER_DLL_insert (lc->cr_head, |
381 | lc->cr_tail, | ||
382 | cr); | ||
376 | options = GSF_PRO_LOCAL_REQUEST; | 383 | options = GSF_PRO_LOCAL_REQUEST; |
377 | if (0 != (SEARCH_MESSAGE_OPTION_LOOPBACK_ONLY & ntohl (sm->options))) | 384 | if (0 != (SEARCH_MESSAGE_OPTION_LOOPBACK_ONLY & ntohl (sm->options))) |
378 | options |= GSF_PRO_LOCAL_ONLY; | 385 | options |= GSF_PRO_LOCAL_ONLY; |
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c index 709874f75..c1ef6891c 100644 --- a/src/fs/gnunet-service-fs_pr.c +++ b/src/fs/gnunet-service-fs_pr.c | |||
@@ -1275,11 +1275,13 @@ warn_delay_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
1275 | { | 1275 | { |
1276 | struct GSF_PendingRequest *pr = cls; | 1276 | struct GSF_PendingRequest *pr = cls; |
1277 | 1277 | ||
1278 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | 1278 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING | GNUNET_ERROR_TYPE_BULK, |
1279 | _("Datastore lookup already took %s!\n"), | 1279 | _("Datastore lookup already took %s!\n"), |
1280 | GNUNET_STRINGS_relative_time_to_string (GNUNET_TIME_absolute_get_duration (pr->qe_start), GNUNET_YES)); | 1280 | GNUNET_STRINGS_relative_time_to_string (GNUNET_TIME_absolute_get_duration (pr->qe_start), |
1281 | GNUNET_YES)); | ||
1281 | pr->warn_task = | 1282 | pr->warn_task = |
1282 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, &warn_delay_task, | 1283 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, |
1284 | &warn_delay_task, | ||
1283 | pr); | 1285 | pr); |
1284 | } | 1286 | } |
1285 | 1287 | ||
@@ -1514,10 +1516,10 @@ process_local_reply (void *cls, | |||
1514 | ((GNUNET_YES == GSF_test_get_load_too_high_ (0)) || | 1516 | ((GNUNET_YES == GSF_test_get_load_too_high_ (0)) || |
1515 | (pr->public_data.results_found > 5 + 2 * pr->public_data.priority))) | 1517 | (pr->public_data.results_found > 5 + 2 * pr->public_data.priority))) |
1516 | { | 1518 | { |
1517 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Load too high, done with request\n"); | 1519 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1520 | "Load too high, done with request\n"); | ||
1518 | GNUNET_STATISTICS_update (GSF_stats, | 1521 | GNUNET_STATISTICS_update (GSF_stats, |
1519 | gettext_noop | 1522 | gettext_noop ("# Datastore lookups concluded (load too high)"), |
1520 | ("# Datastore lookups concluded (load too high)"), | ||
1521 | 1, | 1523 | 1, |
1522 | GNUNET_NO); | 1524 | GNUNET_NO); |
1523 | goto check_error_and_continue; | 1525 | goto check_error_and_continue; |
@@ -1626,7 +1628,8 @@ GSF_local_lookup_ (struct GSF_PendingRequest *pr, | |||
1626 | pr->llc_cont_cls = cont_cls; | 1628 | pr->llc_cont_cls = cont_cls; |
1627 | pr->qe_start = GNUNET_TIME_absolute_get (); | 1629 | pr->qe_start = GNUNET_TIME_absolute_get (); |
1628 | pr->warn_task = | 1630 | pr->warn_task = |
1629 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, &warn_delay_task, | 1631 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, |
1632 | &warn_delay_task, | ||
1630 | pr); | 1633 | pr); |
1631 | #if INSANE_STATISTICS | 1634 | #if INSANE_STATISTICS |
1632 | GNUNET_STATISTICS_update (GSF_stats, | 1635 | GNUNET_STATISTICS_update (GSF_stats, |