aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/include/gnunet_stream_lib.h10
-rw-r--r--src/stream/stream_api.c9
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 */
190void 190void
191GNUNET_STREAM_listen_close (struct GNUNET_STREAM_ListenSocket *socket); 191GNUNET_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 */
277void 277void
278GNUNET_STREAM_io_write_cancel (struct GNUNET_STREAM_IOWriteHandle *ioh); 278GNUNET_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 */
286void 286void
287GNUNET_STREAM_io_read_cancel (struct GNUNET_STREAM_IOReadHandle *ioh); 287GNUNET_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
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);