collecting log functionality

mv structs to perf_ats header

1 files changed, 63 insertions, 2 deletions

diff --git a/src/ats-tests/perf_ats_logging.c b/src/ats-tests/perf_ats_logging.c
index 9cdccf54b..1864e0180 100644
--- a/src/ats-tests/perf_ats_logging.c
+++ b/src/ats-tests/perf_ats_logging.c
@@ -25,18 +25,79 @@
  */
 #include "platform.h"
 #include "gnunet_util_lib.h"
+#include "perf_ats.h"
+
+#define LOGGING_FREQUENCY GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, 500)
+
+static GNUNET_SCHEDULER_TaskIdentifier log_task;
+
+static struct BenchmarkPeer *peers;
+static int num_peers;
+
+static void
+write_to_file ()
+{
+
+}
+
+static void
+collect_log_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+  int c_m;
+  int c_s;
+  log_task = GNUNET_SCHEDULER_NO_TASK;
+
+  struct BenchmarkPeer *m;
+  struct BenchmarkPartner *p;
+
+  for (c_m = 0; c_m < num_peers; c_m++)
+  {
+    m = &peers[c_m];
+    for (c_s = 0; c_s < m->num_partners; c_s++)
+    {
+      p = &peers[c_m].partners[c_s];
+      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
+          "Master [%u]: slave [%u]\n",
+          m->no, p->dest->no);
+    }
+  }
+
+  if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN)
+    return;
+
+  log_task = GNUNET_SCHEDULER_add_delayed (LOGGING_FREQUENCY,
+      &collect_log_task, NULL);
+}
+
 
 void
 perf_logging_stop ()
 {
+  struct GNUNET_SCHEDULER_TaskContext tc;
+
+  if (GNUNET_SCHEDULER_NO_TASK != log_task)
+    GNUNET_SCHEDULER_cancel (log_task);
+  log_task = GNUNET_SCHEDULER_NO_TASK;
+  tc.reason = GNUNET_SCHEDULER_REASON_SHUTDOWN;
+  collect_log_task (NULL, &tc);
+
   GNUNET_log(GNUNET_ERROR_TYPE_INFO,
-      _("Start logging\n"));
+      _("Stop logging\n"));
+
+  write_to_file ();
 }
 
 void
-perf_logging_start ()
+perf_logging_start (struct BenchmarkPeer *masters, int num_masters)
 {
   GNUNET_log(GNUNET_ERROR_TYPE_INFO,
       _("Start logging\n"));
+
+  peers = masters;
+  num_peers = num_masters;
+
+  /* Schedule logging task */
+  log_task = GNUNET_SCHEDULER_add_now (&collect_log_task, NULL);
 }
 /* end of file perf_ats_logging.c */
+