From 9cf3ddc288193e2fe645f34388322f9586ee043d Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期三, 24 三月 2021 16:23:24 +0800
Subject: [PATCH] change mq id from int to uuid.
---
utest/utest.cpp | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/utest/utest.cpp b/utest/utest.cpp
index 11af676..c128d37 100644
--- a/utest/utest.cpp
+++ b/utest/utest.cpp
@@ -109,7 +109,7 @@
const std::string shm_name("shm_wait");
ShmRemover auto_remove(shm_name);
SharedMemory shm(shm_name, 1024*1024);
- ShmMsgQueue q(10000, shm, 64);
+ ShmMsgQueue q(shm, 64);
for (int i = 0; i < 5; ++i) {
int ms = i * 100;
printf("Timeout Test %d: ", ms);
@@ -132,8 +132,8 @@
auto f0 = init_avail;
const int qlen = 64;
- ShmMsgQueue srv(1, shm, qlen);
- ShmMsgQueue cli(2, shm, qlen);
+ ShmMsgQueue srv(shm, qlen);
+ ShmMsgQueue cli(shm, qlen);
auto f1= shm.get_free_memory();
const size_t msg_length = 1000;
@@ -148,11 +148,11 @@
auto Client = [&](int tid, int nmsg){
for (int i = 0; i < nmsg; ++i) {
- if (!cli.Send(srv.id(), msg_content.data(), msg_content.size(), 1000)) {
+ if (!cli.Send(srv.Id(), msg_content.data(), msg_content.size(), 1000)) {
printf("********** client send error.\n");
continue;
}
- MQId id = 0;
+ MQId id;
void *data = 0;
size_t size = 0;
if (!cli.Recv(id, data, size, 1000)) {
@@ -177,7 +177,7 @@
auto Server = [&](){
void *data = 0;
size_t size = 0;
- MQId src_id = 0;
+ MQId src_id;
while (!stop) {
if (srv.Recv(src_id, data, size, 100)) {
DEFER1(free(data));
--
Gitblit v1.8.0