Page MenuHomePhorge
Files F33581447

D4081.1769106513.diff
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

D4081.1769106513.diff
View Options

diff --git a/services/backup/src/Reactors/server/AddAttachmentReactor.h b/services/backup/src/Reactors/server/AddAttachmentReactor.h
new file mode 100644
--- /dev/null
+++ b/services/backup/src/Reactors/server/AddAttachmentReactor.h
@@ -0,0 +1,50 @@
+#pragma once
+
+#include "DatabaseEntitiesTools.h"
+#include "ServerReadReactorBase.h"
+#include "ServiceBlobClient.h"
+
+#include "../_generated/backup.grpc.pb.h"
+#include "../_generated/backup.pb.h"
+
+#include <memory>
+#include <string>
+#include <vector>
+
+namespace comm {
+namespace network {
+namespace reactor {
+
+class AddAttachmentReactor : public ServerReadReactorBase<
+ backup::AddAttachmentRequest,
+ google::protobuf::Empty> {
+ enum class ParentType {
+ UNKNOWN = 0,
+ BACKUP = 1,
+ LOG = 2,
+ };
+
+ ParentType parentType = ParentType::UNKNOWN;
+ std::string userID;
+ std::string backupID;
+ std::string logID;
+ bool parametersPassed = false;
+ std::mutex reactorStateMutex;
+ std::vector<std::string> holders;
+
+ std::condition_variable blobPutDoneCV;
+ std::mutex blobPutDoneCVMutex;
+
+public:
+ using ServerReadReactorBase<
+ backup::AddAttachmentRequest,
+ google::protobuf::Empty>::ServerReadReactorBase;
+
+ std::unique_ptr<grpc::Status>
+ readRequest(backup::AddAttachmentRequest request) override;
+ void terminateCallback() override;
+};
+
+} // namespace reactor
+} // namespace network
+} // namespace comm
diff --git a/services/backup/src/Reactors/server/AddAttachmentReactor.cpp b/services/backup/src/Reactors/server/AddAttachmentReactor.cpp
new file mode 100644
--- /dev/null
+++ b/services/backup/src/Reactors/server/AddAttachmentReactor.cpp
@@ -0,0 +1,27 @@
+#include "AddAttachmentReactor.h"
+
+#include "Constants.h"
+#include "DatabaseManager.h"
+#include "GlobalTools.h"
+#include "Tools.h"
+
+#include <iostream>
+
+namespace comm {
+namespace network {
+namespace reactor {
+
+std::unique_ptr<grpc::Status>
+AddAttachmentReactor::readRequest(backup::AddAttachmentRequest request) {
+ // 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);
+ return nullptr;
+}
+
+void AddAttachmentReactor::terminateCallback() {
+}
+
+} // namespace reactor
+} // namespace network
+} // namespace comm

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 22, 6:28 PM (15 h, 22 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5979408
Default Alt Text
D4081.1769106513.diff (2 KB)

Event Timeline