diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2010-05-17 13:17:29 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2010-05-17 13:17:29 +0000 |
commit | df6e739886b094fd440a5b1c768d8ac789a77880 (patch) | |
tree | 27c146a7760395720bf26753d3acf4ad1d84b0c1 /src/hostlist/test_gnunet_daemon_hostlist_learning.c | |
parent | 33e8e9dfc3e2e69906d1fa122ec37a1605df368f (diff) | |
download | gnunet-df6e739886b094fd440a5b1c768d8ac789a77880.tar.gz gnunet-df6e739886b094fd440a5b1c768d8ac789a77880.zip |
Diffstat (limited to 'src/hostlist/test_gnunet_daemon_hostlist_learning.c')
-rw-r--r-- | src/hostlist/test_gnunet_daemon_hostlist_learning.c | 49 |
1 files changed, 27 insertions, 22 deletions
diff --git a/src/hostlist/test_gnunet_daemon_hostlist_learning.c b/src/hostlist/test_gnunet_daemon_hostlist_learning.c index a9bb6e956..dcfb226cf 100644 --- a/src/hostlist/test_gnunet_daemon_hostlist_learning.c +++ b/src/hostlist/test_gnunet_daemon_hostlist_learning.c | |||
@@ -102,14 +102,10 @@ static void shutdown_testcase() | |||
102 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping Timeout Task.\n"); | 102 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping Timeout Task.\n"); |
103 | if (timeout_task != GNUNET_SCHEDULER_NO_TASK) | 103 | if (timeout_task != GNUNET_SCHEDULER_NO_TASK) |
104 | { | 104 | { |
105 | GNUNET_SCHEDULER_cancel (sched, | 105 | GNUNET_SCHEDULER_cancel (sched, timeout_task); |
106 | timeout_task); | ||
107 | timeout_task = GNUNET_SCHEDULER_NO_TASK; | 106 | timeout_task = GNUNET_SCHEDULER_NO_TASK; |
108 | } | 107 | } |
109 | 108 | ||
110 | |||
111 | |||
112 | |||
113 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping Statistics Check Task.\n"); | 109 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping Statistics Check Task.\n"); |
114 | if (check_task != GNUNET_SCHEDULER_NO_TASK) | 110 | if (check_task != GNUNET_SCHEDULER_NO_TASK) |
115 | { | 111 | { |
@@ -118,14 +114,15 @@ static void shutdown_testcase() | |||
118 | } | 114 | } |
119 | 115 | ||
120 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping Statistics Task.\n"); | 116 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping Statistics Task.\n"); |
121 | /* | 117 | |
122 | if ((NULL != learn_peer.stats) && (NULL != download_stats)) | 118 | if ((NULL != learn_peer.stats) && (NULL != download_stats)) |
123 | GNUNET_STATISTICS_get_cancel (download_stats); | 119 | GNUNET_STATISTICS_get_cancel (download_stats); |
124 | if ((NULL != learn_peer.stats) && (NULL != urisrecv_stat)) | 120 | if ((NULL != learn_peer.stats) && (NULL != urisrecv_stat)) |
125 | GNUNET_STATISTICS_get_cancel (urisrecv_stat); | 121 | GNUNET_STATISTICS_get_cancel (urisrecv_stat); |
126 | if ((NULL != adv_peer.stats) && (NULL != advsent_stat)) | 122 | if ((NULL != adv_peer.stats) && (NULL != advsent_stat)) |
127 | GNUNET_STATISTICS_get_cancel (advsent_stat);*/ | 123 | GNUNET_STATISTICS_get_cancel (advsent_stat); |
128 | // if ( NULL != current_adv_uri ) GNUNET_free (current_adv_uri); | 124 | |
125 | if ( NULL != current_adv_uri ) GNUNET_free (current_adv_uri); | ||
129 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from Transport.\n"); | 126 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from Transport.\n"); |
130 | if (adv_peer.th != NULL) | 127 | if (adv_peer.th != NULL) |
131 | { | 128 | { |
@@ -155,33 +152,34 @@ static void shutdown_testcase() | |||
155 | 152 | ||
156 | #if START_ARM | 153 | #if START_ARM |
157 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 154 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
158 | "Adv Killing ARM process.\n"); | 155 | "Killing hostlist server ARM process.\n"); |
159 | if (0 != PLIBC_KILL (adv_peer.arm_pid, SIGTERM)) | 156 | if (0 != PLIBC_KILL (adv_peer.arm_pid, SIGTERM)) |
160 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); | 157 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); |
161 | if (GNUNET_OS_process_wait(adv_peer.arm_pid) != GNUNET_OK) | 158 | if (GNUNET_OS_process_wait(adv_peer.arm_pid) != GNUNET_OK) |
162 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); | 159 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); |
163 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 160 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
164 | "Adv ARM process %u stopped\n", adv_peer.arm_pid); | 161 | "Hostlist server ARM process %u stopped\n", adv_peer.arm_pid); |
165 | #endif | 162 | #endif |
166 | GNUNET_CONFIGURATION_destroy (adv_peer.cfg); | 163 | /* |
164 | if (NULL != adv_peer.cfg) | ||
165 | GNUNET_CONFIGURATION_destroy (adv_peer.cfg);*/ | ||
167 | 166 | ||
168 | 167 | ||
169 | #if START_ARM | 168 | #if START_ARM |
170 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 169 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
171 | "Learn Killing ARM process.\n"); | 170 | "Killing hostlist client ARM process.\n"); |
172 | if (0 != PLIBC_KILL (learn_peer.arm_pid, SIGTERM)) | 171 | if (0 != PLIBC_KILL (learn_peer.arm_pid, SIGTERM)) |
173 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); | 172 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); |
174 | if (GNUNET_OS_process_wait(learn_peer.arm_pid) != GNUNET_OK) | 173 | if (GNUNET_OS_process_wait(learn_peer.arm_pid) != GNUNET_OK) |
175 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); | 174 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); |
176 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 175 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
177 | "Learn ARM process %u stopped\n", learn_peer.arm_pid); | 176 | "Hostlist client ARM process %u stopped\n", learn_peer.arm_pid); |
178 | #endif | 177 | #endif |
179 | GNUNET_CONFIGURATION_destroy (adv_peer.cfg); | 178 | /* |
179 | if (NULL != learn_peer.cfg) | ||
180 | GNUNET_CONFIGURATION_destroy (learn_peer.cfg);*/ | ||
180 | 181 | ||
181 | /* GNUNET_SCHEDULER_add_now (sched, | 182 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutdown complete....\n"); |
182 | &waitpid_task, &learn_peer); | ||
183 | GNUNET_SCHEDULER_add_now (sched, | ||
184 | &waitpid_task, &adv_peer);*/ | ||
185 | GNUNET_SCHEDULER_shutdown (sched); | 183 | GNUNET_SCHEDULER_shutdown (sched); |
186 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutdown complete....\n"); | 184 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutdown complete....\n"); |
187 | } | 185 | } |
@@ -193,6 +191,8 @@ static void | |||
193 | timeout_error (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 191 | timeout_error (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
194 | { | 192 | { |
195 | timeout_task = GNUNET_SCHEDULER_NO_TASK; | 193 | timeout_task = GNUNET_SCHEDULER_NO_TASK; |
194 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | ||
195 | return; | ||
196 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 196 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, |
197 | "Timeout while executing testcase, test failed.\n"); | 197 | "Timeout while executing testcase, test failed.\n"); |
198 | timeout = GNUNET_YES; | 198 | timeout = GNUNET_YES; |
@@ -260,6 +260,11 @@ static void | |||
260 | check_statistics (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 260 | check_statistics (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
261 | { | 261 | { |
262 | char *stat; | 262 | char *stat; |
263 | |||
264 | check_task = GNUNET_SCHEDULER_NO_TASK; | ||
265 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | ||
266 | return; | ||
267 | |||
263 | GNUNET_asprintf (&stat, | 268 | GNUNET_asprintf (&stat, |
264 | gettext_noop("# advertised URI `%s' downloaded"), | 269 | gettext_noop("# advertised URI `%s' downloaded"), |
265 | current_adv_uri); | 270 | current_adv_uri); |
@@ -292,11 +297,11 @@ check_statistics (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
292 | NULL, | 297 | NULL, |
293 | &process_adv_sent, | 298 | &process_adv_sent, |
294 | NULL); | 299 | NULL); |
295 | check_task = GNUNET_SCHEDULER_add_delayed (sched, | ||
296 | CHECK_INTERVALL, | ||
297 | &check_statistics, | ||
298 | NULL); | ||
299 | } | 300 | } |
301 | check_task = GNUNET_SCHEDULER_add_delayed (sched, | ||
302 | CHECK_INTERVALL, | ||
303 | &check_statistics, | ||
304 | NULL); | ||
300 | } | 305 | } |
301 | 306 | ||
302 | /** | 307 | /** |