* @param channel new handle to the channel
* @param initiator peer that started the channel
* @param port port number
+ * @param options channel options
* @return initial channel context for the channel
* (can be NULL -- that's not an error)
*/
static void *
inbound_channel (void *cls, struct GNUNET_MESH_Channel *channel,
const struct GNUNET_PeerIdentity *initiator,
- uint32_t port)
+ uint32_t port, enum GNUNET_MESH_ChannelOption options)
{
long id = (long) cls;
{
struct GNUNET_PeerIdentity id;
+ if (NULL != tc && 0 != (GNUNET_SCHEDULER_REASON_SHUTDOWN & tc->reason))
+ return;
+
GNUNET_TESTING_peer_get_identity (me, &id);
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "CONNECT BY PORT\n");
ch = GNUNET_MESH_channel_create (mesh_peer_1, NULL, &id, 1,
- GNUNET_YES, GNUNET_NO);
+ GNUNET_MESH_OPTION_DEFAULT);
mth = GNUNET_MESH_notify_transmit_ready (ch, GNUNET_NO,
GNUNET_TIME_UNIT_FOREVER_REL,
sizeof (struct GNUNET_MessageHeader),
(GNUNET_TIME_UNIT_SECONDS, 15), &do_abort,
NULL);
mesh_peer_1 = GNUNET_MESH_connect (cfg, /* configuration */
- (void *) 1L, /* cls */
- &inbound_channel, /* inbound new hndlr */
+ (void *) 1L, /* cls */
+ NULL, /* inbound new hndlr */
&channel_end, /* channel end hndlr */
handlers1, /* traffic handlers */
NULL); /* ports offered */