Load library

Load calculations. More...

Collaboration diagram for Load library:

Macros
#define	GNUNET_LOAD_value_free(lv)   GNUNET_free (lv)
	Free a load value.

Functions
struct GNUNET_LOAD_Value *	GNUNET_LOAD_value_init (struct GNUNET_TIME_Relative autodecline)
	Create a new load value.
void	GNUNET_LOAD_value_set_decline (struct GNUNET_LOAD_Value *load, struct GNUNET_TIME_Relative autodecline)
	Change the value by which the load automatically declines.
double	GNUNET_LOAD_get_load (struct GNUNET_LOAD_Value *load)
	Get the current load.
double	GNUNET_LOAD_get_average (struct GNUNET_LOAD_Value *load)
	Get the average value given to update so far.
void	GNUNET_LOAD_update (struct GNUNET_LOAD_Value *load, uint64_t data)
	Update the current load.

Detailed Description

Load calculations.

Macro Definition Documentation

GNUNET_LOAD_value_free

#define GNUNET_LOAD_value_free

(

lv

)

GNUNET_free (lv)

Free a load value.

Parameters

lv	value to free

Definition at line 83 of file gnunet_load_lib.h.

Function Documentation

GNUNET_LOAD_value_init()

struct GNUNET_LOAD_Value * GNUNET_LOAD_value_init

(

struct GNUNET_TIME_Relative

autodecline

)

Create a new load value.

Parameters

autodecline

speed at which this value should automatically decline in the absence of external events; at the given frequency, 0-load values will be added to the load

Returns

the new load value

Definition at line 124 of file load.c.

{
  struct GNUNET_LOAD_Value *ret;
 
  ret = GNUNET_new (struct GNUNET_LOAD_Value);
  ret->autodecline = autodecline;
  ret->last_update = GNUNET_TIME_absolute_get ();
  return ret;
}

References GNUNET_LOAD_Value::autodecline, GNUNET_new, GNUNET_TIME_absolute_get(), and ret.

Referenced by GSF_peer_connect_handler(), GSF_pending_request_init_(), main_init(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_LOAD_value_set_decline()

void GNUNET_LOAD_value_set_decline	(	struct GNUNET_LOAD_Value *	load,
		struct GNUNET_TIME_Relative	autodecline
	)

Change the value by which the load automatically declines.

Parameters

load	load to update
autodecline	frequency of load decline

Definition at line 142 of file load.c.

{
  internal_update (load);
  load->autodecline = autodecline;
}

References GNUNET_LOAD_Value::autodecline, internal_update(), and load().

Referenced by GSF_update_peer_latency_().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_LOAD_get_load()

double GNUNET_LOAD_get_load

(

struct GNUNET_LOAD_Value *

load

)

Get the current load.

Parameters

load	load handle

Returns

zero for below-average load, otherwise number of std. devs we are above average; 100 if the latest updates were so large that we could not do proper calculations

Definition at line 200 of file load.c.

{
  internal_update (load);
  calculate_load (load);
  return load->load;
}

References calculate_load(), internal_update(), and load().

Referenced by GSF_test_get_load_too_high_(), handle_p2p_get(), handle_p2p_put(), and test_put_load_too_high().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_LOAD_get_average()

double GNUNET_LOAD_get_average

(

struct GNUNET_LOAD_Value *

load

)

Get the average value given to update so far.

Parameters

load	load handle

Returns

zero if update was never called

Definition at line 215 of file load.c.

{
  double n;
  double sum_val_i;
 
  internal_update (load);
  if (load->cummulative_request_count == 0)
    return 0.0;
  n = ((double) load->cummulative_request_count);
  sum_val_i = (double) load->cummulative_delay;
  return sum_val_i / n;
}

References internal_update(), and load().

Referenced by handle_p2p_get(), and test_put_load_too_high().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_LOAD_update()

void GNUNET_LOAD_update	(	struct GNUNET_LOAD_Value *	load,
		uint64_t	data
	)

Update the current load.

Parameters

load	to update
data	latest measurement value (for example, delay)

Definition at line 236 of file load.c.

{
  uint32_t dv;
 
  internal_update (load);
  load->last_update = GNUNET_TIME_absolute_get ();
  if (data > 64 * 1024)
  {
    /* very large */
    load->load = 100.0;
    return;
  }
  dv = (uint32_t) data;
  load->cummulative_delay += dv;
  load->cummulative_squared_delay += dv * dv;
  load->cummulative_request_count++;
  load->runavg_delay = ((load->runavg_delay * 7.0) + dv) / 8.0;
}

References data, GNUNET_TIME_absolute_get(), internal_update(), and load().

Referenced by GSF_update_datastore_delay_(), peer_transmit(), process_reply(), and put_migration_continuation().

Here is the call graph for this function:

Here is the caller graph for this function: