src/ats-tests/ats-testing-preferences.c

   1 /*
   2  This file is part of GNUnet.
   3  (C) 2010-2013 Christian Grothoff (and other contributing authors)
   4
   5  GNUnet is free software; you can redistribute it and/or modify
   6  it under the terms of the GNU General Public License as published
   7  by the Free Software Foundation; either version 3, or (at your
   8  option) any later version.
   9
  10  GNUnet is distributed in the hope that it will be useful, but
  11  WITHOUT ANY WARRANTY; without even the implied warranty of
  12  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  General Public License for more details.
  14
  15  You should have received a copy of the GNU General Public License
  16  along with GNUnet; see the file COPYING.  If not, write to the
  17  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  18  Boston, MA 02111-1307, USA.
  19  */
  20 /**
  21  * @file ats-tests/ats-testing-preferences.c
  22  * @brief ats benchmark: preference generator
  23  * @author Christian Grothoff
  24  * @author Matthias Wachs
  25  */
  26 #include "platform.h"
  27 #include "gnunet_util_lib.h"
  28 #include "ats-testing.h"
  29
  30 static struct PreferenceGenerator *pg_head;
  31 static struct PreferenceGenerator *pg_tail;
  32
  33 extern struct GNUNET_ATS_TEST_Topology *top;
  34
  35 static double
  36 get_preference (struct PreferenceGenerator *pg)
  37 {
  38   struct GNUNET_TIME_Relative time_delta;
  39   double delta_value;
  40   double pref_value;
  41
  42   /* Calculate the current preference value */
  43   switch (pg->type) {
  44     case GNUNET_ATS_TEST_TG_CONSTANT:
  45       pref_value = pg->base_value;
  46       break;
  47     case GNUNET_ATS_TEST_TG_LINEAR:
  48       time_delta = GNUNET_TIME_absolute_get_duration(pg->time_start);
  49       /* Calculate point of time in the current period */
  50       time_delta.rel_value_us = time_delta.rel_value_us %
  51           pg->duration_period.rel_value_us;
  52       delta_value = ((double) time_delta.rel_value_us  /
  53           pg->duration_period.rel_value_us) * (pg->max_value - pg->base_value);
  54       if ((pg->max_value < pg->base_value) &&
  55           ((pg->max_value - pg->base_value) > pg->base_value))
  56       {
  57         /* This will cause an underflow */
  58         GNUNET_break (0);
  59       }
  60       pref_value = pg->base_value + delta_value;
  61       break;
  62     case GNUNET_ATS_TEST_TG_RANDOM:
  63       delta_value =  (double) GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
  64           10000 * (pg->max_value - pg->base_value)) / 10000;
  65       pref_value = pg->base_value + delta_value;
  66       break;
  67     case GNUNET_ATS_TEST_TG_SINUS:
  68       time_delta = GNUNET_TIME_absolute_get_duration(pg->time_start);
  69       /* Calculate point of time in the current period */
  70       time_delta.rel_value_us = time_delta.rel_value_us %
  71           pg->duration_period.rel_value_us;
  72       if ((pg->max_value - pg->base_value) > pg->base_value)
  73       {
  74         /* This will cause an underflow for second half of sinus period,
  75          * will be detected in general when experiments are loaded */
  76         GNUNET_break (0);
  77       }
  78       delta_value = (pg->max_value - pg->base_value) *
  79           sin ( (2 * M_PI) / ((double) pg->duration_period.rel_value_us) *
  80               time_delta.rel_value_us);
  81       pref_value = pg->base_value + delta_value;
  82       break;
  83     default:
  84       pref_value = 0.0;
  85       break;
  86   }
  87   GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Current preference value is %f\n",
  88       pref_value);
  89   return pref_value;
  90 }
  91
  92
  93 static void
  94 set_pref_task (void *cls,
  95                     const struct GNUNET_SCHEDULER_TaskContext *tc)
  96 {
  97   struct BenchmarkPartner *p = cls;
  98   double pref_value;
  99   p->pg->set_task = NULL;
 100
 101   pref_value = get_preference (p->pg);
 102
 103   GNUNET_log(GNUNET_ERROR_TYPE_INFO,
 104       "Setting preference for master [%u] and slave [%u] for %s to %f\n",
 105       p->me->no, p->dest->no,
 106       GNUNET_ATS_print_preference_type (p->pg->kind), pref_value);
 107
 108   GNUNET_ATS_performance_change_preference(p->me->ats_perf_handle,
 109       &p->dest->id, p->pg->kind, pref_value, GNUNET_ATS_PREFERENCE_END);
 110
 111   switch (p->pg->kind) {
 112     case GNUNET_ATS_PREFERENCE_BANDWIDTH:
 113       p->pref_bandwidth = pref_value;
 114       break;
 115     case GNUNET_ATS_PREFERENCE_LATENCY:
 116       p->pref_delay = pref_value;
 117       break;
 118     default:
 119       break;
 120   }
 121
 122   p->pg->set_task = GNUNET_SCHEDULER_add_delayed (p->pg->frequency,
 123       set_pref_task, p);
 124
 125 }
 126
 127
 128 /**
 129  * Generate between the source master and the partner and set preferences with a
 130  * value depending on the generator.
 131  *
 132  * @param src source
 133  * @param dest partner
 134  * @param type type of preferences to generate
 135  * @param base_value traffic base rate to send data with
 136  * @param value_rate  traffic maximum rate to send data with
 137  * @param period duration of a period of preferences generation (~ 1/frequency)
 138  * @param frequency how long to generate preferences
 139  * @param kind ATS preference to generate
 140  * @return the preference generator
 141  */
 142 struct PreferenceGenerator *
 143 GNUNET_ATS_TEST_generate_preferences_start (struct BenchmarkPeer *src,
 144     struct BenchmarkPartner *dest,
 145     enum GeneratorType type,
 146     long int base_value,
 147     long int value_rate,
 148     struct GNUNET_TIME_Relative period,
 149     struct GNUNET_TIME_Relative frequency,
 150     enum GNUNET_ATS_PreferenceKind kind)
 151 {
 152   struct PreferenceGenerator *pg;
 153
 154   if (NULL != dest->pg)
 155   {
 156     GNUNET_break (0);
 157     return NULL;
 158   }
 159
 160   pg = GNUNET_new (struct PreferenceGenerator);
 161   GNUNET_CONTAINER_DLL_insert (pg_head, pg_tail, pg);
 162   pg->type = type;
 163   pg->src = src;
 164   pg->dest = dest;
 165   pg->kind = kind;
 166   pg->base_value = base_value;
 167   pg->max_value = value_rate;
 168   pg->duration_period = period;
 169   pg->frequency = frequency;
 170   pg->time_start = GNUNET_TIME_absolute_get();
 171
 172   switch (type) {
 173     case GNUNET_ATS_TEST_TG_CONSTANT:
 174       GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 175           "Setting up constant preference generator master[%u] `%s' and slave [%u] `%s' max %u Bips\n",
 176           dest->me->no, GNUNET_i2s (&dest->me->id),
 177           dest->dest->no, GNUNET_i2s (&dest->dest->id),
 178           base_value);
 179       break;
 180     case GNUNET_ATS_TEST_TG_LINEAR:
 181       GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 182           "Setting up linear preference generator master[%u] `%s' and slave [%u] `%s' min %u Bips max %u Bips\n",
 183           dest->me->no, GNUNET_i2s (&dest->me->id),
 184           dest->dest->no, GNUNET_i2s (&dest->dest->id),
 185           base_value, value_rate);
 186       break;
 187     case GNUNET_ATS_TEST_TG_SINUS:
 188       GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 189           "Setting up sinus preference generator master[%u] `%s' and slave [%u] `%s' baserate %u Bips, amplitude %u Bps\n",
 190           dest->me->no, GNUNET_i2s (&dest->me->id),
 191           dest->dest->no, GNUNET_i2s (&dest->dest->id),
 192           base_value, value_rate);
 193       break;
 194     case GNUNET_ATS_TEST_TG_RANDOM:
 195       GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 196           "Setting up random preference generator master[%u] `%s' and slave [%u] `%s' min %u Bips max %u Bps\n",
 197           dest->me->no, GNUNET_i2s (&dest->me->id),
 198           dest->dest->no, GNUNET_i2s (&dest->dest->id),
 199           base_value, value_rate);
 200       break;
 201     default:
 202       break;
 203   }
 204
 205   dest->pg = pg;
 206   pg->set_task = GNUNET_SCHEDULER_add_now (&set_pref_task, dest);
 207   return pg;
 208 }
 209
 210
 211 void
 212 GNUNET_ATS_TEST_generate_preferences_stop (struct PreferenceGenerator *pg)
 213 {
 214   GNUNET_CONTAINER_DLL_remove (pg_head, pg_tail, pg);
 215   pg->dest->pg = NULL;
 216
 217   if (NULL != pg->set_task)
 218   {
 219     GNUNET_SCHEDULER_cancel (pg->set_task);
 220     pg->set_task = NULL;
 221   }
 222
 223   GNUNET_free (pg);
 224 }
 225
 226
 227 /**
 228  * Stop all preferences generators
 229  */
 230 void
 231 GNUNET_ATS_TEST_generate_preferences_stop_all ()
 232 {
 233   struct PreferenceGenerator *cur;
 234   struct PreferenceGenerator *next;
 235   next = pg_head;
 236   for (cur = next; NULL != cur; cur = next)
 237   {
 238       next = cur->next;
 239       GNUNET_ATS_TEST_generate_preferences_stop(cur);
 240   }
 241 }
 242
 243 /* end of file ats-testing-preferences.c */
 244