From db322f33ba13592f2492317e3f1a070454c97059 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期四, 13 五月 2021 19:34:46 +0800
Subject: [PATCH] center alloc all msgs.
---
utest/api_test.cpp | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/utest/api_test.cpp b/utest/api_test.cpp
index c6165e8..f48f307 100644
--- a/utest/api_test.cpp
+++ b/utest/api_test.cpp
@@ -118,6 +118,8 @@
printf("maxsec: %ld\n", CountSeconds(max_time));
+ // BHCleanup();
+ // return;
bool reg = false;
for (int i = 0; i < 3 && !reg; ++i) {
ProcInfo proc;
@@ -149,7 +151,7 @@
bool r = BHRegisterTopics(s.data(), s.size(), &reply, &reply_len, 1000);
BHFree(reply, reply_len);
// printf("register topic : %s\n", r ? "ok" : "failed");
- Sleep(1s);
+ // Sleep(1s);
}
{ // Subscribe
@@ -282,7 +284,7 @@
threads.Launch(hb, &run);
threads.Launch(showStatus, &run);
int ncli = 10;
- const uint64_t nreq = 1000 * 100;
+ const int64_t nreq = 1000 * 100;
for (int i = 0; i < ncli; ++i) {
threads.Launch(asyncRequest, nreq);
}
@@ -291,7 +293,7 @@
// }
int same = 0;
- int64_t last = 0;
+ uint64_t last = 0;
while (last < nreq * ncli && same < 2) {
Sleep(1s, false);
auto cur = Status().nreply_.load();
--
Gitblit v1.8.0