diff options
author | Julius Bünger <buenger@mytum.de> | 2018-08-29 15:42:19 +0200 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2018-08-29 15:42:19 +0200 |
commit | 970e25512e192ee37d952b97394c14828672edcd (patch) | |
tree | 9a00cb0eebd84bda94c90bde8a569c44cb45a23d | |
parent | 05eac20b9b8772f5bd6946bb49bf57ad1b66e63c (diff) | |
download | gnunet-970e25512e192ee37d952b97394c14828672edcd.tar.gz gnunet-970e25512e192ee37d952b97394c14828672edcd.zip |
Fix condition for returning peer from sampler element
-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", |