diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-10-23 18:29:31 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-10-23 18:29:31 +0000 |
commit | a25686672d1ca40a856292ee65f45e0e736a7a8f (patch) | |
tree | 923b746e3f8af3b77d90536e5c936c4135c1b781 /src/fs/gnunet-service-fs_pr.c | |
parent | b38b47339b7c806432f251a566c857eb64c6e8cf (diff) | |
download | gnunet-a25686672d1ca40a856292ee65f45e0e736a7a8f.tar.gz gnunet-a25686672d1ca40a856292ee65f45e0e736a7a8f.zip |
-using new MDLL facility to clean up bijection data structure and reduce memory consumption in fs service
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r-- | src/fs/gnunet-service-fs_pr.c | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c index f39f3fb78..74a982970 100644 --- a/src/fs/gnunet-service-fs_pr.c +++ b/src/fs/gnunet-service-fs_pr.c | |||
@@ -819,7 +819,9 @@ process_reply (void *cls, const struct GNUNET_HashCode * key, void *value) | |||
819 | GNUNET_LOAD_update (GSF_rt_entry_lifetime, | 819 | GNUNET_LOAD_update (GSF_rt_entry_lifetime, |
820 | GNUNET_TIME_absolute_get_duration (pr-> | 820 | GNUNET_TIME_absolute_get_duration (pr-> |
821 | public_data.start_time).rel_value); | 821 | public_data.start_time).rel_value); |
822 | if (!GSF_request_plan_reference_get_last_transmission_ (pr->public_data.rpr_head, prq->sender, &last_transmission)) | 822 | if (! GSF_request_plan_reference_get_last_transmission_ (pr->public_data.pr_head, |
823 | prq->sender, | ||
824 | &last_transmission)) | ||
823 | last_transmission.abs_value = GNUNET_TIME_UNIT_FOREVER_ABS.abs_value; | 825 | last_transmission.abs_value = GNUNET_TIME_UNIT_FOREVER_ABS.abs_value; |
824 | /* pass on to other peers / local clients */ | 826 | /* pass on to other peers / local clients */ |
825 | pr->rh (pr->rh_cls, prq->eval, pr, prq->anonymity_level, prq->expiration, | 827 | pr->rh (pr->rh_cls, prq->eval, pr, prq->anonymity_level, prq->expiration, |
@@ -870,9 +872,12 @@ process_reply (void *cls, const struct GNUNET_HashCode * key, void *value) | |||
870 | pr->public_data.results_found++; | 872 | pr->public_data.results_found++; |
871 | prq->request_found = GNUNET_YES; | 873 | prq->request_found = GNUNET_YES; |
872 | /* finally, pass on to other peer / local client */ | 874 | /* finally, pass on to other peer / local client */ |
873 | if (!GSF_request_plan_reference_get_last_transmission_ (pr->public_data.rpr_head, prq->sender, &last_transmission)) | 875 | if (! GSF_request_plan_reference_get_last_transmission_ (pr->public_data.pr_head, |
876 | prq->sender, | ||
877 | &last_transmission)) | ||
874 | last_transmission.abs_value = GNUNET_TIME_UNIT_FOREVER_ABS.abs_value; | 878 | last_transmission.abs_value = GNUNET_TIME_UNIT_FOREVER_ABS.abs_value; |
875 | pr->rh (pr->rh_cls, prq->eval, pr, prq->anonymity_level, prq->expiration, | 879 | pr->rh (pr->rh_cls, prq->eval, pr, |
880 | prq->anonymity_level, prq->expiration, | ||
876 | last_transmission, prq->type, prq->data, prq->size); | 881 | last_transmission, prq->type, prq->data, prq->size); |
877 | return GNUNET_YES; | 882 | return GNUNET_YES; |
878 | } | 883 | } |