diff options
Diffstat (limited to 'src/rps')
-rw-r--r-- | src/rps/gnunet-service-rps_sampler.c | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/rps/gnunet-service-rps_sampler.c b/src/rps/gnunet-service-rps_sampler.c index f1e48d9f8..27c65fff6 100644 --- a/src/rps/gnunet-service-rps_sampler.c +++ b/src/rps/gnunet-service-rps_sampler.c | |||
@@ -605,6 +605,7 @@ sampler_get_rand_peer (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
605 | { | 605 | { |
606 | struct GetPeerCls *gpc = (struct GetPeerCls *) cls; | 606 | struct GetPeerCls *gpc = (struct GetPeerCls *) cls; |
607 | struct GNUNET_PeerIdentity tmp_id; | 607 | struct GNUNET_PeerIdentity tmp_id; |
608 | unsigned int empty_flag; | ||
608 | struct RPS_SamplerElement *s_elem; | 609 | struct RPS_SamplerElement *s_elem; |
609 | struct GNUNET_TIME_Relative last_request_diff; | 610 | struct GNUNET_TIME_Relative last_request_diff; |
610 | uint32_t tmp_client_get_index; | 611 | uint32_t tmp_client_get_index; |
@@ -641,10 +642,12 @@ sampler_get_rand_peer (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
641 | } | 642 | } |
642 | 643 | ||
643 | tmp_id = gpc->sampler->sampler_elements[client_get_index]->peer_id; | 644 | tmp_id = gpc->sampler->sampler_elements[client_get_index]->peer_id; |
645 | empty_flag = gpc->sampler->sampler_elements[client_get_index]->is_empty; | ||
644 | RPS_sampler_elem_reinit (gpc->sampler->sampler_elements[client_get_index]); | 646 | RPS_sampler_elem_reinit (gpc->sampler->sampler_elements[client_get_index]); |
645 | RPS_sampler_elem_next (gpc->sampler->sampler_elements[client_get_index], | 647 | if (EMPTY != empty_flag) |
646 | gpc->sampler, | 648 | RPS_sampler_elem_next (gpc->sampler->sampler_elements[client_get_index], |
647 | &tmp_id); | 649 | gpc->sampler, |
650 | &tmp_id); | ||
648 | 651 | ||
649 | /* Cycle the #client_get_index one step further */ | 652 | /* Cycle the #client_get_index one step further */ |
650 | if ( client_get_index == gpc->sampler->sampler_size - 1 ) | 653 | if ( client_get_index == gpc->sampler->sampler_size - 1 ) |