diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-03-23 16:48:18 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-03-23 16:48:18 +0000 |
commit | d789a10c4b16a551d08372fa6c64e2b5d62d57f2 (patch) | |
tree | a0d3814251d1a3bc699af01ca7fae1297652fb0b /src/core/test_core_api.c | |
parent | b00740436bb127c90c035b9683f024c02f57f1af (diff) | |
download | gnunet-d789a10c4b16a551d08372fa6c64e2b5d62d57f2.tar.gz gnunet-d789a10c4b16a551d08372fa6c64e2b5d62d57f2.zip |
-fix misc core issues
Diffstat (limited to 'src/core/test_core_api.c')
-rw-r--r-- | src/core/test_core_api.c | 50 |
1 files changed, 33 insertions, 17 deletions
diff --git a/src/core/test_core_api.c b/src/core/test_core_api.c index 11fa47f2e..941022c21 100644 --- a/src/core/test_core_api.c +++ b/src/core/test_core_api.c | |||
@@ -58,7 +58,8 @@ static int ok; | |||
58 | 58 | ||
59 | 59 | ||
60 | static void | 60 | static void |
61 | process_hello (void *cls, const struct GNUNET_MessageHeader *message) | 61 | process_hello (void *cls, |
62 | const struct GNUNET_MessageHeader *message) | ||
62 | { | 63 | { |
63 | struct PeerContext *p = cls; | 64 | struct PeerContext *p = cls; |
64 | 65 | ||
@@ -73,7 +74,8 @@ process_hello (void *cls, const struct GNUNET_MessageHeader *message) | |||
73 | 74 | ||
74 | 75 | ||
75 | static void | 76 | static void |
76 | terminate_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 77 | terminate_task (void *cls, |
78 | const struct GNUNET_SCHEDULER_TaskContext *tc) | ||
77 | { | 79 | { |
78 | GNUNET_assert (ok == 6); | 80 | GNUNET_assert (ok == 6); |
79 | GNUNET_CORE_disconnect (p1.ch); | 81 | GNUNET_CORE_disconnect (p1.ch); |
@@ -98,10 +100,12 @@ terminate_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
98 | 100 | ||
99 | 101 | ||
100 | static void | 102 | static void |
101 | terminate_task_error (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 103 | terminate_task_error (void *cls, |
104 | const struct GNUNET_SCHEDULER_TaskContext *tc) | ||
102 | { | 105 | { |
103 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 106 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
104 | "ENDING ANGRILY %u\n", ok); | 107 | "ENDING ANGRILY %u\n", |
108 | ok); | ||
105 | GNUNET_break (0); | 109 | GNUNET_break (0); |
106 | if (NULL != p1.ch) | 110 | if (NULL != p1.ch) |
107 | { | 111 | { |
@@ -143,7 +147,7 @@ transmit_ready (void *cls, size_t size, void *buf) | |||
143 | GNUNET_assert (ok == 4); | 147 | GNUNET_assert (ok == 4); |
144 | OKPP; | 148 | OKPP; |
145 | GNUNET_assert (p == &p1); | 149 | GNUNET_assert (p == &p1); |
146 | GNUNET_assert (buf != NULL); | 150 | GNUNET_assert (NULL != buf); |
147 | m = (struct GNUNET_MessageHeader *) buf; | 151 | m = (struct GNUNET_MessageHeader *) buf; |
148 | m->type = htons (MTYPE); | 152 | m->type = htons (MTYPE); |
149 | m->size = htons (sizeof (struct GNUNET_MessageHeader)); | 153 | m->size = htons (sizeof (struct GNUNET_MessageHeader)); |
@@ -152,7 +156,8 @@ transmit_ready (void *cls, size_t size, void *buf) | |||
152 | 156 | ||
153 | 157 | ||
154 | static void | 158 | static void |
155 | connect_notify (void *cls, const struct GNUNET_PeerIdentity *peer) | 159 | connect_notify (void *cls, |
160 | const struct GNUNET_PeerIdentity *peer) | ||
156 | { | 161 | { |
157 | struct PeerContext *pc = cls; | 162 | struct PeerContext *pc = cls; |
158 | 163 | ||
@@ -224,12 +229,13 @@ outbound_notify (void *cls, const struct GNUNET_PeerIdentity *other, | |||
224 | } | 229 | } |
225 | 230 | ||
226 | 231 | ||
227 | |||
228 | static int | 232 | static int |
229 | process_mtype (void *cls, const struct GNUNET_PeerIdentity *peer, | 233 | process_mtype (void *cls, |
234 | const struct GNUNET_PeerIdentity *peer, | ||
230 | const struct GNUNET_MessageHeader *message) | 235 | const struct GNUNET_MessageHeader *message) |
231 | { | 236 | { |
232 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Receiving message from `%4s'.\n", | 237 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
238 | "Receiving message from `%4s'.\n", | ||
233 | GNUNET_i2s (peer)); | 239 | GNUNET_i2s (peer)); |
234 | GNUNET_assert (ok == 5); | 240 | GNUNET_assert (ok == 5); |
235 | OKPP; | 241 | OKPP; |
@@ -246,7 +252,8 @@ static struct GNUNET_CORE_MessageHandler handlers[] = { | |||
246 | 252 | ||
247 | 253 | ||
248 | static void | 254 | static void |
249 | connect_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 255 | connect_task (void *cls, |
256 | const struct GNUNET_SCHEDULER_TaskContext *tc) | ||
250 | { | 257 | { |
251 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 258 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
252 | { | 259 | { |
@@ -254,7 +261,8 @@ connect_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
254 | return; | 261 | return; |
255 | } | 262 | } |
256 | con_task = | 263 | con_task = |
257 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &connect_task, | 264 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, |
265 | &connect_task, | ||
258 | NULL); | 266 | NULL); |
259 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 267 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
260 | "Asking transport (1) to connect to peer `%4s'\n", | 268 | "Asking transport (1) to connect to peer `%4s'\n", |
@@ -269,7 +277,8 @@ init_notify (void *cls, | |||
269 | { | 277 | { |
270 | struct PeerContext *p = cls; | 278 | struct PeerContext *p = cls; |
271 | 279 | ||
272 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Core connection to `%4s' established\n", | 280 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
281 | "Core connection to `%4s' established\n", | ||
273 | GNUNET_i2s (my_identity)); | 282 | GNUNET_i2s (my_identity)); |
274 | p->id = *my_identity; | 283 | p->id = *my_identity; |
275 | if (cls == &p1) | 284 | if (cls == &p1) |
@@ -293,7 +302,8 @@ init_notify (void *cls, | |||
293 | 302 | ||
294 | 303 | ||
295 | static void | 304 | static void |
296 | setup_peer (struct PeerContext *p, const char *cfgname) | 305 | setup_peer (struct PeerContext *p, |
306 | const char *cfgname) | ||
297 | { | 307 | { |
298 | char *binary; | 308 | char *binary; |
299 | 309 | ||
@@ -314,7 +324,9 @@ setup_peer (struct PeerContext *p, const char *cfgname) | |||
314 | 324 | ||
315 | 325 | ||
316 | static void | 326 | static void |
317 | run (void *cls, char *const *args, const char *cfgfile, | 327 | run (void *cls, |
328 | char *const *args, | ||
329 | const char *cfgfile, | ||
318 | const struct GNUNET_CONFIGURATION_Handle *cfg) | 330 | const struct GNUNET_CONFIGURATION_Handle *cfg) |
319 | { | 331 | { |
320 | GNUNET_assert (ok == 1); | 332 | GNUNET_assert (ok == 1); |
@@ -326,9 +338,13 @@ run (void *cls, char *const *args, const char *cfgfile, | |||
326 | (GNUNET_TIME_UNIT_SECONDS, 300), | 338 | (GNUNET_TIME_UNIT_SECONDS, 300), |
327 | &terminate_task_error, NULL); | 339 | &terminate_task_error, NULL); |
328 | p1.ch = | 340 | p1.ch = |
329 | GNUNET_CORE_connect (p1.cfg, &p1, &init_notify, &connect_notify, | 341 | GNUNET_CORE_connect (p1.cfg, &p1, |
330 | &disconnect_notify, &inbound_notify, GNUNET_YES, | 342 | &init_notify, |
331 | &outbound_notify, GNUNET_YES, handlers); | 343 | &connect_notify, |
344 | &disconnect_notify, | ||
345 | &inbound_notify, GNUNET_YES, | ||
346 | &outbound_notify, GNUNET_YES, | ||
347 | handlers); | ||
332 | } | 348 | } |
333 | 349 | ||
334 | 350 | ||