diff options
Diffstat (limited to 'src/transport/transport_api.c')
-rw-r--r-- | src/transport/transport_api.c | 72 |
1 files changed, 36 insertions, 36 deletions
diff --git a/src/transport/transport_api.c b/src/transport/transport_api.c index dab244e45..eef0ede5e 100644 --- a/src/transport/transport_api.c +++ b/src/transport/transport_api.c | |||
@@ -405,13 +405,13 @@ transport_notify_ready (void *cls, size_t size, void *buf) | |||
405 | do | 405 | do |
406 | { | 406 | { |
407 | th = h->connect_ready_head; | 407 | th = h->connect_ready_head; |
408 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 408 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
409 | { | 409 | { |
410 | /* remove existing time out task (only applies if | 410 | /* remove existing time out task (only applies if |
411 | this is not the first iteration of the loop) */ | 411 | this is not the first iteration of the loop) */ |
412 | GNUNET_SCHEDULER_cancel (h->sched, | 412 | GNUNET_SCHEDULER_cancel (h->sched, |
413 | th->notify_delay_task); | 413 | th->notify_delay_task); |
414 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 414 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
415 | } | 415 | } |
416 | GNUNET_assert (th->notify_size <= size); | 416 | GNUNET_assert (th->notify_size <= size); |
417 | if (th->next != NULL) | 417 | if (th->next != NULL) |
@@ -459,13 +459,13 @@ schedule_transmission (struct GNUNET_TRANSPORT_Handle *h) | |||
459 | th = h->connect_ready_head; | 459 | th = h->connect_ready_head; |
460 | if (th == NULL) | 460 | if (th == NULL) |
461 | return; /* no request pending */ | 461 | return; /* no request pending */ |
462 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 462 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
463 | { | 463 | { |
464 | /* remove existing time out task, will be integrated | 464 | /* remove existing time out task, will be integrated |
465 | with transmit_ready notification! */ | 465 | with transmit_ready notification! */ |
466 | GNUNET_SCHEDULER_cancel (h->sched, | 466 | GNUNET_SCHEDULER_cancel (h->sched, |
467 | th->notify_delay_task); | 467 | th->notify_delay_task); |
468 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 468 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
469 | } | 469 | } |
470 | h->transmission_scheduled = GNUNET_YES; | 470 | h->transmission_scheduled = GNUNET_YES; |
471 | h->network_handle = GNUNET_CLIENT_notify_transmit_ready (h->client, | 471 | h->network_handle = GNUNET_CLIENT_notify_transmit_ready (h->client, |
@@ -529,10 +529,10 @@ remove_from_any_list (struct GNUNET_TRANSPORT_TransmitHandle *th) | |||
529 | struct GNUNET_TRANSPORT_Handle *h; | 529 | struct GNUNET_TRANSPORT_Handle *h; |
530 | 530 | ||
531 | h = th->handle; | 531 | h = th->handle; |
532 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 532 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
533 | { | 533 | { |
534 | GNUNET_SCHEDULER_cancel (h->sched, th->notify_delay_task); | 534 | GNUNET_SCHEDULER_cancel (h->sched, th->notify_delay_task); |
535 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 535 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
536 | } | 536 | } |
537 | if (th->prev == NULL) | 537 | if (th->prev == NULL) |
538 | { | 538 | { |
@@ -573,7 +573,7 @@ transmit_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
573 | { | 573 | { |
574 | struct GNUNET_TRANSPORT_TransmitHandle *th = cls; | 574 | struct GNUNET_TRANSPORT_TransmitHandle *th = cls; |
575 | 575 | ||
576 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 576 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
577 | if (th->neighbour != NULL) | 577 | if (th->neighbour != NULL) |
578 | th->neighbour->transmit_handle = NULL; | 578 | th->neighbour->transmit_handle = NULL; |
579 | #if DEBUG_TRANSPORT | 579 | #if DEBUG_TRANSPORT |
@@ -620,7 +620,7 @@ schedule_control_transmit (struct GNUNET_TRANSPORT_Handle *h, | |||
620 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 620 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
621 | GNUNET_NO, | 621 | GNUNET_NO, |
622 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 622 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
623 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 623 | GNUNET_SCHEDULER_NO_TASK, |
624 | timeout, | 624 | timeout, |
625 | &transmit_timeout, th); | 625 | &transmit_timeout, th); |
626 | if (at_head) | 626 | if (at_head) |
@@ -785,7 +785,7 @@ hello_wait_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
785 | struct HelloWaitList *pos; | 785 | struct HelloWaitList *pos; |
786 | struct HelloWaitList *prev; | 786 | struct HelloWaitList *prev; |
787 | 787 | ||
788 | hwl->task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 788 | hwl->task = GNUNET_SCHEDULER_NO_TASK; |
789 | if (GNUNET_TIME_absolute_get_remaining (hwl->timeout).value > 0) | 789 | if (GNUNET_TIME_absolute_get_remaining (hwl->timeout).value > 0) |
790 | { | 790 | { |
791 | #if DEBUG_TRANSPORT | 791 | #if DEBUG_TRANSPORT |
@@ -797,7 +797,7 @@ hello_wait_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
797 | hwl->task = GNUNET_SCHEDULER_add_delayed (hwl->handle->sched, | 797 | hwl->task = GNUNET_SCHEDULER_add_delayed (hwl->handle->sched, |
798 | GNUNET_YES, | 798 | GNUNET_YES, |
799 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 799 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
800 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 800 | GNUNET_SCHEDULER_NO_TASK, |
801 | GNUNET_TIME_absolute_get_remaining (hwl->timeout), | 801 | GNUNET_TIME_absolute_get_remaining (hwl->timeout), |
802 | &hello_wait_timeout, hwl); | 802 | &hello_wait_timeout, hwl); |
803 | return; | 803 | return; |
@@ -857,7 +857,7 @@ GNUNET_TRANSPORT_get_hello (struct GNUNET_TRANSPORT_Handle *handle, | |||
857 | hwl->task = GNUNET_SCHEDULER_add_delayed (handle->sched, | 857 | hwl->task = GNUNET_SCHEDULER_add_delayed (handle->sched, |
858 | GNUNET_YES, | 858 | GNUNET_YES, |
859 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 859 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
860 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 860 | GNUNET_SCHEDULER_NO_TASK, |
861 | timeout, | 861 | timeout, |
862 | &hello_wait_timeout, hwl); | 862 | &hello_wait_timeout, hwl); |
863 | return; | 863 | return; |
@@ -979,7 +979,7 @@ request_connect (void *cls, size_t size, void *buf) | |||
979 | struct TryConnectMessage *tcm; | 979 | struct TryConnectMessage *tcm; |
980 | struct GNUNET_TRANSPORT_Handle *h; | 980 | struct GNUNET_TRANSPORT_Handle *h; |
981 | 981 | ||
982 | GNUNET_assert (th->notify_delay_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); | 982 | GNUNET_assert (th->notify_delay_task == GNUNET_SCHEDULER_NO_TASK); |
983 | h = th->handle; | 983 | h = th->handle; |
984 | if (buf == NULL) | 984 | if (buf == NULL) |
985 | { | 985 | { |
@@ -1008,7 +1008,7 @@ request_connect (void *cls, size_t size, void *buf) | |||
1008 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 1008 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
1009 | GNUNET_NO, | 1009 | GNUNET_NO, |
1010 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 1010 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
1011 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1011 | GNUNET_SCHEDULER_NO_TASK, |
1012 | GNUNET_TIME_absolute_get_remaining | 1012 | GNUNET_TIME_absolute_get_remaining |
1013 | (th->timeout), | 1013 | (th->timeout), |
1014 | &transmit_timeout, th); | 1014 | &transmit_timeout, th); |
@@ -1028,7 +1028,7 @@ request_connect (void *cls, size_t size, void *buf) | |||
1028 | static void | 1028 | static void |
1029 | try_connect (struct GNUNET_TRANSPORT_TransmitHandle *th) | 1029 | try_connect (struct GNUNET_TRANSPORT_TransmitHandle *th) |
1030 | { | 1030 | { |
1031 | GNUNET_assert (th->notify_delay_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); | 1031 | GNUNET_assert (th->notify_delay_task == GNUNET_SCHEDULER_NO_TASK); |
1032 | schedule_control_transmit (th->handle, | 1032 | schedule_control_transmit (th->handle, |
1033 | sizeof (struct TryConnectMessage), | 1033 | sizeof (struct TryConnectMessage), |
1034 | GNUNET_NO, | 1034 | GNUNET_NO, |
@@ -1050,7 +1050,7 @@ try_connect_task (void *cls, | |||
1050 | { | 1050 | { |
1051 | struct GNUNET_TRANSPORT_TransmitHandle *th = cls; | 1051 | struct GNUNET_TRANSPORT_TransmitHandle *th = cls; |
1052 | 1052 | ||
1053 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1053 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
1054 | try_connect (th); | 1054 | try_connect (th); |
1055 | } | 1055 | } |
1056 | 1056 | ||
@@ -1103,18 +1103,18 @@ remove_neighbour (struct GNUNET_TRANSPORT_Handle *h, | |||
1103 | if (GNUNET_TIME_absolute_get_remaining (th->timeout).value <= CONNECT_RETRY_TIMEOUT.value) | 1103 | if (GNUNET_TIME_absolute_get_remaining (th->timeout).value <= CONNECT_RETRY_TIMEOUT.value) |
1104 | { | 1104 | { |
1105 | /* signal error */ | 1105 | /* signal error */ |
1106 | GNUNET_assert (GNUNET_SCHEDULER_NO_PREREQUISITE_TASK == th->notify_delay_task); | 1106 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == th->notify_delay_task); |
1107 | transmit_timeout (th, NULL); | 1107 | transmit_timeout (th, NULL); |
1108 | } | 1108 | } |
1109 | else | 1109 | else |
1110 | { | 1110 | { |
1111 | /* try again in a bit */ | 1111 | /* try again in a bit */ |
1112 | GNUNET_assert (GNUNET_SCHEDULER_NO_PREREQUISITE_TASK == th->notify_delay_task); | 1112 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == th->notify_delay_task); |
1113 | th->notify_delay_task | 1113 | th->notify_delay_task |
1114 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 1114 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
1115 | GNUNET_NO, | 1115 | GNUNET_NO, |
1116 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 1116 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
1117 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1117 | GNUNET_SCHEDULER_NO_TASK, |
1118 | CONNECT_RETRY_TIMEOUT, | 1118 | CONNECT_RETRY_TIMEOUT, |
1119 | &try_connect_task, | 1119 | &try_connect_task, |
1120 | th); | 1120 | th); |
@@ -1144,7 +1144,7 @@ reconnect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
1144 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Connecting to transport service.\n"); | 1144 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Connecting to transport service.\n"); |
1145 | #endif | 1145 | #endif |
1146 | GNUNET_assert (h->client == NULL); | 1146 | GNUNET_assert (h->client == NULL); |
1147 | h->reconnect_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1147 | h->reconnect_task = GNUNET_SCHEDULER_NO_TASK; |
1148 | h->client = GNUNET_CLIENT_connect (h->sched, "transport", h->cfg); | 1148 | h->client = GNUNET_CLIENT_connect (h->sched, "transport", h->cfg); |
1149 | GNUNET_assert (h->client != NULL); | 1149 | GNUNET_assert (h->client != NULL); |
1150 | /* make sure we don't send "START" twice, | 1150 | /* make sure we don't send "START" twice, |
@@ -1189,12 +1189,12 @@ schedule_reconnect (struct GNUNET_TRANSPORT_Handle *h) | |||
1189 | h->reconnect_delay.value); | 1189 | h->reconnect_delay.value); |
1190 | #endif | 1190 | #endif |
1191 | GNUNET_assert (h->client == NULL); | 1191 | GNUNET_assert (h->client == NULL); |
1192 | GNUNET_assert (h->reconnect_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); | 1192 | GNUNET_assert (h->reconnect_task == GNUNET_SCHEDULER_NO_TASK); |
1193 | h->reconnect_task | 1193 | h->reconnect_task |
1194 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 1194 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
1195 | GNUNET_NO, | 1195 | GNUNET_NO, |
1196 | GNUNET_SCHEDULER_PRIORITY_DEFAULT, | 1196 | GNUNET_SCHEDULER_PRIORITY_DEFAULT, |
1197 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1197 | GNUNET_SCHEDULER_NO_TASK, |
1198 | h->reconnect_delay, &reconnect, h); | 1198 | h->reconnect_delay, &reconnect, h); |
1199 | h->reconnect_delay = GNUNET_TIME_UNIT_SECONDS; | 1199 | h->reconnect_delay = GNUNET_TIME_UNIT_SECONDS; |
1200 | } | 1200 | } |
@@ -1217,7 +1217,7 @@ transmit_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
1217 | { | 1217 | { |
1218 | struct GNUNET_TRANSPORT_TransmitHandle *th = cls; | 1218 | struct GNUNET_TRANSPORT_TransmitHandle *th = cls; |
1219 | 1219 | ||
1220 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1220 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
1221 | schedule_request (th); | 1221 | schedule_request (th); |
1222 | } | 1222 | } |
1223 | 1223 | ||
@@ -1252,10 +1252,10 @@ schedule_request (struct GNUNET_TRANSPORT_TransmitHandle *th) | |||
1252 | 1252 | ||
1253 | h = th->handle; | 1253 | h = th->handle; |
1254 | n = th->neighbour; | 1254 | n = th->neighbour; |
1255 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 1255 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
1256 | { | 1256 | { |
1257 | GNUNET_SCHEDULER_cancel (h->sched, th->notify_delay_task); | 1257 | GNUNET_SCHEDULER_cancel (h->sched, th->notify_delay_task); |
1258 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1258 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
1259 | } | 1259 | } |
1260 | /* check outgoing quota */ | 1260 | /* check outgoing quota */ |
1261 | duration = GNUNET_TIME_absolute_get_duration (n->last_quota_update); | 1261 | duration = GNUNET_TIME_absolute_get_duration (n->last_quota_update); |
@@ -1298,7 +1298,7 @@ schedule_request (struct GNUNET_TRANSPORT_TransmitHandle *th) | |||
1298 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 1298 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
1299 | GNUNET_NO, | 1299 | GNUNET_NO, |
1300 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 1300 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
1301 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1301 | GNUNET_SCHEDULER_NO_TASK, |
1302 | duration, &transmit_ready, th); | 1302 | duration, &transmit_ready, th); |
1303 | return; | 1303 | return; |
1304 | } | 1304 | } |
@@ -1320,7 +1320,7 @@ schedule_request (struct GNUNET_TRANSPORT_TransmitHandle *th) | |||
1320 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 1320 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
1321 | GNUNET_NO, | 1321 | GNUNET_NO, |
1322 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 1322 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
1323 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1323 | GNUNET_SCHEDULER_NO_TASK, |
1324 | GNUNET_TIME_absolute_get_remaining | 1324 | GNUNET_TIME_absolute_get_remaining |
1325 | (th->timeout), &transmit_timeout, th); | 1325 | (th->timeout), &transmit_timeout, th); |
1326 | return; | 1326 | return; |
@@ -1392,10 +1392,10 @@ add_neighbour (struct GNUNET_TRANSPORT_Handle *h, | |||
1392 | "Found pending request for `%4s' will trigger it now.\n", | 1392 | "Found pending request for `%4s' will trigger it now.\n", |
1393 | GNUNET_i2s (&pos->target)); | 1393 | GNUNET_i2s (&pos->target)); |
1394 | #endif | 1394 | #endif |
1395 | if (pos->notify_delay_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 1395 | if (pos->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
1396 | { | 1396 | { |
1397 | GNUNET_SCHEDULER_cancel (h->sched, pos->notify_delay_task); | 1397 | GNUNET_SCHEDULER_cancel (h->sched, pos->notify_delay_task); |
1398 | pos->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1398 | pos->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
1399 | } | 1399 | } |
1400 | schedule_request (pos); | 1400 | schedule_request (pos); |
1401 | } | 1401 | } |
@@ -1495,10 +1495,10 @@ GNUNET_TRANSPORT_disconnect (struct GNUNET_TRANSPORT_Handle *handle) | |||
1495 | while (NULL != (th = handle->connect_wait_head)) | 1495 | while (NULL != (th = handle->connect_wait_head)) |
1496 | { | 1496 | { |
1497 | handle->connect_wait_head = th->next; | 1497 | handle->connect_wait_head = th->next; |
1498 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 1498 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
1499 | { | 1499 | { |
1500 | GNUNET_SCHEDULER_cancel (handle->sched, th->notify_delay_task); | 1500 | GNUNET_SCHEDULER_cancel (handle->sched, th->notify_delay_task); |
1501 | th->notify_delay_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1501 | th->notify_delay_task = GNUNET_SCHEDULER_NO_TASK; |
1502 | } | 1502 | } |
1503 | th->notify (th->notify_cls, 0, NULL); | 1503 | th->notify (th->notify_cls, 0, NULL); |
1504 | GNUNET_free (th); | 1504 | GNUNET_free (th); |
@@ -1519,10 +1519,10 @@ GNUNET_TRANSPORT_disconnect (struct GNUNET_TRANSPORT_Handle *handle) | |||
1519 | hwl->rec (hwl->rec_cls, GNUNET_TIME_UNIT_ZERO, NULL, NULL); | 1519 | hwl->rec (hwl->rec_cls, GNUNET_TIME_UNIT_ZERO, NULL, NULL); |
1520 | GNUNET_free (hwl); | 1520 | GNUNET_free (hwl); |
1521 | } | 1521 | } |
1522 | if (handle->reconnect_task != GNUNET_SCHEDULER_NO_PREREQUISITE_TASK) | 1522 | if (handle->reconnect_task != GNUNET_SCHEDULER_NO_TASK) |
1523 | { | 1523 | { |
1524 | GNUNET_SCHEDULER_cancel (handle->sched, handle->reconnect_task); | 1524 | GNUNET_SCHEDULER_cancel (handle->sched, handle->reconnect_task); |
1525 | handle->reconnect_task = GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1525 | handle->reconnect_task = GNUNET_SCHEDULER_NO_TASK; |
1526 | } | 1526 | } |
1527 | GNUNET_free_non_null (handle->my_hello); | 1527 | GNUNET_free_non_null (handle->my_hello); |
1528 | handle->my_hello = NULL; | 1528 | handle->my_hello = NULL; |
@@ -1578,12 +1578,12 @@ demultiplexer (void *cls, const struct GNUNET_MessageHeader *msg) | |||
1578 | h->transmission_scheduled = GNUNET_NO; | 1578 | h->transmission_scheduled = GNUNET_NO; |
1579 | th = h->connect_ready_head; | 1579 | th = h->connect_ready_head; |
1580 | /* add timeout again, we cancelled the transmit_ready task! */ | 1580 | /* add timeout again, we cancelled the transmit_ready task! */ |
1581 | GNUNET_assert (th->notify_delay_task == GNUNET_SCHEDULER_NO_PREREQUISITE_TASK); | 1581 | GNUNET_assert (th->notify_delay_task == GNUNET_SCHEDULER_NO_TASK); |
1582 | th->notify_delay_task | 1582 | th->notify_delay_task |
1583 | = GNUNET_SCHEDULER_add_delayed (h->sched, | 1583 | = GNUNET_SCHEDULER_add_delayed (h->sched, |
1584 | GNUNET_NO, | 1584 | GNUNET_NO, |
1585 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 1585 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
1586 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1586 | GNUNET_SCHEDULER_NO_TASK, |
1587 | GNUNET_TIME_absolute_get_remaining(th->timeout), | 1587 | GNUNET_TIME_absolute_get_remaining(th->timeout), |
1588 | &transmit_timeout, | 1588 | &transmit_timeout, |
1589 | th); | 1589 | th); |
@@ -1692,7 +1692,7 @@ demultiplexer (void *cls, const struct GNUNET_MessageHeader *msg) | |||
1692 | GNUNET_SCHEDULER_cancel (h->sched, | 1692 | GNUNET_SCHEDULER_cancel (h->sched, |
1693 | n->transmit_handle->notify_delay_task); | 1693 | n->transmit_handle->notify_delay_task); |
1694 | n->transmit_handle->notify_delay_task = | 1694 | n->transmit_handle->notify_delay_task = |
1695 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK; | 1695 | GNUNET_SCHEDULER_NO_TASK; |
1696 | GNUNET_assert (GNUNET_YES == n->received_ack); | 1696 | GNUNET_assert (GNUNET_YES == n->received_ack); |
1697 | schedule_request (n->transmit_handle); | 1697 | schedule_request (n->transmit_handle); |
1698 | } | 1698 | } |
@@ -1927,7 +1927,7 @@ GNUNET_TRANSPORT_notify_transmit_ready (struct GNUNET_TRANSPORT_Handle | |||
1927 | = GNUNET_SCHEDULER_add_delayed (handle->sched, | 1927 | = GNUNET_SCHEDULER_add_delayed (handle->sched, |
1928 | GNUNET_NO, | 1928 | GNUNET_NO, |
1929 | GNUNET_SCHEDULER_PRIORITY_KEEP, | 1929 | GNUNET_SCHEDULER_PRIORITY_KEEP, |
1930 | GNUNET_SCHEDULER_NO_PREREQUISITE_TASK, | 1930 | GNUNET_SCHEDULER_NO_TASK, |
1931 | timeout, &transmit_timeout, th); | 1931 | timeout, &transmit_timeout, th); |
1932 | return th; | 1932 | return th; |
1933 | } | 1933 | } |