aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pe.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-04-21 13:05:22 +0000
committerChristian Grothoff <christian@grothoff.org>2011-04-21 13:05:22 +0000
commit8b23412a0e353778e83b370260e40d63a18c3927 (patch)
treeb2d8321ff0117ce7e394ec6c57e74d6c7d48be57 /src/fs/gnunet-service-fs_pe.c
parenta8fbbd5cba5913f69c6f16e43c7c8cc8165a1f2a (diff)
downloadgnunet-8b23412a0e353778e83b370260e40d63a18c3927.tar.gz
gnunet-8b23412a0e353778e83b370260e40d63a18c3927.zip
cancel completed requests
Diffstat (limited to 'src/fs/gnunet-service-fs_pe.c')
-rw-r--r--src/fs/gnunet-service-fs_pe.c14
1 files changed, 13 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c
index d0e30f025..b3f46cf45 100644
--- a/src/fs/gnunet-service-fs_pe.c
+++ b/src/fs/gnunet-service-fs_pe.c
@@ -134,7 +134,19 @@ plan (struct PeerPlan *pp,
134 134
135 prd = GSF_pending_request_get_data_ (rp->pr); 135 prd = GSF_pending_request_get_data_ (rp->pr);
136 // FIXME: calculate 'rp->earliest_transmission'! 136 // FIXME: calculate 'rp->earliest_transmission'!
137 // fIXME: claculate 'rp->priority'! 137 // FIXME: claculate 'rp->priority'!
138 rp->earliest_transmission
139 = GNUNET_TIME_relative_to_absolute
140 (GNUNET_TIME_relative_multiply
141 (GNUNET_TIME_UNIT_SECONDS,
142 rp->transmission_counter));
143#if DEBUG_FS
144 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
145 "Earliest (re)transmission for `%s' in %us\n",
146 GNUNET_h2s (&prd->query),
147 rp->transmission_counter);
148#endif
149
138 150
139 if (GNUNET_TIME_absolute_get_remaining (rp->earliest_transmission).rel_value == 0) 151 if (GNUNET_TIME_absolute_get_remaining (rp->earliest_transmission).rel_value == 0)
140 rp->hn = GNUNET_CONTAINER_heap_insert (pp->priority_heap, 152 rp->hn = GNUNET_CONTAINER_heap_insert (pp->priority_heap,