D3777.1765353343.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D3777.1765353343.diff
View Options

	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<reactor::BlobPutClientReactor> 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<reactor::BlobPutClientReactor>(
	- 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::string>(""));
	- std::unique_lock<std::mutex> lock2(this->blobDoneCVMutex);
	+ std::unique_lock<std::mutex> 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());
	}