aboutsummaryrefslogtreecommitdiff
path: root/src/util
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2009-07-24 22:04:41 +0000
committerChristian Grothoff <christian@grothoff.org>2009-07-24 22:04:41 +0000
commit70e6847205a9f9b9b660be2a173d5bc309eaa58d (patch)
treee2649865fbff3e7cbb2e85e381a6268b9aa01e0d /src/util
parent0722614037876469e205546db5ab5fc892b5cf8c (diff)
downloadgnunet-70e6847205a9f9b9b660be2a173d5bc309eaa58d.tar.gz
gnunet-70e6847205a9f9b9b660be2a173d5bc309eaa58d.zip
quota management and better name for NO_TASK'
'
Diffstat (limited to 'src/util')
-rw-r--r--src/util/client.c8
-rw-r--r--src/util/crypto_hash.c4
-rw-r--r--src/util/disk.c2
-rw-r--r--src/util/network.c62
-rw-r--r--src/util/scheduler.c14
-rw-r--r--src/util/server.c14
-rw-r--r--src/util/test_network.c2
-rw-r--r--src/util/test_network_addressing.c2
-rw-r--r--src/util/test_network_receive_cancel.c4
-rw-r--r--src/util/test_scheduler.c6
-rw-r--r--src/util/test_scheduler_delay.c2
-rw-r--r--src/util/test_server.c4
-rw-r--r--src/util/test_server_disconnect.c4
-rw-r--r--src/util/test_server_with_client.c2
14 files changed, 65 insertions, 65 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,
diff --git a/src/util/crypto_hash.c b/src/util/crypto_hash.c
index 8df4cc8f4..fc4d24320 100644
--- a/src/util/crypto_hash.c
+++ b/src/util/crypto_hash.c
@@ -484,7 +484,7 @@ file_hash_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
484 GNUNET_SCHEDULER_add_after (tc->sched, 484 GNUNET_SCHEDULER_add_after (tc->sched,
485 fhc->run_on_shutdown, 485 fhc->run_on_shutdown,
486 GNUNET_SCHEDULER_PRIORITY_KEEP, 486 GNUNET_SCHEDULER_PRIORITY_KEEP,
487 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 487 GNUNET_SCHEDULER_NO_TASK,
488 &file_hash_task, fhc); 488 &file_hash_task, fhc);
489} 489}
490 490
@@ -536,7 +536,7 @@ GNUNET_CRYPTO_hash_file (struct GNUNET_SCHEDULER_Handle *sched,
536 GNUNET_SCHEDULER_add_after (sched, 536 GNUNET_SCHEDULER_add_after (sched,
537 run_on_shutdown, 537 run_on_shutdown,
538 priority, 538 priority,
539 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 539 GNUNET_SCHEDULER_NO_TASK,
540 &file_hash_task, fhc); 540 &file_hash_task, fhc);
541} 541}
542 542
diff --git a/src/util/disk.c b/src/util/disk.c
index c70f2cc2b..b0f92c7f2 100644
--- a/src/util/disk.c
+++ b/src/util/disk.c
@@ -735,7 +735,7 @@ GNUNET_DISK_directory_iterator_next (struct GNUNET_DISK_DirectoryIterator
735 GNUNET_SCHEDULER_add_after (iter->sched, 735 GNUNET_SCHEDULER_add_after (iter->sched,
736 GNUNET_YES, 736 GNUNET_YES,
737 iter->priority, 737 iter->priority,
738 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 738 GNUNET_SCHEDULER_NO_TASK,
739 &directory_iterator_task, iter); 739 &directory_iterator_task, iter);
740 return GNUNET_YES; 740 return GNUNET_YES;
741} 741}
diff --git a/src/util/network.c b/src/util/network.c
index cb8542329..9b61bd8c2 100644
--- a/src/util/network.c
+++ b/src/util/network.c
@@ -541,7 +541,7 @@ connect_continuation (void *cls,
541 int error; 541 int error;
542 542
543 /* nobody needs to wait for us anymore... */ 543 /* nobody needs to wait for us anymore... */
544 sock->connect_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 544 sock->connect_task = GNUNET_SCHEDULER_NO_TASK;
545 /* Note: write-ready does NOT mean connect succeeded, 545 /* Note: write-ready does NOT mean connect succeeded,
546 we need to use getsockopt to be sure */ 546 we need to use getsockopt to be sure */
547 len = sizeof (error); 547 len = sizeof (error);
@@ -574,7 +574,7 @@ connect_continuation (void *cls,
574 } 574 }
575 sock->connect_task = GNUNET_SCHEDULER_add_write (tc->sched, GNUNET_NO, /* abort on shutdown */ 575 sock->connect_task = GNUNET_SCHEDULER_add_write (tc->sched, GNUNET_NO, /* abort on shutdown */
576 GNUNET_SCHEDULER_PRIORITY_KEEP, 576 GNUNET_SCHEDULER_PRIORITY_KEEP,
577 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 577 GNUNET_SCHEDULER_NO_TASK,
578 GNUNET_NETWORK_CONNECT_RETRY_TIMEOUT, 578 GNUNET_NETWORK_CONNECT_RETRY_TIMEOUT,
579 sock->sock, 579 sock->sock,
580 &connect_continuation, 580 &connect_continuation,
@@ -630,7 +630,7 @@ GNUNET_NETWORK_socket_create_from_connect (struct GNUNET_SCHEDULER_Handle
630 } 630 }
631 ret->connect_task = GNUNET_SCHEDULER_add_write (sched, GNUNET_NO, /* abort on shutdown */ 631 ret->connect_task = GNUNET_SCHEDULER_add_write (sched, GNUNET_NO, /* abort on shutdown */
632 GNUNET_SCHEDULER_PRIORITY_KEEP, 632 GNUNET_SCHEDULER_PRIORITY_KEEP,
633 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 633 GNUNET_SCHEDULER_NO_TASK,
634 GNUNET_NETWORK_CONNECT_RETRY_TIMEOUT, 634 GNUNET_NETWORK_CONNECT_RETRY_TIMEOUT,
635 ret->sock, 635 ret->sock,
636 &connect_continuation, ret); 636 &connect_continuation, ret);
@@ -727,7 +727,7 @@ destroy_continuation (void *cls,
727 struct GNUNET_NETWORK_SocketHandle *sock = cls; 727 struct GNUNET_NETWORK_SocketHandle *sock = cls;
728 GNUNET_NETWORK_TransmitReadyNotify notify; 728 GNUNET_NETWORK_TransmitReadyNotify notify;
729 729
730 if (sock->write_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 730 if (sock->write_task != GNUNET_SCHEDULER_NO_TASK)
731 { 731 {
732 GNUNET_SCHEDULER_add_after (sock->sched, 732 GNUNET_SCHEDULER_add_after (sock->sched,
733 GNUNET_YES, 733 GNUNET_YES,
@@ -743,7 +743,7 @@ destroy_continuation (void *cls,
743#endif 743#endif
744 SHUTDOWN (sock->sock, SHUT_RDWR); 744 SHUTDOWN (sock->sock, SHUT_RDWR);
745 } 745 }
746 if (sock->read_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 746 if (sock->read_task != GNUNET_SCHEDULER_NO_TASK)
747 { 747 {
748 GNUNET_SCHEDULER_add_after (sock->sched, 748 GNUNET_SCHEDULER_add_after (sock->sched,
749 GNUNET_YES, 749 GNUNET_YES,
@@ -756,10 +756,10 @@ destroy_continuation (void *cls,
756 { 756 {
757 sock->nth.notify_ready = NULL; 757 sock->nth.notify_ready = NULL;
758 notify (sock->nth.notify_ready_cls, 0, NULL); 758 notify (sock->nth.notify_ready_cls, 0, NULL);
759 if (sock->nth.timeout_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 759 if (sock->nth.timeout_task != GNUNET_SCHEDULER_NO_TASK)
760 { 760 {
761 GNUNET_SCHEDULER_cancel (sock->sched, sock->nth.timeout_task); 761 GNUNET_SCHEDULER_cancel (sock->sched, sock->nth.timeout_task);
762 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 762 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_TASK;
763 } 763 }
764 } 764 }
765 if (sock->sock != -1) 765 if (sock->sock != -1)
@@ -837,7 +837,7 @@ receive_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
837 ssize_t ret; 837 ssize_t ret;
838 GNUNET_NETWORK_Receiver receiver; 838 GNUNET_NETWORK_Receiver receiver;
839 839
840 sh->read_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 840 sh->read_task = GNUNET_SCHEDULER_NO_TASK;
841 now = GNUNET_TIME_absolute_get (); 841 now = GNUNET_TIME_absolute_get ();
842 if ((now.value > sh->receive_timeout.value) || 842 if ((now.value > sh->receive_timeout.value) ||
843 (0 != (tc->reason & GNUNET_SCHEDULER_REASON_TIMEOUT)) || 843 (0 != (tc->reason & GNUNET_SCHEDULER_REASON_TIMEOUT)) ||
@@ -907,9 +907,9 @@ receive_again (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
907 struct GNUNET_NETWORK_SocketHandle *sh = cls; 907 struct GNUNET_NETWORK_SocketHandle *sh = cls;
908 struct GNUNET_TIME_Absolute now; 908 struct GNUNET_TIME_Absolute now;
909 909
910 sh->read_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 910 sh->read_task = GNUNET_SCHEDULER_NO_TASK;
911 if ((sh->sock == -1) && 911 if ((sh->sock == -1) &&
912 (sh->connect_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK)) 912 (sh->connect_task == GNUNET_SCHEDULER_NO_TASK))
913 { 913 {
914 /* not connected and no longer trying */ 914 /* not connected and no longer trying */
915#if DEBUG_NETWORK 915#if DEBUG_NETWORK
@@ -930,7 +930,7 @@ receive_again (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
930 signal_timeout (sh); 930 signal_timeout (sh);
931 return; 931 return;
932 } 932 }
933 if (sh->connect_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 933 if (sh->connect_task != GNUNET_SCHEDULER_NO_TASK)
934 { 934 {
935 /* connect was retried */ 935 /* connect was retried */
936 sh->read_task = GNUNET_SCHEDULER_add_after (tc->sched, 936 sh->read_task = GNUNET_SCHEDULER_add_after (tc->sched,
@@ -965,7 +965,7 @@ receive_again (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
965 * @param timeout maximum amount of time to wait (use -1 for "forever") 965 * @param timeout maximum amount of time to wait (use -1 for "forever")
966 * @param receiver function to call with received data 966 * @param receiver function to call with received data
967 * @param receiver_cls closure for receiver 967 * @param receiver_cls closure for receiver
968 * @return scheduler task ID used for receiving, GNUNET_SCHEDULER_NO_PREREQUISITE_TASK on error 968 * @return scheduler task ID used for receiving, GNUNET_SCHEDULER_NO_TASK on error
969 */ 969 */
970GNUNET_SCHEDULER_TaskIdentifier 970GNUNET_SCHEDULER_TaskIdentifier
971GNUNET_NETWORK_receive (struct GNUNET_NETWORK_SocketHandle *sock, 971GNUNET_NETWORK_receive (struct GNUNET_NETWORK_SocketHandle *sock,
@@ -975,7 +975,7 @@ GNUNET_NETWORK_receive (struct GNUNET_NETWORK_SocketHandle *sock,
975{ 975{
976 struct GNUNET_SCHEDULER_TaskContext tc; 976 struct GNUNET_SCHEDULER_TaskContext tc;
977 977
978 GNUNET_assert ((sock->read_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) && 978 GNUNET_assert ((sock->read_task == GNUNET_SCHEDULER_NO_TASK) &&
979 (sock->receiver == NULL)); 979 (sock->receiver == NULL));
980 sock->receiver = receiver; 980 sock->receiver = receiver;
981 sock->receiver_cls = receiver_cls; 981 sock->receiver_cls = receiver_cls;
@@ -1004,7 +1004,7 @@ GNUNET_NETWORK_receive_cancel (struct GNUNET_NETWORK_SocketHandle *sock,
1004{ 1004{
1005 GNUNET_assert (sock->read_task == task); 1005 GNUNET_assert (sock->read_task == task);
1006 GNUNET_assert (sock == GNUNET_SCHEDULER_cancel (sock->sched, task)); 1006 GNUNET_assert (sock == GNUNET_SCHEDULER_cancel (sock->sched, task));
1007 sock->read_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 1007 sock->read_task = GNUNET_SCHEDULER_NO_TASK;
1008 sock->receiver = NULL; 1008 sock->receiver = NULL;
1009 return sock->receiver_cls; 1009 return sock->receiver_cls;
1010} 1010}
@@ -1025,7 +1025,7 @@ process_notify (struct GNUNET_NETWORK_SocketHandle *sock)
1025 size_t size; 1025 size_t size;
1026 GNUNET_NETWORK_TransmitReadyNotify notify; 1026 GNUNET_NETWORK_TransmitReadyNotify notify;
1027 1027
1028 GNUNET_assert (sock->write_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); 1028 GNUNET_assert (sock->write_task == GNUNET_SCHEDULER_NO_TASK);
1029 if (NULL == (notify = sock->nth.notify_ready)) 1029 if (NULL == (notify = sock->nth.notify_ready))
1030 return GNUNET_NO; 1030 return GNUNET_NO;
1031 used = sock->write_buffer_off - sock->write_buffer_pos; 1031 used = sock->write_buffer_off - sock->write_buffer_pos;
@@ -1034,10 +1034,10 @@ process_notify (struct GNUNET_NETWORK_SocketHandle *sock)
1034 if (sock->nth.notify_size > avail) 1034 if (sock->nth.notify_size > avail)
1035 return GNUNET_NO; 1035 return GNUNET_NO;
1036 sock->nth.notify_ready = NULL; 1036 sock->nth.notify_ready = NULL;
1037 if (sock->nth.timeout_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 1037 if (sock->nth.timeout_task != GNUNET_SCHEDULER_NO_TASK)
1038 { 1038 {
1039 GNUNET_SCHEDULER_cancel (sock->sched, sock->nth.timeout_task); 1039 GNUNET_SCHEDULER_cancel (sock->sched, sock->nth.timeout_task);
1040 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 1040 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_TASK;
1041 } 1041 }
1042 if (sock->write_buffer_size - sock->write_buffer_off < size) 1042 if (sock->write_buffer_size - sock->write_buffer_off < size)
1043 { 1043 {
@@ -1084,10 +1084,10 @@ transmit_error (struct GNUNET_NETWORK_SocketHandle *sock)
1084{ 1084{
1085 if (sock->nth.notify_ready == NULL) 1085 if (sock->nth.notify_ready == NULL)
1086 return; /* nobody to tell about it */ 1086 return; /* nobody to tell about it */
1087 if (sock->nth.timeout_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 1087 if (sock->nth.timeout_task != GNUNET_SCHEDULER_NO_TASK)
1088 { 1088 {
1089 GNUNET_SCHEDULER_cancel (sock->sched, sock->nth.timeout_task); 1089 GNUNET_SCHEDULER_cancel (sock->sched, sock->nth.timeout_task);
1090 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 1090 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_TASK;
1091 } 1091 }
1092 transmit_timeout (sock, NULL); 1092 transmit_timeout (sock, NULL);
1093} 1093}
@@ -1105,13 +1105,13 @@ transmit_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
1105 ssize_t ret; 1105 ssize_t ret;
1106 size_t have; 1106 size_t have;
1107 1107
1108 GNUNET_assert (sock->write_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); 1108 GNUNET_assert (sock->write_task != GNUNET_SCHEDULER_NO_TASK);
1109 sock->write_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 1109 sock->write_task = GNUNET_SCHEDULER_NO_TASK;
1110 if (sock->connect_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 1110 if (sock->connect_task != GNUNET_SCHEDULER_NO_TASK)
1111 { 1111 {
1112 /* still waiting for connect */ 1112 /* still waiting for connect */
1113 GNUNET_assert (sock->write_task == 1113 GNUNET_assert (sock->write_task ==
1114 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); 1114 GNUNET_SCHEDULER_NO_TASK);
1115 sock->write_task = 1115 sock->write_task =
1116 GNUNET_SCHEDULER_add_delayed (tc->sched, GNUNET_NO, 1116 GNUNET_SCHEDULER_add_delayed (tc->sched, GNUNET_NO,
1117 GNUNET_SCHEDULER_PRIORITY_KEEP, 1117 GNUNET_SCHEDULER_PRIORITY_KEEP,
@@ -1195,12 +1195,12 @@ RETRY:
1195 return; /* all data sent! */ 1195 return; /* all data sent! */
1196 /* not done writing, schedule more */ 1196 /* not done writing, schedule more */
1197SCHEDULE_WRITE: 1197SCHEDULE_WRITE:
1198 if (sock->write_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 1198 if (sock->write_task == GNUNET_SCHEDULER_NO_TASK)
1199 sock->write_task = 1199 sock->write_task =
1200 GNUNET_SCHEDULER_add_write (tc->sched, 1200 GNUNET_SCHEDULER_add_write (tc->sched,
1201 GNUNET_NO, 1201 GNUNET_NO,
1202 GNUNET_SCHEDULER_PRIORITY_KEEP, 1202 GNUNET_SCHEDULER_PRIORITY_KEEP,
1203 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 1203 GNUNET_SCHEDULER_NO_TASK,
1204 GNUNET_TIME_absolute_get_remaining (sock->nth.transmit_timeout), 1204 GNUNET_TIME_absolute_get_remaining (sock->nth.transmit_timeout),
1205 sock->sock, &transmit_ready, sock); 1205 sock->sock, &transmit_ready, sock);
1206} 1206}
@@ -1233,7 +1233,7 @@ GNUNET_NETWORK_notify_transmit_ready (struct GNUNET_NETWORK_SocketHandle
1233 GNUNET_assert (sock->write_buffer_size >= size); 1233 GNUNET_assert (sock->write_buffer_size >= size);
1234 1234
1235 if ((sock->sock == -1) && 1235 if ((sock->sock == -1) &&
1236 (sock->connect_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK)) 1236 (sock->connect_task == GNUNET_SCHEDULER_NO_TASK))
1237 { 1237 {
1238#if DEBUG_NETWORK 1238#if DEBUG_NETWORK
1239 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 1239 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -1254,17 +1254,17 @@ GNUNET_NETWORK_notify_transmit_ready (struct GNUNET_NETWORK_SocketHandle
1254 sock->nth.timeout_task = GNUNET_SCHEDULER_add_delayed (sock->sched, 1254 sock->nth.timeout_task = GNUNET_SCHEDULER_add_delayed (sock->sched,
1255 GNUNET_NO, 1255 GNUNET_NO,
1256 GNUNET_SCHEDULER_PRIORITY_KEEP, 1256 GNUNET_SCHEDULER_PRIORITY_KEEP,
1257 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 1257 GNUNET_SCHEDULER_NO_TASK,
1258 timeout, 1258 timeout,
1259 &transmit_timeout, 1259 &transmit_timeout,
1260 sock); 1260 sock);
1261 if (sock->write_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 1261 if (sock->write_task == GNUNET_SCHEDULER_NO_TASK)
1262 { 1262 {
1263 if (sock->connect_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 1263 if (sock->connect_task == GNUNET_SCHEDULER_NO_TASK)
1264 sock->write_task = GNUNET_SCHEDULER_add_write (sock->sched, 1264 sock->write_task = GNUNET_SCHEDULER_add_write (sock->sched,
1265 GNUNET_NO, 1265 GNUNET_NO,
1266 GNUNET_SCHEDULER_PRIORITY_KEEP, 1266 GNUNET_SCHEDULER_PRIORITY_KEEP,
1267 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 1267 GNUNET_SCHEDULER_NO_TASK,
1268 GNUNET_TIME_absolute_get_remaining (sock->nth.transmit_timeout), 1268 GNUNET_TIME_absolute_get_remaining (sock->nth.transmit_timeout),
1269 sock->sock, 1269 sock->sock,
1270 &transmit_ready, sock); 1270 &transmit_ready, sock);
@@ -1290,7 +1290,7 @@ GNUNET_NETWORK_notify_transmit_ready_cancel (struct
1290{ 1290{
1291 GNUNET_assert (h->notify_ready != NULL); 1291 GNUNET_assert (h->notify_ready != NULL);
1292 GNUNET_SCHEDULER_cancel (h->sh->sched, h->timeout_task); 1292 GNUNET_SCHEDULER_cancel (h->sh->sched, h->timeout_task);
1293 h->timeout_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 1293 h->timeout_task = GNUNET_SCHEDULER_NO_TASK;
1294 h->notify_ready = NULL; 1294 h->notify_ready = NULL;
1295} 1295}
1296 1296
diff --git a/src/util/scheduler.c b/src/util/scheduler.c
index 4872eee41..0b5307290 100644
--- a/src/util/scheduler.c
+++ b/src/util/scheduler.c
@@ -255,7 +255,7 @@ update_sets (struct GNUNET_SCHEDULER_Handle *sched,
255 pos = sched->pending; 255 pos = sched->pending;
256 while (pos != NULL) 256 while (pos != NULL)
257 { 257 {
258 if ((pos->prereq_id != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) && 258 if ((pos->prereq_id != GNUNET_SCHEDULER_NO_TASK) &&
259 (GNUNET_YES == is_pending (sched, pos->prereq_id))) 259 (GNUNET_YES == is_pending (sched, pos->prereq_id)))
260 { 260 {
261 pos = pos->next; 261 pos = pos->next;
@@ -329,7 +329,7 @@ is_ready (struct GNUNET_SCHEDULER_Handle *sched,
329 task->reason |= GNUNET_SCHEDULER_REASON_WRITE_READY; 329 task->reason |= GNUNET_SCHEDULER_REASON_WRITE_READY;
330 if (task->reason == 0) 330 if (task->reason == 0)
331 return GNUNET_NO; /* not ready */ 331 return GNUNET_NO; /* not ready */
332 if (task->prereq_id != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) 332 if (task->prereq_id != GNUNET_SCHEDULER_NO_TASK)
333 { 333 {
334 if (GNUNET_YES == is_pending (sched, task->prereq_id)) 334 if (GNUNET_YES == is_pending (sched, task->prereq_id))
335 return GNUNET_NO; /* prereq waiting */ 335 return GNUNET_NO; /* prereq waiting */
@@ -671,7 +671,7 @@ GNUNET_SCHEDULER_add_continuation (struct GNUNET_SCHEDULER_Handle *sched,
671 * @param prerequisite_task run this task after the task with the given 671 * @param prerequisite_task run this task after the task with the given
672 * task identifier completes (and any of our other 672 * task identifier completes (and any of our other
673 * conditions, such as delay, read or write-readyness 673 * conditions, such as delay, read or write-readyness
674 * are satisfied). Use GNUNET_SCHEDULER_NO_PREREQUISITE_TASK to not have any dependency 674 * are satisfied). Use GNUNET_SCHEDULER_NO_TASK to not have any dependency
675 * on completion of other tasks. 675 * on completion of other tasks.
676 * @param main main function of the task 676 * @param main main function of the task
677 * @param cls closure of task 677 * @param cls closure of task
@@ -707,7 +707,7 @@ GNUNET_SCHEDULER_add_after (struct GNUNET_SCHEDULER_Handle *sched,
707 * @param prerequisite_task run this task after the task with the given 707 * @param prerequisite_task run this task after the task with the given
708 * task identifier completes (and any of our other 708 * task identifier completes (and any of our other
709 * conditions, such as delay, read or write-readyness 709 * conditions, such as delay, read or write-readyness
710 * are satisfied). Use GNUNET_SCHEDULER_NO_PREREQUISITE_TASK to not have any dependency 710 * are satisfied). Use GNUNET_SCHEDULER_NO_TASK to not have any dependency
711 * on completion of other tasks. 711 * on completion of other tasks.
712 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever" 712 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever"
713 * @param main main function of the task 713 * @param main main function of the task
@@ -745,7 +745,7 @@ GNUNET_SCHEDULER_add_delayed (struct GNUNET_SCHEDULER_Handle * sched,
745 * @param prerequisite_task run this task after the task with the given 745 * @param prerequisite_task run this task after the task with the given
746 * task identifier completes (and any of our other 746 * task identifier completes (and any of our other
747 * conditions, such as delay, read or write-readyness 747 * conditions, such as delay, read or write-readyness
748 * are satisfied). Use GNUNET_SCHEDULER_NO_PREREQUISITE_TASK to not have any dependency 748 * are satisfied). Use GNUNET_SCHEDULER_NO_TASK to not have any dependency
749 * on completion of other tasks. 749 * on completion of other tasks.
750 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever" 750 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever"
751 * @param rfd read file-descriptor 751 * @param rfd read file-descriptor
@@ -788,7 +788,7 @@ GNUNET_SCHEDULER_add_read (struct GNUNET_SCHEDULER_Handle * sched,
788 * @param prerequisite_task run this task after the task with the given 788 * @param prerequisite_task run this task after the task with the given
789 * task identifier completes (and any of our other 789 * task identifier completes (and any of our other
790 * conditions, such as delay, read or write-readyness 790 * conditions, such as delay, read or write-readyness
791 * are satisfied). Use GNUNET_SCHEDULER_NO_PREREQUISITE_TASK to not have any dependency 791 * are satisfied). Use GNUNET_SCHEDULER_NO_TASK to not have any dependency
792 * on completion of other tasks. 792 * on completion of other tasks.
793 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever" 793 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever"
794 * @param wfd write file-descriptor 794 * @param wfd write file-descriptor
@@ -841,7 +841,7 @@ GNUNET_SCHEDULER_add_write (struct GNUNET_SCHEDULER_Handle * sched,
841 * @param prerequisite_task run this task after the task with the given 841 * @param prerequisite_task run this task after the task with the given
842 * task identifier completes (and any of our other 842 * task identifier completes (and any of our other
843 * conditions, such as delay, read or write-readyness 843 * conditions, such as delay, read or write-readyness
844 * are satisfied). Use GNUNET_SCHEDULER_NO_PREREQUISITE_TASK to not have any dependency 844 * are satisfied). Use GNUNET_SCHEDULER_NO_TASK to not have any dependency
845 * on completion of other tasks. 845 * on completion of other tasks.
846 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever" 846 * @param delay how long should we wait? Use GNUNET_TIME_UNIT_FOREVER_REL for "forever"
847 * @param nfds highest-numbered file descriptor in any of the two sets plus one 847 * @param nfds highest-numbered file descriptor in any of the two sets plus one
diff --git a/src/util/server.c b/src/util/server.c
index f604fbc50..8ffc9c027 100644
--- a/src/util/server.c
+++ b/src/util/server.c
@@ -223,7 +223,7 @@ struct GNUNET_SERVER_Client
223 223
224 /** 224 /**
225 * Current task identifier for the receive call 225 * Current task identifier for the receive call
226 * (or GNUNET_SCHEDULER_NO_PREREQUISITE_TASK for none). 226 * (or GNUNET_SCHEDULER_NO_TASK for none).
227 */ 227 */
228 GNUNET_SCHEDULER_TaskIdentifier my_receive; 228 GNUNET_SCHEDULER_TaskIdentifier my_receive;
229 229
@@ -351,7 +351,7 @@ process_listen_socket (void *cls,
351 GNUNET_SCHEDULER_add_select (server->sched, 351 GNUNET_SCHEDULER_add_select (server->sched,
352 GNUNET_YES, 352 GNUNET_YES,
353 GNUNET_SCHEDULER_PRIORITY_HIGH, 353 GNUNET_SCHEDULER_PRIORITY_HIGH,
354 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 354 GNUNET_SCHEDULER_NO_TASK,
355 GNUNET_TIME_UNIT_FOREVER_REL, 355 GNUNET_TIME_UNIT_FOREVER_REL,
356 GNUNET_MAX (server->listen_socket, 356 GNUNET_MAX (server->listen_socket,
357 server->shutpipe[0]) + 1, &r, NULL, 357 server->shutpipe[0]) + 1, &r, NULL,
@@ -483,7 +483,7 @@ GNUNET_SERVER_create (struct GNUNET_SCHEDULER_Handle *sched,
483 GNUNET_SCHEDULER_add_select (sched, 483 GNUNET_SCHEDULER_add_select (sched,
484 GNUNET_YES, 484 GNUNET_YES,
485 GNUNET_SCHEDULER_PRIORITY_HIGH, 485 GNUNET_SCHEDULER_PRIORITY_HIGH,
486 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 486 GNUNET_SCHEDULER_NO_TASK,
487 GNUNET_TIME_UNIT_FOREVER_REL, 487 GNUNET_TIME_UNIT_FOREVER_REL,
488 GNUNET_MAX (ret->listen_socket, 488 GNUNET_MAX (ret->listen_socket,
489 ret->shutpipe[0]) + 1, &r, 489 ret->shutpipe[0]) + 1, &r,
@@ -621,7 +621,7 @@ shutdown_incoming_processing (struct GNUNET_SERVER_Client *client)
621 struct NotifyList *n; 621 struct NotifyList *n;
622 unsigned int rc; 622 unsigned int rc;
623 623
624 GNUNET_assert (client->my_receive == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); 624 GNUNET_assert (client->my_receive == GNUNET_SCHEDULER_NO_TASK);
625 rc = client->reference_count; 625 rc = client->reference_count;
626 if (client->server != NULL) 626 if (client->server != NULL)
627 { 627 {
@@ -740,7 +740,7 @@ process_incoming (void *cls,
740 const char *cbuf = buf; 740 const char *cbuf = buf;
741 size_t maxcpy; 741 size_t maxcpy;
742 742
743 client->my_receive = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 743 client->my_receive = GNUNET_SCHEDULER_NO_TASK;
744 if ((buf == NULL) || 744 if ((buf == NULL) ||
745 (available == 0) || 745 (available == 0) ||
746 (errCode != 0) || 746 (errCode != 0) ||
@@ -1107,9 +1107,9 @@ GNUNET_SERVER_client_disconnect (struct GNUNET_SERVER_Client *client)
1107{ 1107{
1108 if (client->server == NULL) 1108 if (client->server == NULL)
1109 return; /* already disconnected */ 1109 return; /* already disconnected */
1110 GNUNET_assert (client->my_receive != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); 1110 GNUNET_assert (client->my_receive != GNUNET_SCHEDULER_NO_TASK);
1111 client->receive_cancel (client->client_closure, client->my_receive); 1111 client->receive_cancel (client->client_closure, client->my_receive);
1112 client->my_receive = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 1112 client->my_receive = GNUNET_SCHEDULER_NO_TASK;
1113 shutdown_incoming_processing (client); 1113 shutdown_incoming_processing (client);
1114} 1114}
1115 1115
diff --git a/src/util/test_network.c b/src/util/test_network.c
index b55b346a7..02555c299 100644
--- a/src/util/test_network.c
+++ b/src/util/test_network.c
@@ -169,7 +169,7 @@ task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
169 GNUNET_SCHEDULER_add_read (tc->sched, 169 GNUNET_SCHEDULER_add_read (tc->sched,
170 GNUNET_NO, 170 GNUNET_NO,
171 GNUNET_SCHEDULER_PRIORITY_HIGH, 171 GNUNET_SCHEDULER_PRIORITY_HIGH,
172 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 172 GNUNET_SCHEDULER_NO_TASK,
173 GNUNET_TIME_UNIT_FOREVER_REL, 173 GNUNET_TIME_UNIT_FOREVER_REL,
174 ls, &run_accept, cls); 174 ls, &run_accept, cls);
175} 175}
diff --git a/src/util/test_network_addressing.c b/src/util/test_network_addressing.c
index 4a571fff5..3c2a690d9 100644
--- a/src/util/test_network_addressing.c
+++ b/src/util/test_network_addressing.c
@@ -159,7 +159,7 @@ task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
159 GNUNET_SCHEDULER_add_read (tc->sched, 159 GNUNET_SCHEDULER_add_read (tc->sched,
160 GNUNET_NO, 160 GNUNET_NO,
161 GNUNET_SCHEDULER_PRIORITY_HIGH, 161 GNUNET_SCHEDULER_PRIORITY_HIGH,
162 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 162 GNUNET_SCHEDULER_NO_TASK,
163 GNUNET_TIME_UNIT_FOREVER_REL, 163 GNUNET_TIME_UNIT_FOREVER_REL,
164 ls, &run_accept, cls); 164 ls, &run_accept, cls);
165} 165}
diff --git a/src/util/test_network_receive_cancel.c b/src/util/test_network_receive_cancel.c
index e22e24d8c..7eb31153c 100644
--- a/src/util/test_network_receive_cancel.c
+++ b/src/util/test_network_receive_cancel.c
@@ -123,13 +123,13 @@ task_receive_cancel (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
123 GNUNET_SCHEDULER_add_read (tc->sched, 123 GNUNET_SCHEDULER_add_read (tc->sched,
124 GNUNET_NO, 124 GNUNET_NO,
125 GNUNET_SCHEDULER_PRIORITY_HIGH, 125 GNUNET_SCHEDULER_PRIORITY_HIGH,
126 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 126 GNUNET_SCHEDULER_NO_TASK,
127 GNUNET_TIME_UNIT_FOREVER_REL, 127 GNUNET_TIME_UNIT_FOREVER_REL,
128 ls, &run_accept_cancel, cls); 128 ls, &run_accept_cancel, cls);
129 GNUNET_SCHEDULER_add_delayed (tc->sched, 129 GNUNET_SCHEDULER_add_delayed (tc->sched,
130 GNUNET_NO, 130 GNUNET_NO,
131 GNUNET_SCHEDULER_PRIORITY_KEEP, 131 GNUNET_SCHEDULER_PRIORITY_KEEP,
132 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 132 GNUNET_SCHEDULER_NO_TASK,
133 GNUNET_TIME_UNIT_SECONDS, 133 GNUNET_TIME_UNIT_SECONDS,
134 &receive_cancel_task, cls); 134 &receive_cancel_task, cls);
135} 135}
diff --git a/src/util/test_scheduler.c b/src/util/test_scheduler.c
index 855b3a08a..d5a93ed7d 100644
--- a/src/util/test_scheduler.c
+++ b/src/util/test_scheduler.c
@@ -118,13 +118,13 @@ task5 (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
118 GNUNET_SCHEDULER_add_read (tc->sched, 118 GNUNET_SCHEDULER_add_read (tc->sched,
119 GNUNET_NO, 119 GNUNET_NO,
120 GNUNET_SCHEDULER_PRIORITY_DEFAULT, 120 GNUNET_SCHEDULER_PRIORITY_DEFAULT,
121 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 121 GNUNET_SCHEDULER_NO_TASK,
122 GNUNET_TIME_UNIT_FOREVER_REL, 122 GNUNET_TIME_UNIT_FOREVER_REL,
123 fds[0], &taskRd, cls); 123 fds[0], &taskRd, cls);
124 GNUNET_SCHEDULER_add_write (tc->sched, 124 GNUNET_SCHEDULER_add_write (tc->sched,
125 GNUNET_NO, 125 GNUNET_NO,
126 GNUNET_SCHEDULER_PRIORITY_DEFAULT, 126 GNUNET_SCHEDULER_PRIORITY_DEFAULT,
127 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 127 GNUNET_SCHEDULER_NO_TASK,
128 GNUNET_TIME_UNIT_FOREVER_REL, 128 GNUNET_TIME_UNIT_FOREVER_REL,
129 fds[1], &taskWrt, cls); 129 fds[1], &taskWrt, cls);
130} 130}
@@ -144,7 +144,7 @@ task1 (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
144 t2 = GNUNET_SCHEDULER_add_after (tc->sched, 144 t2 = GNUNET_SCHEDULER_add_after (tc->sched,
145 GNUNET_NO, 145 GNUNET_NO,
146 GNUNET_SCHEDULER_PRIORITY_IDLE, 146 GNUNET_SCHEDULER_PRIORITY_IDLE,
147 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 147 GNUNET_SCHEDULER_NO_TASK,
148 &task2, cls); 148 &task2, cls);
149 /* t3 will go before t4: higher priority */ 149 /* t3 will go before t4: higher priority */
150 t4 = GNUNET_SCHEDULER_add_after (tc->sched, 150 t4 = GNUNET_SCHEDULER_add_after (tc->sched,
diff --git a/src/util/test_scheduler_delay.c b/src/util/test_scheduler_delay.c
index 76cbf94d8..f5477fd4c 100644
--- a/src/util/test_scheduler_delay.c
+++ b/src/util/test_scheduler_delay.c
@@ -68,7 +68,7 @@ test_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
68 GNUNET_SCHEDULER_add_delayed (tc->sched, 68 GNUNET_SCHEDULER_add_delayed (tc->sched,
69 GNUNET_NO, 69 GNUNET_NO,
70 GNUNET_SCHEDULER_PRIORITY_DEFAULT, 70 GNUNET_SCHEDULER_PRIORITY_DEFAULT,
71 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 71 GNUNET_SCHEDULER_NO_TASK,
72 GNUNET_TIME_relative_multiply 72 GNUNET_TIME_relative_multiply
73 (GNUNET_TIME_UNIT_MILLISECONDS, i), 73 (GNUNET_TIME_UNIT_MILLISECONDS, i),
74 &test_task, NULL); 74 &test_task, NULL);
diff --git a/src/util/test_server.c b/src/util/test_server.c
index c26d64270..0f2ea3ce7 100644
--- a/src/util/test_server.c
+++ b/src/util/test_server.c
@@ -77,7 +77,7 @@ my_receive (void *cls,
77 struct SignalTimeoutContext *stctx; 77 struct SignalTimeoutContext *stctx;
78 GNUNET_SCHEDULER_TaskIdentifier ret; 78 GNUNET_SCHEDULER_TaskIdentifier ret;
79 79
80 ret = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; 80 ret = GNUNET_SCHEDULER_NO_TASK;
81 switch (*ok) 81 switch (*ok)
82 { 82 {
83 case 1: 83 case 1:
@@ -98,7 +98,7 @@ my_receive (void *cls,
98 ret = GNUNET_SCHEDULER_add_delayed (sched, 98 ret = GNUNET_SCHEDULER_add_delayed (sched,
99 GNUNET_NO, 99 GNUNET_NO,
100 GNUNET_SCHEDULER_PRIORITY_KEEP, 100 GNUNET_SCHEDULER_PRIORITY_KEEP,
101 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 101 GNUNET_SCHEDULER_NO_TASK,
102 timeout, &signal_timeout, stctx); 102 timeout, &signal_timeout, stctx);
103 break; 103 break;
104 default: 104 default:
diff --git a/src/util/test_server_disconnect.c b/src/util/test_server_disconnect.c
index 7eab48284..d737e92ec 100644
--- a/src/util/test_server_disconnect.c
+++ b/src/util/test_server_disconnect.c
@@ -94,7 +94,7 @@ recv_cb (void *cls,
94 GNUNET_SCHEDULER_add_delayed (sched, 94 GNUNET_SCHEDULER_add_delayed (sched,
95 GNUNET_YES, 95 GNUNET_YES,
96 GNUNET_SCHEDULER_PRIORITY_KEEP, 96 GNUNET_SCHEDULER_PRIORITY_KEEP,
97 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 97 GNUNET_SCHEDULER_NO_TASK,
98 GNUNET_TIME_relative_multiply 98 GNUNET_TIME_relative_multiply
99 (GNUNET_TIME_UNIT_MILLISECONDS, 50), 99 (GNUNET_TIME_UNIT_MILLISECONDS, 50),
100 &send_done, argclient); 100 &send_done, argclient);
@@ -104,7 +104,7 @@ recv_cb (void *cls,
104 GNUNET_SCHEDULER_add_delayed (sched, 104 GNUNET_SCHEDULER_add_delayed (sched,
105 GNUNET_YES, 105 GNUNET_YES,
106 GNUNET_SCHEDULER_PRIORITY_KEEP, 106 GNUNET_SCHEDULER_PRIORITY_KEEP,
107 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 107 GNUNET_SCHEDULER_NO_TASK,
108 GNUNET_TIME_relative_multiply 108 GNUNET_TIME_relative_multiply
109 (GNUNET_TIME_UNIT_MILLISECONDS, 50), 109 (GNUNET_TIME_UNIT_MILLISECONDS, 50),
110 &server_disconnect, argclient); 110 &server_disconnect, argclient);
diff --git a/src/util/test_server_with_client.c b/src/util/test_server_with_client.c
index 22cf2cded..e5eb50d8e 100644
--- a/src/util/test_server_with_client.c
+++ b/src/util/test_server_with_client.c
@@ -86,7 +86,7 @@ recv_cb (void *cls,
86 GNUNET_SCHEDULER_add_delayed (sched, 86 GNUNET_SCHEDULER_add_delayed (sched,
87 GNUNET_YES, 87 GNUNET_YES,
88 GNUNET_SCHEDULER_PRIORITY_KEEP, 88 GNUNET_SCHEDULER_PRIORITY_KEEP,
89 GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, 89 GNUNET_SCHEDULER_NO_TASK,
90 GNUNET_TIME_relative_multiply 90 GNUNET_TIME_relative_multiply
91 (GNUNET_TIME_UNIT_MILLISECONDS, 50), 91 (GNUNET_TIME_UNIT_MILLISECONDS, 50),
92 &send_done, argclient); 92 &send_done, argclient);