aboutsummaryrefslogtreecommitdiff
path: root/src/rps
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2015-02-17 03:38:40 +0000
committerJulius Bünger <buenger@mytum.de>2015-02-17 03:38:40 +0000
commit5c336ce9a914cdd62982844381fc6b8e77681c46 (patch)
tree568fcb0e6209a3eb0f1f970b8558af18baa34762 /src/rps
parent9678cbd3c4826dda99eb5aff900bee602f5b25ec (diff)
downloadgnunet-5c336ce9a914cdd62982844381fc6b8e77681c46.tar.gz
gnunet-5c336ce9a914cdd62982844381fc6b8e77681c46.zip
- fixed logic
Diffstat (limited to 'src/rps')
-rw-r--r--src/rps/gnunet-service-rps_sampler.c9
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 )