tcp server call center to send proxy requests.

lichao

2021-05-27 026bbfaf2b5d73a26b8e2fa49158883ef64c211b

 src/shm_socket.h

@@ -68,16 +68,16 @@

   bool RequestAlloc(const int64_t size, std::function<void(MsgI &msg)> const &onResult);

   bool Send(const MQInfo &remote, const MsgI &msg, const std::string &msg_id, RecvCB &&cb);
   template <class Body>
   bool Send(const MQInfo &remote, BHMsgHead &head, Body &body, RecvCB &&cb = RecvCB())
   {
      return Send(remote, MsgI::Serialize(head, body), head.msg_id(), std::move(cb));
   }
   template <class... T>
   bool Send(const MQInfo &remote, const MsgI &imsg, T &&...t)
   {
      return SendImpl(remote, imsg, std::forward<decltype(t)>(t)...);
   }
   bool Send(const MQInfo &remote, BHMsgHead &head, Body &body, RecvCB &&cb) { return Send(remote, MsgI::Serialize(head, body), head.msg_id(), std::move(cb)); }
   bool Send(const MQInfo &remote, std::string &&content, const std::string &msg_id, RecvCB &&cb);

   template <class Body>
   bool Send(const MQInfo &remote, BHMsgHead &head, Body &body) { return Send(remote, MsgI::Serialize(head, body)); }
   bool Send(const MQInfo &remote, std::string &&content);
   bool Send(const MQInfo &remote, const MsgI &imsg) { return SendImpl(remote, imsg); }

   template <class... T>
   bool Send(const MQInfo &remote, const int64_t cmd, T &&...t)
   {
@@ -135,8 +135,6 @@
private:
   bool StopNoLock();
   bool RunningNoLock() { return !workers_.empty(); }

   bool Send(const MQInfo &remote, std::string &&content, const std::string &msg_id, RecvCB &&cb = RecvCB());

   template <class... Rest>
   bool SendImpl(Rest &&...rest)