aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rps/gnunet-service-rps_sampler.c23
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",