node remove mq if never registered; refactor.

lichao

2021-04-16 c6964d5af25d4ec7ed9dbe7674dc4e3896b36ead

 utest/speed_test.cpp

@@ -161,9 +161,9 @@
            req_body.set_topic("topic");
            req_body.set_data(msg_content);
            auto req_head(InitMsgHead(GetType(req_body), client_proc_id));
            return cli.Send(&srv.id(), req_head, req_body, 100);
            return cli.Send(&srv.id(), req_head, req_body);
         };
         auto ReqRC = [&]() { return cli.Send(&srv.id(), request_rc, 1000); };
         auto ReqRC = [&]() { return cli.Send(&srv.id(), request_rc); };

         if (!ReqRC()) {
            printf("********** client send error.\n");
@@ -192,7 +192,7 @@
      BHMsgHead req_head;

      while (!stop) {
         if (srv.SyncRecv(req, req_head, 100)) {
         if (srv.SyncRecv(req, req_head, 10)) {
            DEFER1(req.Release(shm));

            if (req.ParseHead(req_head) && req_head.type() == kMsgTypeRequestTopic) {
@@ -204,9 +204,9 @@
                  reply_body.set_topic("topic");
                  reply_body.set_data(msg_content);
                  auto reply_head(InitMsgHead(GetType(reply_body), server_proc_id, req_head.msg_id()));
                  return srv.Send(&src_id, reply_head, reply_body, 100);
                  return srv.Send(&src_id, reply_head, reply_body);
               };
               auto ReplyRC = [&]() { return srv.Send(&src_id, reply_rc, 100); };
               auto ReplyRC = [&]() { return srv.Send(&src_id, reply_rc); };

               if (ReplyRC()) {
               }