From aa1542b6d6a4680088ac715c4ce40f97ada554fb Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期三, 14 四月 2021 17:52:31 +0800
Subject: [PATCH] add SendQ TrySend() TryRecv(); handle re-register.
---
utest/speed_test.cpp | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/utest/speed_test.cpp b/utest/speed_test.cpp
index 7f77b02..0c40f14 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");
@@ -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