From 1ff714838c03cba1a18884d5b48a20ee6c4275ac Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 21 五月 2021 15:00:53 +0800
Subject: [PATCH] class MsgI, ShmMsgQueue, no bind to shm.
---
utest/speed_test.cpp | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/utest/speed_test.cpp b/utest/speed_test.cpp
index ef56678..f33f0db 100644
--- a/utest/speed_test.cpp
+++ b/utest/speed_test.cpp
@@ -24,7 +24,7 @@
{
SharedMemory &shm = TestShm();
GlobalInit(shm);
- MQId server_id = ShmMsgQueue::NewId();
+ MQId server_id = NewSession();
ShmMsgQueue server(server_id, shm, 1000);
const int timeout = 1000;
@@ -35,10 +35,10 @@
std::string str(data_size, 'a');
auto Writer = [&](int writer_id, uint64_t n) {
- MQId cli_id = ShmMsgQueue::NewId();
+ MQId cli_id = NewSession();
ShmMsgQueue mq(cli_id, shm, 64);
- MsgI msg;
+ MsgI msg(shm);
MsgRequestTopic body;
body.set_topic("topic");
body.set_data(str);
@@ -58,7 +58,7 @@
auto now = []() { return steady_clock::now(); };
auto tm = now();
while (*run) {
- MsgI msg;
+ MsgI msg(shm);
BHMsgHead head;
if (mq.TryRecv(msg)) {
DEFER1(msg.Release());
@@ -149,8 +149,8 @@
auto Avail = [&]() { return shm.get_free_memory(); };
auto init_avail = Avail();
- ShmSocket srv(shm, ShmMsgQueue::NewId(), qlen);
- ShmSocket cli(shm, ShmMsgQueue::NewId(), qlen);
+ ShmSocket srv(shm, NewSession(), qlen);
+ ShmSocket cli(shm, NewSession(), qlen);
int ncli = 1;
uint64_t nmsg = 1000 * 1000 * 1;
--
Gitblit v1.8.0