diff options
Diffstat (limited to 'src/stream/stream_api.c')
-rw-r--r-- | src/stream/stream_api.c | 9 |
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 | |||
431 | static unsigned int default_timeout = 10; | 431 | static 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 | */ |
2485 | void | 2486 | void |
2486 | GNUNET_STREAM_listen_close (struct GNUNET_STREAM_ListenSocket *socket) | 2487 | GNUNET_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); |