diff options
Diffstat (limited to 'src/set/gnunet-service-set.c')
-rw-r--r-- | src/set/gnunet-service-set.c | 12 |
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; |