diff options
author | Julius Bünger <buenger@mytum.de> | 2018-08-24 12:47:54 +0200 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2018-08-24 12:47:54 +0200 |
commit | dc86c377a63e79ab2d17ce644ea060d1ce0c6b0c (patch) | |
tree | 51dfb1671a70af89076d14be05018035662b835f /src | |
parent | ccd23df541fac1192f492b0169cb87f0f23a726d (diff) | |
download | gnunet-dc86c377a63e79ab2d17ce644ea060d1ce0c6b0c.tar.gz gnunet-dc86c377a63e79ab2d17ce644ea060d1ce0c6b0c.zip |
Reinitialise the (client) sampler element after querying
Diffstat (limited to 'src')
-rw-r--r-- | src/rps/gnunet-service-rps_sampler.c | 7 |
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 | */ |
255 | static void | 255 | static void |
256 | check_n_peers_ready (void *cls, | 256 | check_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 | */ |
577 | static void | 577 | static void |
578 | sampler_mod_get_rand_peer (void *cls) | 578 | sampler_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, |