diff options
author | Christian Grothoff <christian@grothoff.org> | 2009-07-24 22:04:41 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2009-07-24 22:04:41 +0000 |
commit | 70e6847205a9f9b9b660be2a173d5bc309eaa58d (patch) | |
tree | e2649865fbff3e7cbb2e85e381a6268b9aa01e0d /src/util | |
parent | 0722614037876469e205546db5ab5fc892b5cf8c (diff) | |
download | gnunet-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.c | 8 | ||||
-rw-r--r-- | src/util/crypto_hash.c | 4 | ||||
-rw-r--r-- | src/util/disk.c | 2 | ||||
-rw-r--r-- | src/util/network.c | 62 | ||||
-rw-r--r-- | src/util/scheduler.c | 14 | ||||
-rw-r--r-- | src/util/server.c | 14 | ||||
-rw-r--r-- | src/util/test_network.c | 2 | ||||
-rw-r--r-- | src/util/test_network_addressing.c | 2 | ||||
-rw-r--r-- | src/util/test_network_receive_cancel.c | 4 | ||||
-rw-r--r-- | src/util/test_scheduler.c | 6 | ||||
-rw-r--r-- | src/util/test_scheduler_delay.c | 2 | ||||
-rw-r--r-- | src/util/test_server.c | 4 | ||||
-rw-r--r-- | src/util/test_server_disconnect.c | 4 | ||||
-rw-r--r-- | src/util/test_server_with_client.c | 2 |
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 | */ |
970 | GNUNET_SCHEDULER_TaskIdentifier | 970 | GNUNET_SCHEDULER_TaskIdentifier |
971 | GNUNET_NETWORK_receive (struct GNUNET_NETWORK_SocketHandle *sock, | 971 | GNUNET_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 */ |
1197 | SCHEDULE_WRITE: | 1197 | SCHEDULE_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); |