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.c8
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,