sampler implementation More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_statistics_service.h"
#include "rps.h"
#include "rps-sampler_common.h"
#include "gnunet-service-rps_sampler.h"
#include "gnunet-service-rps_sampler_elem.h"
#include <math.h>
#include <inttypes.h>
#include "rps-test_util.h"

Include dependency graph for gnunet-service-rps_sampler.c:

Data Structures
struct	SamplerNotifyUpdateCTX
	Context for a callback. More...

struct	RPS_SamplerRequestHandle
	Closure to _get_n_rand_peers_ready_cb() More...

Macros
#define	LOG(kind, ...) GNUNET_log_from (kind, "rps-sampler", __VA_ARGS__)

Typedefs
typedef void(*	SamplerNotifyUpdateCB) (void *cls)
	Callback called each time a new peer was put into the sampler. More...

typedef void(*	RPS_get_peers_type) (void *cls)
	Type of function used to differentiate between modified and not modified Sampler. More...

Functions
static void	sampler_get_rand_peer (void *cls)
	Get one random peer out of the sampled peers. More...

struct RPS_Sampler *	RPS_sampler_init (size_t init_size, struct GNUNET_TIME_Relative max_round_interval)
	Initialise a tuple of sampler elements. More...

Variables
static size_t	min_size
	‍** More...

static size_t	max_size
	The maximal size the extended sampler elements should grow to. More...

static uint32_t	client_get_index
	The size the extended sampler elements currently have. More...

Detailed Description

sampler implementation

Author: Julius Bünger

Definition in file gnunet-service-rps_sampler.c.

Macro Definition Documentation

◆ LOG

#define LOG	(	kind,
		...
	)	GNUNET_log_from (kind, "rps-sampler", __VA_ARGS__)

Definition at line 40 of file gnunet-service-rps_sampler.c.

Typedef Documentation

◆ SamplerNotifyUpdateCB

typedef void(* SamplerNotifyUpdateCB) (void *cls)

Callback called each time a new peer was put into the sampler.

Parameters

cls	A possibly given closure

Definition at line 63 of file gnunet-service-rps_sampler.c.

◆ RPS_get_peers_type

typedef void(* RPS_get_peers_type) (void *cls)

Type of function used to differentiate between modified and not modified Sampler.

Definition at line 99 of file gnunet-service-rps_sampler.c.

Function Documentation

◆ sampler_get_rand_peer()

static void sampler_get_rand_peer ( void * cls )

static

Get one random peer out of the sampled peers.

We might want to reinitialise this sampler after giving the corrsponding peer to the client. Only used internally

; Choose the r_index of the peer we want to return at random from the interval of the gossip list

Definition at line 228 of file gnunet-service-rps_sampler.c.

{
  struct GetPeerCls *gpc = cls;
  uint32_t r_index;
  struct RPS_Sampler *sampler;
 
  gpc->get_peer_task = NULL;
  gpc->notify_ctx = NULL;
  sampler = gpc->req_handle->sampler;
 
  r_index = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_STRONG,
                                      sampler->sampler_size);
 
  if (EMPTY == sampler->sampler_elements[r_index]->is_empty)
  {
    // LOG (GNUNET_ERROR_TYPE_DEBUG,
    //     "Not returning randomly selected, empty PeerID. - Rescheduling.\n");
 
    gpc->notify_ctx =
      sampler_notify_on_update (sampler,
                                &sampler_get_rand_peer,
                                gpc);
    return;
  }
 
  GNUNET_CONTAINER_DLL_remove (gpc->req_handle->gpc_head,
                               gpc->req_handle->gpc_tail,
                               gpc);
  *gpc->id = sampler->sampler_elements[r_index]->peer_id;
  gpc->cont (gpc->cont_cls, gpc->id, 0,
             sampler->sampler_elements[r_index]->num_peers);
 
  GNUNET_free (gpc);
}

References GetPeerCls::cont, GetPeerCls::cont_cls, EMPTY, GetPeerCls::get_peer_task, GNUNET_CONTAINER_DLL_remove, GNUNET_CRYPTO_QUALITY_STRONG, GNUNET_CRYPTO_random_u64(), GNUNET_free, RPS_SamplerRequestHandle::gpc_head, RPS_SamplerRequestHandle::gpc_tail, GetPeerCls::id, RPS_SamplerElement::is_empty, GetPeerCls::notify_ctx, RPS_SamplerElement::num_peers, RPS_SamplerElement::peer_id, GetPeerCls::req_handle, RPS_SamplerRequestHandle::sampler, RPS_Sampler::sampler_elements, sampler_get_rand_peer(), sampler_notify_on_update(), and RPS_Sampler::sampler_size.

Referenced by RPS_sampler_init(), and sampler_get_rand_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RPS_sampler_init()

struct RPS_Sampler * RPS_sampler_init	(	size_t	init_size,
		struct GNUNET_TIME_Relative	max_round_interval
	)

Initialise a tuple of sampler elements.

Initialise a tuple of samplers.

Parameters

init_size	the size the sampler is initialised with
max_round_interval	maximum time a round takes

Returns: a handle to a sampler that consists of sampler elements.

Definition at line 196 of file gnunet-service-rps_sampler.c.

{
  struct RPS_Sampler *sampler;
 
  /* Initialise context around extended sampler */
  min_size = 10; // TODO make input to _samplers_init()
  max_size = 1000; // TODO make input to _samplers_init()
 
  sampler = GNUNET_new (struct RPS_Sampler);
 
  sampler->max_round_interval = max_round_interval;
  sampler->get_peers = sampler_get_rand_peer;
  // sampler->sampler_elements = GNUNET_new_array(init_size, struct GNUNET_PeerIdentity);
  // GNUNET_array_grow (sampler->sampler_elements, sampler->sampler_size, min_size);
  RPS_sampler_resize (sampler, init_size);
 
  client_get_index = 0;
 
  // GNUNET_assert (init_size == sampler->sampler_size);
  return sampler;
}