speedup.c File Reference

functions to speedup peer execution by manipulation system time More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "speedup.h"

Include dependency graph for speedup.c:

Go to the source code of this file.

Macros
#define	LOG(kind, ...)   GNUNET_log_from(kind, "util-speedup", __VA_ARGS__)

Functions
static void	do_speedup (void *cls)
int	GNUNET_SPEEDUP_start_ (const struct GNUNET_CONFIGURATION_Handle *cfg)
	Start task that may speed up our system clock artificially. More...
void	GNUNET_SPEEDUP_stop_ ()
	Stop tasks that modify clock behavior. More...

Variables
static struct GNUNET_TIME_Relative	interval
static struct GNUNET_TIME_Relative	delta
static struct GNUNET_SCHEDULER_Task *	speedup_task

Detailed Description

functions to speedup peer execution by manipulation system time

Interface for speedup routinues.

Author

Matthias Wachs

Sree Harsha Totakura sreeh.nosp@m.arsh.nosp@m.a@tot.nosp@m.akur.nosp@m.a.in

Definition in file speedup.c.

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log_from(kind, "util-speedup", __VA_ARGS__)

Definition at line 30 of file speedup.c.

Referenced by do_speedup(), GNUNET_SPEEDUP_start_(), and GNUNET_SPEEDUP_stop_().

Function Documentation

do_speedup()

static void do_speedup ( void *  cls )

static

Definition at line 41 of file speedup.c.

References delta, GNUNET_ERROR_TYPE_DEBUG, GNUNET_NO, GNUNET_SCHEDULER_add_delayed(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_TIME_set_offset(), interval, LOG, and GNUNET_TIME_Relative::rel_value_us.

Referenced by GNUNET_SPEEDUP_start_().

{
  static long long current_offset;

  (void)cls;
  speedup_task = NULL;
  current_offset += delta.rel_value_us;
  GNUNET_TIME_set_offset(current_offset);
  LOG(GNUNET_ERROR_TYPE_DEBUG,
      "Speeding up execution time by %s\n",
      GNUNET_STRINGS_relative_time_to_string(delta, GNUNET_NO));
  speedup_task = GNUNET_SCHEDULER_add_delayed(interval,
                                              &do_speedup,
                                              NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_SPEEDUP_start_()

int GNUNET_SPEEDUP_start_

(

const struct GNUNET_CONFIGURATION_Handle *

cfg

)

Start task that may speed up our system clock artificially.

Parameters

cfg	configuration to use

Returns

GNUNET_OK on success, GNUNET_SYSERR if the speedup was not configured

Definition at line 65 of file speedup.c.

References delta, do_speedup(), GNUNET_assert, GNUNET_CONFIGURATION_get_value_time(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_now_with_lifeness(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_SYSERR, interval, LOG, and GNUNET_TIME_Relative::rel_value_us.

Referenced by program_main().

{
  GNUNET_assert(NULL == speedup_task);
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time(cfg,
                                          "testing",
                                          "SPEEDUP_INTERVAL",
                                          &interval))
    return GNUNET_SYSERR;
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time(cfg,
                                          "testing",
                                          "SPEEDUP_DELTA",
                                          &delta))
    return GNUNET_SYSERR;

  if ((0 == interval.rel_value_us) ||
      (0 == delta.rel_value_us))
    {
      LOG(GNUNET_ERROR_TYPE_DEBUG,
          "Speed up disabled\n");
      return GNUNET_OK;
    }
  LOG(GNUNET_ERROR_TYPE_DEBUG,
      "Speed up execution by %s\n",
      GNUNET_STRINGS_relative_time_to_string(delta, GNUNET_NO));
  LOG(GNUNET_ERROR_TYPE_DEBUG,
      "Speed up executed every %s\n",
      GNUNET_STRINGS_relative_time_to_string(interval, GNUNET_NO));
  speedup_task = GNUNET_SCHEDULER_add_now_with_lifeness(GNUNET_NO,
                                                        &do_speedup,
                                                        NULL);
  return GNUNET_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_SPEEDUP_stop_()

void GNUNET_SPEEDUP_stop_

(

void

)

Stop tasks that modify clock behavior.

Definition at line 105 of file speedup.c.

References delta, GNUNET_ERROR_TYPE_DEBUG, GNUNET_SCHEDULER_cancel(), interval, LOG, and GNUNET_TIME_Relative::rel_value_us.

Referenced by GNUNET_SERVICE_run_(), and shutdown_task().

{
  if (NULL != speedup_task)
    {
      GNUNET_SCHEDULER_cancel(speedup_task);
      speedup_task = NULL;
    }
  if ((0 != interval.rel_value_us) &&
      (0 != delta.rel_value_us))
    LOG(GNUNET_ERROR_TYPE_DEBUG,
        "Stopped execution speed up\n");
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

interval

struct GNUNET_TIME_Relative interval

static

Definition at line 33 of file speedup.c.

Referenced by do_speedup(), GNUNET_SPEEDUP_start_(), GNUNET_SPEEDUP_stop_(), and libgnunet_plugin_transport_udp_init().

delta

struct GNUNET_TIME_Relative delta

static

Definition at line 35 of file speedup.c.

Referenced by add_setter_action(), adjust_running_peers(), agent_update(), churn_cb(), disk_utilization_change_cb(), do_speedup(), envi_get_reward(), file_hash_task(), GCCH_handle_channel_plaintext_data(), GCCH_handle_channel_plaintext_data_ack(), GCPP_update_score(), GNUNET_MST_from_buffer(), GNUNET_PEER_change_rc(), GNUNET_SERVER_mst_receive(), GNUNET_SPEEDUP_start_(), GNUNET_SPEEDUP_stop_(), handle_client_recv_ok(), handle_set(), is_before(), main(), manage_service_wrapper(), mst_receive(), pick_random_dv_hops(), pong_handler(), send_get_known_results(), and solver_bandwidth_changed_cb().

speedup_task

struct GNUNET_SCHEDULER_Task* speedup_task

static

Definition at line 37 of file speedup.c.