lichao
2021-04-30 d33a69463f1a75134d01191be0b9e1bdd757dd4b
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());