mod: no protected methods feat: dispatcher with tags

Author: eigen-value

src/client.h

@@ -44,7 +44,6 @@ class RPCClient {
 
     }
 
-protected:
     template<typename... Args>
     bool send_rpc(const MsgPack::str_t method, Args&&... args) {
         int msg_id;

src/dispatcher.h

@@ -6,21 +6,22 @@
 
 struct DispatchEntry {
     MsgPack::str_t name;
+    MsgPack::str_t tag;
     IFunctionWrapper* fn;
 };
 
 template<size_t N>
 class RpcFunctionDispatcher {
 public:
     template<typename F>
-    bool bind(MsgPack::str_t name, F&& f) {
+    bool bind(MsgPack::str_t name, F&& f, MsgPack::str_t tag="") {
         if (_count >= N) return false;
 
         if (isBound(name)) return false;
 
         using WrapperT = decltype(wrap(std::forward<F>(f)));
         WrapperT* instance = new WrapperT(wrap(std::forward<F>(f)));
-        _entries[_count++] = {name, instance};
+        _entries[_count++] = {name, tag, instance};
         return true;
     }
 
@@ -33,6 +34,15 @@ class RpcFunctionDispatcher {
         return false;
     }
 
+    bool hasTag(MsgPack::str_t name,MsgPack::str_t tag) const {
+        for (size_t i = 0; i < _count; ++i) {
+            if (_entries[i].name == name && _entries[i].tag == tag) {
+                return true;
+            }
+        }
+        return false;
+    }
+
     bool call(MsgPack::str_t name, MsgPack::Unpacker& unpacker, MsgPack::Packer& packer) {
         for (size_t i = 0; i < _count; ++i) {
             if (_entries[i].name == name) {

src/server.h

@@ -23,8 +23,12 @@ class RPCServer {
     // }
 
     template<typename F>
-    bool bind(const MsgPack::str_t& name, F&& func){
-        return dispatcher.bind(name, func);
+    bool bind(const MsgPack::str_t& name, F&& func, MsgPack::str_t& tag){
+        return dispatcher.bind(name, func, tag);
+    }
+
+    bool hasTag(MsgPack::str_t name, MsgPack::str_t tag){
+        return dispatcher.hasTag(name, tag);
     }
 
     void run() {
@@ -34,15 +38,15 @@ class RPCServer {
         //delay(1);
     }
 
-protected:
     bool get_rpc() {
         decoder->decode();
         if (_rpc_size > 0) return true; // Already have a request
+        // TODO USE A QUEUE
         _rpc_size = decoder->get_request(_rpc_buffer, RPC_BUFFER_SIZE);
         return _rpc_size > 0;
     }
 
-    void process_request() {
+    void process_request(MsgPack::str_t tag="") {
         if (_rpc_size == 0) return;
 
         MsgPack::Unpacker unpacker;
@@ -78,6 +82,8 @@ class RPCServer {
             return; // Invalid request size/type
         }
 
+        if (!hasTag(method, tag)) return;
+
         _rpc_type = msg_type;
 
         MsgPack::arr_size_t resp_size(RESPONSE_SIZE);