diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2012-07-14 18:39:06 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2012-07-14 18:39:06 +0000 |
commit | 3fe84176dfb6b14ecb7995126145060bec0c1269 (patch) | |
tree | 4c86d49aa0a60f526353bdc010d625b8acf4e672 /src/testbed | |
parent | 41eebf21e8f0b3a824f216fd6fd372a79dcf0991 (diff) | |
download | gnunet-3fe84176dfb6b14ecb7995126145060bec0c1269.tar.gz gnunet-3fe84176dfb6b14ecb7995126145060bec0c1269.zip |
relaxed time for shutdown
Diffstat (limited to 'src/testbed')
-rw-r--r-- | src/testbed/gnunet-testbed-helper.c | 3 | ||||
-rw-r--r-- | src/testbed/test_gnunet_testbed_helper.c | 4 |
2 files changed, 5 insertions, 2 deletions
diff --git a/src/testbed/gnunet-testbed-helper.c b/src/testbed/gnunet-testbed-helper.c index 0b590daa1..371ac8951 100644 --- a/src/testbed/gnunet-testbed-helper.c +++ b/src/testbed/gnunet-testbed-helper.c | |||
@@ -150,7 +150,7 @@ read_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
150 | if (GNUNET_YES == ignore_reading) | 150 | if (GNUNET_YES == ignore_reading) |
151 | return; | 151 | return; |
152 | ret = GNUNET_SERVER_mst_receive (tokenizer, NULL, buf, sread, | 152 | ret = GNUNET_SERVER_mst_receive (tokenizer, NULL, buf, sread, |
153 | GNUNET_YES, GNUNET_YES); | 153 | GNUNET_NO, GNUNET_NO); |
154 | GNUNET_assert (GNUNET_SYSERR != ret); | 154 | GNUNET_assert (GNUNET_SYSERR != ret); |
155 | if (GNUNET_NO == ret) | 155 | if (GNUNET_NO == ret) |
156 | { | 156 | { |
@@ -172,6 +172,7 @@ static void | |||
172 | run (void *cls, char *const *args, const char *cfgfile, | 172 | run (void *cls, char *const *args, const char *cfgfile, |
173 | const struct GNUNET_CONFIGURATION_Handle * cfg) | 173 | const struct GNUNET_CONFIGURATION_Handle * cfg) |
174 | { | 174 | { |
175 | LOG_DEBUG ("Starting testbed helper...\n"); | ||
175 | tokenizer = GNUNET_SERVER_mst_create (&tokenizer_cb, NULL); | 176 | tokenizer = GNUNET_SERVER_mst_create (&tokenizer_cb, NULL); |
176 | stdin_fd = GNUNET_DISK_get_handle_from_native (stdin); | 177 | stdin_fd = GNUNET_DISK_get_handle_from_native (stdin); |
177 | buf_size = sizeof (struct GNUNET_TESTBED_HelperInit) + 8 * 1024; | 178 | buf_size = sizeof (struct GNUNET_TESTBED_HelperInit) + 8 * 1024; |
diff --git a/src/testbed/test_gnunet_testbed_helper.c b/src/testbed/test_gnunet_testbed_helper.c index 518825427..b41410ce9 100644 --- a/src/testbed/test_gnunet_testbed_helper.c +++ b/src/testbed/test_gnunet_testbed_helper.c | |||
@@ -109,7 +109,9 @@ cont_cb (void *cls, int result) | |||
109 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Message sent\n"); | 109 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Message sent\n"); |
110 | GNUNET_assert (GNUNET_OK == result); | 110 | GNUNET_assert (GNUNET_OK == result); |
111 | if (GNUNET_SCHEDULER_NO_TASK == shutdown_task) | 111 | if (GNUNET_SCHEDULER_NO_TASK == shutdown_task) |
112 | shutdown_task = GNUNET_SCHEDULER_add_now (&do_shutdown, NULL); | 112 | shutdown_task = GNUNET_SCHEDULER_add_delayed |
113 | (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 2), | ||
114 | &do_shutdown, NULL); | ||
113 | } | 115 | } |
114 | 116 | ||
115 | 117 | ||