diff options
Diffstat (limited to 'src/rps')
-rw-r--r-- | src/rps/gnunet-service-rps_sampler.c | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/src/rps/gnunet-service-rps_sampler.c b/src/rps/gnunet-service-rps_sampler.c index 6129f1b5b..53d982621 100644 --- a/src/rps/gnunet-service-rps_sampler.c +++ b/src/rps/gnunet-service-rps_sampler.c | |||
@@ -633,18 +633,19 @@ sampler_mod_get_rand_peer (void *cls) | |||
633 | cls); | 633 | cls); |
634 | return; | 634 | return; |
635 | } | 635 | } |
636 | else if (2 < s_elem->num_peers) | ||
637 | { | ||
638 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
639 | "This s_elem saw less than two peers -- scheduling for later\n"); | ||
640 | GNUNET_assert (NULL == gpc->get_peer_task); | ||
641 | gpc->get_peer_task = | ||
642 | GNUNET_SCHEDULER_add_delayed (sampler->max_round_interval, | ||
643 | &sampler_mod_get_rand_peer, | ||
644 | cls); | ||
645 | } | ||
646 | /* More reasons to wait could be added here */ | ||
647 | } | 636 | } |
637 | if (2 > s_elem->num_peers) | ||
638 | { | ||
639 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
640 | "This s_elem saw less than two peers -- scheduling for later\n"); | ||
641 | GNUNET_assert (NULL == gpc->get_peer_task); | ||
642 | gpc->get_peer_task = | ||
643 | GNUNET_SCHEDULER_add_delayed (sampler->max_round_interval, | ||
644 | &sampler_mod_get_rand_peer, | ||
645 | cls); | ||
646 | return; | ||
647 | } | ||
648 | /* More reasons to wait could be added here */ | ||
648 | 649 | ||
649 | GNUNET_STATISTICS_set (stats, | 650 | GNUNET_STATISTICS_set (stats, |
650 | "# client sampler element input", | 651 | "# client sampler element input", |