diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-04-21 13:05:22 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-04-21 13:05:22 +0000 |
commit | 8b23412a0e353778e83b370260e40d63a18c3927 (patch) | |
tree | b2d8321ff0117ce7e394ec6c57e74d6c7d48be57 /src/fs/gnunet-service-fs_pe.c | |
parent | a8fbbd5cba5913f69c6f16e43c7c8cc8165a1f2a (diff) | |
download | gnunet-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.c | 14 |
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, |