reset_cadet (struct CadetHandle *mh)
{
struct GNUNET_CADET_Channel *channel = mh->channel;
+ struct GNUNET_HashCode port;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Resetting cadet channel to %s\n",
GNUNET_CONTAINER_multihashmap_iterate (mh->waiting_map,
&move_to_pending,
mh);
+ GNUNET_CRYPTO_hash (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER,
+ strlen (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER),
+ &port);
mh->channel = GNUNET_CADET_channel_create (cadet_handle,
- mh,
- &mh->target,
- GC_u2h (GNUNET_APPLICATION_TYPE_FS_BLOCK_TRANSFER),
- GNUNET_CADET_OPTION_RELIABLE);
+ mh,
+ &mh->target,
+ &port,
+ GNUNET_CADET_OPTION_RELIABLE);
transmit_pending (mh);
}
get_cadet (const struct GNUNET_PeerIdentity *target)
{
struct CadetHandle *mh;
+ struct GNUNET_HashCode port;
mh = GNUNET_CONTAINER_multipeermap_get (cadet_map,
target);
&mh->target,
mh,
GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
+ GNUNET_CRYPTO_hash (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER,
+ strlen (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER),
+ &port);
mh->channel = GNUNET_CADET_channel_create (cadet_handle,
- mh,
- &mh->target,
- GC_u2h (GNUNET_APPLICATION_TYPE_FS_BLOCK_TRANSFER),
- GNUNET_CADET_OPTION_RELIABLE);
+ mh,
+ &mh->target,
+ &port,
+ GNUNET_CADET_OPTION_RELIABLE);
GNUNET_assert (mh ==
GNUNET_CONTAINER_multipeermap_get (cadet_map,
target));
{ &request_cb, GNUNET_MESSAGE_TYPE_FS_CADET_QUERY, sizeof (struct CadetQueryMessage)},
{ NULL, 0, 0 }
};
+ struct GNUNET_HashCode port;
+
if (GNUNET_YES !=
GNUNET_CONFIGURATION_get_value_number (GSF_cfg,
"fs",
&cleaner_cb,
handlers);
GNUNET_assert (NULL != listen_channel);
+ GNUNET_CRYPTO_hash (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER,
+ strlen (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER),
+ &port);
GNUNET_CADET_open_port (listen_channel,
- GC_u2h (GNUNET_APPLICATION_TYPE_FS_BLOCK_TRANSFER),
- &accept_cb, NULL);
+ &port,
+ &accept_cb,
+ NULL);
}