diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h b/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h --- a/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h +++ b/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h @@ -42,8 +42,9 @@ // true) std::string value; std::mutex reactorStateMutex; - std::condition_variable blobDoneCV; - std::mutex blobDoneCVMutex; + + std::condition_variable blobPutDoneCV; + std::mutex blobPutDoneCVMutex; std::shared_ptr putReactor; ServiceBlobClient blobClient; @@ -98,7 +99,7 @@ } if (this->putReactor == nullptr) { this->putReactor = std::make_shared( - this->value, this->hash, &this->blobDoneCV); + this->value, this->hash, &this->blobPutDoneCV); this->blobClient.put(this->putReactor); } } @@ -188,9 +189,9 @@ return; } this->putReactor->scheduleSendingDataChunk(std::make_unique("")); - std::unique_lock lock2(this->blobDoneCVMutex); + std::unique_lock lockPut(this->blobPutDoneCVMutex); if (!this->putReactor->isDone()) { - this->blobDoneCV.wait(lock2); + this->blobPutDoneCV.wait(lockPut); } else if (!this->putReactor->getStatus().ok()) { throw std::runtime_error(this->putReactor->getStatus().error_message()); }