aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport-testing2.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/transport-testing2.c')
-rw-r--r--src/transport/transport-testing2.c4
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;