refactor mutex.

lichao

2021-04-29 72bffb0807925a156b076b71f78c848a08d27b87

 src/topic_node.cpp

@@ -389,7 +389,7 @@

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