add add_data_rpc_service to repl_dev

Author: JacksonYao287

src/include/homestore/replication/repl_dev.h

@@ -446,6 +446,8 @@ class ReplDevListener {
     std::weak_ptr< ReplDev > m_repl_dev;
 };
 
+using data_service_request_handler_t = std::function< void(boost::intrusive_ptr< sisl::GenericRpcData >& rpc_data) >;
+
 class ReplDev {
 public:
     ReplDev() = default;
@@ -628,6 +630,11 @@ class ReplDev {
     // create a snapshot manually and try to compact logs upto compact_lsn
     virtual void trigger_snapshot_creation(repl_lsn_t compact_lsn, bool wait_for_commit) = 0;
 
+    virtual bool add_data_rpc_service(std::string const& request_name,
+                                      data_service_request_handler_t const& request_handler) {
+        return true;
+    }
+
 protected:
     shared< ReplDevListener > m_listener;
 

src/lib/replication/repl_dev/raft_repl_dev.cpp

@@ -138,6 +138,11 @@ bool RaftReplDev::join_group() {
     return true;
 }
 
+bool RaftReplDev::add_data_rpc_service(std::string const& request_name,
+                                       data_service_request_handler_t const& request_handler) {
+    return m_msg_mgr.bind_data_service_request(request_name, m_group_id, request_handler);
+}
+
 // All the steps in the implementation should be idempotent and retryable.
 AsyncReplResult<> RaftReplDev::start_replace_member(std::string& task_id, const replica_member_info& member_out,
                                                     const replica_member_info& member_in, uint32_t commit_quorum,

src/lib/replication/repl_dev/raft_repl_dev.h

@@ -322,6 +322,8 @@ class RaftReplDev : public ReplDev,
     void pause_state_machine(size_t timeout) override;
     void resume_state_machine() override;
     bool is_state_machine_paused() override;
+    bool add_data_rpc_service(std::string const& request_name,
+                              data_service_request_handler_t const& request_handler) override;
 
     std::shared_ptr< snapshot_context > deserialize_snapshot_context(sisl::io_blob_safe& snp_ctx) override {
         return std::make_shared< nuraft_snapshot_context >(snp_ctx);