aboutsummaryrefslogtreecommitdiff
path: root/src/util/client.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/client.c')
-rw-r--r--src/util/client.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/util/client.c b/src/util/client.c
index 82ab35d21..9a2f47678 100644
--- a/src/util/client.c
+++ b/src/util/client.c
@@ -303,25 +303,25 @@ receive_task (void *scls, const struct GNUNET_SCHEDULER_TaskContext *tc)
303 * 303 *
304 * @param sock the service 304 * @param sock the service
305 * @param handler function to call with the message 305 * @param handler function to call with the message
306 * @param cls closure for handler 306 * @param handler_cls closure for handler
307 * @param timeout how long to wait until timing out 307 * @param timeout how long to wait until timing out
308 */ 308 */
309void 309void
310GNUNET_CLIENT_receive (struct GNUNET_CLIENT_Connection *sock, 310GNUNET_CLIENT_receive (struct GNUNET_CLIENT_Connection *sock,
311 GNUNET_CLIENT_MessageHandler handler, 311 GNUNET_CLIENT_MessageHandler handler,
312 void *cls, struct GNUNET_TIME_Relative timeout) 312 void *handler_cls, struct GNUNET_TIME_Relative timeout)
313{ 313{
314 if (sock->sock == NULL) 314 if (sock->sock == NULL)
315 { 315 {
316 /* already disconnected, fail instantly! */ 316 /* already disconnected, fail instantly! */
317 GNUNET_break (0); /* this should not happen in well-written code! */ 317 GNUNET_break (0); /* this should not happen in well-written code! */
318 handler (cls, NULL); 318 handler (handler_cls, NULL);
319 return; 319 return;
320 } 320 }
321 GNUNET_assert (sock->receiver_task == 321 GNUNET_assert (sock->receiver_task ==
322 GNUNET_SCHEDULER_NO_TASK); 322 GNUNET_SCHEDULER_NO_TASK);
323 sock->receiver_handler = handler; 323 sock->receiver_handler = handler;
324 sock->receiver_handler_cls = cls; 324 sock->receiver_handler_cls = handler_cls;
325 sock->receive_timeout = GNUNET_TIME_relative_to_absolute (timeout); 325 sock->receive_timeout = GNUNET_TIME_relative_to_absolute (timeout);
326 if (GNUNET_YES == sock->msg_complete) 326 if (GNUNET_YES == sock->msg_complete)
327 sock->receiver_task = GNUNET_SCHEDULER_add_after (sock->sched, 327 sock->receiver_task = GNUNET_SCHEDULER_add_after (sock->sched,
@@ -331,9 +331,9 @@ GNUNET_CLIENT_receive (struct GNUNET_CLIENT_Connection *sock,
331 &receive_task, sock); 331 &receive_task, sock);
332 else 332 else
333 sock->receiver_task = GNUNET_CONNECTION_receive (sock->sock, 333 sock->receiver_task = GNUNET_CONNECTION_receive (sock->sock,
334 GNUNET_SERVER_MAX_MESSAGE_SIZE, 334 GNUNET_SERVER_MAX_MESSAGE_SIZE,
335 timeout, 335 timeout,
336 &receive_helper, sock); 336 &receive_helper, sock);
337} 337}
338 338
339 339