add_to_queue (struct GNUNET_CADET_Handle *h,
struct GNUNET_CADET_TransmitHandle *th)
{
- GNUNET_CONTAINER_DLL_insert_tail (h->th_head, h->th_tail, th);
+ GNUNET_CONTAINER_DLL_insert_tail (h->th_head,
+ h->th_tail,
+ th);
}
th->size,
&msg[1]);
GNUNET_assert (osize == th->size);
+
GNUNET_MQ_send (th->channel->cadet->mq,
env);
GNUNET_free (th);
const struct GNUNET_MessageHeader *payload;
const struct GNUNET_CADET_MessageHandler *handler;
struct GNUNET_CADET_Channel *ch;
- unsigned int i;
uint16_t type;
ch = retrieve_channel (h,
ntohl (message->ccn.channel_of_client),
GC_m2s (type),
type);
-
- for (i = 0; i < h->n_handlers; i++)
+ for (unsigned i=0;i<h->n_handlers;i++)
{
handler = &h->message_handlers[i];
if (handler->type == type)
LOG (GNUNET_ERROR_TYPE_DEBUG,
"callback caused disconnection\n");
GNUNET_CADET_channel_destroy (ch);
- break;
+ return;
}
- break;
+ return;
}
}
+ /* Other peer sent message we do not comprehend. */
+ GNUNET_break_op (0);
+ GNUNET_CADET_receive_done (ch);
}
GNUNET_assert (GNUNET_CONSTANTS_MAX_CADET_MESSAGE_SIZE >= notify_size);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"CADET NOTIFY TRANSMIT READY on channel %X allow_send is %u to %s with %u bytes\n",
- channel->ccn,
+ ntohl (channel->ccn.channel_of_client),
channel->allow_send,
(ntohl (channel->ccn.channel_of_client) >=
GNUNET_CADET_LOCAL_CHANNEL_ID_CLI)
GNUNET_MESSAGE_TYPE_CADET_LOCAL_ACK);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Sending ACK on channel %X\n",
- channel->ccn.channel_of_client);
+ ntohl (channel->ccn.channel_of_client));
msg->ccn = channel->ccn;
GNUNET_MQ_send (channel->cadet->mq,
env);