diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-03-25 08:18:47 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-03-25 08:18:47 +0000 |
commit | 2574474f98d5a4feefab2bbd7092c9d0ff9d64e8 (patch) | |
tree | bb769a4ade0c1017940a557faf8611aaf043bc64 /src/fs/gnunet-service-fs_pr.c | |
parent | f094448e150652facb82024f45dea7193650c2bc (diff) | |
download | gnunet-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.c | 15 |
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); |