aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-03-25 08:18:47 +0000
committerChristian Grothoff <christian@grothoff.org>2011-03-25 08:18:47 +0000
commit2574474f98d5a4feefab2bbd7092c9d0ff9d64e8 (patch)
treebb769a4ade0c1017940a557faf8611aaf043bc64 /src/fs/gnunet-service-fs_pr.c
parentf094448e150652facb82024f45dea7193650c2bc (diff)
downloadgnunet-2574474f98d5a4feefab2bbd7092c9d0ff9d64e8.tar.gz
gnunet-2574474f98d5a4feefab2bbd7092c9d0ff9d64e8.zip
fixes
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r--src/fs/gnunet-service-fs_pr.c15
1 files changed, 13 insertions, 2 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c
index d8cd8716e..c3116ba23 100644
--- a/src/fs/gnunet-service-fs_pr.c
+++ b/src/fs/gnunet-service-fs_pr.c
@@ -1034,10 +1034,21 @@ process_local_reply (void *cls,
1034 GSF_update_datastore_delay_ (pr->public_data.start_time); 1034 GSF_update_datastore_delay_ (pr->public_data.start_time);
1035 process_reply (&prq, key, pr); 1035 process_reply (&prq, key, pr);
1036 if (prq.finished == GNUNET_YES) 1036 if (prq.finished == GNUNET_YES)
1037 return; 1037 {
1038#if DEBUG_FS
1039 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1040 "Request processing finished, not asking datastore for more\n");
1041#endif
1042 return;
1043 }
1038 pr->local_result = prq.eval; 1044 pr->local_result = prq.eval;
1039 if (pr->qe == NULL) 1045 if (pr->qe == NULL)
1040 return; /* done here */ 1046 {
1047#if DEBUG_FS
1048 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1049 "Request cancelled, not asking datastore for more\n");
1050#endif
1051 }
1041 if (prq.eval == GNUNET_BLOCK_EVALUATION_OK_LAST) 1052 if (prq.eval == GNUNET_BLOCK_EVALUATION_OK_LAST)
1042 { 1053 {
1043 GNUNET_DATASTORE_get_next (GSF_dsh, GNUNET_NO); 1054 GNUNET_DATASTORE_get_next (GSF_dsh, GNUNET_NO);