diff options
Diffstat (limited to 'src/util/mq.c')
-rw-r--r-- | src/util/mq.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index d34850b8c..254e5d33e 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
@@ -133,7 +133,7 @@ struct GNUNET_MQ_Handle | |||
133 | /** | 133 | /** |
134 | * Task scheduled during #GNUNET_MQ_impl_send_continue. | 134 | * Task scheduled during #GNUNET_MQ_impl_send_continue. |
135 | */ | 135 | */ |
136 | GNUNET_SCHEDULER_TaskIdentifier continue_task; | 136 | struct GNUNET_SCHEDULER_Task * continue_task; |
137 | 137 | ||
138 | /** | 138 | /** |
139 | * Next id that should be used for the @e assoc_map, | 139 | * Next id that should be used for the @e assoc_map, |
@@ -310,7 +310,7 @@ impl_send_continue (void *cls, | |||
310 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 310 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
311 | return; | 311 | return; |
312 | 312 | ||
313 | mq->continue_task = GNUNET_SCHEDULER_NO_TASK; | 313 | mq->continue_task = NULL; |
314 | /* call is only valid if we're actually currently sending | 314 | /* call is only valid if we're actually currently sending |
315 | * a message */ | 315 | * a message */ |
316 | current_envelope = mq->current_envelope; | 316 | current_envelope = mq->current_envelope; |
@@ -345,7 +345,7 @@ impl_send_continue (void *cls, | |||
345 | void | 345 | void |
346 | GNUNET_MQ_impl_send_continue (struct GNUNET_MQ_Handle *mq) | 346 | GNUNET_MQ_impl_send_continue (struct GNUNET_MQ_Handle *mq) |
347 | { | 347 | { |
348 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == mq->continue_task); | 348 | GNUNET_assert (NULL == mq->continue_task); |
349 | mq->continue_task = GNUNET_SCHEDULER_add_now (&impl_send_continue, | 349 | mq->continue_task = GNUNET_SCHEDULER_add_now (&impl_send_continue, |
350 | mq); | 350 | mq); |
351 | } | 351 | } |
@@ -776,10 +776,10 @@ GNUNET_MQ_destroy (struct GNUNET_MQ_Handle *mq) | |||
776 | { | 776 | { |
777 | mq->destroy_impl (mq, mq->impl_state); | 777 | mq->destroy_impl (mq, mq->impl_state); |
778 | } | 778 | } |
779 | if (GNUNET_SCHEDULER_NO_TASK != mq->continue_task) | 779 | if (NULL != mq->continue_task) |
780 | { | 780 | { |
781 | GNUNET_SCHEDULER_cancel (mq->continue_task); | 781 | GNUNET_SCHEDULER_cancel (mq->continue_task); |
782 | mq->continue_task = GNUNET_SCHEDULER_NO_TASK; | 782 | mq->continue_task = NULL; |
783 | } | 783 | } |
784 | while (NULL != mq->envelope_head) | 784 | while (NULL != mq->envelope_head) |
785 | { | 785 | { |