diff options
Diffstat (limited to 'src/util/client.c')
-rw-r--r-- | src/util/client.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/util/client.c b/src/util/client.c index 487f3f8e8..7d380fa5c 100644 --- a/src/util/client.c +++ b/src/util/client.c | |||
@@ -230,7 +230,7 @@ receive_helper (void *cls, | |||
230 | struct GNUNET_TIME_Relative remaining; | 230 | struct GNUNET_TIME_Relative remaining; |
231 | 231 | ||
232 | GNUNET_assert (conn->msg_complete == GNUNET_NO); | 232 | GNUNET_assert (conn->msg_complete == GNUNET_NO); |
233 | conn->receiver_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 233 | conn->receiver_task = GNUNET_SCHEDULER_NO_TASK; |
234 | 234 | ||
235 | if ((available == 0) || (conn->sock == NULL) || (errCode != 0)) | 235 | if ((available == 0) || (conn->sock == NULL) || (errCode != 0)) |
236 | { | 236 | { |
@@ -284,7 +284,7 @@ receive_task (void *scls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
284 | struct GNUNET_MessageHeader *msg = (struct GNUNET_MessageHeader*) mbuf; | 284 | struct GNUNET_MessageHeader *msg = (struct GNUNET_MessageHeader*) mbuf; |
285 | 285 | ||
286 | GNUNET_assert (GNUNET_YES == sock->msg_complete); | 286 | GNUNET_assert (GNUNET_YES == sock->msg_complete); |
287 | sock->receiver_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 287 | sock->receiver_task = GNUNET_SCHEDULER_NO_TASK; |
288 | GNUNET_assert (sock->received_pos >= msize); | 288 | GNUNET_assert (sock->received_pos >= msize); |
289 | memcpy (msg, cmsg, msize); | 289 | memcpy (msg, cmsg, msize); |
290 | memmove (sock->received_buf, | 290 | memmove (sock->received_buf, |
@@ -320,7 +320,7 @@ GNUNET_CLIENT_receive (struct GNUNET_CLIENT_Connection *sock, | |||
320 | return; | 320 | return; |
321 | } | 321 | } |
322 | GNUNET_assert (sock->receiver_task == | 322 | GNUNET_assert (sock->receiver_task == |
323 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); | 323 | GNUNET_SCHEDULER_NO_TASK); |
324 | sock->receiver_handler = handler; | 324 | sock->receiver_handler = handler; |
325 | sock->receiver_handler_cls = cls; | 325 | sock->receiver_handler_cls = cls; |
326 | sock->receive_timeout = GNUNET_TIME_relative_to_absolute (timeout); | 326 | sock->receive_timeout = GNUNET_TIME_relative_to_absolute (timeout); |
@@ -328,7 +328,7 @@ GNUNET_CLIENT_receive (struct GNUNET_CLIENT_Connection *sock, | |||
328 | sock->receiver_task = GNUNET_SCHEDULER_add_after (sock->sched, | 328 | sock->receiver_task = GNUNET_SCHEDULER_add_after (sock->sched, |
329 | GNUNET_YES, | 329 | GNUNET_YES, |
330 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 330 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
331 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 331 | GNUNET_SCHEDULER_NO_TASK, |
332 | &receive_task, sock); | 332 | &receive_task, sock); |
333 | else | 333 | else |
334 | sock->receiver_task = GNUNET_NETWORK_receive (sock->sock, | 334 | sock->receiver_task = GNUNET_NETWORK_receive (sock->sock, |