aboutsummaryrefslogtreecommitdiff
path: root/src/set/gnunet-service-set.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/set/gnunet-service-set.c')
-rw-r--r--src/set/gnunet-service-set.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/set/gnunet-service-set.c b/src/set/gnunet-service-set.c
index 2291bd2f2..dc5a787f6 100644
--- a/src/set/gnunet-service-set.c
+++ b/src/set/gnunet-service-set.c
@@ -475,10 +475,10 @@ incoming_destroy (struct Operation *incoming)
475 GNUNET_CONTAINER_DLL_remove (incoming_head, 475 GNUNET_CONTAINER_DLL_remove (incoming_head,
476 incoming_tail, 476 incoming_tail,
477 incoming); 477 incoming);
478 if (GNUNET_SCHEDULER_NO_TASK != incoming->timeout_task) 478 if (NULL != incoming->timeout_task)
479 { 479 {
480 GNUNET_SCHEDULER_cancel (incoming->timeout_task); 480 GNUNET_SCHEDULER_cancel (incoming->timeout_task);
481 incoming->timeout_task = GNUNET_SCHEDULER_NO_TASK; 481 incoming->timeout_task = NULL;
482 } 482 }
483 /* make sure that the tunnel end handler will not destroy us again */ 483 /* make sure that the tunnel end handler will not destroy us again */
484 incoming->vt = NULL; 484 incoming->vt = NULL;
@@ -543,9 +543,9 @@ incoming_suggest (struct Operation *incoming,
543 incoming->suggest_id = suggest_id++; 543 incoming->suggest_id = suggest_id++;
544 if (0 == suggest_id) 544 if (0 == suggest_id)
545 suggest_id++; 545 suggest_id++;
546 GNUNET_assert (GNUNET_SCHEDULER_NO_TASK != incoming->timeout_task); 546 GNUNET_assert (NULL != incoming->timeout_task);
547 GNUNET_SCHEDULER_cancel (incoming->timeout_task); 547 GNUNET_SCHEDULER_cancel (incoming->timeout_task);
548 incoming->timeout_task = GNUNET_SCHEDULER_NO_TASK; 548 incoming->timeout_task = NULL;
549 mqm = GNUNET_MQ_msg_nested_mh (cmsg, 549 mqm = GNUNET_MQ_msg_nested_mh (cmsg,
550 GNUNET_MESSAGE_TYPE_SET_REQUEST, 550 GNUNET_MESSAGE_TYPE_SET_REQUEST,
551 incoming->spec->context_msg); 551 incoming->spec->context_msg);
@@ -624,7 +624,7 @@ handle_incoming_msg (struct Operation *op,
624 &msg->app_id); 624 &msg->app_id);
625 if (NULL == listener) 625 if (NULL == listener)
626 { 626 {
627 GNUNET_break (GNUNET_SCHEDULER_NO_TASK != op->timeout_task); 627 GNUNET_break (NULL != op->timeout_task);
628 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 628 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
629 "No matching listener for incoming request (op %u, app %s), waiting with timeout\n", 629 "No matching listener for incoming request (op %u, app %s), waiting with timeout\n",
630 ntohl (msg->operation), 630 ntohl (msg->operation),
@@ -1279,7 +1279,7 @@ incoming_timeout_cb (void *cls,
1279{ 1279{
1280 struct Operation *incoming = cls; 1280 struct Operation *incoming = cls;
1281 1281
1282 incoming->timeout_task = GNUNET_SCHEDULER_NO_TASK; 1282 incoming->timeout_task = NULL;
1283 GNUNET_assert (GNUNET_YES == incoming->is_incoming); 1283 GNUNET_assert (GNUNET_YES == incoming->is_incoming);
1284 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 1284 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
1285 return; 1285 return;