aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/transport/transport-testing-main.c22
-rw-r--r--src/transport/transport-testing.c26
2 files changed, 25 insertions, 23 deletions
diff --git a/src/transport/transport-testing-main.c b/src/transport/transport-testing-main.c
index a79d81cb9..81a66e113 100644
--- a/src/transport/transport-testing-main.c
+++ b/src/transport/transport-testing-main.c
@@ -146,7 +146,7 @@ struct GNUNET_TRANSPORT_TESTING_InternalPeerContext
146 146
147/** 147/**
148 * Information tracked per connected peer. 148 * Information tracked per connected peer.
149 */ 149 */
150struct ConnectPairInfo 150struct ConnectPairInfo
151{ 151{
152 /** 152 /**
@@ -235,7 +235,7 @@ my_nc (void *cls,
235 struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls; 235 struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls;
236 struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc; 236 struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
237 struct ConnectPairInfo *cpi; 237 struct ConnectPairInfo *cpi;
238 238
239 if (NULL != ccc->nc) 239 if (NULL != ccc->nc)
240 ccc->nc (ccc->cls, 240 ccc->nc (ccc->cls,
241 ccc->p[ipi->off], 241 ccc->p[ipi->off],
@@ -262,7 +262,7 @@ my_nd (void *cls,
262 struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls; 262 struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls;
263 struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc; 263 struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
264 struct ConnectPairInfo *cpi = custom_cls; 264 struct ConnectPairInfo *cpi = custom_cls;
265 265
266 if (NULL != ccc->nd) 266 if (NULL != ccc->nd)
267 ccc->nd (ccc->cls, 267 ccc->nd (ccc->cls,
268 ccc->p[ipi->off], 268 ccc->p[ipi->off],
@@ -535,13 +535,15 @@ GNUNET_TRANSPORT_TESTING_connect_check (void *cls,
535 ip[i].off = i; 535 ip[i].off = i;
536 ip[i].ccc = ccc; 536 ip[i].ccc = ccc;
537 } 537 }
538 GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1, 538 if (GNUNET_OK !=
539 argv, 539 GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1,
540 test_name_, 540 argv,
541 "nohelp", 541 test_name_,
542 options, 542 "nohelp",
543 &connect_check_run, 543 options,
544 ccc); 544 &connect_check_run,
545 ccc))
546 return GNUNET_SYSERR;
545 return ccc->global_ret; 547 return ccc->global_ret;
546} 548}
547 549
diff --git a/src/transport/transport-testing.c b/src/transport/transport-testing.c
index c0775a135..53a44f338 100644
--- a/src/transport/transport-testing.c
+++ b/src/transport/transport-testing.c
@@ -49,7 +49,7 @@ find_peer_context (struct GNUNET_TRANSPORT_TESTING_Handle *tth,
49 * 49 *
50 * @param p1 first peer 50 * @param p1 first peer
51 * @param p2 second peer 51 * @param p2 second peer
52 * @param cb function to call 52 * @param cb function to call
53 * @param cb_cls closure for @a cb 53 * @param cb_cls closure for @a cb
54 */ 54 */
55void 55void
@@ -66,7 +66,7 @@ GNUNET_TRANSPORT_TESTING_find_connecting_context (struct GNUNET_TRANSPORT_TESTIN
66 { 66 {
67 ccn = cc->next; 67 ccn = cc->next;
68 if ( (cc->p1 == p1) && 68 if ( (cc->p1 == p1) &&
69 (cc->p2 == p2) ) 69 (cc->p2 == p2) )
70 cb (cb_cls, 70 cb (cb_cls,
71 cc); 71 cc);
72 } 72 }
@@ -74,7 +74,7 @@ GNUNET_TRANSPORT_TESTING_find_connecting_context (struct GNUNET_TRANSPORT_TESTIN
74 74
75 75
76static void 76static void
77set_p1c (void *cls, 77set_p1c (void *cls,
78 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx) 78 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx)
79{ 79{
80 int *found = cls; 80 int *found = cls;
@@ -86,7 +86,7 @@ set_p1c (void *cls,
86 86
87 87
88static void 88static void
89set_mq (void *cls, 89set_mq (void *cls,
90 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx) 90 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx)
91{ 91{
92 struct GNUNET_MQ_Handle *mq = cls; 92 struct GNUNET_MQ_Handle *mq = cls;
@@ -96,7 +96,7 @@ set_mq (void *cls,
96 96
97 97
98static void 98static void
99set_p2c (void *cls, 99set_p2c (void *cls,
100 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx) 100 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx)
101{ 101{
102 int *found = cls; 102 int *found = cls;
@@ -108,7 +108,7 @@ set_p2c (void *cls,
108 108
109 109
110static void 110static void
111clear_p1c (void *cls, 111clear_p1c (void *cls,
112 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx) 112 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx)
113{ 113{
114 int *found = cls; 114 int *found = cls;
@@ -120,7 +120,7 @@ clear_p1c (void *cls,
120 120
121 121
122static void 122static void
123clear_p2c (void *cls, 123clear_p2c (void *cls,
124 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx) 124 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cx)
125{ 125{
126 int *found = cls; 126 int *found = cls;
@@ -154,7 +154,7 @@ notify_connect (void *cls,
154 else 154 else
155 ret = NULL; 155 ret = NULL;
156 156
157 if (p2 != NULL) 157 if (NULL != p2)
158 GNUNET_asprintf (&p2_s, 158 GNUNET_asprintf (&p2_s,
159 "%u (`%s')", 159 "%u (`%s')",
160 p2->no, 160 p2->no,
@@ -267,7 +267,7 @@ notify_disconnect (void *cls,
267 int no = 0; 267 int no = 0;
268 struct GNUNET_TRANSPORT_TESTING_PeerContext *p2 = NULL; 268 struct GNUNET_TRANSPORT_TESTING_PeerContext *p2 = NULL;
269 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc; 269 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
270 270
271 p2 = find_peer_context (p->tth, 271 p2 = find_peer_context (p->tth,
272 peer); 272 peer);
273 no = p->no; 273 no = p->no;
@@ -386,7 +386,7 @@ GNUNET_TRANSPORT_TESTING_start_peer (struct GNUNET_TRANSPORT_TESTING_Handle *tth
386 struct GNUNET_TRANSPORT_TESTING_PeerContext *p; 386 struct GNUNET_TRANSPORT_TESTING_PeerContext *p;
387 struct GNUNET_PeerIdentity *dummy; 387 struct GNUNET_PeerIdentity *dummy;
388 unsigned int i; 388 unsigned int i;
389 389
390 if (GNUNET_NO == GNUNET_DISK_file_test (cfgname)) 390 if (GNUNET_NO == GNUNET_DISK_file_test (cfgname))
391 { 391 {
392 LOG (GNUNET_ERROR_TYPE_ERROR, 392 LOG (GNUNET_ERROR_TYPE_ERROR,
@@ -407,7 +407,7 @@ GNUNET_TRANSPORT_TESTING_start_peer (struct GNUNET_TRANSPORT_TESTING_Handle *tth
407 GNUNET_memcpy (p->handlers, 407 GNUNET_memcpy (p->handlers,
408 handlers, 408 handlers,
409 i * sizeof (struct GNUNET_MQ_MessageHandler)); 409 i * sizeof (struct GNUNET_MQ_MessageHandler));
410 } 410 }
411 if (NULL != cb_cls) 411 if (NULL != cb_cls)
412 p->cb_cls = cb_cls; 412 p->cb_cls = cb_cls;
413 else 413 else
@@ -532,7 +532,7 @@ GNUNET_TRANSPORT_TESTING_restart_peer (struct GNUNET_TRANSPORT_TESTING_PeerConte
532{ 532{
533 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc; 533 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
534 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn; 534 struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn;
535 535
536 /* shutdown */ 536 /* shutdown */
537 LOG (GNUNET_ERROR_TYPE_DEBUG, 537 LOG (GNUNET_ERROR_TYPE_DEBUG,
538 "Stopping peer %u (`%s')\n", 538 "Stopping peer %u (`%s')\n",
@@ -770,7 +770,7 @@ GNUNET_TRANSPORT_TESTING_connect_peers (struct GNUNET_TRANSPORT_TESTING_PeerCont
770 break; 770 break;
771 } 771 }
772 } 772 }
773 773
774 cc = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_ConnectRequest); 774 cc = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_ConnectRequest);
775 cc->p1 = p1; 775 cc->p1 = p1;
776 cc->p2 = p2; 776 cc->p2 = p2;