aboutsummaryrefslogtreecommitdiff
path: root/src/fs
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-03-07 19:10:51 +0000
committerChristian Grothoff <christian@grothoff.org>2015-03-07 19:10:51 +0000
commitcd0ad4c559f9338eec2a152ded51d16e021eca06 (patch)
tree151c7e7b1483f4b50411e1fd30be1091cc7480bd /src/fs
parent71c9ff44f0b1b1f6c3dc72e945644e47ab5ab921 (diff)
downloadgnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.tar.gz
gnunet-cd0ad4c559f9338eec2a152ded51d16e021eca06.zip
-indentation and comment fixes
Diffstat (limited to 'src/fs')
-rw-r--r--src/fs/gnunet-service-fs_lc.c15
-rw-r--r--src/fs/gnunet-service-fs_pr.c17
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,