change SendQ data from variant to int64.

lichao

2021-05-14 34bc326eab06b9b1da2004a9e0d2182d63501d68

 src/topic_node.h

@@ -122,13 +122,21 @@
         eSockSub,
         eSockEnd,
   };
   std::vector<std::unique_ptr<ShmSocket>> sockets_;
   std::vector<std::shared_ptr<ShmSocket>> sockets_;

   ShmSocket &SockNode() { return *sockets_[eSockNode]; }
   ShmSocket &SockPub() { return *sockets_[eSockPub]; }
   ShmSocket &SockSub() { return *sockets_[eSockSub]; }
   ShmSocket &SockClient() { return *sockets_[eSockClient]; }
   ShmSocket &SockServer() { return *sockets_[eSockServer]; }

   void SetProcIndex(int index)
   {
      proc_index_ = index;
      for (int i = eSockStart; i < eSockEnd; ++i) {
         sockets_[i]->SetNodeProc(index, i);
      }
   }

   enum State {
      eStateUnregistered,
@@ -144,6 +152,7 @@
   std::mutex mutex_;
   MQId ssn_id_ = 0;
   std::atomic<State> state_;
   int proc_index_ = -1;

   TopicQueryCache topic_query_cache_;
};