aboutsummaryrefslogtreecommitdiff
path: root/src/hostlist/test_gnunet_daemon_hostlist_learning.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2010-05-17 13:17:29 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2010-05-17 13:17:29 +0000
commitdf6e739886b094fd440a5b1c768d8ac789a77880 (patch)
tree27c146a7760395720bf26753d3acf4ad1d84b0c1 /src/hostlist/test_gnunet_daemon_hostlist_learning.c
parent33e8e9dfc3e2e69906d1fa122ec37a1605df368f (diff)
downloadgnunet-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.c49
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
193timeout_error (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 191timeout_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
260check_statistics (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 260check_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/**