add node init msg, alloc msgq on success.

lichao

2021-04-30 377e395a5fdc6ad44bdd5a2d41d2930f45fc4384

 src/topic_node.h

@@ -22,6 +22,7 @@
#include "socket.h"
#include <atomic>
#include <memory>
#include <mutex>
#include <vector>

using namespace bhome_shm;
@@ -137,7 +138,11 @@
   void state(const State st) { state_.store(st); }
   void state_cas(State expected, const State val) { state_.compare_exchange_strong(expected, val); }
   State state() const { return state_.load(); }
   bool IsOnline() const { return state() == eStateOnline; }
   bool IsOnline() { return Init() && state() == eStateOnline; }
   bool Init();
   bool Valid() const { return !sockets_.empty(); }
   std::mutex mutex_;
   MQId ssn_id_ = 0;
   std::atomic<State> state_;

   TopicQueryCache topic_query_cache_;