Handle closing during file reference repair.
GitOrigin-RevId: 2712f7be176353afee0551f519dff34d4369e262
This commit is contained in:
parent
175da716bb
commit
4a36aaaa9d
|
@ -157,8 +157,18 @@ void FileReferenceManager::send_query(Destination dest, FileSourceId file_source
|
||||||
|
|
||||||
auto promise = PromiseCreator::lambda([dest, file_source_id, file_reference_manager = G()->file_reference_manager(),
|
auto promise = PromiseCreator::lambda([dest, file_source_id, file_reference_manager = G()->file_reference_manager(),
|
||||||
file_manager = G()->file_manager()](Result<Unit> result) mutable {
|
file_manager = G()->file_manager()](Result<Unit> result) mutable {
|
||||||
|
if (G()->close_flag()) {
|
||||||
|
VLOG(file_references) << "Ignore file reference repair from " << file_source_id << " during closing";
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
auto new_promise =
|
auto new_promise =
|
||||||
PromiseCreator::lambda([dest, file_source_id, file_reference_manager](Result<Unit> result) mutable {
|
PromiseCreator::lambda([dest, file_source_id, file_reference_manager](Result<Unit> result) mutable {
|
||||||
|
if (G()->close_flag()) {
|
||||||
|
VLOG(file_references) << "Ignore file reference repair from " << file_source_id << " during closing";
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
Status status;
|
Status status;
|
||||||
if (result.is_error()) {
|
if (result.is_error()) {
|
||||||
status = result.move_as_error();
|
status = result.move_as_error();
|
||||||
|
|
Reference in New Issue
Block a user