add logging, use boost.log.

lichao

2021-05-06 0117d5f8ff386075b0c4cbec0cbe460fe3cfa680

 src/topic_node.cpp

@@ -44,7 +44,7 @@

TopicNode::~TopicNode()
{
   printf("~TopicNode()\n");
   LOG_DEBUG() << "~TopicNode()";
   Stop();
}

@@ -59,7 +59,7 @@
   if (ssn_id_ == 0) {
      ssn_id_ = ShmMsgQueue::NewId();
   }
   printf("Node Init, id %ld \n", ssn_id_);
   LOG_DEBUG() << "Node Init, id " << ssn_id_;
   MsgI msg;
   msg.OffsetRef() = ssn_id_;
   if (ShmMsgQueue::TrySend(shm(), BHInitAddress(), msg)) {
@@ -95,9 +95,9 @@
}
void TopicNode::Stop()
{
   printf("Node Stopping\n");
   LOG_DEBUG() << "Node Stopping";
   for (auto &p : sockets_) { p->Stop(); }
   printf("Node Stopped\n");
   LOG_INFO() << "Node Stopped";
}

bool TopicNode::Register(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms)
@@ -423,7 +423,7 @@

      BHAddress addr;
      if (ClientQueryRPCTopic(request.topic(), addr, timeout_ms)) {
         // printf("node: %ld, topic dest: %ld\n", SockNode().id(), addr.mq_id());
         LOG_TRACE() << "node: " << SockNode().id() << ", topic dest: " << addr.mq_id();
         BHMsgHead head(InitMsgHead(GetType(request), proc_id(), ssn()));
         AddRoute(head, sock.id());
         head.set_topic(request.topic());