diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-06-07 22:08:36 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-06-07 22:08:36 +0000 |
commit | 4cb7e23cef8a149ac1334519ff898cc05811ac66 (patch) | |
tree | 74701b6ef23c97b508a8a382fc929ed4ca783bbf /src/fs/gnunet-service-fs_pr.c | |
parent | a75ced83ea0041bc72e615743aa192f141ead643 (diff) | |
download | gnunet-4cb7e23cef8a149ac1334519ff898cc05811ac66.tar.gz gnunet-4cb7e23cef8a149ac1334519ff898cc05811ac66.zip |
add support for delays
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r-- | src/fs/gnunet-service-fs_pr.c | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c index d4f14985b..55b256e7d 100644 --- a/src/fs/gnunet-service-fs_pr.c +++ b/src/fs/gnunet-service-fs_pr.c | |||
@@ -366,6 +366,7 @@ GSF_pending_request_create_ (enum GSF_PendingRequestOptions options, | |||
366 | dpr->rh (dpr->rh_cls, | 366 | dpr->rh (dpr->rh_cls, |
367 | GNUNET_BLOCK_EVALUATION_REQUEST_VALID, | 367 | GNUNET_BLOCK_EVALUATION_REQUEST_VALID, |
368 | dpr, | 368 | dpr, |
369 | UINT32_MAX, | ||
369 | GNUNET_TIME_UNIT_FOREVER_ABS, | 370 | GNUNET_TIME_UNIT_FOREVER_ABS, |
370 | GNUNET_BLOCK_TYPE_ANY, | 371 | GNUNET_BLOCK_TYPE_ANY, |
371 | NULL, 0); | 372 | NULL, 0); |
@@ -726,7 +727,7 @@ update_request_performance_data (struct ProcessReplyClosure *prq, | |||
726 | */ | 727 | */ |
727 | static int | 728 | static int |
728 | process_reply (void *cls, | 729 | process_reply (void *cls, |
729 | const GNUNET_HashCode * key, | 730 | const GNUNET_HashCode *key, |
730 | void *value) | 731 | void *value) |
731 | { | 732 | { |
732 | struct ProcessReplyClosure *prq = cls; | 733 | struct ProcessReplyClosure *prq = cls; |
@@ -766,6 +767,7 @@ process_reply (void *cls, | |||
766 | pr->rh (pr->rh_cls, | 767 | pr->rh (pr->rh_cls, |
767 | prq->eval, | 768 | prq->eval, |
768 | pr, | 769 | pr, |
770 | prq->anonymity_level, | ||
769 | prq->expiration, | 771 | prq->expiration, |
770 | prq->type, | 772 | prq->type, |
771 | prq->data, prq->size); | 773 | prq->data, prq->size); |
@@ -825,6 +827,7 @@ process_reply (void *cls, | |||
825 | pr->rh (pr->rh_cls, | 827 | pr->rh (pr->rh_cls, |
826 | prq->eval, | 828 | prq->eval, |
827 | pr, | 829 | pr, |
830 | prq->anonymity_level, | ||
828 | prq->expiration, | 831 | prq->expiration, |
829 | prq->type, | 832 | prq->type, |
830 | prq->data, prq->size); | 833 | prq->data, prq->size); |
@@ -1426,7 +1429,7 @@ GSF_handle_p2p_content_ (struct GSF_ConnectedPeer *cp, | |||
1426 | prq.type = type; | 1429 | prq.type = type; |
1427 | prq.expiration = expiration; | 1430 | prq.expiration = expiration; |
1428 | prq.priority = 0; | 1431 | prq.priority = 0; |
1429 | prq.anonymity_level = 1; | 1432 | prq.anonymity_level = UINT32_MAX; |
1430 | prq.request_found = GNUNET_NO; | 1433 | prq.request_found = GNUNET_NO; |
1431 | GNUNET_CONTAINER_multihashmap_get_multiple (pr_map, | 1434 | GNUNET_CONTAINER_multihashmap_get_multiple (pr_map, |
1432 | &query, | 1435 | &query, |