aboutsummaryrefslogtreecommitdiff
path: root/src/stream/stream_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/stream/stream_api.c')
-rw-r--r--src/stream/stream_api.c9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/stream/stream_api.c b/src/stream/stream_api.c
index 56dbdc478..f9895ae77 100644
--- a/src/stream/stream_api.c
+++ b/src/stream/stream_api.c
@@ -431,7 +431,7 @@ struct GNUNET_STREAM_IOReadHandle
431static unsigned int default_timeout = 10; 431static unsigned int default_timeout = 10;
432 432
433/** 433/**
434 * Callback function for sending hello message 434 * Callback function for sending queued message
435 * 435 *
436 * @param cls closure the socket 436 * @param cls closure the socket
437 * @param size number of bytes available in buf 437 * @param size number of bytes available in buf
@@ -777,7 +777,8 @@ write_data (struct GNUNET_STREAM_Socket *socket)
777 packet = ack_packet + 1; 777 packet = ack_packet + 1;
778 /* Now send new packets if there is enough buffer space */ 778 /* Now send new packets if there is enough buffer space */
779 while ( (NULL != io_handle->messages[packet]) && 779 while ( (NULL != io_handle->messages[packet]) &&
780 (socket->receiver_window_available >= ntohs (io_handle->messages[packet]->header.header.size)) ) 780 (socket->receiver_window_available
781 >= ntohs (io_handle->messages[packet]->header.header.size)) )
781 { 782 {
782 socket->receiver_window_available -= 783 socket->receiver_window_available -=
783 ntohs (io_handle->messages[packet]->header.header.size); 784 ntohs (io_handle->messages[packet]->header.header.size);
@@ -2480,10 +2481,10 @@ GNUNET_STREAM_listen (const struct GNUNET_CONFIGURATION_Handle *cfg,
2480/** 2481/**
2481 * Closes the listen socket 2482 * Closes the listen socket
2482 * 2483 *
2483 * @param socket the listen socket 2484 * @param lsocket the listen socket
2484 */ 2485 */
2485void 2486void
2486GNUNET_STREAM_listen_close (struct GNUNET_STREAM_ListenSocket *socket) 2487GNUNET_STREAM_listen_close (struct GNUNET_STREAM_ListenSocket *lsocket)
2487{ 2488{
2488 /* Close MESH connection */ 2489 /* Close MESH connection */
2489 GNUNET_assert (NULL != lsocket->mesh); 2490 GNUNET_assert (NULL != lsocket->mesh);