aboutsummaryrefslogtreecommitdiff
path: root/src/core/test_core_api.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-03-23 16:48:18 +0000
committerChristian Grothoff <christian@grothoff.org>2015-03-23 16:48:18 +0000
commitd789a10c4b16a551d08372fa6c64e2b5d62d57f2 (patch)
treea0d3814251d1a3bc699af01ca7fae1297652fb0b /src/core/test_core_api.c
parentb00740436bb127c90c035b9683f024c02f57f1af (diff)
downloadgnunet-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.c50
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
60static void 60static void
61process_hello (void *cls, const struct GNUNET_MessageHeader *message) 61process_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
75static void 76static void
76terminate_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 77terminate_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
100static void 102static void
101terminate_task_error (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 103terminate_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
154static void 158static void
155connect_notify (void *cls, const struct GNUNET_PeerIdentity *peer) 159connect_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
228static int 232static int
229process_mtype (void *cls, const struct GNUNET_PeerIdentity *peer, 233process_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
248static void 254static void
249connect_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 255connect_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
295static void 304static void
296setup_peer (struct PeerContext *p, const char *cfgname) 305setup_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
316static void 326static void
317run (void *cls, char *const *args, const char *cfgfile, 327run (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