aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2018-08-24 12:47:54 +0200
committerJulius Bünger <buenger@mytum.de>2018-08-24 12:47:54 +0200
commitdc86c377a63e79ab2d17ce644ea060d1ce0c6b0c (patch)
tree51dfb1671a70af89076d14be05018035662b835f
parentccd23df541fac1192f492b0169cb87f0f23a726d (diff)
downloadgnunet-dc86c377a63e79ab2d17ce644ea060d1ce0c6b0c.tar.gz
gnunet-dc86c377a63e79ab2d17ce644ea060d1ce0c6b0c.zip
Reinitialise the (client) sampler element after querying
-rw-r--r--src/rps/gnunet-service-rps_sampler.c7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rps/gnunet-service-rps_sampler.c b/src/rps/gnunet-service-rps_sampler.c
index 4d1ae4650..2974c3cbc 100644
--- a/src/rps/gnunet-service-rps_sampler.c
+++ b/src/rps/gnunet-service-rps_sampler.c
@@ -254,9 +254,10 @@ static uint32_t client_get_index;
254 */ 254 */
255static void 255static void
256check_n_peers_ready (void *cls, 256check_n_peers_ready (void *cls,
257 const struct GNUNET_PeerIdentity *id) 257 const struct GNUNET_PeerIdentity *id)
258{ 258{
259 struct RPS_SamplerRequestHandle *req_handle = cls; 259 struct RPS_SamplerRequestHandle *req_handle = cls;
260 (void) id;
260 261
261 req_handle->cur_num_peers++; 262 req_handle->cur_num_peers++;
262 LOG (GNUNET_ERROR_TYPE_DEBUG, 263 LOG (GNUNET_ERROR_TYPE_DEBUG,
@@ -571,8 +572,7 @@ sampler_get_rand_peer (void *cls)
571/** 572/**
572 * Get one random peer out of the sampled peers. 573 * Get one random peer out of the sampled peers.
573 * 574 *
574 * We might want to reinitialise this sampler after giving the 575 * This reinitialises the queried sampler element.
575 * corrsponding peer to the client.
576 */ 576 */
577static void 577static void
578sampler_mod_get_rand_peer (void *cls) 578sampler_mod_get_rand_peer (void *cls)
@@ -635,6 +635,7 @@ sampler_mod_get_rand_peer (void *cls)
635 } 635 }
636 636
637 s_elem->last_client_request = GNUNET_TIME_absolute_get (); 637 s_elem->last_client_request = GNUNET_TIME_absolute_get ();
638 RPS_sampler_elem_reinit (s_elem);
638 639
639 GNUNET_CONTAINER_DLL_remove (gpc->req_handle->gpc_head, 640 GNUNET_CONTAINER_DLL_remove (gpc->req_handle->gpc_head,
640 gpc->req_handle->gpc_tail, 641 gpc->req_handle->gpc_tail,