diff options
Diffstat (limited to 'src/fs/gnunet-service-fs_pe.c')
-rw-r--r-- | src/fs/gnunet-service-fs_pe.c | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c index 58fb11cee..d1a8a1163 100644 --- a/src/fs/gnunet-service-fs_pe.c +++ b/src/fs/gnunet-service-fs_pe.c | |||
@@ -207,9 +207,9 @@ static unsigned long long plan_count; | |||
207 | * @param cls the 'struct GSF_ConnectedPeer' for transmission | 207 | * @param cls the 'struct GSF_ConnectedPeer' for transmission |
208 | * @param tc scheduler context | 208 | * @param tc scheduler context |
209 | */ | 209 | */ |
210 | static void schedule_peer_transmission (void *cls, | 210 | static void |
211 | const struct | 211 | schedule_peer_transmission (void *cls, |
212 | GNUNET_SCHEDULER_TaskContext *tc); | 212 | const struct GNUNET_SCHEDULER_TaskContext *tc); |
213 | 213 | ||
214 | 214 | ||
215 | /** | 215 | /** |
@@ -243,8 +243,8 @@ plan (struct PeerPlan *pp, struct GSF_RequestPlan *rp) | |||
243 | #endif | 243 | #endif |
244 | 244 | ||
245 | GNUNET_assert (rp->hn == NULL); | 245 | GNUNET_assert (rp->hn == NULL); |
246 | if (GNUNET_TIME_absolute_get_remaining (rp->earliest_transmission). | 246 | if (GNUNET_TIME_absolute_get_remaining (rp->earliest_transmission).rel_value |
247 | rel_value == 0) | 247 | == 0) |
248 | rp->hn = GNUNET_CONTAINER_heap_insert (pp->priority_heap, rp, rp->priority); | 248 | rp->hn = GNUNET_CONTAINER_heap_insert (pp->priority_heap, rp, rp->priority); |
249 | else | 249 | else |
250 | rp->hn = | 250 | rp->hn = |
@@ -359,8 +359,8 @@ schedule_peer_transmission (void *cls, | |||
359 | } | 359 | } |
360 | /* move ready requests to priority queue */ | 360 | /* move ready requests to priority queue */ |
361 | while ((NULL != (rp = GNUNET_CONTAINER_heap_peek (pp->delay_heap))) && | 361 | while ((NULL != (rp = GNUNET_CONTAINER_heap_peek (pp->delay_heap))) && |
362 | (GNUNET_TIME_absolute_get_remaining (rp->earliest_transmission). | 362 | (GNUNET_TIME_absolute_get_remaining |
363 | rel_value == 0)) | 363 | (rp->earliest_transmission).rel_value == 0)) |
364 | { | 364 | { |
365 | GNUNET_assert (rp == GNUNET_CONTAINER_heap_remove_root (pp->delay_heap)); | 365 | GNUNET_assert (rp == GNUNET_CONTAINER_heap_remove_root (pp->delay_heap)); |
366 | rp->hn = GNUNET_CONTAINER_heap_insert (pp->priority_heap, rp, rp->priority); | 366 | rp->hn = GNUNET_CONTAINER_heap_insert (pp->priority_heap, rp, rp->priority); |
@@ -380,9 +380,9 @@ schedule_peer_transmission (void *cls, | |||
380 | #if DEBUG_FS | 380 | #if DEBUG_FS |
381 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 381 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
382 | "Sleeping for %llu ms before retrying requests on plan %p.\n", | 382 | "Sleeping for %llu ms before retrying requests on plan %p.\n", |
383 | (unsigned long long) GNUNET_TIME_absolute_get_remaining (rp-> | 383 | (unsigned long long) |
384 | earliest_transmission). | 384 | GNUNET_TIME_absolute_get_remaining |
385 | rel_value, pp); | 385 | (rp->earliest_transmission).rel_value, pp); |
386 | #endif | 386 | #endif |
387 | pp->task = | 387 | pp->task = |
388 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_absolute_get_remaining | 388 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_absolute_get_remaining |