From 1fbfef2a51db4a3bac9d8a5b87af94a40a913b7a Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期日, 25 四月 2021 15:33:40 +0800
Subject: [PATCH] change mqid from uuid to uint64.
---
utest/speed_test.cpp | 12 +++++-------
1 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/utest/speed_test.cpp b/utest/speed_test.cpp
index 4615c53..d145ab4 100644
--- a/utest/speed_test.cpp
+++ b/utest/speed_test.cpp
@@ -26,7 +26,7 @@
SharedMemory &shm = TestShm();
MsgI::BindShm(shm);
- MQId id = boost::uuids::random_generator()();
+ MQId id = ShmMsgQueue::NewId();
const int timeout = 1000;
const uint32_t data_size = 4000;
const std::string proc_id = "demo_proc";
@@ -157,8 +157,8 @@
req_body.set_topic("topic");
req_body.set_data(msg_content);
auto req_head(InitMsgHead(GetType(req_body), client_proc_id));
- req_head.add_route()->set_mq_id(&cli.id(), cli.id().size());
- return cli.Send(&srv.id(), req_head, req_body);
+ req_head.add_route()->set_mq_id(cli.id());
+ return cli.Send(srv.id(), req_head, req_body);
};
Req();
@@ -175,15 +175,13 @@
DEFER1(req.Release());
if (req.ParseHead(req_head) && req_head.type() == kMsgTypeRequestTopic) {
- auto &mqid = req_head.route()[0].mq_id();
- MQId src_id;
- memcpy(&src_id, mqid.data(), sizeof(src_id));
+ auto src_id = req_head.route()[0].mq_id();
auto Reply = [&]() {
MsgRequestTopic reply_body;
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);
+ return srv.Send(src_id, reply_head, reply_body);
};
Reply();
}
--
Gitblit v1.8.0