diff options
-rw-r--r-- | src/include/gnunet_stream_lib.h | 10 | ||||
-rw-r--r-- | src/stream/stream_api.c | 9 |
2 files changed, 10 insertions, 9 deletions
diff --git a/src/include/gnunet_stream_lib.h b/src/include/gnunet_stream_lib.h index 930cc1d3d..78b11d1c5 100644 --- a/src/include/gnunet_stream_lib.h +++ b/src/include/gnunet_stream_lib.h | |||
@@ -185,10 +185,10 @@ GNUNET_STREAM_listen (const struct GNUNET_CONFIGURATION_Handle *cfg, | |||
185 | /** | 185 | /** |
186 | * Closes the listen socket | 186 | * Closes the listen socket |
187 | * | 187 | * |
188 | * @param socket the listen socket | 188 | * @param lsocket the listen socket |
189 | */ | 189 | */ |
190 | void | 190 | void |
191 | GNUNET_STREAM_listen_close (struct GNUNET_STREAM_ListenSocket *socket); | 191 | GNUNET_STREAM_listen_close (struct GNUNET_STREAM_ListenSocket *lsocket); |
192 | 192 | ||
193 | 193 | ||
194 | /** | 194 | /** |
@@ -243,7 +243,7 @@ GNUNET_STREAM_write (struct GNUNET_STREAM_Socket *socket, | |||
243 | * @param cls the closure from GNUNET_STREAM_read | 243 | * @param cls the closure from GNUNET_STREAM_read |
244 | * @param status the status of the stream at the time this function is called | 244 | * @param status the status of the stream at the time this function is called |
245 | * @param data traffic from the other side | 245 | * @param data traffic from the other side |
246 | * @param size the number of bytes available in data read | 246 | * @param size the number of bytes available in data read; will be 0 on timeout |
247 | * @return number of bytes of processed from 'data' (any data remaining should be | 247 | * @return number of bytes of processed from 'data' (any data remaining should be |
248 | * given to the next time the read processor is called). | 248 | * given to the next time the read processor is called). |
249 | */ | 249 | */ |
@@ -275,7 +275,7 @@ GNUNET_STREAM_read (struct GNUNET_STREAM_Socket *socket, | |||
275 | * @param ioh handle to operation to cancel | 275 | * @param ioh handle to operation to cancel |
276 | */ | 276 | */ |
277 | void | 277 | void |
278 | GNUNET_STREAM_io_write_cancel (struct GNUNET_STREAM_IOWriteHandle *ioh); | 278 | GNUNET_STREAM_io_write_cancel (struct GNUNET_STREAM_IOWriteHandle *iowh); |
279 | 279 | ||
280 | 280 | ||
281 | /** | 281 | /** |
@@ -284,7 +284,7 @@ GNUNET_STREAM_io_write_cancel (struct GNUNET_STREAM_IOWriteHandle *ioh); | |||
284 | * @param ioh handle to operation to cancel | 284 | * @param ioh handle to operation to cancel |
285 | */ | 285 | */ |
286 | void | 286 | void |
287 | GNUNET_STREAM_io_read_cancel (struct GNUNET_STREAM_IOReadHandle *ioh); | 287 | GNUNET_STREAM_io_read_cancel (struct GNUNET_STREAM_IOReadHandle *iorh); |
288 | 288 | ||
289 | 289 | ||
290 | #if 0 | 290 | #if 0 |
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); |