diff options
| -rw-r--r-- | src/conversation/gnunet-service-conversation.c | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/conversation/gnunet-service-conversation.c b/src/conversation/gnunet-service-conversation.c index c50c688c21..58d1254ccc 100644 --- a/src/conversation/gnunet-service-conversation.c +++ b/src/conversation/gnunet-service-conversation.c @@ -922,6 +922,7 @@ handle_mesh_ring_message (void *cls, GNUNET_break_op (0); return GNUNET_SYSERR; } + GNUNET_MESH_receive_done (channel); /* needed? */ for (line = lines_head; NULL != line; line = line->next) if (line->local_line == ntohl (msg->remote_line)) break; @@ -938,7 +939,6 @@ handle_mesh_ring_message (void *cls, reliable_mq = GNUNET_MESH_mq_create (channel); GNUNET_MQ_send (reliable_mq, e); /* FIXME: do we need to clean up reliable_mq somehow/somewhere? */ - GNUNET_MESH_receive_done (channel); /* needed? */ return GNUNET_OK; } ch = GNUNET_new (struct Channel); @@ -964,7 +964,6 @@ handle_mesh_ring_message (void *cls, line->client, &cring.header, GNUNET_NO); - GNUNET_MESH_receive_done (channel); return GNUNET_OK; } @@ -1257,7 +1256,7 @@ handle_mesh_audio_message (void *cls, if (NULL == info) { GNUNET_break (0); - return GNUNET_OK; + return GNUNET_SYSERR; } sender = info->peer; for (line = lines_head; NULL != line; line = line->next) @@ -1294,12 +1293,13 @@ handle_mesh_audio_message (void *cls, GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received %u bytes of AUDIO data on suspended channel CID %u:(%u:%u); dropping\n", msize, ch->cid, ch->remote_line, line->local_line); + GNUNET_MESH_receive_done (channel); return GNUNET_OK; } ch->channel_unreliable = channel; *channel_ctx = ch; } - GNUNET_break (ch->line->local_line == ntohl (msg->remote_line)); + GNUNET_MESH_receive_done (channel); GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Forwarding %u bytes of AUDIO data to client CID %u:(%u:%u)\n", msize, ch->cid, ch->remote_line, ch->line->local_line); @@ -1312,7 +1312,6 @@ handle_mesh_audio_message (void *cls, ch->line->client, &cam->header, GNUNET_YES); - GNUNET_MESH_receive_done (channel); return GNUNET_OK; } |