relaxed time for shutdown
authorSree Harsha Totakura <totakura@in.tum.de>
Sat, 14 Jul 2012 18:39:06 +0000 (18:39 +0000)
committerSree Harsha Totakura <totakura@in.tum.de>
Sat, 14 Jul 2012 18:39:06 +0000 (18:39 +0000)
src/testbed/gnunet-testbed-helper.c
src/testbed/test_gnunet_testbed_helper.c

index 0b590daa1f5e0a78dc06f208cb2d8f35e5769cf8..371ac8951dbd93a2a0e9df1ad55c6c62d48e7006 100644 (file)
@@ -150,7 +150,7 @@ read_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
   if (GNUNET_YES == ignore_reading)
     return;
   ret = GNUNET_SERVER_mst_receive (tokenizer, NULL, buf, sread,
-                                   GNUNET_YES, GNUNET_YES);
+                                   GNUNET_NO, GNUNET_NO);
   GNUNET_assert (GNUNET_SYSERR != ret);
   if (GNUNET_NO == ret)
   {
@@ -172,6 +172,7 @@ static void
 run (void *cls, char *const *args, const char *cfgfile,
      const struct GNUNET_CONFIGURATION_Handle * cfg)
 {
+  LOG_DEBUG ("Starting testbed helper...\n");
   tokenizer = GNUNET_SERVER_mst_create (&tokenizer_cb, NULL);
   stdin_fd = GNUNET_DISK_get_handle_from_native (stdin);
   buf_size = sizeof (struct GNUNET_TESTBED_HelperInit) + 8 * 1024;
index 5188254278521e2878138256cf39c6e4c44268bd..b41410ce9ed8737479eddf049ada2bf097b92395 100644 (file)
@@ -109,7 +109,9 @@ cont_cb (void *cls, int result)
   LOG (GNUNET_ERROR_TYPE_DEBUG, "Message sent\n");
   GNUNET_assert (GNUNET_OK == result);
   if (GNUNET_SCHEDULER_NO_TASK == shutdown_task)
-    shutdown_task = GNUNET_SCHEDULER_add_now (&do_shutdown, NULL);
+    shutdown_task = GNUNET_SCHEDULER_add_delayed 
+      (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 2),
+       &do_shutdown, NULL);
 }