diff options
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r-- | src/fs/gnunet-service-fs_pr.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c index f809efd6c..5dc03393a 100644 --- a/src/fs/gnunet-service-fs_pr.c +++ b/src/fs/gnunet-service-fs_pr.c | |||
@@ -157,7 +157,7 @@ struct GSF_PendingRequest | |||
157 | /** | 157 | /** |
158 | * Task that warns us if the local datastore lookup takes too long. | 158 | * Task that warns us if the local datastore lookup takes too long. |
159 | */ | 159 | */ |
160 | GNUNET_SCHEDULER_TaskIdentifier warn_task; | 160 | struct GNUNET_SCHEDULER_Task * warn_task; |
161 | 161 | ||
162 | /** | 162 | /** |
163 | * Current offset for querying our local datastore for results. | 163 | * Current offset for querying our local datastore for results. |
@@ -632,10 +632,10 @@ clean_request (void *cls, const struct GNUNET_HashCode *key, void *value) | |||
632 | GNUNET_DHT_get_stop (pr->gh); | 632 | GNUNET_DHT_get_stop (pr->gh); |
633 | pr->gh = NULL; | 633 | pr->gh = NULL; |
634 | } | 634 | } |
635 | if (GNUNET_SCHEDULER_NO_TASK != pr->warn_task) | 635 | if (NULL != pr->warn_task) |
636 | { | 636 | { |
637 | GNUNET_SCHEDULER_cancel (pr->warn_task); | 637 | GNUNET_SCHEDULER_cancel (pr->warn_task); |
638 | pr->warn_task = GNUNET_SCHEDULER_NO_TASK; | 638 | pr->warn_task = NULL; |
639 | } | 639 | } |
640 | GNUNET_assert (GNUNET_OK == | 640 | GNUNET_assert (GNUNET_OK == |
641 | GNUNET_CONTAINER_multihashmap_remove (pr_map, | 641 | GNUNET_CONTAINER_multihashmap_remove (pr_map, |
@@ -690,10 +690,10 @@ GSF_pending_request_cancel_ (struct GSF_PendingRequest *pr, int full_cleanup) | |||
690 | GNUNET_DHT_get_stop (pr->gh); | 690 | GNUNET_DHT_get_stop (pr->gh); |
691 | pr->gh = NULL; | 691 | pr->gh = NULL; |
692 | } | 692 | } |
693 | if (GNUNET_SCHEDULER_NO_TASK != pr->warn_task) | 693 | if (NULL != pr->warn_task) |
694 | { | 694 | { |
695 | GNUNET_SCHEDULER_cancel (pr->warn_task); | 695 | GNUNET_SCHEDULER_cancel (pr->warn_task); |
696 | pr->warn_task = GNUNET_SCHEDULER_NO_TASK; | 696 | pr->warn_task = NULL; |
697 | } | 697 | } |
698 | return; | 698 | return; |
699 | } | 699 | } |
@@ -1307,7 +1307,7 @@ process_local_reply (void *cls, const struct GNUNET_HashCode * key, size_t size, | |||
1307 | unsigned int old_rf; | 1307 | unsigned int old_rf; |
1308 | 1308 | ||
1309 | GNUNET_SCHEDULER_cancel (pr->warn_task); | 1309 | GNUNET_SCHEDULER_cancel (pr->warn_task); |
1310 | pr->warn_task = GNUNET_SCHEDULER_NO_TASK; | 1310 | pr->warn_task = NULL; |
1311 | if (NULL != pr->qe) | 1311 | if (NULL != pr->qe) |
1312 | { | 1312 | { |
1313 | pr->qe = NULL; | 1313 | pr->qe = NULL; |
@@ -1514,10 +1514,10 @@ process_local_reply (void *cls, const struct GNUNET_HashCode * key, size_t size, | |||
1514 | check_error_and_continue: | 1514 | check_error_and_continue: |
1515 | if (NULL != pr->qe) | 1515 | if (NULL != pr->qe) |
1516 | return; | 1516 | return; |
1517 | if (GNUNET_SCHEDULER_NO_TASK != pr->warn_task) | 1517 | if (NULL != pr->warn_task) |
1518 | { | 1518 | { |
1519 | GNUNET_SCHEDULER_cancel (pr->warn_task); | 1519 | GNUNET_SCHEDULER_cancel (pr->warn_task); |
1520 | pr->warn_task = GNUNET_SCHEDULER_NO_TASK; | 1520 | pr->warn_task = NULL; |
1521 | } | 1521 | } |
1522 | if (NULL == (cont = pr->llc_cont)) | 1522 | if (NULL == (cont = pr->llc_cont)) |
1523 | return; /* no continuation */ | 1523 | return; /* no continuation */ |
@@ -1620,7 +1620,7 @@ GSF_local_lookup_ (struct GSF_PendingRequest *pr, | |||
1620 | ("# Datastore lookups concluded (error queueing)"), | 1620 | ("# Datastore lookups concluded (error queueing)"), |
1621 | 1, GNUNET_NO); | 1621 | 1, GNUNET_NO); |
1622 | GNUNET_SCHEDULER_cancel (pr->warn_task); | 1622 | GNUNET_SCHEDULER_cancel (pr->warn_task); |
1623 | pr->warn_task = GNUNET_SCHEDULER_NO_TASK; | 1623 | pr->warn_task = NULL; |
1624 | pr->llc_cont = NULL; | 1624 | pr->llc_cont = NULL; |
1625 | if (NULL != cont) | 1625 | if (NULL != cont) |
1626 | cont (cont_cls, pr, pr->local_result); | 1626 | cont (cont_cls, pr, pr->local_result); |