aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-06-07 22:08:36 +0000
committerChristian Grothoff <christian@grothoff.org>2011-06-07 22:08:36 +0000
commit4cb7e23cef8a149ac1334519ff898cc05811ac66 (patch)
tree74701b6ef23c97b508a8a382fc929ed4ca783bbf /src/fs/gnunet-service-fs_pr.c
parenta75ced83ea0041bc72e615743aa192f141ead643 (diff)
downloadgnunet-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.c7
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 */
727static int 728static int
728process_reply (void *cls, 729process_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,