Page MenuHomePhabricator
Files F3356915

D4160.id13447.diff
No OneTemporary
Actions

D4160.id13447.diff
View Options

diff --git a/services/backup/src/Reactors/server/CreateNewBackupReactor.cpp b/services/backup/src/Reactors/server/CreateNewBackupReactor.cpp
--- a/services/backup/src/Reactors/server/CreateNewBackupReactor.cpp
+++ b/services/backup/src/Reactors/server/CreateNewBackupReactor.cpp
@@ -85,14 +85,13 @@
}
this->putReactor->scheduleSendingDataChunk(std::make_unique<std::string>(""));
std::unique_lock<std::mutex> lock2(this->blobPutDoneCVMutex);
- if (this->putReactor->getStatusHolder()->state == ReactorState::DONE &&
- !this->putReactor->getStatusHolder()->getStatus().ok()) {
- throw std::runtime_error(
- this->putReactor->getStatusHolder()->getStatus().error_message());
- }
if (this->putReactor->getStatusHolder()->state != ReactorState::DONE) {
this->blobPutDoneCV.wait(lock2);
- } else if (!this->putReactor->getStatusHolder()->getStatus().ok()) {
+ }
+ if (this->putReactor->getStatusHolder()->state != ReactorState::DONE) {
+ throw std::runtime_error("put reactor has not been terminated properly");
+ }
+ if (!this->putReactor->getStatusHolder()->getStatus().ok()) {
throw std::runtime_error(
this->putReactor->getStatusHolder()->getStatus().error_message());
}

File Metadata

Mime Type
text/plain
Expires
Sun, Nov 24, 9:27 PM (20 h, 49 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2577366
Default Alt Text
D4160.id13447.diff (1 KB)

Event Timeline