Page MenuHomePhorge
Files F32405086

D3778.1765342643.diff
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

D3778.1765342643.diff
View Options

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,16 +42,22 @@
// true)
std::string value;
std::mutex reactorStateMutex;
- std::condition_variable blobDoneCV;
- std::mutex blobDoneCVMutex;
+
+ std::condition_variable blobPutDoneCV;
+ std::mutex blobPutDoneCVMutex;
+
+ std::condition_variable blobAppendHolderDoneCV;
+ std::mutex blobAppendHolderDoneCVMutex;
std::shared_ptr<reactor::BlobPutClientReactor> putReactor;
+ std::shared_ptr<reactor::BlobAppendHolderClientReactor> holderReactor;
ServiceBlobClient blobClient;
void storeInDatabase();
std::string generateHolder();
std::string generateLogID();
void initializePutReactor();
+ void initializeHolderReactor();
void storeInBlob(const std::string &data) {
}
@@ -98,11 +104,28 @@
}
if (this->putReactor == nullptr) {
this->putReactor = std::make_shared<reactor::BlobPutClientReactor>(
- this->value, this->hash, &this->blobDoneCV);
+ this->value, this->hash, &this->blobPutDoneCV);
this->blobClient.put(this->putReactor);
}
}
+void SendLogReactor::initializeHolderReactor() {
+ if (this->value.empty()) {
+ throw std::runtime_error(
+ "holder reactor cannot be initialized with empty value");
+ }
+ if (this->hash.empty()) {
+ throw std::runtime_error(
+ "holder reactor cannot be initialized with empty hash");
+ }
+ if (this->holderReactor == nullptr) {
+ this->holderReactor =
+ std::make_shared<reactor::BlobAppendHolderClientReactor>(
+ this->value, this->hash, &this->blobAppendHolderDoneCV);
+ this->blobClient.appendHolder(this->holderReactor);
+ }
+}
+
std::unique_ptr<grpc::Status>
SendLogReactor::readRequest(backup::SendLogRequest request) {
// we make sure that the blob client's state is flushed to the main memory
@@ -188,14 +211,25 @@
return;
}
this->putReactor->scheduleSendingDataChunk(std::make_unique<std::string>(""));
- std::unique_lock<std::mutex> lock2(this->blobDoneCVMutex);
+ std::unique_lock<std::mutex> 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());
}
- // store in db only when we successfully upload chunks
- this->storeInDatabase();
+}
+if (this->putReactor->getDataExists()) {
+ this->initializeHolderReactor();
+ std::unique_lock<std::mutex> lockHolder(this->blobAppendHolderDoneCVMutex);
+ if (!this->holderReactor->isDone()) {
+ this->blobAppendHolderDoneCV.wait(lockHolder);
+ } else if (!this->holderReactor->getStatus().ok()) {
+ throw std::runtime_error(this->holderReactor->getStatus().error_message());
+ }
+}
+}
+// store in db only when we successfully upload chunks
+this->storeInDatabase();
}
void SendLogReactor::doneCallback() {

File Metadata

Mime Type
text/plain
Expires
Wed, Dec 10, 4:57 AM (19 h, 6 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5861149
Default Alt Text
D3778.1765342643.diff (3 KB)

Event Timeline