diff options
Diffstat (limited to 'src/util/client.c')
-rw-r--r-- | src/util/client.c | 14 |
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 | */ |
309 | void | 309 | void |
310 | GNUNET_CLIENT_receive (struct GNUNET_CLIENT_Connection *sock, | 310 | GNUNET_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 | ||