diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/CreateNewBackupReactor.h b/services/backup/docker-server/contents/server/src/Reactors/server/CreateNewBackupReactor.h --- a/services/backup/docker-server/contents/server/src/Reactors/server/CreateNewBackupReactor.h +++ b/services/backup/docker-server/contents/server/src/Reactors/server/CreateNewBackupReactor.h @@ -34,10 +34,12 @@ std::string holder; std::string backupID; std::shared_ptr putReactor; + ServiceBlobClient blobClient; std::mutex reactorStateMutex; - std::condition_variable blobDoneCV; - std::mutex blobDoneCVMutex; + + std::condition_variable blobPutDoneCV; + std::mutex blobPutDoneCVMutex; std::string generateBackupID(); @@ -89,7 +91,7 @@ response->set_backupid(this->backupID); this->holder = this->backupID; this->putReactor = std::make_shared( - this->holder, this->dataHash, &this->blobDoneCV); + this->holder, this->dataHash, &this->blobPutDoneCV); this->blobClient.put(this->putReactor); return nullptr; } @@ -108,9 +110,9 @@ return; } this->putReactor->scheduleSendingDataChunk(std::make_unique("")); - std::unique_lock lock2(this->blobDoneCVMutex); + std::unique_lock lock2(this->blobPutDoneCVMutex); if (!this->putReactor->isDone()) { - this->blobDoneCV.wait(lock2); + this->blobPutDoneCV.wait(lock2); } else if (!this->putReactor->getStatus().ok()) { throw std::runtime_error(this->putReactor->getStatus().error_message()); }