aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/transport_api.c')
-rw-r--r--src/transport/transport_api.c72
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)
1028static void 1028static void
1029try_connect (struct GNUNET_TRANSPORT_TransmitHandle *th) 1029try_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 }