From 708ff9e8af731e2799767ed8bfca7df3b74fc26a Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 16 四月 2021 19:20:21 +0800
Subject: [PATCH] sendq use less shm, copy data.
---
utest/api_test.cpp | 19 ++++++++++++++++---
1 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/utest/api_test.cpp b/utest/api_test.cpp
index 58c73c6..da51044 100644
--- a/utest/api_test.cpp
+++ b/utest/api_test.cpp
@@ -138,6 +138,19 @@
}
}
+namespace
+{
+struct CCC {
+};
+void F(CCC &&c) {}
+
+template <class... T>
+void Pass(T &&...t)
+{
+ F(std::forward<decltype(t)>(t)...);
+}
+
+} // namespace
BOOST_AUTO_TEST_CASE(ApiTest)
{
auto max_time = std::chrono::steady_clock::time_point::max();
@@ -241,7 +254,7 @@
MsgStatus last;
while (*run) {
auto &st = Status();
- std::this_thread::sleep_for(1s);
+ Sleep(1s, false);
printf("nreq: %8ld, spd %8ld | failed: %8ld | nsrv: %8ld, spd %8ld | nreply: %8ld, spd %8ld\n",
st.nrequest_.load(), st.nrequest_ - last.nrequest_,
st.nfailed_.load(),
@@ -270,8 +283,8 @@
int same = 0;
int64_t last = 0;
- while (last < nreq * ncli && same < 3) {
- Sleep(1s);
+ while (last < nreq * ncli && same < 2) {
+ Sleep(1s, false);
auto cur = Status().nreply_.load();
if (last == cur) {
++same;
--
Gitblit v1.8.0