aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r--src/fs/gnunet-service-fs_pr.c24
1 files changed, 23 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c
index 67c935acd..a9530f53a 100644
--- a/src/fs/gnunet-service-fs_pr.c
+++ b/src/fs/gnunet-service-fs_pr.c
@@ -128,7 +128,7 @@ struct GSF_PendingRequest
128 GSF_LocalLookupContinuation llc_cont; 128 GSF_LocalLookupContinuation llc_cont;
129 129
130 /** 130 /**
131 * Closure for llc_cont. 131 * Closure for @e llc_cont.
132 */ 132 */
133 void *llc_cont_cls; 133 void *llc_cont_cls;
134 134
@@ -1514,6 +1514,28 @@ check_error_and_continue:
1514 if (NULL == (cont = pr->llc_cont)) 1514 if (NULL == (cont = pr->llc_cont))
1515 return; /* no continuation */ 1515 return; /* no continuation */
1516 pr->llc_cont = NULL; 1516 pr->llc_cont = NULL;
1517 if (0 != (GSF_PRO_LOCAL_ONLY & pr->public_data.options))
1518 {
1519 if (GNUNET_BLOCK_EVALUATION_OK_LAST != pr->local_result)
1520 {
1521 /* Signal that we are done and that there won't be any
1522 additional results to allow client to clean up state. */
1523 pr->rh (pr->rh_cls,
1524 GNUNET_BLOCK_EVALUATION_OK_LAST,
1525 pr,
1526 UINT32_MAX,
1527 GNUNET_TIME_UNIT_ZERO_ABS,
1528 GNUNET_TIME_UNIT_FOREVER_ABS,
1529 GNUNET_BLOCK_TYPE_ANY,
1530 NULL, 0);
1531 }
1532 /* Finally, call our continuation to signal that we are
1533 done with local processing of this request; i.e. to
1534 start reading again from the client. */
1535 cont (pr->llc_cont_cls, NULL, GNUNET_BLOCK_EVALUATION_OK_LAST);
1536 return;
1537 }
1538
1517 cont (pr->llc_cont_cls, pr, pr->local_result); 1539 cont (pr->llc_cont_cls, pr, pr->local_result);
1518} 1540}
1519 1541