Page MenuHomePhorge
Files F33483251

D3637.1769044922.diff
No OneTemporary
Actions

Size
1 KB
Referenced Files
None
Subscribers
None

D3637.1769044922.diff
View Options

diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h b/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h
--- a/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h
+++ b/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h
@@ -29,6 +29,7 @@
std::shared_ptr<database::BackupItem> backupItem;
std::shared_ptr<reactor::BlobGetClientReactor> getReactor;
+ std::mutex reactorStateMutex;
std::shared_ptr<folly::MPMCQueue<std::string>> dataChunks;
ServiceBlobClient blobClient;
State state = State::COMPACTION;
@@ -65,7 +66,24 @@
}
void PullBackupReactor::initialize() {
- throw std::runtime_error("unimplemented");
+ // we make sure that the blob client's state is flushed to the main memory
+ // as there may be multiple threads from the pool taking over here
+ const std::lock_guard<std::mutex> lock(this->reactorStateMutex);
+ if (this->request.userid().empty()) {
+ throw std::runtime_error("no user id provided");
+ }
+ if (this->request.backupid().empty()) {
+ throw std::runtime_error("no backup id provided");
+ }
+ this->backupItem = database::DatabaseManager::getInstance().findBackupItem(
+ this->request.userid(), this->request.backupid());
+ if (this->backupItem == nullptr) {
+ throw std::runtime_error(
+ "no backup found for provided parameters: user id [" +
+ this->request.userid() + "], backup id [" + this->request.backupid() +
+ "]");
+ }
+ // TODO get logs
}
std::unique_ptr<grpc::Status>

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 22, 1:22 AM (3 h, 53 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5973068
Default Alt Text
D3637.1769044922.diff (1 KB)

Event Timeline