[GNUnet-SVN] r33303 - gnunet/src/ats

[gnunet]

Author: wachs
Date: 2014-05-15 18:47:24 +0200 (Thu, 15 May 2014)
New Revision: 33303

Modified:
   gnunet/src/ats/gnunet-ats-solver-eval.c
   gnunet/src/ats/gnunet-ats-solver-eval.h
Log:
log if peer is requested


Modified: gnunet/src/ats/gnunet-ats-solver-eval.c
===================================================================
--- gnunet/src/ats/gnunet-ats-solver-eval.c     2014-05-15 14:48:59 UTC (rev 
33302)
+++ gnunet/src/ats/gnunet-ats-solver-eval.c     2014-05-15 16:47:24 UTC (rev 
33303)
@@ -199,6 +199,7 @@
     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];
@@ -383,7 +384,7 @@
           GNUNET_free (filename);
           GNUNET_CONTAINER_DLL_insert (lf_head, lf_tail, cur);
 
-          GNUNET_asprintf(&datastring,"#time delta;log duration; addr net; 
addr_active; bw in; bw out; " \
+          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; " \
@@ -427,10 +428,12 @@
           propstring = GNUNET_strdup(propstring_tmp);
           GNUNET_free (propstring_tmp);
         }
-
-        GNUNET_asprintf(&datastring,"%llu;%llu;%u;%i;%u;%u;%s;%s\n",
+        if (GNUNET_YES==log_p->is_requested)
+          GNUNET_break (0);
+        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,
             ntohl (log_a->assigned_bw_in.value__),
@@ -2279,6 +2282,7 @@
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Requesting address for peer %u\n",
       op->peer_id);
+  p->is_requested = GNUNET_YES;
 
   res = sh->env.sf.s_get (sh->solver, &p->peer_id);
   if (NULL != res)
@@ -2307,7 +2311,7 @@
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Stop requesting address for peer %u\n",
       op->peer_id);
-
+  p->is_requested = GNUNET_NO;
   sh->env.sf.s_get_stop (sh->solver, &p->peer_id);
 
   if (NULL != l)

Modified: gnunet/src/ats/gnunet-ats-solver-eval.h
===================================================================
--- gnunet/src/ats/gnunet-ats-solver-eval.h     2014-05-15 14:48:59 UTC (rev 
33302)
+++ gnunet/src/ats/gnunet-ats-solver-eval.h     2014-05-15 16:47:24 UTC (rev 
33303)
@@ -122,6 +122,7 @@
   struct GNUNET_PeerIdentity peer_id;
   double pref_abs[GNUNET_ATS_PreferenceCount];
   double pref_norm[GNUNET_ATS_PreferenceCount];
+  int is_requested;
 
   struct LoggingAddress *addr_head;
   struct LoggingAddress *addr_tail;
@@ -149,7 +150,9 @@
   struct TestPeer *prev;
   struct TestPeer *next;
 
+
   long long unsigned int id;
+  int is_requested;
   struct GNUNET_PeerIdentity peer_id;
 
   double pref_abs[GNUNET_ATS_PreferenceCount];