From c6964d5af25d4ec7ed9dbe7674dc4e3896b36ead Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 16 四月 2021 16:10:02 +0800
Subject: [PATCH] node remove mq if never registered; refactor.
---
utest/speed_test.cpp | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/utest/speed_test.cpp b/utest/speed_test.cpp
index 77c018a..52fe824 100644
--- a/utest/speed_test.cpp
+++ b/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()) {
}
--
Gitblit v1.8.0