diff options
Diffstat (limited to 'src/cadet/test_cadet_local_mq.c')
-rw-r--r-- | src/cadet/test_cadet_local_mq.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/cadet/test_cadet_local_mq.c b/src/cadet/test_cadet_local_mq.c index 19bafbed1..3089c7fbb 100644 --- a/src/cadet/test_cadet_local_mq.c +++ b/src/cadet/test_cadet_local_mq.c | |||
@@ -132,12 +132,12 @@ do_abort (void *cls) | |||
132 | /** | 132 | /** |
133 | * Method called whenever a peer connects to a port in MQ-based CADET. | 133 | * Method called whenever a peer connects to a port in MQ-based CADET. |
134 | * | 134 | * |
135 | * @param cls Closure from #GNUNET_CADET_open_porT. | 135 | * @param cls Closure from #GNUNET_CADET_open_port. |
136 | * @param channel New handle to the channel. | 136 | * @param channel New handle to the channel. |
137 | * @param source Peer that started this channel. | 137 | * @param source Peer that started this channel. |
138 | * @return Closure for the incoming @a channel. It's given to: | 138 | * @return Closure for the incoming @a channel. It's given to: |
139 | * - The #GNUNET_CADET_DisconnectEventHandler (given to | 139 | * - The #GNUNET_CADET_DisconnectEventHandler (given to |
140 | * #GNUNET_CADET_open_porT) when the channel dies. | 140 | * #GNUNET_CADET_open_port) when the channel dies. |
141 | * - Each the #GNUNET_MQ_MessageCallback handlers for each message | 141 | * - Each the #GNUNET_MQ_MessageCallback handlers for each message |
142 | * received on the @a channel. | 142 | * received on the @a channel. |
143 | */ | 143 | */ |
@@ -235,7 +235,7 @@ do_connect (void *cls) | |||
235 | GNUNET_TESTING_peer_get_identity (me, &id); | 235 | GNUNET_TESTING_peer_get_identity (me, &id); |
236 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 236 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
237 | "creating channel\n"); | 237 | "creating channel\n"); |
238 | ch = GNUNET_CADET_channel_creatE (cadet_peer_1, /* cadet handle */ | 238 | ch = GNUNET_CADET_channel_create (cadet_peer_1, /* cadet handle */ |
239 | NULL, /* channel cls */ | 239 | NULL, /* channel cls */ |
240 | &id, /* destination */ | 240 | &id, /* destination */ |
241 | GC_u2h (TEST_MESSAGE_TYPE), /* port */ | 241 | GC_u2h (TEST_MESSAGE_TYPE), /* port */ |
@@ -282,8 +282,8 @@ run (void *cls, | |||
282 | abort_task = GNUNET_SCHEDULER_add_delayed (delay, | 282 | abort_task = GNUNET_SCHEDULER_add_delayed (delay, |
283 | &do_abort, | 283 | &do_abort, |
284 | (void *) (long) __LINE__); | 284 | (void *) (long) __LINE__); |
285 | cadet_peer_1 = GNUNET_CADET_connecT (cfg); | 285 | cadet_peer_1 = GNUNET_CADET_connect (cfg); |
286 | cadet_peer_2 = GNUNET_CADET_connecT (cfg); | 286 | cadet_peer_2 = GNUNET_CADET_connect (cfg); |
287 | 287 | ||
288 | if ( (NULL == cadet_peer_1) || | 288 | if ( (NULL == cadet_peer_1) || |
289 | (NULL == cadet_peer_2) ) | 289 | (NULL == cadet_peer_2) ) |
@@ -297,7 +297,7 @@ run (void *cls, | |||
297 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "CADET 1: %p\n", cadet_peer_1); | 297 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "CADET 1: %p\n", cadet_peer_1); |
298 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "CADET 2: %p\n", cadet_peer_2); | 298 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "CADET 2: %p\n", cadet_peer_2); |
299 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "handlers 2: %p\n", handlers); | 299 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "handlers 2: %p\n", handlers); |
300 | GNUNET_CADET_open_porT (cadet_peer_2, /* cadet handle */ | 300 | GNUNET_CADET_open_port (cadet_peer_2, /* cadet handle */ |
301 | GC_u2h (TEST_PORT_ID), /* port id */ | 301 | GC_u2h (TEST_PORT_ID), /* port id */ |
302 | &connected, /* connect handler */ | 302 | &connected, /* connect handler */ |
303 | (void *) 2L, /* handle for #connected */ | 303 | (void *) 2L, /* handle for #connected */ |