diff options
Diffstat (limited to 'src/transport/transport-testing2.c')
-rw-r--r-- | src/transport/transport-testing2.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/transport/transport-testing2.c b/src/transport/transport-testing2.c index 8250027f7..e85e46b11 100644 --- a/src/transport/transport-testing2.c +++ b/src/transport/transport-testing2.c | |||
@@ -525,6 +525,7 @@ handle_incoming_msg (void *cls, | |||
525 | struct GNUNET_TRANSPORT_IncomingMessageAck *ack; | 525 | struct GNUNET_TRANSPORT_IncomingMessageAck *ack; |
526 | 526 | ||
527 | env = GNUNET_MQ_msg (ack, GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK); | 527 | env = GNUNET_MQ_msg (ack, GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK); |
528 | GNUNET_assert (NULL != env); | ||
528 | ack->reserved = htonl (0); | 529 | ack->reserved = htonl (0); |
529 | ack->fc_id = inc_msg->fc_id; | 530 | ack->fc_id = inc_msg->fc_id; |
530 | ack->sender = inc_msg->sender; | 531 | ack->sender = inc_msg->sender; |
@@ -770,6 +771,8 @@ disconnect_cb (void *cls, | |||
770 | GNUNET_CONTAINER_DLL_remove (tc_h->client_head, | 771 | GNUNET_CONTAINER_DLL_remove (tc_h->client_head, |
771 | tc_h->client_tail, | 772 | tc_h->client_tail, |
772 | cl); | 773 | cl); |
774 | if (cl->c_mq == tc_h->c_mq) | ||
775 | tc_h->c_mq = NULL; | ||
773 | GNUNET_free (cl); | 776 | GNUNET_free (cl); |
774 | break; | 777 | break; |
775 | } | 778 | } |
@@ -1164,6 +1167,7 @@ GNUNET_TRANSPORT_TESTING_transport_communicator_send | |||
1164 | env = GNUNET_MQ_msg_extra (msg, | 1167 | env = GNUNET_MQ_msg_extra (msg, |
1165 | inbox_size, | 1168 | inbox_size, |
1166 | GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG); | 1169 | GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG); |
1170 | GNUNET_assert (NULL != env); | ||
1167 | msg->qid = htonl (tc_queue->qid); | 1171 | msg->qid = htonl (tc_queue->qid); |
1168 | msg->mid = tc_queue->mid++; | 1172 | msg->mid = tc_queue->mid++; |
1169 | msg->receiver = tc_queue->peer_id; | 1173 | msg->receiver = tc_queue->peer_id; |