- continous watch for statistics

diff --git a/src/statistics/gnunet-statistics.c b/src/statistics/gnunet-statistics.c
index ce91572dfa6b6a42f657cb5671b7bc2f38dbcb5e..8b163ef899264fba48b69a3669076cdbefb7e274 100644 (file)
--- a/src/statistics/gnunet-statistics.c
+++ b/src/statistics/gnunet-statistics.c
@@ -52,6 +52,11 @@ static char *name;
  */
 static int persistent;
 
+/**
+ * Watch value continuously
+ */
+static int watch;
+
 /**
  * Quiet mode
  */
@@ -101,7 +106,14 @@ cleanup (void *cls, int success)
   if (h != NULL)
     GNUNET_STATISTICS_destroy (h, GNUNET_NO);
 }
-
+static void
+shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+  struct GNUNET_STATISTICS_Handle *h = cls;
+  GNUNET_STATISTICS_watch_cancel (h, subsystem, name, &printer, h);
+  if (h != NULL)
+    GNUNET_STATISTICS_destroy (h, GNUNET_NO);
+}
 
 /**
  * Main function that will be run by the scheduler.
@@ -143,10 +155,26 @@ run (void *cls, char *const *args, const char *cfgfile,
     ret = 1;
     return;
   }
-  if (NULL ==
+  if (GNUNET_NO == watch)
+  {
+    if (NULL ==
       GNUNET_STATISTICS_get (h, subsystem, name, GET_TIMEOUT, &cleanup,
                              &printer, h))
     cleanup (h, GNUNET_SYSERR);
+  }
+  else
+  {
+    if ((NULL == subsystem) || (NULL == name))
+    {
+      printf (_("No subsystem or name given\n"));
+      if (h != NULL)
+        GNUNET_STATISTICS_destroy (h, GNUNET_NO);
+      ret = 1;
+      return;
+    }
+    GNUNET_STATISTICS_watch(h, subsystem, name, &printer, h);
+    GNUNET_SCHEDULER_add_delayed(GNUNET_TIME_UNIT_FOREVER_REL, &shutdown_task, h);
+  }
 }
 
 /**
@@ -172,6 +200,9 @@ main (int argc, char *const *argv)
     {'q', "quiet", NULL,
      gettext_noop ("just print the statistics value"), 0,
      &GNUNET_GETOPT_set_one, &quiet},
+    {'w', "watch", NULL,
+     gettext_noop ("watch value continously"), 0,
+     &GNUNET_GETOPT_set_one, &watch},
     GNUNET_GETOPT_OPTION_END
   };
   return (GNUNET_OK ==