[fabric::rds] Added fabric factory

receiver/src/receiver_data_server/fabric_server_rds.cpp

@@ -2,7 +2,7 @@
 
 using namespace asapo;
 
-FabricServerRds::FabricServerRds(const std::string& address) {
+FabricServerRds::FabricServerRds(const std::string& address) : factory__(fabric::GenerateDefaultFabricFactory()) {
 
 }
 
@@ -14,7 +14,14 @@ GenericRequests FabricServerRds::GetNewRequests(Error* err) const noexcept {
     return asapo::GenericRequests();
 }
 
-Error FabricServerRds::SendData(uint64_t source_id, void* buf, uint64_t size) const noexcept {
+Error
+FabricServerRds::SendResponse(const ReceiverDataServerRequest* request, const GenericNetworkResponse* response) const noexcept {
+    return asapo::Error();
+}
+
+Error FabricServerRds::SendResponseAndSlotData(const ReceiverDataServerRequest* request,
+                                               const GenericNetworkResponse* response,
+                                               const CacheMeta* cache_slot) const noexcept {
     return asapo::Error();
 }
 

receiver/src/receiver_data_server/fabric_server_rds.h

 #ifndef ASAPO_RDS_FABRIC_SERVER_H
 #define ASAPO_RDS_FABRIC_SERVER_H
 
-#include "net_server.h"
+#include "rds_net_server.h"
+#include "asapo_fabric/asapo_fabric.h"
 
 namespace asapo {
 
-class FabricServerRds : public NetServer {
+class FabricServerRds : public RdsNetServer {
 public:
     explicit FabricServerRds(const std::string& address);
     ~FabricServerRds() override;
+    std::unique_ptr<asapo::fabric::FabricFactory> factory__; // modified in testings to mock system calls, otherwise do not touch
 public: // NetServer implementation
     GenericRequests GetNewRequests(Error* err) const noexcept override;
-    Error SendData(uint64_t source_id, void* buf, uint64_t size) const noexcept override;
+
+    Error SendResponse(const ReceiverDataServerRequest* request, const GenericNetworkResponse* response) const noexcept override;
+
+    Error SendResponseAndSlotData(const ReceiverDataServerRequest* request, const GenericNetworkResponse* response,
+                                  const CacheMeta* cache_slot) const noexcept override;
+
     void HandleAfterError(uint64_t source_id) const noexcept override;
 };