diff options
Diffstat (limited to 'src/fs/gnunet-service-fs.c')
-rw-r--r-- | src/fs/gnunet-service-fs.c | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c index 11cbe5a70..a4300a4ce 100644 --- a/src/fs/gnunet-service-fs.c +++ b/src/fs/gnunet-service-fs.c | |||
@@ -575,7 +575,7 @@ shutdown_task (void *cls, | |||
575 | * peer connects, giving us a chance to decide about submitting | 575 | * peer connects, giving us a chance to decide about submitting |
576 | * the existing request to the new peer. | 576 | * the existing request to the new peer. |
577 | * | 577 | * |
578 | * @param cls the 'struct GSF_ConnectedPeer' of the new peer | 578 | * @param cls the `struct GSF_ConnectedPeer` of the new peer |
579 | * @param key query for the request | 579 | * @param key query for the request |
580 | * @param pr handle to the pending request | 580 | * @param pr handle to the pending request |
581 | * @return #GNUNET_YES to continue to iterate | 581 | * @return #GNUNET_YES to continue to iterate |
@@ -589,10 +589,12 @@ consider_peer_for_forwarding (void *cls, | |||
589 | struct GNUNET_PeerIdentity pid; | 589 | struct GNUNET_PeerIdentity pid; |
590 | 590 | ||
591 | GSF_connected_peer_get_identity_ (cp, &pid); | 591 | GSF_connected_peer_get_identity_ (cp, &pid); |
592 | if (GNUNET_YES != GSF_pending_request_test_target_ (pr, &pid)) | 592 | if (GNUNET_YES != |
593 | GSF_pending_request_test_target_ (pr, &pid)) | ||
593 | { | 594 | { |
594 | GNUNET_STATISTICS_update (GSF_stats, | 595 | GNUNET_STATISTICS_update (GSF_stats, |
595 | gettext_noop ("# Loopback routes suppressed"), 1, | 596 | gettext_noop ("# Loopback routes suppressed"), |
597 | 1, | ||
596 | GNUNET_NO); | 598 | GNUNET_NO); |
597 | return GNUNET_YES; | 599 | return GNUNET_YES; |
598 | } | 600 | } |
@@ -608,11 +610,13 @@ consider_peer_for_forwarding (void *cls, | |||
608 | * @param cp handle to the newly created connected peer record | 610 | * @param cp handle to the newly created connected peer record |
609 | */ | 611 | */ |
610 | static void | 612 | static void |
611 | connected_peer_cb (void *cls, struct GSF_ConnectedPeer *cp) | 613 | connected_peer_cb (void *cls, |
614 | struct GSF_ConnectedPeer *cp) | ||
612 | { | 615 | { |
613 | if (NULL == cp) | 616 | if (NULL == cp) |
614 | return; | 617 | return; |
615 | GSF_iterate_pending_requests_ (&consider_peer_for_forwarding, cp); | 618 | GSF_iterate_pending_requests_ (&consider_peer_for_forwarding, |
619 | cp); | ||
616 | } | 620 | } |
617 | 621 | ||
618 | 622 | ||