aboutsummaryrefslogtreecommitdiff
path: root/src/util/mq.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/mq.c')
-rw-r--r--src/util/mq.c10
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,
345void 345void
346GNUNET_MQ_impl_send_continue (struct GNUNET_MQ_Handle *mq) 346GNUNET_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 {