aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r--src/fs/gnunet-service-fs_pr.c18
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,
1514check_error_and_continue: 1514check_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);