gnunet-ats-solver-eval.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet-ats-solver-eval.h"
#include "gnunet-service-ats_normalization.h"
#include "gnunet-service-ats_preferences.c"

Include dependency graph for gnunet-ats-solver-eval.c:

Go to the source code of this file.

Macros
#define	BIG_M_STRING   "unlimited"

Functions
static void	end_now ()
	Do shutdown. More...
static char *	print_generator_type (enum GeneratorType g)
static struct TestPeer *	find_peer_by_id (int id)
static struct TestPeer *	find_peer_by_pid (const struct GNUNET_PeerIdentity *pid)
static struct TestAddress *	find_address_by_id (struct TestPeer *peer, int aid)
void	GNUNET_ATS_solver_logging_now (struct LoggingHandle *l)
	Logging. More...
static void	logging_task (void *cls)
struct LoggingHandle *	GNUNET_ATS_solver_logging_start (struct GNUNET_TIME_Relative freq)
void	GNUNET_ATS_solver_logging_stop (struct LoggingHandle *l)
static struct LoggingFileHandle *	find_logging_file_handle (struct LoggingFileHandle *lf_head, struct LoggingFileHandle *lf_tail, int peer_id, int address_id)
void	GNUNET_ATS_solver_logging_write_to_disk (struct LoggingHandle *l, int add_time_stamp, char *output_dir)
void	GNUNET_ATS_solver_logging_eval (struct LoggingHandle *l)
void	GNUNET_ATS_solver_logging_free (struct LoggingHandle *l)
static double	get_property (struct PropertyGenerator *pg)
static void	set_prop_task (void *cls)
static struct PropertyGenerator *	find_prop_gen (unsigned int peer, unsigned int address, uint32_t ats_property)
	Set ats_property to 0 to find all pgs. More...
void	GNUNET_ATS_solver_generate_property_stop (struct PropertyGenerator *pg)
struct PropertyGenerator *	GNUNET_ATS_solver_generate_property_start (unsigned int peer, unsigned int address_id, struct TestPeer *test_peer, struct TestAddress *test_address, enum GeneratorType type, long int base_value, long int value_rate, struct GNUNET_TIME_Relative period, struct GNUNET_TIME_Relative frequency, uint32_t ats_property)
	Generate between the source master and the partner and set property with a value depending on the generator. More...
void	GNUNET_ATS_solver_generate_property_stop_all ()
	Stop all preferences generators. More...
static double	get_preference (struct PreferenceGenerator *pg)
static void	set_feedback_task (void *cls)
static void	set_pref_task (void *cls)
static struct PreferenceGenerator *	find_pref_gen (unsigned int peer, enum GNUNET_ATS_PreferenceKind kind)
void	GNUNET_ATS_solver_generate_preferences_stop (struct PreferenceGenerator *pg)
static struct TestAddress *	find_active_address (struct TestPeer *p)
struct PreferenceGenerator *	GNUNET_ATS_solver_generate_preferences_start (unsigned int peer, unsigned int address_id, unsigned int client_id, enum GeneratorType type, long int base_value, long int value_rate, struct GNUNET_TIME_Relative period, struct GNUNET_TIME_Relative frequency, enum GNUNET_ATS_PreferenceKind kind, struct GNUNET_TIME_Relative feedback_frequency)
	Generate between the source master and the partner and set property with a value depending on the generator. More...
void	GNUNET_ATS_solver_generate_preferences_stop_all ()
	Stop all preferences generators. More...
static const char *	print_op (enum OperationType op)
	Experiments. More...
static struct Experiment *	create_experiment ()
static void	free_experiment (struct Experiment *e)
static int	load_op_add_address (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_op_del_address (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static enum GNUNET_ATS_Property	parse_preference_string (const char *str)
static int	load_op_start_set_preference (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_op_stop_set_preference (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static enum GNUNET_ATS_Property	parse_property_string (const char *str)
static int	load_op_start_set_property (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_op_stop_set_property (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_op_start_request (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_op_stop_request (struct GNUNET_ATS_TEST_Operation *o, struct Episode *e, int op_counter, char *sec_name, const struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_episode (struct Experiment *e, struct Episode *cur, struct GNUNET_CONFIGURATION_Handle *cfg)
static int	load_episodes (struct Experiment *e, struct GNUNET_CONFIGURATION_Handle *cfg)
static void	timeout_experiment (void *cls)
struct ATS_Address *	create_ats_address (const struct GNUNET_PeerIdentity *peer, const char *plugin_name, const void *plugin_addr, size_t plugin_addr_len, uint32_t session_id, uint32_t network)
static void	enforce_add_address (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_del_address (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_start_property (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_stop_property (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_start_preference (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_stop_preference (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_start_request (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_stop_request (struct GNUNET_ATS_TEST_Operation *op)
static void	enforce_episode (struct Episode *ep)
static void	timeout_episode (void *cls)
void	GNUNET_ATS_solvers_experimentation_run (struct Experiment *e, GNUNET_ATS_TESTING_EpisodeDoneCallback ep_done_cb, GNUNET_ATS_TESTING_ExperimentDoneCallback e_done_cb)
void	GNUNET_ATS_solvers_experimentation_stop (struct Experiment *e)
struct Experiment *	GNUNET_ATS_solvers_experimentation_load (char *filename)
static int	free_all_it (void *cls, const struct GNUNET_PeerIdentity *key, void *value)
	Solver. More...
void	GNUNET_ATS_solvers_solver_stop (struct SolverHandle *sh)
unsigned int	GNUNET_ATS_solvers_load_quotas (const struct GNUNET_CONFIGURATION_Handle *cfg, unsigned long long *out_dest, unsigned long long *in_dest, int dest_length)
	Load quotas for networks from configuration. More...
static void	solver_info_cb (void *cls, enum GAS_Solver_Operation op, enum GAS_Solver_Status stat, enum GAS_Solver_Additional_Information add)
	Information callback for the solver. More...
static void	solver_bandwidth_changed_cb (void *cls, struct ATS_Address *address)
const double *	get_preferences_cb (void *cls, const struct GNUNET_PeerIdentity *id)
struct SolverHandle *	GNUNET_ATS_solvers_solver_start (enum GNUNET_ATS_Solvers type)
static void	done ()
static void	experiment_done_cb (struct Experiment *e, struct GNUNET_TIME_Relative duration, int success)
static void	episode_done_cb (struct Episode *ep)
static void	run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg)
int	main (int argc, char *argv[])
	Main function of the benchmark. More...

Variables
struct GNUNET_STATISTICS_Handle *	GSA_stats
	Handle for statistics. More...
static struct Experiment *	e
static struct LoggingHandle *	l
static struct SolverHandle *	sh
static struct TestPeer *	peer_head
static struct TestPeer *	peer_tail
static double	default_properties [GNUNET_ATS_PropertyCount]
static double	default_preferences [GNUNET_ATS_PreferenceCount]
static char *	opt_exp_file
	cmd option -e: experiment file More...
static char *	opt_solver
static int	opt_log
	cmd option -l: enable logging More...
static int	opt_save
	cmd option -p: enable plots More...
static int	opt_verbose
	cmd option -v: verbose logs More...
static int	opt_print
	cmd option -p: print logs More...
static int	opt_disable_normalization
	cmd option -d: disable normalization More...
static int	res
static struct PropertyGenerator *	prop_gen_head
	Property Generators. More...
static struct PropertyGenerator *	prop_gen_tail
static struct PreferenceGenerator *	pref_gen_head
	Preference Generators. More...
static struct PreferenceGenerator *	pref_gen_tail

Macro Definition Documentation

BIG_M_STRING

#define BIG_M_STRING   "unlimited"

Definition at line 32 of file gnunet-ats-solver-eval.c.

Function Documentation

end_now()

static void end_now ( )

static

Do shutdown.

Definition at line 3435 of file gnunet-ats-solver-eval.c.

{
  if (NULL != e)
  {
    GNUNET_ATS_solvers_experimentation_stop (e);
    e = NULL;
  }
  if (NULL != sh)
  {
    GNUNET_ATS_solvers_solver_stop (sh);
    sh = NULL;
  }
}

References e, GNUNET_ATS_solvers_experimentation_stop(), GNUNET_ATS_solvers_solver_stop(), and sh.

Referenced by done(), GNUNET_ATS_solvers_solver_start(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

print_generator_type()

static char* print_generator_type ( enum GeneratorType  g )

static

Definition at line 92 of file gnunet-ats-solver-eval.c.

{
  switch (g)
  {
  case GNUNET_ATS_TEST_TG_CONSTANT:
    return "CONSTANT";
 
  case GNUNET_ATS_TEST_TG_LINEAR:
    return "LINEAR";
 
  case GNUNET_ATS_TEST_TG_RANDOM:
    return "RANDOM";
 
  case GNUNET_ATS_TEST_TG_SINUS:
    return "SINUS";
 
  default:
    return "INVALID";
    break;
  }
}

References GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, and GNUNET_ATS_TEST_TG_SINUS.

Referenced by GNUNET_ATS_solver_generate_preferences_start(), and GNUNET_ATS_solver_generate_property_start().

Here is the caller graph for this function:

find_peer_by_id()

static struct TestPeer* find_peer_by_id ( int  id )

static

Definition at line 116 of file gnunet-ats-solver-eval.c.

{
  struct TestPeer *cur;
 
  for (cur = peer_head; NULL != cur; cur = cur->next)
    if (cur->id == id)
      return cur;
  return NULL;
}

References TestPeer::id, TestPeer::next, and peer_head.

Referenced by enforce_add_address(), enforce_del_address(), enforce_start_preference(), enforce_start_property(), enforce_start_request(), enforce_stop_request(), GNUNET_ATS_solver_generate_preferences_start(), set_feedback_task(), set_pref_task(), and set_prop_task().

Here is the caller graph for this function:

find_peer_by_pid()

static struct TestPeer* find_peer_by_pid ( const struct GNUNET_PeerIdentity *  pid )

static

Definition at line 128 of file gnunet-ats-solver-eval.c.

{
  struct TestPeer *cur;
 
  for (cur = peer_head; NULL != cur; cur = cur->next)
    if (0 == GNUNET_memcmp (&cur->peer_id, pid))
      return cur;
  return NULL;
}

References GNUNET_memcmp, TestPeer::next, peer_head, TestPeer::peer_id, and pid.

Referenced by get_preferences_cb(), and solver_bandwidth_changed_cb().

Here is the caller graph for this function:

find_address_by_id()

static struct TestAddress* find_address_by_id ( struct TestPeer *  peer, int  aid  )

static

Definition at line 140 of file gnunet-ats-solver-eval.c.

{
  struct TestAddress *cur;
 
  for (cur = peer->addr_head; NULL != cur; cur = cur->next)
    if (cur->aid == aid)
      return cur;
  return NULL;
}

References TestAddress::aid, TestAddress::next, and peer.

Referenced by enforce_add_address(), enforce_del_address(), enforce_start_property(), and set_prop_task().

Here is the caller graph for this function:

GNUNET_ATS_solver_logging_now()

void GNUNET_ATS_solver_logging_now

(

struct LoggingHandle *

l

)

Logging.

Definition at line 155 of file gnunet-ats-solver-eval.c.

{
  struct LoggingTimeStep *lts;
  struct TestPeer *cur;
  struct TestAddress *cur_addr;
  struct LoggingPeer *log_p;
  struct LoggingAddress *log_a;
  int c;
 
  lts = GNUNET_new (struct LoggingTimeStep);
  GNUNET_CONTAINER_DLL_insert_tail (l->head, l->tail, lts);
  lts->timestamp = GNUNET_TIME_absolute_get ();
  if (NULL == lts->prev)
    lts->delta = GNUNET_TIME_UNIT_ZERO;
  else
    lts->delta = GNUNET_TIME_absolute_get_duration (lts->prev->timestamp);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Logging %llu, delta %llu\n",
              lts->timestamp.abs_value_us, lts->delta.rel_value_us);
 
 
  /* Store logging data here */
  for (cur = peer_head; NULL != cur; cur = cur->next)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Logging peer id %llu\n", cur->id);
 
    log_p = GNUNET_new (struct LoggingPeer);
    log_p->id = cur->id;
    log_p->peer_id = cur->peer_id;
    log_p->is_requested = cur->is_requested;
    for (c = 0; c < GNUNET_ATS_PreferenceCount; c++)
    {
      log_p->pref_abs[c] = cur->pref_abs[c];
      log_p->pref_norm[c] = cur->pref_norm[c];
      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                  "\t %s = %.2f %.2f [abs/rel]\n",
                  GNUNET_ATS_print_preference_type (c),
                  log_p->pref_abs[c], log_p->pref_norm[c]);
    }
    GNUNET_CONTAINER_DLL_insert_tail (lts->head, lts->tail, log_p);
 
    for (cur_addr = cur->addr_head; NULL != cur_addr; cur_addr = cur_addr->next)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                  "Logging peer id %llu address %llu\n",
                  cur->id, cur_addr->aid);
      log_a = GNUNET_new (struct LoggingAddress);
      log_a->aid = cur_addr->aid;
      log_a->active = cur_addr->ats_addr->active;
      log_a->network = cur_addr->network;
      log_a->assigned_bw_in = cur_addr->ats_addr->assigned_bw_in;
      log_a->assigned_bw_out = cur_addr->ats_addr->assigned_bw_out;
      for (c = 0; c < GNUNET_ATS_PropertyCount; c++)
      {
        log_a->prop_abs[c] = cur_addr->prop_abs[c];
        log_a->prop_norm[c] = cur_addr->prop_norm[c];
        GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                    "\t %s = %.2f %.2f [abs/rel]\n",
                    GNUNET_ATS_print_property_type (c),
                    log_a->prop_abs[c],
                    log_a->prop_norm[c]);
      }
      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "\t Active = %i\n", log_a->active);
      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "\t BW in = %llu\n",
                  log_a->assigned_bw_in);
      GNUNET_log (GNUNET_ERROR_TYPE_INFO, "\t BW out = %llu\n",
                  log_a->assigned_bw_out);
 
      GNUNET_CONTAINER_DLL_insert_tail (log_p->addr_head, log_p->addr_tail,
                                        log_a);
    }
  }
}

References GNUNET_TIME_Absolute::abs_value_us, LoggingAddress::active, ATS_Address::active, LoggingPeer::addr_head, TestPeer::addr_head, LoggingPeer::addr_tail, LoggingAddress::aid, TestAddress::aid, LoggingAddress::assigned_bw_in, ATS_Address::assigned_bw_in, LoggingAddress::assigned_bw_out, ATS_Address::assigned_bw_out, TestAddress::ats_addr, LoggingTimeStep::delta, GNUNET_ATS_print_preference_type(), GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_new, GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_get_duration(), GNUNET_TIME_UNIT_ZERO, LoggingTimeStep::head, LoggingHandle::head, LoggingPeer::id, TestPeer::id, LoggingPeer::is_requested, TestPeer::is_requested, l, LoggingAddress::network, TestAddress::network, TestPeer::next, TestAddress::next, peer_head, LoggingPeer::peer_id, TestPeer::peer_id, LoggingPeer::pref_abs, TestPeer::pref_abs, LoggingPeer::pref_norm, TestPeer::pref_norm, LoggingTimeStep::prev, LoggingAddress::prop_abs, TestAddress::prop_abs, LoggingAddress::prop_norm, TestAddress::prop_norm, GNUNET_TIME_Relative::rel_value_us, LoggingTimeStep::tail, LoggingHandle::tail, and LoggingTimeStep::timestamp.

Referenced by enforce_del_address(), enforce_stop_request(), logging_task(), and solver_bandwidth_changed_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

logging_task()

static void logging_task ( void *  cls )

static

Definition at line 232 of file gnunet-ats-solver-eval.c.

{
  struct LoggingHandle *l = cls;
 
  l->logging_task = NULL;
  GNUNET_ATS_solver_logging_now (l);
  l->logging_task = GNUNET_SCHEDULER_add_delayed (l->log_freq,
                                                  &logging_task,
                                                  l);
}

References GNUNET_ATS_solver_logging_now(), GNUNET_SCHEDULER_add_delayed(), l, LoggingHandle::log_freq, and LoggingHandle::logging_task.

Referenced by GNUNET_ATS_solver_logging_start().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_logging_start()

struct LoggingHandle* GNUNET_ATS_solver_logging_start

(

struct GNUNET_TIME_Relative

freq

)

Definition at line 245 of file gnunet-ats-solver-eval.c.

{
  struct LoggingHandle *l;
 
  l = GNUNET_new (struct LoggingHandle);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Start logging every  %s\n",
              GNUNET_STRINGS_relative_time_to_string (freq, GNUNET_NO));
  l->log_freq = freq;
  l->logging_task = GNUNET_SCHEDULER_add_now (&logging_task, l);
  return l;
}

References GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_new, GNUNET_NO, GNUNET_SCHEDULER_add_now(), GNUNET_STRINGS_relative_time_to_string(), l, LoggingHandle::log_freq, logging_task(), and LoggingHandle::logging_task.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_logging_stop()

void GNUNET_ATS_solver_logging_stop

(

struct LoggingHandle *

l

)

Definition at line 260 of file gnunet-ats-solver-eval.c.

{
  if (NULL != l->logging_task)
    GNUNET_SCHEDULER_cancel (l->logging_task);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Stop logging\n");
 
  l->logging_task = NULL;
}

References GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_SCHEDULER_cancel(), l, and LoggingHandle::logging_task.

Referenced by done().

Here is the call graph for this function:

Here is the caller graph for this function:

find_logging_file_handle()

static struct LoggingFileHandle* find_logging_file_handle ( struct LoggingFileHandle *  lf_head, struct LoggingFileHandle *  lf_tail, int  peer_id, int  address_id  )

static

Definition at line 272 of file gnunet-ats-solver-eval.c.

{
  struct LoggingFileHandle *res;
 
  for (res = lf_head; NULL != res; res = res->next)
    if ((res->pid == peer_id) && (res->aid == address_id))
      return res;
  return NULL;
}

References peer_id, and res.

Referenced by GNUNET_ATS_solver_logging_write_to_disk().

Here is the caller graph for this function:

GNUNET_ATS_solver_logging_write_to_disk()

void GNUNET_ATS_solver_logging_write_to_disk	(	struct LoggingHandle *	l,
		int	add_time_stamp,
		char *	output_dir
	)

Definition at line 286 of file gnunet-ats-solver-eval.c.

{
  struct LoggingTimeStep *lts;
  struct LoggingPeer *log_p;
  struct LoggingAddress *log_a;
  struct LoggingFileHandle *lf_head;
  struct LoggingFileHandle *lf_tail;
  struct LoggingFileHandle *cur;
  struct LoggingFileHandle *next;
  char *filename;
  char *datastring;
  char *propstring;
  char *propstring_tmp;
  char *prefstring;
  char *prefstring_tmp;
  int c;
  int use_dir;
 
  use_dir = GNUNET_NO;
  if (NULL != output_dir)
  {
    if (GNUNET_OK != GNUNET_DISK_directory_create_for_file (output_dir))
    {
      fprintf (stderr, "Failed to create directory `%s'\n", output_dir);
      return;
    }
    else
    {
      fprintf (stderr, "Created directory `%s'\n", output_dir);
      use_dir = GNUNET_YES;
    }
  }
 
  lf_head = NULL;
  lf_tail = NULL;
 
  for (lts = l->head; NULL != lts; lts = lts->next)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Writing log step %llu\n",
                (long long unsigned int) lts->timestamp.abs_value_us);
 
    for (log_p = lts->head; NULL != log_p; log_p = log_p->next)
    {
      for (log_a = log_p->addr_head; NULL != log_a; log_a = log_a->next)
      {
        cur = find_logging_file_handle (lf_head, lf_tail, log_p->id,
                                        log_a->aid);
        if (NULL == cur)
        {
          cur = GNUNET_new (struct LoggingFileHandle);
          cur->aid = log_a->aid;
          cur->pid = log_p->id;
 
          if (GNUNET_YES == add_time_stamp)
            GNUNET_asprintf (&filename, "%s%s%s_%s_p%u_a%u_%llu.log",
                             (GNUNET_YES == use_dir) ? output_dir : "",
                             (GNUNET_YES == use_dir) ? DIR_SEPARATOR_STR : "",
                             e->log_prefix,
                             opt_solver,
                             cur->pid,
                             cur->aid,
                             l->head->timestamp.abs_value_us);
          else
            GNUNET_asprintf (&filename, "%s%s%s_%s_p%u_a%u.log",
                             (GNUNET_YES == use_dir) ? output_dir : "",
                             (GNUNET_YES == use_dir) ? DIR_SEPARATOR_STR : "",
                             e->log_prefix,
                             opt_solver,
                             cur->pid,
                             cur->aid);
 
          fprintf (stderr,
                   "Add writing log data for peer %llu address %llu to file `%s'\n",
                   cur->pid, cur->aid, filename);
 
 
          cur->f_hd = GNUNET_DISK_file_open (filename,
                                             GNUNET_DISK_OPEN_READWRITE
                                             | GNUNET_DISK_OPEN_CREATE
                                             | GNUNET_DISK_OPEN_TRUNCATE,
                                             GNUNET_DISK_PERM_USER_READ
                                             | GNUNET_DISK_PERM_USER_WRITE
                                             | GNUNET_DISK_PERM_GROUP_READ
                                             | GNUNET_DISK_PERM_OTHER_READ);
          if (NULL == cur->f_hd)
          {
            fprintf (stderr, "Cannot open `%s' to write log data!\n", filename);
            GNUNET_free (filename);
            GNUNET_free (cur);
            goto cleanup;
          }
          GNUNET_free (filename);
          GNUNET_CONTAINER_DLL_insert (lf_head, lf_tail, cur);
 
          GNUNET_asprintf (&datastring,
                           "#time delta;log duration;peer_requested;addr net; addr_active; bw in; bw out; " \
                           "UTILIZATION_UP [abs/rel]; UTILIZATION_UP; UTILIZATION_DOWN; UTILIZATION_DOWN; " \
                           "UTILIZATION_PAYLOAD_UP; UTILIZATION_PAYLOAD_UP; UTILIZATION_PAYLOAD_DOWN; UTILIZATION_PAYLOAD_DOWN;" \
                           "DELAY; DELAY; " \
                           "DISTANCE ;DISTANCE ; COST_WAN; COST_WAN; COST_LAN; COST_LAN; " \
                           "COST_WLAN; COST_WLAN;COST_BT; COST_BT; PREF BW abs; PREF BW rel; PREF LATENCY abs; PREF LATENCY rel;\n");
          GNUNET_DISK_file_write (cur->f_hd, datastring, strlen (datastring));
          GNUNET_free (datastring);
        }
 
        prefstring = GNUNET_strdup ("");
        for (c = 1; c < GNUNET_ATS_PreferenceCount; c++)
        {
          /*
             fprintf(stderr,"\t %s = %.2f %.2f [abs/rel]\n",
              GNUNET_ATS_print_preference_type(c),
              log_p->pref_abs[c], log_p->pref_norm[c]);
           */GNUNET_asprintf (&prefstring_tmp, "%s;%.3f;%.3f",
                           prefstring, log_p->pref_abs[c], log_p->pref_norm[c]);
 
 
          GNUNET_free (prefstring);
          prefstring = GNUNET_strdup (prefstring_tmp);
          GNUNET_free (prefstring_tmp);
        }
 
 
        propstring = GNUNET_strdup ("");
        for (c = 1; c < GNUNET_ATS_PropertyCount; c++)
        {
          if (GNUNET_ATS_NETWORK_TYPE == c)
            continue;
          /*
             fprintf(stderr, "\t %s = %.2f %.2f [abs/rel]\n",
              GNUNET_ATS_print_property_type(c),
              log_a->prop_abs[c], log_a->prop_norm[c]);*/
          GNUNET_asprintf (&propstring_tmp, "%s%.3f;%.3f;",
                           propstring,
                           log_a->prop_abs[c],
                           log_a->prop_norm[c]);
          GNUNET_free (propstring);
          propstring = GNUNET_strdup (propstring_tmp);
          GNUNET_free (propstring_tmp);
        }
        GNUNET_asprintf (&datastring, "%llu;%llu;%u;%u;%i;%u;%u;%s;%s\n",
                         GNUNET_TIME_absolute_get_difference (
                           l->head->timestamp,
                           lts->timestamp).
                         rel_value_us / 1000, lts->delta,
                         log_p->is_requested, log_a->network, log_a->active,
                         log_a->assigned_bw_in, log_a->assigned_bw_out,
                         propstring,
                         prefstring);
 
        GNUNET_DISK_file_write (cur->f_hd, datastring, strlen (datastring));
        GNUNET_free (datastring);
        GNUNET_free (prefstring);
        GNUNET_free (propstring);
      }
    }
  }
 
  cleanup:
  next = lf_head;
  for (cur = next; NULL != cur; cur = next)
  {
    next = cur->next;
    GNUNET_CONTAINER_DLL_remove (lf_head, lf_tail, cur);
    if (NULL != cur->f_hd)
      GNUNET_DISK_file_close (cur->f_hd);
    GNUNET_free (cur);
  }
}

References GNUNET_TIME_Absolute::abs_value_us, LoggingAddress::active, LoggingPeer::addr_head, LoggingFileHandle::aid, LoggingAddress::aid, LoggingAddress::assigned_bw_in, LoggingAddress::assigned_bw_out, cleanup(), LoggingTimeStep::delta, DIR_SEPARATOR_STR, e, LoggingFileHandle::f_hd, filename, find_logging_file_handle(), GNUNET_asprintf(), GNUNET_CONTAINER_DLL_insert, GNUNET_CONTAINER_DLL_remove, GNUNET_DISK_directory_create_for_file(), GNUNET_DISK_file_close(), GNUNET_DISK_file_open(), GNUNET_DISK_file_write(), GNUNET_DISK_OPEN_CREATE, GNUNET_DISK_OPEN_READWRITE, GNUNET_DISK_OPEN_TRUNCATE, GNUNET_DISK_PERM_GROUP_READ, GNUNET_DISK_PERM_OTHER_READ, GNUNET_DISK_PERM_USER_READ, GNUNET_DISK_PERM_USER_WRITE, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_log, GNUNET_new, GNUNET_NO, GNUNET_OK, GNUNET_strdup, GNUNET_TIME_absolute_get_difference(), GNUNET_YES, LoggingTimeStep::head, LoggingHandle::head, LoggingPeer::id, LoggingPeer::is_requested, l, Experiment::log_prefix, LoggingAddress::network, LoggingFileHandle::next, LoggingTimeStep::next, LoggingPeer::next, LoggingAddress::next, opt_solver, LoggingFileHandle::pid, LoggingPeer::pref_abs, LoggingPeer::pref_norm, LoggingAddress::prop_abs, LoggingAddress::prop_norm, and LoggingTimeStep::timestamp.

Referenced by done().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_logging_eval()

void GNUNET_ATS_solver_logging_eval

(

struct LoggingHandle *

l

)

Definition at line 459 of file gnunet-ats-solver-eval.c.

{
  struct LoggingTimeStep *lts;
  struct LoggingPeer *log_p;
  struct LoggingAddress *log_a;
  int c;
 
  for (lts = l->head; NULL != lts; lts = lts->next)
  {
    fprintf (stderr, "Log step %llu %llu: \n",
             (long long unsigned int) lts->timestamp.abs_value_us,
             (long long unsigned int) lts->delta.rel_value_us);
 
    for (log_p = lts->head; NULL != log_p; log_p = log_p->next)
    {
      fprintf (stderr, "\tLogging peer pid %llu\n", log_p->id);
      for (c = 1; c < GNUNET_ATS_PreferenceCount; c++)
      {
        fprintf (stderr, "\t %s = %.2f %.2f [abs/rel]\n",
                 GNUNET_ATS_print_preference_type (c),
                 log_p->pref_abs[c], log_p->pref_norm[c]);
      }
 
      for (log_a = log_p->addr_head; NULL != log_a; log_a = log_a->next)
      {
        fprintf (stderr, "\tPeer pid %llu address %llu: %u %u %u\n",
                 log_p->id, log_a->aid, log_a->active,
                 log_a->assigned_bw_in,
                 log_a->assigned_bw_out);
 
        for (c = 1; c < GNUNET_ATS_PropertyCount; c++)
        {
          if (GNUNET_ATS_NETWORK_TYPE == c)
            continue;
          fprintf (stderr, "\t %s = %.2f %.2f [abs/rel]\n",
                   GNUNET_ATS_print_property_type (c),
                   log_a->prop_abs[c], log_a->prop_norm[c]);
        }
      }
    }
  }
}

References GNUNET_TIME_Absolute::abs_value_us, LoggingAddress::active, LoggingPeer::addr_head, LoggingAddress::aid, LoggingAddress::assigned_bw_in, LoggingAddress::assigned_bw_out, LoggingTimeStep::delta, GNUNET_ATS_print_preference_type(), LoggingTimeStep::head, LoggingHandle::head, LoggingPeer::id, l, LoggingTimeStep::next, LoggingPeer::next, LoggingAddress::next, LoggingPeer::pref_abs, LoggingPeer::pref_norm, LoggingAddress::prop_abs, LoggingAddress::prop_norm, GNUNET_TIME_Relative::rel_value_us, and LoggingTimeStep::timestamp.

Referenced by done().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_logging_free()

void GNUNET_ATS_solver_logging_free

(

struct LoggingHandle *

l

)

Definition at line 504 of file gnunet-ats-solver-eval.c.

{
  struct LoggingTimeStep *lts_cur;
  struct LoggingTimeStep *lts_next;
  struct LoggingPeer *log_p_cur;
  struct LoggingPeer *log_p_next;
  struct LoggingAddress *log_a_cur;
  struct LoggingAddress *log_a_next;
 
  if (NULL != l->logging_task)
    GNUNET_SCHEDULER_cancel (l->logging_task);
  l->logging_task = NULL;
 
  lts_next = l->head;
  while (NULL != (lts_cur = lts_next))
  {
    lts_next = lts_cur->next;
 
    log_p_next = lts_cur->head;
    while (NULL != (log_p_cur = log_p_next))
    {
      log_p_next = log_p_cur->next;
 
      log_a_next = log_p_cur->addr_head;
      while (NULL != (log_a_cur = log_a_next))
      {
        log_a_next = log_a_cur->next;
 
        GNUNET_CONTAINER_DLL_remove (log_p_cur->addr_head, log_p_cur->addr_tail,
                                     log_a_cur);
        GNUNET_free (log_a_cur);
      }
 
      GNUNET_CONTAINER_DLL_remove (lts_cur->head, lts_cur->tail, log_p_cur);
      GNUNET_free (log_p_cur);
    }
 
    GNUNET_CONTAINER_DLL_remove (l->head, l->tail, lts_cur);
    GNUNET_free (lts_cur);
  }
 
  GNUNET_free (l);
}

References LoggingPeer::addr_head, LoggingPeer::addr_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_SCHEDULER_cancel(), LoggingTimeStep::head, LoggingHandle::head, l, LoggingHandle::logging_task, LoggingTimeStep::next, LoggingPeer::next, LoggingAddress::next, LoggingTimeStep::tail, and LoggingHandle::tail.

Referenced by done().

Here is the call graph for this function:

Here is the caller graph for this function:

get_property()

static double get_property ( struct PropertyGenerator *  pg )

static

Definition at line 557 of file gnunet-ats-solver-eval.c.

{
  struct GNUNET_TIME_Relative time_delta;
  double delta_value;
  double pref_value;
 
  /* Calculate the current preference value */
  switch (pg->type)
  {
  case GNUNET_ATS_TEST_TG_CONSTANT:
    pref_value = pg->base_value;
    break;
 
  case GNUNET_ATS_TEST_TG_LINEAR:
    time_delta = GNUNET_TIME_absolute_get_duration (pg->time_start);
    /* Calculate point of time in the current period */
    time_delta.rel_value_us = time_delta.rel_value_us
                              % pg->duration_period.rel_value_us;
    delta_value = ((double) time_delta.rel_value_us
                   / pg->duration_period.rel_value_us) * (pg->max_value
                                                          - pg->base_value);
    if ((pg->max_value < pg->base_value) &&
        ((pg->max_value - pg->base_value) > pg->base_value))
    {
      /* This will cause an underflow */
      GNUNET_break (0);
    }
    pref_value = pg->base_value + delta_value;
    break;
 
  case GNUNET_ATS_TEST_TG_RANDOM:
    delta_value = (double) GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
                                                     10000 * (pg->max_value
                                                              - pg->base_value))
                  / 10000;
    pref_value = pg->base_value + delta_value;
    break;
 
  case GNUNET_ATS_TEST_TG_SINUS:
    time_delta = GNUNET_TIME_absolute_get_duration (pg->time_start);
    /* Calculate point of time in the current period */
    time_delta.rel_value_us = time_delta.rel_value_us
                              % pg->duration_period.rel_value_us;
    if ((pg->max_value - pg->base_value) > pg->base_value)
    {
      /* This will cause an underflow for second half of sinus period,
       * will be detected in general when experiments are loaded */
      GNUNET_break (0);
    }
    delta_value = (pg->max_value - pg->base_value)
                  * sin ((2 * M_PI)
                         / ((double) pg->duration_period.rel_value_us)
                         * time_delta.rel_value_us);
    pref_value = pg->base_value + delta_value;
    break;
 
  default:
    pref_value = 0.0;
    break;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Current property value is %f\n",
              pref_value);
  return pref_value;
}

References PropertyGenerator::base_value, PropertyGenerator::duration_period, GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, GNUNET_ATS_TEST_TG_SINUS, GNUNET_break, GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u32(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_TIME_absolute_get_duration(), PropertyGenerator::max_value, GNUNET_TIME_Relative::rel_value_us, PropertyGenerator::time_start, and PropertyGenerator::type.

Referenced by set_prop_task().

Here is the call graph for this function:

Here is the caller graph for this function:

set_prop_task()

static void set_prop_task ( void *  cls )

static

Definition at line 624 of file gnunet-ats-solver-eval.c.

{
  struct PropertyGenerator *pg = cls;
  struct TestPeer *p;
  struct TestAddress *a;
  double prop_value;
  struct GNUNET_ATS_Information atsi;
 
  pg->set_task = NULL;
 
  if (GNUNET_NO == GNUNET_CONTAINER_multipeermap_contains_value (sh->addresses,
                                                                 &pg->test_peer
                                                                 ->peer_id,
                                                                 pg->
                                                                 test_address->
                                                                 ats_addr))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting property generation for unknown address [%u:%u]\n",
                pg->peer, pg->address_id);
    return;
  }
  if (NULL == (p = find_peer_by_id (pg->peer)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting property generation for unknown peer %u\n",
                pg->peer);
    return;
  }
  if (NULL == (a = find_address_by_id (p, pg->address_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting property generation for unknown peer %u\n",
                pg->peer);
    return;
  }
 
  prop_value = get_property (pg);
  a->prop_abs[pg->ats_property] = prop_value;
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Setting property for peer [%u] address [%u] for %s to %f\n",
              pg->peer, pg->address_id,
              GNUNET_ATS_print_property_type (pg->ats_property), prop_value);
 
  atsi.type = htonl (pg->ats_property);
  atsi.value = htonl ((uint32_t) prop_value);
 
  /* set performance here! */
  sh->sf->s_bulk_start (sh->sf->cls);
  if (GNUNET_YES == opt_disable_normalization)
  {
    a->prop_abs[pg->ats_property] = prop_value;
    a->prop_norm[pg->ats_property] = prop_value;
    sh->sf->s_address_update_property (sh->sf->cls, a->ats_addr,
                                       pg->ats_property, prop_value,
                                       prop_value);
  }
  else
    GAS_normalization_update_property (pg->test_address->ats_addr, &atsi, 1);
  sh->sf->s_bulk_stop (sh->sf->cls);
 
  pg->set_task = GNUNET_SCHEDULER_add_delayed (pg->frequency,
                                               &set_prop_task, pg);
}

References PropertyGenerator::address_id, SolverHandle::addresses, TestAddress::ats_addr, PropertyGenerator::ats_property, GNUNET_ATS_SolverFunctions::cls, find_address_by_id(), find_peer_by_id(), PropertyGenerator::frequency, GAS_normalization_update_property(), get_property(), GNUNET_break, GNUNET_CONTAINER_multipeermap_contains_value(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_NO, GNUNET_SCHEDULER_add_delayed(), GNUNET_YES, opt_disable_normalization, p, PropertyGenerator::peer, TestPeer::peer_id, TestAddress::prop_abs, TestAddress::prop_norm, GNUNET_ATS_SolverFunctions::s_address_update_property, GNUNET_ATS_SolverFunctions::s_bulk_start, GNUNET_ATS_SolverFunctions::s_bulk_stop, PropertyGenerator::set_task, SolverHandle::sf, sh, PropertyGenerator::test_address, test_address(), and PropertyGenerator::test_peer.

Referenced by GNUNET_ATS_solver_generate_property_start().

Here is the call graph for this function:

Here is the caller graph for this function:

find_prop_gen()

static struct PropertyGenerator* find_prop_gen ( unsigned int  peer, unsigned int  address, uint32_t  ats_property  )

static

Set ats_property to 0 to find all pgs.

Definition at line 698 of file gnunet-ats-solver-eval.c.

{
  struct PropertyGenerator *cur;
 
  for (cur = prop_gen_head; NULL != cur; cur = cur->next)
    if ((cur->peer == peer) && (cur->address_id == address))
    {
      if ((cur->ats_property == ats_property) || (0 == ats_property))
        return cur;
    }
  return NULL;
}

References address, PropertyGenerator::address_id, PropertyGenerator::ats_property, PropertyGenerator::next, PropertyGenerator::peer, peer, and prop_gen_head.

Referenced by enforce_del_address(), enforce_start_property(), and enforce_stop_property().

Here is the caller graph for this function:

GNUNET_ATS_solver_generate_property_stop()

void GNUNET_ATS_solver_generate_property_stop

(

struct PropertyGenerator *

pg

)

Definition at line 714 of file gnunet-ats-solver-eval.c.

{
  GNUNET_CONTAINER_DLL_remove (prop_gen_head, prop_gen_tail, pg);
 
  if (NULL != pg->set_task)
  {
    GNUNET_SCHEDULER_cancel (pg->set_task);
    pg->set_task = NULL;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Removing old up preference generator peer [%u] address [%u] `%s'\n",
              pg->peer, pg->address_id,
              GNUNET_ATS_print_property_type (pg->ats_property));
 
  GNUNET_free (pg);
}

References PropertyGenerator::address_id, PropertyGenerator::ats_property, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_SCHEDULER_cancel(), PropertyGenerator::peer, prop_gen_head, prop_gen_tail, and PropertyGenerator::set_task.

Referenced by enforce_del_address(), enforce_start_property(), enforce_stop_property(), and GNUNET_ATS_solver_generate_property_stop_all().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_generate_property_start()

struct PropertyGenerator* GNUNET_ATS_solver_generate_property_start	(	unsigned int	peer,
		unsigned int	address_id,
		struct TestPeer *	test_peer,
		struct TestAddress *	test_address,
		enum GeneratorType	type,
		long int	base_value,
		long int	value_rate,
		struct GNUNET_TIME_Relative	period,
		struct GNUNET_TIME_Relative	frequency,
		uint32_t	ats_property
	)

Generate between the source master and the partner and set property with a value depending on the generator.

Parameters

peer	source
address_id	partner
test_peer	the peer
test_address	the address
type	type of generator
base_value	base value
value_rate	maximum value
period	duration of a period of generation (~ 1/frequency)
frequency	how long to generate property
ats_property	ATS property to generate

Returns

the property generator

Definition at line 749 of file gnunet-ats-solver-eval.c.

{
  struct PropertyGenerator *pg;
 
  pg = GNUNET_new (struct PropertyGenerator);
  GNUNET_CONTAINER_DLL_insert (prop_gen_head, prop_gen_tail, pg);
  pg->type = type;
  pg->peer = peer;
  pg->test_address = test_address;
  pg->test_peer = test_peer;
  pg->address_id = address_id;
  pg->ats_property = ats_property;
  pg->base_value = base_value;
  pg->max_value = value_rate;
  pg->duration_period = period;
  pg->frequency = frequency;
  pg->time_start = GNUNET_TIME_absolute_get ();
 
  switch (type)
  {
  case GNUNET_ATS_TEST_TG_CONSTANT:
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Setting up %s property generator peer [%u] address [%u] `%s'" \
                "max %u Bips\n",
                print_generator_type (type), pg->peer, pg->address_id,
                GNUNET_ATS_print_property_type (ats_property),
                base_value);
    break;
 
  case GNUNET_ATS_TEST_TG_LINEAR:
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Setting up %s property generator peer [%u] address [%u] `%s' " \
                "min %u Bips max %u Bips\n",
                print_generator_type (type), pg->peer, pg->address_id,
                GNUNET_ATS_print_property_type (ats_property),
                base_value, value_rate);
    break;
 
  case GNUNET_ATS_TEST_TG_SINUS:
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Setting up %s property generator peer [%u] address [%u] `%s' " \
                "baserate %u Bips, amplitude %u Bps\n",
                print_generator_type (type), pg->peer, pg->address_id,
                GNUNET_ATS_print_property_type (ats_property),
                base_value, value_rate);
    break;
 
  case GNUNET_ATS_TEST_TG_RANDOM:
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Setting up %s property generator peer [%u] address [%u] `%s' " \
                "min %u Bips max %u Bps\n",
                print_generator_type (type), pg->peer, pg->address_id,
                GNUNET_ATS_print_property_type (ats_property),
                base_value, value_rate);
    break;
 
  default:
    break;
  }
 
  pg->set_task = GNUNET_SCHEDULER_add_now (&set_prop_task, pg);
  return pg;
}

References PropertyGenerator::address_id, PropertyGenerator::ats_property, PropertyGenerator::base_value, PropertyGenerator::duration_period, PropertyGenerator::frequency, GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, GNUNET_ATS_TEST_TG_SINUS, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_new, GNUNET_SCHEDULER_add_now(), GNUNET_TIME_absolute_get(), PropertyGenerator::max_value, PropertyGenerator::peer, peer, print_generator_type(), prop_gen_head, prop_gen_tail, set_prop_task(), PropertyGenerator::set_task, PropertyGenerator::test_address, test_address(), PropertyGenerator::test_peer, PropertyGenerator::time_start, PropertyGenerator::type, and type.

Referenced by enforce_start_property().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_generate_property_stop_all()

void GNUNET_ATS_solver_generate_property_stop_all

(

)

Stop all preferences generators.

Definition at line 828 of file gnunet-ats-solver-eval.c.

{
  struct PropertyGenerator *cur;
  struct PropertyGenerator *next;
 
  next = prop_gen_head;
  for (cur = next; NULL != cur; cur = next)
  {
    next = cur->next;
    GNUNET_ATS_solver_generate_property_stop (cur);
  }
}

References GNUNET_ATS_solver_generate_property_stop(), PropertyGenerator::next, and prop_gen_head.

Referenced by done().

Here is the call graph for this function:

Here is the caller graph for this function:

get_preference()

static double get_preference ( struct PreferenceGenerator *  pg )

static

Definition at line 850 of file gnunet-ats-solver-eval.c.

{
  struct GNUNET_TIME_Relative time_delta;
  double delta_value;
  double pref_value;
 
  /* Calculate the current preference value */
  switch (pg->type)
  {
  case GNUNET_ATS_TEST_TG_CONSTANT:
    pref_value = pg->base_value;
    break;
 
  case GNUNET_ATS_TEST_TG_LINEAR:
    time_delta = GNUNET_TIME_absolute_get_duration (pg->time_start);
    /* Calculate point of time in the current period */
    time_delta.rel_value_us = time_delta.rel_value_us
                              % pg->duration_period.rel_value_us;
    delta_value = ((double) time_delta.rel_value_us
                   / pg->duration_period.rel_value_us) * (pg->max_value
                                                          - pg->base_value);
    if ((pg->max_value < pg->base_value) &&
        ((pg->max_value - pg->base_value) > pg->base_value))
    {
      /* This will cause an underflow */
      GNUNET_break (0);
    }
    pref_value = pg->base_value + delta_value;
    break;
 
  case GNUNET_ATS_TEST_TG_RANDOM:
    delta_value = (double) GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
                                                     10000 * (pg->max_value
                                                              - pg->base_value))
                  / 10000;
    pref_value = pg->base_value + delta_value;
    break;
 
  case GNUNET_ATS_TEST_TG_SINUS:
    time_delta = GNUNET_TIME_absolute_get_duration (pg->time_start);
    /* Calculate point of time in the current period */
    time_delta.rel_value_us = time_delta.rel_value_us
                              % pg->duration_period.rel_value_us;
    if ((pg->max_value - pg->base_value) > pg->base_value)
    {
      /* This will cause an underflow for second half of sinus period,
       * will be detected in general when experiments are loaded */
      GNUNET_break (0);
    }
    delta_value = (pg->max_value - pg->base_value)
                  * sin ((2 * M_PI)
                         / ((double) pg->duration_period.rel_value_us)
                         * time_delta.rel_value_us);
    pref_value = pg->base_value + delta_value;
    break;
 
  default:
    pref_value = 0.0;
    break;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Current preference value is %f\n",
              pref_value);
  return pref_value;
}

References PreferenceGenerator::base_value, PreferenceGenerator::duration_period, GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, GNUNET_ATS_TEST_TG_SINUS, GNUNET_break, GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u32(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_TIME_absolute_get_duration(), PreferenceGenerator::max_value, GNUNET_TIME_Relative::rel_value_us, PreferenceGenerator::time_start, and PreferenceGenerator::type.

Referenced by set_feedback_task(), and set_pref_task().

Here is the call graph for this function:

Here is the caller graph for this function:

set_feedback_task()

static void set_feedback_task ( void *  cls )

static

Definition at line 917 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *pg = cls;
  struct TestPeer *p;
  double feedback;
  uint32_t bw_acc_out;
  uint32_t bw_acc_in;
  uint32_t delay_acc_in;
  struct GNUNET_TIME_Relative dur;
  double p_new;
 
  pg->feedback_task = NULL;
 
  if (NULL == (p = find_peer_by_id (pg->peer)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting feedback for unknown peer %u\n", pg->peer);
    return;
  }
 
  switch (pg->kind)
  {
  case GNUNET_ATS_PREFERENCE_BANDWIDTH:
    dur = GNUNET_TIME_absolute_get_duration (pg->feedback_last_bw_update);
    bw_acc_in = dur.rel_value_us * pg->last_assigned_bw_in
                + pg->feedback_bw_in_acc;
    pg->feedback_bw_in_acc = 0;
 
    bw_acc_out = dur.rel_value_us * pg->last_assigned_bw_out
                 + pg->feedback_bw_out_acc;
    p_new = get_preference (pg);
    feedback = (p_new / pg->pref_bw_old) * (bw_acc_in + bw_acc_out)
               / (2 * GNUNET_TIME_absolute_get_duration (
                    pg->feedback_last).rel_value_us);
 
    break;
 
  case GNUNET_ATS_PREFERENCE_LATENCY:
    dur = GNUNET_TIME_absolute_get_duration (pg->feedback_last_delay_update);
    delay_acc_in = dur.rel_value_us * pg->last_delay_value
                   + pg->feedback_delay_acc;
    pg->feedback_delay_acc = 0;
 
    p_new = get_preference (pg);
    feedback = (p_new / pg->pref_latency_old) * (delay_acc_in)
               / (GNUNET_TIME_absolute_get_duration (
                    pg->feedback_last).rel_value_us);
 
    break;
 
  default:
    GNUNET_break (0);
    feedback = 0.0;
    break;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Giving feedback for peer [%u] for client %p pref %s of %.3f\n",
              pg->peer, NULL + (pg->client_id),
              GNUNET_ATS_print_preference_type (pg->kind),
              feedback);
 
  sh->sf->s_feedback (sh->sf->cls, NULL + (pg->client_id), &p->peer_id,
                      pg->feedback_frequency, pg->kind, feedback);
  pg->feedback_last = GNUNET_TIME_absolute_get ();
 
 
  pg->feedback_bw_out_acc = 0;
  pg->feedback_bw_in_acc = 0;
  pg->feedback_last_bw_update = GNUNET_TIME_absolute_get ();
 
  pg->feedback_delay_acc = 0;
  pg->feedback_last_delay_update = GNUNET_TIME_absolute_get ();
 
 
  pg->feedback_task = GNUNET_SCHEDULER_add_delayed (pg->feedback_frequency,
                                                    &set_feedback_task, pg);
}

References PreferenceGenerator::client_id, GNUNET_ATS_SolverFunctions::cls, PreferenceGenerator::feedback_bw_in_acc, PreferenceGenerator::feedback_bw_out_acc, PreferenceGenerator::feedback_delay_acc, PreferenceGenerator::feedback_frequency, PreferenceGenerator::feedback_last, PreferenceGenerator::feedback_last_bw_update, PreferenceGenerator::feedback_last_delay_update, PreferenceGenerator::feedback_task, find_peer_by_id(), get_preference(), GNUNET_ATS_PREFERENCE_BANDWIDTH, GNUNET_ATS_PREFERENCE_LATENCY, GNUNET_ATS_print_preference_type(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_get_duration(), PreferenceGenerator::kind, PreferenceGenerator::last_assigned_bw_in, PreferenceGenerator::last_assigned_bw_out, PreferenceGenerator::last_delay_value, p, PreferenceGenerator::peer, PreferenceGenerator::pref_bw_old, PreferenceGenerator::pref_latency_old, GNUNET_TIME_Relative::rel_value_us, GNUNET_ATS_SolverFunctions::s_feedback, SolverHandle::sf, and sh.

Referenced by GNUNET_ATS_solver_generate_preferences_start().

Here is the call graph for this function:

Here is the caller graph for this function:

set_pref_task()

static void set_pref_task ( void *  cls )

static

Definition at line 998 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *pg = cls;
  struct TestPeer *p;
  double pref_value;
 
  pg->set_task = NULL;
 
  if (NULL == (p = find_peer_by_id (pg->peer)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting preference for unknown peer %u\n", pg->peer);
    return;
  }
 
  pref_value = get_preference (pg);
  switch (pg->kind)
  {
  case GNUNET_ATS_PREFERENCE_BANDWIDTH:
    pg->pref_bw_old = pref_value;
    break;
 
  case GNUNET_ATS_PREFERENCE_LATENCY:
    pg->pref_latency_old = pref_value;
    break;
 
  default:
    break;
  }
 
  p->pref_abs[pg->kind] = pref_value;
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Setting preference for peer [%u] for client %p pref %s to %f\n",
              pg->peer, NULL + (pg->client_id),
              GNUNET_ATS_print_preference_type (pg->kind), pref_value);
 
  if (GNUNET_YES == opt_disable_normalization)
  {
    p->pref_abs[pg->kind] = pref_value;
    p->pref_norm[pg->kind] = pref_value;
    sh->sf->s_pref (sh->sf->cls, &p->peer_id, pg->kind, pref_value);
  }
  else
    update_preference (NULL + (pg->client_id),
                       &p->peer_id,
                       pg->kind,
                       pref_value);
 
  pg->set_task = GNUNET_SCHEDULER_add_delayed (pg->frequency,
                                               &set_pref_task,
                                               pg);
}

References PreferenceGenerator::client_id, GNUNET_ATS_SolverFunctions::cls, find_peer_by_id(), PreferenceGenerator::frequency, get_preference(), GNUNET_ATS_PREFERENCE_BANDWIDTH, GNUNET_ATS_PREFERENCE_LATENCY, GNUNET_ATS_print_preference_type(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_SCHEDULER_add_delayed(), GNUNET_YES, PreferenceGenerator::kind, opt_disable_normalization, p, PreferenceGenerator::peer, PreferenceGenerator::pref_bw_old, PreferenceGenerator::pref_latency_old, GNUNET_ATS_SolverFunctions::s_pref, PreferenceGenerator::set_task, SolverHandle::sf, sh, and update_preference().

Referenced by GNUNET_ATS_solver_generate_preferences_start().

Here is the call graph for this function:

Here is the caller graph for this function:

find_pref_gen()

static struct PreferenceGenerator* find_pref_gen ( unsigned int  peer, enum GNUNET_ATS_PreferenceKind  kind  )

static

Definition at line 1055 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *cur;
 
  for (cur = pref_gen_head; NULL != cur; cur = cur->next)
    if (cur->peer == peer)
    {
      if ((cur->kind == kind) || (GNUNET_ATS_PREFERENCE_END == kind))
        return cur;
    }
  return NULL;
}

References GNUNET_ATS_PREFERENCE_END, PreferenceGenerator::kind, PreferenceGenerator::next, PreferenceGenerator::peer, peer, and pref_gen_head.

Referenced by enforce_start_preference(), and enforce_stop_preference().

Here is the caller graph for this function:

GNUNET_ATS_solver_generate_preferences_stop()

void GNUNET_ATS_solver_generate_preferences_stop

(

struct PreferenceGenerator *

pg

)

Definition at line 1070 of file gnunet-ats-solver-eval.c.

{
  GNUNET_CONTAINER_DLL_remove (pref_gen_head, pref_gen_tail, pg);
 
  if (NULL != pg->feedback_task)
  {
    GNUNET_SCHEDULER_cancel (pg->feedback_task);
    pg->feedback_task = NULL;
  }
 
  if (NULL != pg->set_task)
  {
    GNUNET_SCHEDULER_cancel (pg->set_task);
    pg->set_task = NULL;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Removing old up preference generator peer [%u] `%s'\n",
              pg->peer, GNUNET_ATS_print_preference_type (pg->kind));
 
  GNUNET_free (pg);
}

References PreferenceGenerator::feedback_task, GNUNET_ATS_print_preference_type(), GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_SCHEDULER_cancel(), PreferenceGenerator::kind, PreferenceGenerator::peer, pref_gen_head, pref_gen_tail, and PreferenceGenerator::set_task.

Referenced by enforce_start_preference(), enforce_stop_preference(), and GNUNET_ATS_solver_generate_preferences_stop_all().

Here is the call graph for this function:

Here is the caller graph for this function:

find_active_address()

static struct TestAddress* find_active_address ( struct TestPeer *  p )

static

Definition at line 1094 of file gnunet-ats-solver-eval.c.

{
  struct TestAddress *cur;
 
  for (cur = p->addr_head; NULL != cur; cur = cur->next)
    if (GNUNET_YES == cur->ats_addr->active)
      return cur;
  return NULL;
}

References ATS_Address::active, TestAddress::ats_addr, GNUNET_YES, TestAddress::next, and p.

Referenced by GNUNET_ATS_solver_generate_preferences_start().

Here is the caller graph for this function:

GNUNET_ATS_solver_generate_preferences_start()

struct PreferenceGenerator* GNUNET_ATS_solver_generate_preferences_start	(	unsigned int	peer,
		unsigned int	address_id,
		unsigned int	client_id,
		enum GeneratorType	type,
		long int	base_value,
		long int	value_rate,
		struct GNUNET_TIME_Relative	period,
		struct GNUNET_TIME_Relative	frequency,
		enum GNUNET_ATS_PreferenceKind	kind,
		struct GNUNET_TIME_Relative	feedback_frequency
	)

Generate between the source master and the partner and set property with a value depending on the generator.

Parameters

peer	source
address_id	partner
client_id	the client
type	type of generator
base_value	base value
value_rate	maximum value
period	duration of a period of generation (~ 1/frequency)
frequency	how long to generate property
kind	ATS preference to generate
feedback_frequency	how often to give feedback

Returns

the preference generator

Definition at line 1122 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *pg;
  struct TestPeer *p;
 
  if (NULL == (p = find_peer_by_id (peer)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Starting preference for unknown peer %u\n", peer);
    return NULL;
  }
 
  pg = GNUNET_new (struct PreferenceGenerator);
  GNUNET_CONTAINER_DLL_insert (pref_gen_head, pref_gen_tail, pg);
  pg->type = type;
  pg->peer = peer;
  pg->client_id = client_id;
  pg->kind = kind;
  pg->base_value = base_value;
  pg->max_value = value_rate;
  pg->duration_period = period;
  pg->frequency = frequency;
  pg->time_start = GNUNET_TIME_absolute_get ();
  pg->feedback_frequency = feedback_frequency;
 
  switch (type)
  {
  case GNUNET_ATS_TEST_TG_CONSTANT:
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting up %s preference generator peer [%u] `%s' max %u Bips\n",
                print_generator_type (type), pg->peer,
                GNUNET_ATS_print_preference_type (kind),
                base_value);
    break;
 
  case GNUNET_ATS_TEST_TG_LINEAR:
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting up %s preference generator peer [%u] `%s' min %u Bips max %u Bips\n",
                print_generator_type (type), pg->peer,
                GNUNET_ATS_print_preference_type (kind),
                base_value, value_rate);
    break;
 
  case GNUNET_ATS_TEST_TG_SINUS:
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting up %s preference generator peer [%u] `%s' baserate %u Bips, amplitude %u Bps\n",
                print_generator_type (type), pg->peer,
                GNUNET_ATS_print_preference_type (kind),
                base_value, value_rate);
    break;
 
  case GNUNET_ATS_TEST_TG_RANDOM:
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting up %s preference generator peer [%u] `%s' min %u Bips max %u Bps\n",
                print_generator_type (type), pg->peer,
                GNUNET_ATS_print_preference_type (kind),
                base_value, value_rate);
    break;
 
  default:
    break;
  }
 
  pg->set_task = GNUNET_SCHEDULER_add_now (&set_pref_task, pg);
  if (GNUNET_TIME_UNIT_FOREVER_REL.rel_value_us !=
      feedback_frequency.rel_value_us)
  {
    struct TestAddress *addr = find_active_address (p);
 
    pg->last_assigned_bw_in = p->assigned_bw_in;
    pg->last_assigned_bw_out = p->assigned_bw_out;
    pg->feedback_bw_in_acc = 0;
    pg->feedback_bw_out_acc = 0;
    pg->last_delay_value = addr->prop_norm[GNUNET_ATS_QUALITY_NET_DELAY];
    pg->feedback_delay_acc = 0;
 
    pg->feedback_last_bw_update = GNUNET_TIME_absolute_get ();
    pg->feedback_last_delay_update = GNUNET_TIME_absolute_get ();
    pg->feedback_last = GNUNET_TIME_absolute_get ();
    pg->feedback_task = GNUNET_SCHEDULER_add_delayed (feedback_frequency,
                                                      &set_feedback_task, pg);
  }
 
  return pg;
}

References PreferenceGenerator::base_value, PreferenceGenerator::client_id, PreferenceGenerator::duration_period, PreferenceGenerator::feedback_bw_in_acc, PreferenceGenerator::feedback_bw_out_acc, PreferenceGenerator::feedback_delay_acc, PreferenceGenerator::feedback_frequency, PreferenceGenerator::feedback_last, PreferenceGenerator::feedback_last_bw_update, PreferenceGenerator::feedback_last_delay_update, PreferenceGenerator::feedback_task, find_active_address(), find_peer_by_id(), PreferenceGenerator::frequency, GNUNET_ATS_print_preference_type(), GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, GNUNET_ATS_TEST_TG_SINUS, GNUNET_break, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_new, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_add_now(), GNUNET_TIME_absolute_get(), GNUNET_TIME_UNIT_FOREVER_REL, PreferenceGenerator::kind, PreferenceGenerator::last_assigned_bw_in, PreferenceGenerator::last_assigned_bw_out, PreferenceGenerator::last_delay_value, PreferenceGenerator::max_value, p, PreferenceGenerator::peer, peer, pref_gen_head, pref_gen_tail, print_generator_type(), TestAddress::prop_norm, GNUNET_TIME_Relative::rel_value_us, set_feedback_task(), set_pref_task(), PreferenceGenerator::set_task, PreferenceGenerator::time_start, PreferenceGenerator::type, and type.

Referenced by enforce_start_preference().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solver_generate_preferences_stop_all()

void GNUNET_ATS_solver_generate_preferences_stop_all

(

)

Stop all preferences generators.

Definition at line 1227 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *cur;
  struct PreferenceGenerator *next;
 
  next = pref_gen_head;
  for (cur = next; NULL != cur; cur = next)
  {
    next = cur->next;
    GNUNET_ATS_solver_generate_preferences_stop (cur);
  }
}

References GNUNET_ATS_solver_generate_preferences_stop(), PreferenceGenerator::next, and pref_gen_head.

Referenced by done().

Here is the call graph for this function:

Here is the caller graph for this function:

print_op()

static const char* print_op ( enum OperationType  op )

static

Experiments.

Definition at line 1245 of file gnunet-ats-solver-eval.c.

{
  switch (op)
  {
  case SOLVER_OP_ADD_ADDRESS:
    return "ADD_ADDRESS";
 
  case SOLVER_OP_DEL_ADDRESS:
    return "DEL_ADDRESS";
 
  case SOLVER_OP_START_SET_PREFERENCE:
    return "START_SET_PREFERENCE";
 
  case SOLVER_OP_STOP_SET_PREFERENCE:
    return "STOP_STOP_PREFERENCE";
 
  case SOLVER_OP_START_SET_PROPERTY:
    return "START_SET_PROPERTY";
 
  case SOLVER_OP_STOP_SET_PROPERTY:
    return "STOP_SET_PROPERTY";
 
  case SOLVER_OP_START_REQUEST:
    return "START_REQUEST";
 
  case SOLVER_OP_STOP_REQUEST:
    return "STOP_REQUEST";
 
  default:
    break;
  }
  return "";
}

References op, SOLVER_OP_ADD_ADDRESS, SOLVER_OP_DEL_ADDRESS, SOLVER_OP_START_REQUEST, SOLVER_OP_START_SET_PREFERENCE, SOLVER_OP_START_SET_PROPERTY, SOLVER_OP_STOP_REQUEST, SOLVER_OP_STOP_SET_PREFERENCE, and SOLVER_OP_STOP_SET_PROPERTY.

Referenced by enforce_episode().

Here is the caller graph for this function:

create_experiment()

static struct Experiment* create_experiment ( )

static

Definition at line 1281 of file gnunet-ats-solver-eval.c.

{
  struct Experiment *e;
 
  e = GNUNET_new (struct Experiment);
  e->name = NULL;
  e->start = NULL;
  e->total_duration = GNUNET_TIME_UNIT_ZERO;
  return e;
}

References e, GNUNET_new, GNUNET_TIME_UNIT_ZERO, Experiment::name, Experiment::start, and Experiment::total_duration.

Referenced by GNUNET_ATS_solvers_experimentation_load().

Here is the caller graph for this function:

free_experiment()

static void free_experiment ( struct Experiment *  e )

static

Definition at line 1294 of file gnunet-ats-solver-eval.c.

{
  struct Episode *cur;
  struct Episode *next;
  struct GNUNET_ATS_TEST_Operation *cur_o;
  struct GNUNET_ATS_TEST_Operation *next_o;
 
  next = e->start;
  for (cur = next; NULL != cur; cur = next)
  {
    next = cur->next;
 
    next_o = cur->head;
    for (cur_o = next_o; NULL != cur_o; cur_o = next_o)
    {
      next_o = cur_o->next;
      GNUNET_free (cur_o->address);
      GNUNET_free (cur_o->plugin);
      GNUNET_free (cur_o);
    }
    GNUNET_free (cur);
  }
 
  GNUNET_free (e->name);
  GNUNET_free (e->log_prefix);
  GNUNET_free (e->log_output_dir);
  GNUNET_free (e->cfg_file);
  GNUNET_free (e);
}

References GNUNET_ATS_TEST_Operation::address, Experiment::cfg_file, e, GNUNET_free, Episode::head, Experiment::log_output_dir, Experiment::log_prefix, Experiment::name, GNUNET_ATS_TEST_Operation::next, Episode::next, GNUNET_ATS_TEST_Operation::plugin, and Experiment::start.

Referenced by GNUNET_ATS_solvers_experimentation_load(), and GNUNET_ATS_solvers_experimentation_stop().

Here is the caller graph for this function:

load_op_add_address()

static int load_op_add_address ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 1326 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
  char *op_network;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u `%s' in episode `%s'\n",
             op_counter, "ADD_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address pid */
  GNUNET_asprintf (&op_name, "op-%u-address-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->address_id))
  {
    fprintf (stderr,
             "Missing address-id in operation %u `%s' in episode `%s'\n",
             op_counter, "ADD_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* plugin */
  GNUNET_asprintf (&op_name, "op-%u-plugin", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &o->plugin))
  {
    fprintf (stderr, "Missing plugin in operation %u `%s' in episode `%s'\n",
             op_counter, "ADD_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address  */
  GNUNET_asprintf (&op_name, "op-%u-address", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &o->address))
  {
    fprintf (stderr, "Missing address in operation %u `%s' in episode `%s'\n",
             op_counter, "ADD_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* session */
  GNUNET_asprintf (&op_name, "op-%u-address-session", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->
                                                              address_session))
  {
    fprintf (stderr,
             "Missing address-session in operation %u `%s' in episode `%s'\n",
             op_counter, "ADD_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* network */
  GNUNET_asprintf (&op_name, "op-%u-address-network", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &op_network))
  {
    fprintf (stderr,
             "Missing address-network in operation %u `%s' in episode `%s'\n",
             op_counter, "ADD_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  else
  {
    GNUNET_break (GNUNET_OK == GNUNET_STRINGS_utf8_toupper (op_network,
                                                            op_network));
    if (0 == strcmp (op_network, "UNSPECIFIED"))
    {
      o->address_network = GNUNET_NT_UNSPECIFIED;
    }
    else if (0 == strcmp (op_network, "LOOPBACK"))
    {
      o->address_network = GNUNET_NT_LOOPBACK;
    }
    else if (0 == strcmp (op_network, "LAN"))
    {
      o->address_network = GNUNET_NT_LAN;
    }
    else if (0 == strcmp (op_network, "WAN"))
    {
      o->address_network = GNUNET_NT_WAN;
    }
    else if (0 == strcmp (op_network, "WLAN"))
    {
      o->address_network = GNUNET_NT_WLAN;
    }
    else if (0 == strcmp (op_network, "BT"))
    {
      o->address_network = GNUNET_NT_BT;
    }
    else
    {
      fprintf (stderr,
               "Invalid address-network in operation %u `%s' in episode `%s': `%s'\n",
               op_counter, "ADD_ADDRESS", op_name, op_network);
      GNUNET_free (op_network);
      GNUNET_free (op_name);
      return GNUNET_SYSERR;
    }
  }
  GNUNET_free (op_network);
  GNUNET_free (op_name);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Found operation %s: [%llu:%llu] address `%s' plugin `%s' \n",
              "ADD_ADDRESS", o->peer_id, o->address_id, o->address, o->plugin);
 
  return GNUNET_OK;
}

References GNUNET_ATS_TEST_Operation::address, GNUNET_ATS_TEST_Operation::address_id, GNUNET_ATS_TEST_Operation::address_network, GNUNET_ATS_TEST_Operation::address_session, cfg, GNUNET_asprintf(), GNUNET_break, GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_NT_BT, GNUNET_NT_LAN, GNUNET_NT_LOOPBACK, GNUNET_NT_UNSPECIFIED, GNUNET_NT_WAN, GNUNET_NT_WLAN, GNUNET_OK, GNUNET_STRINGS_utf8_toupper(), GNUNET_SYSERR, GNUNET_ATS_TEST_Operation::peer_id, and GNUNET_ATS_TEST_Operation::plugin.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

load_op_del_address()

static int load_op_del_address ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 1465 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
 
  // char *op_network;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u `%s' in episode `%s'\n",
             op_counter, "DEL_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address pid */
  GNUNET_asprintf (&op_name, "op-%u-address-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->address_id))
  {
    fprintf (stderr,
             "Missing address-id in operation %u `%s' in episode `%s'\n",
             op_counter, "DEL_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
#if 0
  /* plugin */
  GNUNET_asprintf (&op_name, "op-%u-plugin", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &o->plugin))
  {
    fprintf (stderr, "Missing plugin in operation %u `%s' in episode `%s'\n",
             op_counter, "DEL_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address  */
  GNUNET_asprintf (&op_name, "op-%u-address", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &o->address))
  {
    fprintf (stderr, "Missing address in operation %u `%s' in episode `%s'\n",
             op_counter, "DEL_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* session */
  GNUNET_asprintf (&op_name, "op-%u-address-session", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->
                                                              address_session))
  {
    fprintf (stderr,
             "Missing address-session in operation %u `%s' in episode `%s'\n",
             op_counter, "DEL_ADDRESS", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
#endif
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Found operation %s: [%llu:%llu] address `%s' plugin `%s' \n",
              "DEL_ADDRESS", o->peer_id, o->address_id, o->address, o->plugin);
 
  return GNUNET_OK;
}

References GNUNET_ATS_TEST_Operation::address, GNUNET_ATS_TEST_Operation::address_id, GNUNET_ATS_TEST_Operation::address_session, cfg, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, GNUNET_ATS_TEST_Operation::peer_id, and GNUNET_ATS_TEST_Operation::plugin.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

parse_preference_string()

static enum GNUNET_ATS_Property parse_preference_string ( const char *  str )

static

Definition at line 1465 of file gnunet-ats-solver-eval.c.

{
  int c = 0;
  char *props[GNUNET_ATS_PreferenceCount] = GNUNET_ATS_PreferenceTypeString;
 
  for (c = 0; c < GNUNET_ATS_PreferenceCount; c++)
    if (0 == strcmp (str, props[c]))
      return c;
  return 0;
}

Referenced by load_op_start_set_preference(), and load_op_stop_set_preference().

Here is the caller graph for this function:

load_op_start_set_preference()

static int load_op_start_set_preference ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 1567 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
  char *type;
  char *pref;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u  `%s' in episode `%s'\n",
             op_counter, "START_SET_PREFERENCE", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address pid */
  GNUNET_asprintf (&op_name, "op-%u-client-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->client_id))
  {
    fprintf (stderr, "Missing client-id in operation %u `%s' in episode `%s'\n",
             op_counter, "START_SET_PREFERENCE", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* generator */
  GNUNET_asprintf (&op_name, "op-%u-gen-type", op_counter);
  if ((GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                               sec_name,
                                                               op_name, &type)))
  {
    fprintf (stderr, "Missing type in operation %u `%s' in episode `%s'\n",
             op_counter, "START_SET_PREFERENCE", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
 
  /* Load arguments for set_rate, start_send, set_preference */
  if (0 == strcmp (type, "constant"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_CONSTANT;
  }
  else if (0 == strcmp (type, "linear"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_LINEAR;
  }
  else if (0 == strcmp (type, "sinus"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_SINUS;
  }
  else if (0 == strcmp (type, "random"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_RANDOM;
  }
  else
  {
    fprintf (stderr, "Invalid generator type %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (type);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (type);
  GNUNET_free (op_name);
 
 
  /* Get base rate */
  GNUNET_asprintf (&op_name, "op-%u-base-rate", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->base_rate))
  {
    fprintf (stderr, "Missing base rate in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
 
  /* Get max rate */
  GNUNET_asprintf (&op_name, "op-%u-max-rate", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->max_rate))
  {
    if ((GNUNET_ATS_TEST_TG_LINEAR == o->gen_type) ||
        (GNUNET_ATS_TEST_TG_RANDOM == o->gen_type) ||
        (GNUNET_ATS_TEST_TG_SINUS == o->gen_type))
    {
      fprintf (stderr, "Missing max rate in operation %u `%s' in episode %u\n",
               op_counter, op_name, e->id);
      GNUNET_free (op_name);
      return GNUNET_SYSERR;
    }
  }
  GNUNET_free (op_name);
 
  /* Get period */
  GNUNET_asprintf (&op_name, "op-%u-period", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg,
                                                            sec_name, op_name,
                                                            &o->period))
  {
    o->period = e->duration;
  }
  GNUNET_free (op_name);
 
  /* Get frequency */
  GNUNET_asprintf (&op_name, "op-%u-frequency", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg,
                                                            sec_name, op_name,
                                                            &o->frequency))
  {
    fprintf (stderr, "Missing frequency in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* Get preference */
  GNUNET_asprintf (&op_name, "op-%u-pref", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &pref))
  {
    fprintf (stderr, "Missing preference in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
 
  if (0 == (o->pref_type = parse_preference_string (pref)))
  {
    fprintf (stderr, "Invalid preference in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    GNUNET_free (pref);
    return GNUNET_SYSERR;
  }
  GNUNET_free (pref);
  GNUNET_free (op_name);
 
  /* Get feedback delay */
  GNUNET_asprintf (&op_name, "op-%u-feedback_delay", op_counter);
  if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_time (cfg,
                                                        sec_name, op_name,
                                                        &o->feedback_delay))
  {
    fprintf (stderr,
             "Using feedback delay %llu in operation %u `%s' in episode %u\n",
             (long long unsigned int) o->feedback_delay.rel_value_us,
             op_counter, op_name, e->id);
  }
  else
    o->feedback_delay = GNUNET_TIME_UNIT_FOREVER_REL;
  GNUNET_free (op_name);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Found operation %s: [%llu:%llu]: %s = %llu\n",
              "START_SET_PREFERENCE", o->peer_id, o->address_id,
              GNUNET_ATS_print_preference_type (o->pref_type), o->base_rate);
 
  return GNUNET_OK;
}

References GNUNET_ATS_TEST_Operation::address_id, GNUNET_ATS_TEST_Operation::base_rate, cfg, GNUNET_ATS_TEST_Operation::client_id, e, GNUNET_ATS_TEST_Operation::feedback_delay, GNUNET_ATS_TEST_Operation::frequency, GNUNET_ATS_TEST_Operation::gen_type, GNUNET_asprintf(), GNUNET_ATS_print_preference_type(), GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, GNUNET_ATS_TEST_TG_SINUS, GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_ATS_TEST_Operation::max_rate, parse_preference_string(), GNUNET_ATS_TEST_Operation::peer_id, GNUNET_ATS_TEST_Operation::period, GNUNET_ATS_TEST_Operation::pref_type, GNUNET_TIME_Relative::rel_value_us, and type.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

load_op_stop_set_preference()

static int load_op_stop_set_preference ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 1747 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
  char *pref;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u  `%s' in episode `%s'\n",
             op_counter, "STOP_SET_PREFERENCE", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address pid */
  GNUNET_asprintf (&op_name, "op-%u-address-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->address_id))
  {
    fprintf (stderr,
             "Missing address-id in operation %u `%s' in episode `%s'\n",
             op_counter, "STOP_SET_PREFERENCE", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* Get preference */
  GNUNET_asprintf (&op_name, "op-%u-pref", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &pref))
  {
    fprintf (stderr,
             "Missing preference in operation %u `%s' in episode `%s'\n",
             op_counter, "STOP_SET_PREFERENCE", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
 
  if (0 == (o->pref_type = parse_preference_string (pref)))
  {
    fprintf (stderr, "Invalid preference in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    GNUNET_free (pref);
    return GNUNET_SYSERR;
  }
  GNUNET_free (pref);
  GNUNET_free (op_name);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Found operation %s: [%llu:%llu]: %s\n",
              "STOP_SET_PREFERENCE", o->peer_id, o->address_id,
              GNUNET_ATS_print_preference_type (o->pref_type));
  return GNUNET_OK;
}

References GNUNET_ATS_TEST_Operation::address_id, cfg, e, GNUNET_asprintf(), GNUNET_ATS_print_preference_type(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, parse_preference_string(), GNUNET_ATS_TEST_Operation::peer_id, and GNUNET_ATS_TEST_Operation::pref_type.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

parse_property_string()

static enum GNUNET_ATS_Property parse_property_string ( const char *  str )

static

Definition at line 1747 of file gnunet-ats-solver-eval.c.

{
  enum GNUNET_ATS_Property c;
 
  for (c = 0; c < GNUNET_ATS_PropertyCount; c++)
    if (0 == strcmp (str,
                     GNUNET_ATS_print_property_type (c)))
      return c;
  return 0;
}

Referenced by load_op_start_set_property(), and load_op_stop_set_property().

Here is the caller graph for this function:

load_op_start_set_property()

static int load_op_start_set_property ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 1829 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
  char *type;
  char *prop;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u  `%s' in episode `%s'\n",
             op_counter, "START_SET_PROPERTY", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address pid */
  GNUNET_asprintf (&op_name, "op-%u-address-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->address_id))
  {
    fprintf (stderr,
             "Missing address-id in operation %u `%s' in episode `%s'\n",
             op_counter, "START_SET_PROPERTY", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* generator */
  GNUNET_asprintf (&op_name, "op-%u-gen-type", op_counter);
  if ((GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                               sec_name,
                                                               op_name, &type)))
  {
    fprintf (stderr, "Missing type in operation %u `%s' in episode `%s'\n",
             op_counter, "START_SET_PROPERTY", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
 
  /* Load arguments for set_rate, start_send, set_preference */
  if (0 == strcmp (type, "constant"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_CONSTANT;
  }
  else if (0 == strcmp (type, "linear"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_LINEAR;
  }
  else if (0 == strcmp (type, "sinus"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_SINUS;
  }
  else if (0 == strcmp (type, "random"))
  {
    o->gen_type = GNUNET_ATS_TEST_TG_RANDOM;
  }
  else
  {
    fprintf (stderr, "Invalid generator type %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (type);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (type);
  GNUNET_free (op_name);
 
 
  /* Get base rate */
  GNUNET_asprintf (&op_name, "op-%u-base-rate", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->base_rate))
  {
    fprintf (stderr, "Missing base rate in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
 
  /* Get max rate */
  GNUNET_asprintf (&op_name, "op-%u-max-rate", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->max_rate))
  {
    if ((GNUNET_ATS_TEST_TG_LINEAR == o->gen_type) ||
        (GNUNET_ATS_TEST_TG_RANDOM == o->gen_type) ||
        (GNUNET_ATS_TEST_TG_SINUS == o->gen_type))
    {
      fprintf (stderr, "Missing max rate in operation %u `%s' in episode %u\n",
               op_counter, op_name, e->id);
      GNUNET_free (op_name);
      return GNUNET_SYSERR;
    }
  }
  GNUNET_free (op_name);
 
  /* Get period */
  GNUNET_asprintf (&op_name, "op-%u-period", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg,
                                                            sec_name, op_name,
                                                            &o->period))
  {
    o->period = e->duration;
  }
  GNUNET_free (op_name);
 
  /* Get frequency */
  GNUNET_asprintf (&op_name, "op-%u-frequency", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg,
                                                            sec_name, op_name,
                                                            &o->frequency))
  {
    fprintf (stderr, "Missing frequency in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* Get preference */
  GNUNET_asprintf (&op_name, "op-%u-property", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &prop))
  {
    fprintf (stderr, "Missing property in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    GNUNET_free (prop);
    return GNUNET_SYSERR;
  }
 
  if (0 == (o->prop_type = parse_property_string (prop)))
  {
    fprintf (stderr, "Invalid property in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    GNUNET_free (prop);
    return GNUNET_SYSERR;
  }
 
  GNUNET_free (prop);
  GNUNET_free (op_name);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Found operation %s: [%llu:%llu] %s = %llu\n",
              "START_SET_PROPERTY", o->peer_id, o->address_id,
              GNUNET_ATS_print_property_type (o->prop_type), o->base_rate);
 
  return GNUNET_OK;
}

References GNUNET_ATS_TEST_Operation::address_id, GNUNET_ATS_TEST_Operation::base_rate, cfg, e, GNUNET_ATS_TEST_Operation::frequency, GNUNET_ATS_TEST_Operation::gen_type, GNUNET_asprintf(), GNUNET_ATS_TEST_TG_CONSTANT, GNUNET_ATS_TEST_TG_LINEAR, GNUNET_ATS_TEST_TG_RANDOM, GNUNET_ATS_TEST_TG_SINUS, GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, GNUNET_ATS_TEST_Operation::max_rate, parse_property_string(), GNUNET_ATS_TEST_Operation::peer_id, GNUNET_ATS_TEST_Operation::period, and type.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

load_op_stop_set_property()

static int load_op_stop_set_property ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 1997 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
  char *pref;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u  `%s' in episode `%s'\n",
             op_counter, "STOP_SET_PROPERTY", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* address pid */
  GNUNET_asprintf (&op_name, "op-%u-address-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->address_id))
  {
    fprintf (stderr,
             "Missing address-id in operation %u `%s' in episode `%s'\n",
             op_counter, "STOP_SET_PROPERTY", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
 
  /* Get property */
  GNUNET_asprintf (&op_name, "op-%u-property", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                              sec_name, op_name,
                                                              &pref))
  {
    fprintf (stderr, "Missing property in operation %u `%s' in episode `%s'\n",
             op_counter, "STOP_SET_PROPERTY", op_name);
    GNUNET_free (op_name);
    GNUNET_free (pref);
    return GNUNET_SYSERR;
  }
 
  if (0 == (o->prop_type = parse_property_string (pref)))
  {
    fprintf (stderr, "Invalid property in operation %u `%s' in episode %u\n",
             op_counter, op_name, e->id);
    GNUNET_free (op_name);
    GNUNET_free (pref);
    return GNUNET_SYSERR;
  }
 
  GNUNET_free (pref);
  GNUNET_free (op_name);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Found operation %s: [%llu:%llu] %s\n",
              "STOP_SET_PROPERTY", o->peer_id, o->address_id,
              GNUNET_ATS_print_property_type (o->prop_type));
 
  return GNUNET_OK;
}

References GNUNET_ATS_TEST_Operation::address_id, cfg, e, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, parse_property_string(), and GNUNET_ATS_TEST_Operation::peer_id.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

load_op_start_request()

static int load_op_start_request ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 2068 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u  `%s' in episode `%s'\n",
             op_counter, "START_REQUEST", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
  return GNUNET_OK;
}

References cfg, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_free, GNUNET_OK, GNUNET_SYSERR, and GNUNET_ATS_TEST_Operation::peer_id.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

load_op_stop_request()

static int load_op_stop_request ( struct GNUNET_ATS_TEST_Operation *  o, struct Episode *  e, int  op_counter, char *  sec_name, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 2093 of file gnunet-ats-solver-eval.c.

{
  char *op_name;
 
  /* peer pid */
  GNUNET_asprintf (&op_name, "op-%u-peer-id", op_counter);
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_number (cfg,
                                                              sec_name, op_name,
                                                              &o->peer_id))
  {
    fprintf (stderr, "Missing peer-id in operation %u  `%s' in episode `%s'\n",
             op_counter, "STOP_REQUEST", op_name);
    GNUNET_free (op_name);
    return GNUNET_SYSERR;
  }
  GNUNET_free (op_name);
  return GNUNET_OK;
}

References cfg, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_free, GNUNET_OK, GNUNET_SYSERR, and GNUNET_ATS_TEST_Operation::peer_id.

Referenced by load_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

load_episode()

static int load_episode ( struct Experiment *  e, struct Episode *  cur, struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 2118 of file gnunet-ats-solver-eval.c.

{
  struct GNUNET_ATS_TEST_Operation *o;
  char *sec_name;
  char *op_name;
  char *op;
  int op_counter = 0;
  int res;
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "=== Parsing episode %u\n", cur->id);
  GNUNET_asprintf (&sec_name, "episode-%u", cur->id);
 
  while (1)
  {
    /* Load operation */
    GNUNET_asprintf (&op_name, "op-%u-operation", op_counter);
    if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg,
                                                                sec_name,
                                                                op_name, &op))
    {
      GNUNET_free (op_name);
      break;
    }
    o = GNUNET_new (struct GNUNET_ATS_TEST_Operation);
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "==== Parsing operation %u: `%s'\n",
                cur->id, op_name);
 
    /* operations = set_rate, start_send, stop_send, set_preference */
    if (0 == strcmp (op, "address_add"))
    {
      o->type = SOLVER_OP_ADD_ADDRESS;
      res = load_op_add_address (o, cur,
                                 op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "address_del"))
    {
      o->type = SOLVER_OP_DEL_ADDRESS;
      res = load_op_del_address (o, cur,
                                 op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "start_set_property"))
    {
      o->type = SOLVER_OP_START_SET_PROPERTY;
      res = load_op_start_set_property (o, cur,
                                        op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "stop_set_property"))
    {
      o->type = SOLVER_OP_STOP_SET_PROPERTY;
      res = load_op_stop_set_property (o, cur,
                                       op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "start_set_preference"))
    {
      o->type = SOLVER_OP_START_SET_PREFERENCE;
      res = load_op_start_set_preference (o, cur,
                                          op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "stop_set_preference"))
    {
      o->type = SOLVER_OP_STOP_SET_PREFERENCE;
      res = load_op_stop_set_preference (o, cur,
                                         op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "start_request"))
    {
      o->type = SOLVER_OP_START_REQUEST;
      res = load_op_start_request (o, cur,
                                   op_counter, sec_name, cfg);
    }
    else if (0 == strcmp (op, "stop_request"))
    {
      o->type = SOLVER_OP_STOP_REQUEST;
      res = load_op_stop_request (o, cur,
                                  op_counter, sec_name, cfg);
    }
    else
    {
      fprintf (stderr, "Invalid operation %u `%s' in episode %u\n",
               op_counter, op, cur->id);
      res = GNUNET_SYSERR;
    }
 
    GNUNET_free (op);
    GNUNET_free (op_name);
 
    if (GNUNET_SYSERR == res)
    {
      GNUNET_free (o);
      GNUNET_free (sec_name);
      return GNUNET_SYSERR;
    }
 
    GNUNET_CONTAINER_DLL_insert_tail (cur->head, cur->tail, o);
    op_counter++;
  }
  GNUNET_free (sec_name);
  return GNUNET_OK;
}

References cfg, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_new, GNUNET_OK, GNUNET_SYSERR, Episode::head, Episode::id, load_op_add_address(), load_op_del_address(), load_op_start_request(), load_op_start_set_preference(), load_op_start_set_property(), load_op_stop_request(), load_op_stop_set_preference(), load_op_stop_set_property(), op, res, SOLVER_OP_ADD_ADDRESS, SOLVER_OP_DEL_ADDRESS, SOLVER_OP_START_REQUEST, SOLVER_OP_START_SET_PREFERENCE, SOLVER_OP_START_SET_PROPERTY, SOLVER_OP_STOP_REQUEST, SOLVER_OP_STOP_SET_PREFERENCE, SOLVER_OP_STOP_SET_PROPERTY, Episode::tail, and GNUNET_ATS_TEST_Operation::type.

Referenced by load_episodes().

Here is the call graph for this function:

Here is the caller graph for this function:

load_episodes()

static int load_episodes ( struct Experiment *  e, struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Definition at line 2221 of file gnunet-ats-solver-eval.c.

{
  int e_counter = 0;
  char *sec_name;
  struct GNUNET_TIME_Relative e_duration;
  struct Episode *cur;
  struct Episode *last;
 
  e_counter = 0;
  last = NULL;
  while (1)
  {
    GNUNET_asprintf (&sec_name, "episode-%u", e_counter);
    if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg,
                                                              sec_name,
                                                              "duration",
                                                              &e_duration))
    {
      GNUNET_free (sec_name);
      break;
    }
 
    cur = GNUNET_new (struct Episode);
    cur->duration = e_duration;
    cur->id = e_counter;
 
    if (GNUNET_OK != load_episode (e, cur, cfg))
    {
      GNUNET_free (sec_name);
      GNUNET_free (cur);
      return GNUNET_SYSERR;
    }
 
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Found episode %u with duration %s \n",
                e_counter,
                GNUNET_STRINGS_relative_time_to_string (cur->duration,
                                                        GNUNET_YES));
 
    /* Update experiment */
    e->num_episodes++;
    e->total_duration = GNUNET_TIME_relative_add (e->total_duration,
                                                  cur->duration);
    /* Put in linked list */
    if (NULL == last)
      e->start = cur;
    else
      last->next = cur;
 
    GNUNET_free (sec_name);
    e_counter++;
    last = cur;
  }
  return e_counter;
}

References cfg, Episode::duration, e, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_new, GNUNET_OK, GNUNET_STRINGS_relative_time_to_string(), GNUNET_SYSERR, GNUNET_TIME_relative_add(), GNUNET_YES, Episode::id, load_episode(), Episode::next, Experiment::num_episodes, Experiment::start, and Experiment::total_duration.

Referenced by GNUNET_ATS_solvers_experimentation_load().

Here is the call graph for this function:

Here is the caller graph for this function:

timeout_experiment()

static void timeout_experiment ( void *  cls )

static

Definition at line 2278 of file gnunet-ats-solver-eval.c.

{
  struct Experiment *e = cls;
 
  e->experiment_timeout_task = NULL;
  fprintf (stderr, "Experiment timeout!\n");
 
  if (NULL != e->episode_timeout_task)
  {
    GNUNET_SCHEDULER_cancel (e->episode_timeout_task);
    e->episode_timeout_task = NULL;
  }
 
  e->e_done_cb (e, GNUNET_TIME_absolute_get_duration (e->start_time),
                GNUNET_SYSERR);
}

References e, Experiment::e_done_cb, Experiment::episode_timeout_task, Experiment::experiment_timeout_task, GNUNET_SCHEDULER_cancel(), GNUNET_SYSERR, GNUNET_TIME_absolute_get_duration(), and Experiment::start_time.

Referenced by GNUNET_ATS_solvers_experimentation_run().

Here is the call graph for this function:

Here is the caller graph for this function:

create_ats_address()

struct ATS_Address* create_ats_address	(	const struct GNUNET_PeerIdentity *	peer,
		const char *	plugin_name,
		const void *	plugin_addr,
		size_t	plugin_addr_len,
		uint32_t	session_id,
		uint32_t	network
	)

Definition at line 2297 of file gnunet-ats-solver-eval.c.

{
  struct ATS_Address *aa = NULL;
 
  aa = GNUNET_malloc (sizeof(struct ATS_Address) + plugin_addr_len + strlen (
                        plugin_name) + 1);
  aa->atsi = GNUNET_new (struct GNUNET_ATS_Information);
  aa->atsi[0].type = htonl (GNUNET_ATS_NETWORK_TYPE);
  aa->atsi[0].value = htonl (network);
  aa->atsi_count = 1;
 
  aa->peer = *peer;
  aa->addr_len = plugin_addr_len;
  aa->addr = &aa[1];
  aa->plugin = (char *) &aa[1] + plugin_addr_len;
  GNUNET_memcpy (&aa[1], plugin_addr, plugin_addr_len);
  GNUNET_memcpy (aa->plugin, plugin_name, strlen (plugin_name) + 1);
  aa->session_id = session_id;
 
  return aa;
}

References ATS_Address::addr, ATS_Address::addr_len, ATS_Address::atsi_count, GNUNET_malloc, GNUNET_memcpy, GNUNET_new, ATS_Address::peer, peer, ATS_Address::plugin, plugin_name, ATS_Address::session_id, and session_id.

Referenced by enforce_add_address().

Here is the caller graph for this function:

enforce_add_address()

static void enforce_add_address ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2326 of file gnunet-ats-solver-eval.c.

{
  struct TestPeer *p;
  struct TestAddress *a;
  int c;
 
  if (NULL == (p = find_peer_by_id (op->peer_id)))
  {
    p = GNUNET_new (struct TestPeer);
    p->id = op->peer_id;
    p->assigned_bw_in = 0;
    p->assigned_bw_out = 0;
    memset (&p->peer_id, op->peer_id, sizeof(p->peer_id));
    for (c = 0; c < GNUNET_ATS_PreferenceCount; c++)
    {
      p->pref_abs[c] = DEFAULT_ABS_PREFERENCE;
      p->pref_norm[c] = DEFAULT_REL_PREFERENCE;
    }
 
    GNUNET_CONTAINER_DLL_insert (peer_head, peer_tail, p);
  }
 
  if (NULL != (find_address_by_id (p, op->address_id)))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Duplicate address %u for peer %u\n",
                op->address_id, op->peer_id);
    return;
  }
 
  a = GNUNET_new (struct TestAddress);
  a->aid = op->address_id;
  a->network = op->address_network;
  a->ats_addr = create_ats_address (&p->peer_id, op->plugin, op->address,
                                    strlen (op->address) + 1,
                                    op->address_session, op->address_network);
  memset (&p->peer_id, op->peer_id, sizeof(p->peer_id));
  GNUNET_CONTAINER_DLL_insert_tail (p->addr_head, p->addr_tail, a);
 
  for (c = 0; c < GNUNET_ATS_PropertyCount; c++)
    a->prop_norm[c] = DEFAULT_REL_QUALITY;
 
  GNUNET_CONTAINER_multipeermap_put (sh->addresses, &p->peer_id, a->ats_addr,
                                     GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Adding address %u for peer %u in network `%s'\n",
              op->address_id, op->peer_id, GNUNET_NT_to_string (a->network));
 
  sh->sf->s_add (sh->sf->cls, a->ats_addr, op->address_network);
}

References SolverHandle::addresses, TestAddress::aid, TestAddress::ats_addr, GNUNET_ATS_SolverFunctions::cls, create_ats_address(), DEFAULT_ABS_PREFERENCE, DEFAULT_REL_PREFERENCE, DEFAULT_REL_QUALITY, find_address_by_id(), find_peer_by_id(), GNUNET_CONTAINER_DLL_insert, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_multipeermap_put(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_new, GNUNET_NT_to_string(), TestAddress::network, op, p, peer_head, peer_tail, TestAddress::prop_norm, GNUNET_ATS_SolverFunctions::s_add, SolverHandle::sf, and sh.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_del_address()

static void enforce_del_address ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2379 of file gnunet-ats-solver-eval.c.

{
  struct TestPeer *p;
  struct TestAddress *a;
  struct PropertyGenerator *pg;
 
  if (NULL == (p = find_peer_by_id (op->peer_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Deleting address for unknown peer %u\n", op->peer_id);
    return;
  }
 
  if (NULL == (a = find_address_by_id (p, op->address_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Deleting address for unknown peer %u\n", op->peer_id);
    return;
  }
 
  while (NULL != (pg = find_prop_gen (p->id, a->aid, 0)))
  {
    GNUNET_ATS_solver_generate_property_stop (pg);
  }
 
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multipeermap_remove (sh->addresses,
                                                       &p->peer_id,
                                                       a->ats_addr));
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Removing address %u for peer %u\n",
              op->address_id,
              op->peer_id);
 
  sh->sf->s_del (sh->sf->cls, a->ats_addr);
 
  if (NULL != l)
  {
    GNUNET_ATS_solver_logging_now (l);
  }
  GNUNET_CONTAINER_DLL_remove (p->addr_head, p->addr_tail, a);
 
  GNUNET_free (a->ats_addr->atsi);
  GNUNET_free (a->ats_addr);
  GNUNET_free (a);
}

References SolverHandle::addresses, TestAddress::aid, TestAddress::ats_addr, GNUNET_ATS_SolverFunctions::cls, find_address_by_id(), find_peer_by_id(), find_prop_gen(), GNUNET_assert, GNUNET_ATS_solver_generate_property_stop(), GNUNET_ATS_solver_logging_now(), GNUNET_break, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_YES, l, op, p, GNUNET_ATS_SolverFunctions::s_del, SolverHandle::sf, and sh.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_start_property()

static void enforce_start_property ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2430 of file gnunet-ats-solver-eval.c.

{
  struct PropertyGenerator *pg;
  struct TestPeer *p;
  struct TestAddress *a;
 
  if (NULL != (pg = find_prop_gen (op->peer_id, op->address_id, op->prop_type)))
  {
    GNUNET_ATS_solver_generate_property_stop (pg);
    GNUNET_free (pg);
  }
 
  if (NULL == (p = find_peer_by_id (op->peer_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Starting property generation for unknown peer %u\n",
                op->peer_id);
    return;
  }
 
  if (NULL == (a = find_address_by_id (p, op->address_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Setting property for unknown address %u\n", op->peer_id);
    return;
  }
 
  GNUNET_ATS_solver_generate_property_start (op->peer_id,
                                             op->address_id,
                                             p, a,
                                             op->gen_type,
                                             op->base_rate,
                                             op->max_rate,
                                             op->period,
                                             op->frequency,
                                             op->prop_type);
}

References find_address_by_id(), find_peer_by_id(), find_prop_gen(), GNUNET_ATS_solver_generate_property_start(), GNUNET_ATS_solver_generate_property_stop(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, op, and p.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_stop_property()

static void enforce_stop_property ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2472 of file gnunet-ats-solver-eval.c.

{
  struct PropertyGenerator *pg = find_prop_gen (op->peer_id, op->address_id,
                                                op->prop_type);
 
  if (NULL != pg)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Stopping preference generation for peer %u address %u\n",
                op->peer_id,
                op->address_id);
    GNUNET_ATS_solver_generate_property_stop (pg);
  }
  else
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Cannot find preference generator for peer %u address %u\n",
                op->peer_id, op->address_id);
    GNUNET_break (0);
  }
}

References find_prop_gen(), GNUNET_ATS_solver_generate_property_stop(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, and op.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_start_preference()

static void enforce_start_preference ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2496 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *pg;
 
  if (NULL != (pg = find_pref_gen (op->peer_id, op->pref_type)))
  {
    GNUNET_ATS_solver_generate_preferences_stop (pg);
    GNUNET_free (pg);
  }
 
  if (NULL == (find_peer_by_id (op->peer_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Starting preference generation for unknown peer %u\n",
                op->peer_id);
    return;
  }
 
  GNUNET_ATS_solver_generate_preferences_start (op->peer_id,
                                                op->address_id,
                                                op->client_id,
                                                op->gen_type,
                                                op->base_rate,
                                                op->max_rate,
                                                op->period,
                                                op->frequency,
                                                op->pref_type,
                                                op->frequency);
}

References find_peer_by_id(), find_pref_gen(), GNUNET_ATS_solver_generate_preferences_start(), GNUNET_ATS_solver_generate_preferences_stop(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, and op.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_stop_preference()

static void enforce_stop_preference ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2529 of file gnunet-ats-solver-eval.c.

{
  struct PreferenceGenerator *pg = find_pref_gen (op->peer_id,
                                                  op->pref_type);
 
  if (NULL != pg)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Stopping property generation for peer %u address %u\n",
                op->peer_id,
                op->address_id);
    GNUNET_ATS_solver_generate_preferences_stop (pg);
  }
  else
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Cannot find preference generator for peer %u address %u\n",
                op->peer_id, op->address_id);
    GNUNET_break (0);
  }
}

References find_pref_gen(), GNUNET_ATS_solver_generate_preferences_stop(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, and op.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_start_request()

static void enforce_start_request ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2553 of file gnunet-ats-solver-eval.c.

{
  struct TestPeer *p;
 
  if (NULL == (p = find_peer_by_id (op->peer_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Requesting address for unknown peer %u\n", op->peer_id);
    return;
  }
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Requesting address for peer %u\n",
              op->peer_id);
  p->is_requested = GNUNET_YES;
 
  sh->sf->s_get (sh->sf->cls, &p->peer_id);
}

References GNUNET_ATS_SolverFunctions::cls, find_peer_by_id(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_YES, op, p, GNUNET_ATS_SolverFunctions::s_get, SolverHandle::sf, and sh.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_stop_request()

static void enforce_stop_request ( struct GNUNET_ATS_TEST_Operation *  op )

static

Definition at line 2574 of file gnunet-ats-solver-eval.c.

{
  struct TestPeer *p;
 
  if (NULL == (p = find_peer_by_id (op->peer_id)))
  {
    GNUNET_break (0);
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Requesting address for unknown peer %u\n", op->peer_id);
    return;
  }
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Stop requesting address for peer %u\n",
              op->peer_id);
  p->is_requested = GNUNET_NO;
  p->assigned_bw_in = 0;
  p->assigned_bw_out = 0;
  sh->sf->s_get_stop (sh->sf->cls, &p->peer_id);
 
  if (NULL != l)
  {
    GNUNET_ATS_solver_logging_now (l);
  }
}

References GNUNET_ATS_SolverFunctions::cls, find_peer_by_id(), GNUNET_ATS_solver_logging_now(), GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_NO, l, op, p, GNUNET_ATS_SolverFunctions::s_get_stop, SolverHandle::sf, and sh.

Referenced by enforce_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

enforce_episode()

static void enforce_episode ( struct Episode *  ep )

static

Definition at line 2602 of file gnunet-ats-solver-eval.c.

{
  struct GNUNET_ATS_TEST_Operation *cur;
 
  for (cur = ep->head; NULL != cur; cur = cur->next)
  {
    switch (cur->type)
    {
    case SOLVER_OP_ADD_ADDRESS:
      fprintf (stderr, "Enforcing operation: %s [%llu:%llu]\n",
               print_op (cur->type), cur->peer_id, cur->address_id);
      enforce_add_address (cur);
      break;
 
    case SOLVER_OP_DEL_ADDRESS:
      fprintf (stderr, "Enforcing operation: %s [%llu:%llu]\n",
               print_op (cur->type), cur->peer_id, cur->address_id);
      enforce_del_address (cur);
      break;
 
    case SOLVER_OP_START_SET_PROPERTY:
      fprintf (stderr, "Enforcing operation: %s [%llu:%llu] == %llu\n",
               print_op (cur->type), cur->peer_id, cur->address_id,
               cur->base_rate);
      enforce_start_property (cur);
      break;
 
    case SOLVER_OP_STOP_SET_PROPERTY:
      fprintf (stderr, "Enforcing operation: %s [%llu:%llu] == %llu\n",
               print_op (cur->type), cur->peer_id, cur->address_id,
               cur->base_rate);
      enforce_stop_property (cur);
      break;
 
    case SOLVER_OP_START_SET_PREFERENCE:
      fprintf (stderr, "Enforcing operation: %s [%llu:%llu] == %llu\n",
               print_op (cur->type), cur->peer_id, cur->address_id,
               cur->base_rate);
      enforce_start_preference (cur);
      break;
 
    case SOLVER_OP_STOP_SET_PREFERENCE:
      fprintf (stderr, "Enforcing operation: %s [%llu:%llu] == %llu\n",
               print_op (cur->type), cur->peer_id, cur->address_id,
               cur->base_rate);
      enforce_stop_preference (cur);
      break;
 
    case SOLVER_OP_START_REQUEST:
      fprintf (stderr, "Enforcing operation: %s [%llu]\n",
               print_op (cur->type), cur->peer_id);
      enforce_start_request (cur);
      break;
 
    case SOLVER_OP_STOP_REQUEST:
      fprintf (stderr, "Enforcing operation: %s [%llu]\n",
               print_op (cur->type), cur->peer_id);
      enforce_stop_request (cur);
      break;
 
    default:
      break;
    }
  }
}

References GNUNET_ATS_TEST_Operation::address_id, GNUNET_ATS_TEST_Operation::base_rate, enforce_add_address(), enforce_del_address(), enforce_start_preference(), enforce_start_property(), enforce_start_request(), enforce_stop_preference(), enforce_stop_property(), enforce_stop_request(), Episode::head, GNUNET_ATS_TEST_Operation::next, GNUNET_ATS_TEST_Operation::peer_id, print_op(), SOLVER_OP_ADD_ADDRESS, SOLVER_OP_DEL_ADDRESS, SOLVER_OP_START_REQUEST, SOLVER_OP_START_SET_PREFERENCE, SOLVER_OP_START_SET_PROPERTY, SOLVER_OP_STOP_REQUEST, SOLVER_OP_STOP_SET_PREFERENCE, SOLVER_OP_STOP_SET_PROPERTY, and GNUNET_ATS_TEST_Operation::type.

Referenced by GNUNET_ATS_solvers_experimentation_run(), and timeout_episode().

Here is the call graph for this function:

Here is the caller graph for this function:

timeout_episode()

static void timeout_episode ( void *  cls )

static

Definition at line 2670 of file gnunet-ats-solver-eval.c.

{
  struct Experiment *e = cls;
 
  e->episode_timeout_task = NULL;
  if (NULL != e->ep_done_cb)
    e->ep_done_cb (e->cur);
 
  /* Scheduling next */
  e->cur = e->cur->next;
  if (NULL == e->cur)
  {
    /* done */
    fprintf (stderr, "Last episode done!\n");
    if (NULL != e->experiment_timeout_task)
    {
      GNUNET_SCHEDULER_cancel (e->experiment_timeout_task);
      e->experiment_timeout_task = NULL;
    }
    e->e_done_cb (e, GNUNET_TIME_absolute_get_duration (e->start_time),
                  GNUNET_OK);
    return;
  }
 
  fprintf (stderr, "Running episode %u with timeout %s\n",
           e->cur->id,
           GNUNET_STRINGS_relative_time_to_string (e->cur->duration,
                                                   GNUNET_YES));
  e->episode_timeout_task = GNUNET_SCHEDULER_add_delayed (e->cur->duration,
                                                          &timeout_episode, e);
  enforce_episode (e->cur);
}

References Experiment::cur, Episode::duration, e, Experiment::e_done_cb, enforce_episode(), Experiment::ep_done_cb, Experiment::episode_timeout_task, Experiment::experiment_timeout_task, GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_cancel(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_TIME_absolute_get_duration(), GNUNET_YES, Episode::id, Episode::next, and Experiment::start_time.

Referenced by GNUNET_ATS_solvers_experimentation_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solvers_experimentation_run()

void GNUNET_ATS_solvers_experimentation_run	(	struct Experiment *	e,
		GNUNET_ATS_TESTING_EpisodeDoneCallback	ep_done_cb,
		GNUNET_ATS_TESTING_ExperimentDoneCallback	e_done_cb
	)

Definition at line 2705 of file gnunet-ats-solver-eval.c.

{
  fprintf (stderr, "Running experiment `%s'  with timeout %s\n", e->name,
           GNUNET_STRINGS_relative_time_to_string (e->max_duration,
                                                   GNUNET_YES));
  e->e_done_cb = e_done_cb;
  e->ep_done_cb = ep_done_cb;
  e->start_time = GNUNET_TIME_absolute_get ();
 
  /* Start total time out */
  e->experiment_timeout_task = GNUNET_SCHEDULER_add_delayed (e->max_duration,
                                                             &timeout_experiment,
                                                             e);
 
  /* Start */
  if (NULL == e->start)
  {
    GNUNET_break (0);
    return;
  }
 
  e->cur = e->start;
  fprintf (stderr, "Running episode %u with timeout %s\n",
           e->cur->id,
           GNUNET_STRINGS_relative_time_to_string (e->cur->duration,
                                                   GNUNET_YES));
  e->episode_timeout_task = GNUNET_SCHEDULER_add_delayed (e->cur->duration,
                                                          &timeout_episode, e);
  enforce_episode (e->cur);
}

References Experiment::cur, Episode::duration, e, Experiment::e_done_cb, enforce_episode(), Experiment::ep_done_cb, Experiment::episode_timeout_task, Experiment::experiment_timeout_task, GNUNET_break, GNUNET_SCHEDULER_add_delayed(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_TIME_absolute_get(), GNUNET_YES, Episode::id, Experiment::max_duration, Experiment::name, Experiment::start, Experiment::start_time, timeout_episode(), and timeout_experiment().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solvers_experimentation_stop()

void GNUNET_ATS_solvers_experimentation_stop

(

struct Experiment *

e

)

Definition at line 2742 of file gnunet-ats-solver-eval.c.

{
  if (NULL != e->experiment_timeout_task)
  {
    GNUNET_SCHEDULER_cancel (e->experiment_timeout_task);
    e->experiment_timeout_task = NULL;
  }
  if (NULL != e->episode_timeout_task)
  {
    GNUNET_SCHEDULER_cancel (e->episode_timeout_task);
    e->episode_timeout_task = NULL;
  }
  if (NULL != e->cfg)
  {
    GNUNET_CONFIGURATION_destroy (e->cfg);
    e->cfg = NULL;
  }
  free_experiment (e);
}

References Experiment::cfg, e, Experiment::episode_timeout_task, Experiment::experiment_timeout_task, free_experiment(), GNUNET_CONFIGURATION_destroy(), and GNUNET_SCHEDULER_cancel().

Referenced by done(), end_now(), and GNUNET_ATS_solvers_experimentation_load().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solvers_experimentation_load()

struct Experiment* GNUNET_ATS_solvers_experimentation_load

(

char *

filename

)

Definition at line 2764 of file gnunet-ats-solver-eval.c.

{
  struct Experiment *e;
  struct GNUNET_CONFIGURATION_Handle *cfg;
 
  e = NULL;
 
  cfg = GNUNET_CONFIGURATION_create ();
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_load (cfg, filename))
  {
    fprintf (stderr, "Failed to load `%s'\n", filename);
    GNUNET_CONFIGURATION_destroy (cfg);
    return NULL;
  }
 
  e = create_experiment ();
 
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg, "experiment",
                                                              "name", &e->name))
  {
    fprintf (stderr, "Invalid %s \n", "name");
    free_experiment (e);
    return NULL;
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Experiment name: `%s'\n", e->name);
 
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_string (cfg, "experiment",
                                                              "log_prefix",
                                                              &e->log_prefix))
  {
    fprintf (stderr, "Invalid %s \n", "log_prefix");
    free_experiment (e);
    return NULL;
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Experiment logging prefix: `%s'\n",
                e->log_prefix);
 
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_filename (cfg,
                                                                "experiment",
                                                                "log_output_dir",
                                                                &e->
                                                                log_output_dir))
  {
    e->log_output_dir = NULL;
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Experiment logging output directory: `%s'\n",
                e->log_output_dir);
 
 
  if (GNUNET_SYSERR == (e->log_append_time_stamp =
                          GNUNET_CONFIGURATION_get_value_yesno (cfg,
                                                                "experiment",
                                                                "log_append_time_stamp")))
    e->log_append_time_stamp = GNUNET_YES;
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Experiment logging append timestamp: `%s'\n",
              (GNUNET_YES == e->log_append_time_stamp) ? "yes" : "no");
 
 
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_filename (cfg,
                                                                "experiment",
                                                                "cfg_file",
                                                                &e->cfg_file))
  {
    fprintf (stderr, "Invalid %s \n", "cfg_file");
    free_experiment (e);
    return NULL;
  }
  else
  {
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Experiment configuration: `%s'\n",
                e->cfg_file);
    e->cfg = GNUNET_CONFIGURATION_create ();
    if (GNUNET_SYSERR == GNUNET_CONFIGURATION_load (e->cfg, e->cfg_file))
    {
      fprintf (stderr, "Invalid configuration %s \n", "cfg_file");
      free_experiment (e);
      return NULL;
    }
  }
 
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg, "experiment",
                                                            "log_freq",
                                                            &e->log_freq))
  {
    fprintf (stderr, "Invalid %s \n", "log_freq");
    free_experiment (e);
    return NULL;
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Experiment logging frequency: `%s'\n",
                GNUNET_STRINGS_relative_time_to_string (e->log_freq,
                                                        GNUNET_YES));
 
  if (GNUNET_SYSERR == GNUNET_CONFIGURATION_get_value_time (cfg, "experiment",
                                                            "max_duration",
                                                            &e->max_duration))
  {
    fprintf (stderr, "Invalid %s", "max_duration");
    free_experiment (e);
    return NULL;
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Experiment duration: `%s'\n",
                GNUNET_STRINGS_relative_time_to_string (e->max_duration,
                                                        GNUNET_YES));
 
  if (GNUNET_SYSERR == load_episodes (e, cfg))
  {
    GNUNET_ATS_solvers_experimentation_stop (e);
    GNUNET_CONFIGURATION_destroy (cfg);
    e = NULL;
    fprintf (stderr, "Failed to load experiment\n");
    return NULL;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Loaded %u episodes with total duration %s\n",
              e->num_episodes,
              GNUNET_STRINGS_relative_time_to_string (e->total_duration,
                                                      GNUNET_YES));
 
  GNUNET_CONFIGURATION_destroy (cfg);
  return e;
}

References cfg, Experiment::cfg, Experiment::cfg_file, create_experiment(), e, filename, free_experiment(), GNUNET_ATS_solvers_experimentation_stop(), GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_CONFIGURATION_get_value_yesno(), GNUNET_CONFIGURATION_load(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_STRINGS_relative_time_to_string(), GNUNET_SYSERR, GNUNET_YES, load_episodes(), Experiment::log_append_time_stamp, Experiment::log_freq, Experiment::log_output_dir, Experiment::log_prefix, Experiment::max_duration, Experiment::name, Experiment::num_episodes, and Experiment::total_duration.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

free_all_it()

static int free_all_it ( void *  cls, const struct GNUNET_PeerIdentity *  key, void *  value  )

static

Solver.

Definition at line 2899 of file gnunet-ats-solver-eval.c.

{
  struct ATS_Address *address = value;
 
  GNUNET_break (GNUNET_OK == GNUNET_CONTAINER_multipeermap_remove (
                  sh->env.addresses,
                  key, value));
  GNUNET_free (address);
 
  return GNUNET_OK;
}

References address, GNUNET_ATS_PluginEnvironment::addresses, SolverHandle::env, GNUNET_break, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_free, GNUNET_OK, key, sh, and value.

Referenced by GNUNET_ATS_solvers_solver_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solvers_solver_stop()

void GNUNET_ATS_solvers_solver_stop

(

struct SolverHandle *

sh

)

Definition at line 2915 of file gnunet-ats-solver-eval.c.

{
  GNUNET_STATISTICS_destroy ((struct GNUNET_STATISTICS_Handle *) sh->env.stats,
                             GNUNET_NO);
  GNUNET_PLUGIN_unload (sh->plugin, sh->sf);
  sh->sf = NULL;
  GAS_normalization_stop ();
 
  GNUNET_CONTAINER_multipeermap_iterate (sh->addresses,
                                         &free_all_it,
                                         NULL);
  GNUNET_CONTAINER_multipeermap_destroy (sh->addresses);
  GNUNET_free (sh->plugin);
  GNUNET_free (sh);
}

References SolverHandle::addresses, SolverHandle::env, free_all_it(), GAS_normalization_stop(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_free, GNUNET_NO, GNUNET_PLUGIN_unload(), GNUNET_STATISTICS_destroy(), SolverHandle::plugin, SolverHandle::sf, sh, and GNUNET_ATS_PluginEnvironment::stats.

Referenced by done(), and end_now().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_ATS_solvers_load_quotas()

unsigned int GNUNET_ATS_solvers_load_quotas	(	const struct GNUNET_CONFIGURATION_Handle *	cfg,
		unsigned long long *	out_dest,
		unsigned long long *	in_dest,
		int	dest_length
	)

Load quotas for networks from configuration.

Parameters

cfg	configuration handle
out_dest	where to write outbound quotas
in_dest	where to write inbound quotas
dest_length	length of inbound and outbound arrays

Returns

number of networks loaded

Definition at line 2942 of file gnunet-ats-solver-eval.c.

{
  char *entry_in = NULL;
  char *entry_out = NULL;
  char *quota_out_str;
  char *quota_in_str;
  int c;
  int res;
 
  for (c = 0; (c < GNUNET_NT_COUNT) && (c < dest_length); c++)
  {
    in_dest[c] = 0;
    out_dest[c] = 0;
    GNUNET_asprintf (&entry_out,
                     "%s_QUOTA_OUT",
                     GNUNET_NT_to_string (c));
    GNUNET_asprintf (&entry_in,
                     "%s_QUOTA_IN",
                     GNUNET_NT_to_string (c));
 
    /* quota out */
    if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_string (cfg, "ats",
                                                            entry_out,
                                                            &quota_out_str))
    {
      res = GNUNET_NO;
      if (0 == strcmp (quota_out_str, BIG_M_STRING))
      {
        out_dest[c] = GNUNET_ATS_MaxBandwidth;
        res = GNUNET_YES;
      }
      if ((GNUNET_NO == res) && (GNUNET_OK ==
                                 GNUNET_STRINGS_fancy_size_to_bytes (
                                   quota_out_str, &out_dest[c])))
        res = GNUNET_YES;
      if ((GNUNET_NO == res) && (GNUNET_OK ==
                                 GNUNET_CONFIGURATION_get_value_number (cfg,
                                                                        "ats",
                                                                        entry_out,
                                                                        &
                                                                        out_dest
                                                                        [c])))
        res = GNUNET_YES;
 
      if (GNUNET_NO == res)
      {
        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                    _ (
                      "Could not load quota for network `%s':  `%s', assigning default bandwidth %llu\n"),
                    GNUNET_NT_to_string (c),
                    quota_out_str,
                    GNUNET_ATS_DefaultBandwidth);
        out_dest[c] = GNUNET_ATS_DefaultBandwidth;
      }
      else
      {
        GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                    "Outbound quota configure for network `%s' is %llu\n",
                    GNUNET_NT_to_string (c),
                    out_dest[c]);
      }
      GNUNET_free (quota_out_str);
    }
    else
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  _ (
                    "No outbound quota configured for network `%s', assigning default bandwidth %llu\n"),
                  GNUNET_NT_to_string (c),
                  GNUNET_ATS_DefaultBandwidth);
      out_dest[c] = GNUNET_ATS_DefaultBandwidth;
    }
 
    /* quota in */
    if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_string (cfg, "ats",
                                                            entry_in,
                                                            &quota_in_str))
    {
      res = GNUNET_NO;
      if (0 == strcmp (quota_in_str, BIG_M_STRING))
      {
        in_dest[c] = GNUNET_ATS_MaxBandwidth;
        res = GNUNET_YES;
      }
      if ((GNUNET_NO == res) && (GNUNET_OK ==
                                 GNUNET_STRINGS_fancy_size_to_bytes (
                                   quota_in_str, &in_dest[c])))
        res = GNUNET_YES;
      if ((GNUNET_NO == res) && (GNUNET_OK ==
                                 GNUNET_CONFIGURATION_get_value_number (cfg,
                                                                        "ats",
                                                                        entry_in,
                                                                        &in_dest
                                                                        [c])))
        res = GNUNET_YES;
 
      if (GNUNET_NO == res)
      {
        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                    _ (
                      "Could not load quota for network `%s':  `%s', assigning default bandwidth %llu\n"),
                    GNUNET_NT_to_string (c),
                    quota_in_str,
                    GNUNET_ATS_DefaultBandwidth);
        in_dest[c] = GNUNET_ATS_DefaultBandwidth;
      }
      else
      {
        GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                    "Inbound quota configured for network `%s' is %llu\n",
                    GNUNET_NT_to_string (c),
                    in_dest[c]);
      }
      GNUNET_free (quota_in_str);
    }
    else
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  _ (
                    "No outbound quota configure for network `%s', assigning default bandwidth %llu\n"),
                  GNUNET_NT_to_string (c),
                  GNUNET_ATS_DefaultBandwidth);
      out_dest[c] = GNUNET_ATS_DefaultBandwidth;
    }
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Loaded quota for network `%s' (in/out): %llu %llu\n",
                GNUNET_NT_to_string (c),
                in_dest[c],
                out_dest[c]);
    GNUNET_free (entry_out);
    GNUNET_free (entry_in);
  }
  return GNUNET_NT_COUNT;
}

References _, BIG_M_STRING, cfg, GNUNET_asprintf(), GNUNET_ATS_DefaultBandwidth, GNUNET_ATS_MaxBandwidth, GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_NO, GNUNET_NT_COUNT, GNUNET_NT_to_string(), GNUNET_OK, GNUNET_STRINGS_fancy_size_to_bytes(), GNUNET_YES, and res.

Referenced by GNUNET_ATS_solvers_solver_start().

Here is the call graph for this function:

Here is the caller graph for this function:

solver_info_cb()

static void solver_info_cb ( void *  cls, enum GAS_Solver_Operation  op, enum GAS_Solver_Status  stat, enum GAS_Solver_Additional_Information  add  )

static

Information callback for the solver.

Parameters

cls	the closure
op	the solver operation
stat	status of the solver operation
add	additional solver information

Definition at line 3090 of file gnunet-ats-solver-eval.c.

{
  char *add_info;
 
  switch (add)
  {
  case GAS_INFO_NONE:
    add_info = "GAS_INFO_NONE";
    break;
 
  case GAS_INFO_FULL:
    add_info = "GAS_INFO_MLP_FULL";
    break;
 
  case GAS_INFO_UPDATED:
    add_info = "GAS_INFO_MLP_UPDATED";
    break;
 
  case GAS_INFO_PROP_ALL:
    add_info = "GAS_INFO_PROP_ALL";
    break;
 
  case GAS_INFO_PROP_SINGLE:
    add_info = "GAS_INFO_PROP_SINGLE";
    break;
 
  default:
    add_info = "INVALID";
    break;
  }
 
  switch (op)
  {
  case GAS_OP_SOLVE_START:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Solver notifies `%s' with result `%s' `%s'\n",
                "GAS_OP_SOLVE_START",
                (GAS_STAT_SUCCESS == stat) ? "SUCCESS" : "FAIL", add_info);
    return;
 
  case GAS_OP_SOLVE_STOP:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Solver notifies `%s' with result `%s'\n", "GAS_OP_SOLVE_STOP",
                (GAS_STAT_SUCCESS == stat) ? "SUCCESS" : "FAIL", add_info);
    return;
 
  case GAS_OP_SOLVE_SETUP_START:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Solver notifies `%s' with result `%s'\n",
                "GAS_OP_SOLVE_SETUP_START",
                (GAS_STAT_SUCCESS == stat) ? "SUCCESS" : "FAIL");
    return;
 
  case GAS_OP_SOLVE_SETUP_STOP:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Solver notifies `%s' with result `%s'\n",
                "GAS_OP_SOLVE_SETUP_STOP",
                (GAS_STAT_SUCCESS == stat) ? "SUCCESS" : "FAIL");
    return;
 
  case GAS_OP_SOLVE_MLP_LP_START:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Solver notifies `%s' with result `%s'\n",
                "GAS_OP_SOLVE_LP_START",
                (GAS_STAT_SUCCESS == stat) ? "SUCCESS" : "FAIL");
    return;
 
  case GAS_OP_SOLVE_MLP_LP_STOP:
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Solver notifies `%s' with result `%s'\n",
                "GAS_OP_SOLVE_LP_STOP",
                (