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/robust_test.cpp | 45 ++++++++++++++++++++++++++-------------------
1 files changed, 26 insertions(+), 19 deletions(-)
diff --git a/utest/robust_test.cpp b/utest/robust_test.cpp
index 0645918..e7b8894 100644
--- a/utest/robust_test.cpp
+++ b/utest/robust_test.cpp
@@ -39,19 +39,24 @@
std::atomic<uint64_t> nwrite(0);
std::atomic<uint64_t> writedone(0);
-#if 0
- typedef AtomicQueue<4> Rcb;
+#if 1
+ const int kPower = 0;
+ typedef AtomicQueue<kPower> Rcb;
Rcb tmp;
- BOOST_CHECK(tmp.like_empty());
+ // BOOST_CHECK(tmp.like_empty());
BOOST_CHECK(tmp.push(1));
- BOOST_CHECK(tmp.tail() == 1);
+ if (kPower != 0) {
+ BOOST_CHECK(tmp.tail() == 1);
+ }
BOOST_CHECK(tmp.head() == 0);
int64_t d;
BOOST_CHECK(tmp.pop(d));
- BOOST_CHECK(tmp.like_empty());
- BOOST_CHECK(tmp.head() == 1);
- BOOST_CHECK(tmp.tail() == 1);
+ if (kPower != 0) {
+ // BOOST_CHECK(tmp.like_empty());
+ BOOST_CHECK(tmp.head() == 1);
+ BOOST_CHECK(tmp.tail() == 1);
+ }
ShmObject<Rcb> rcb(shm, "test_rcb");
bool try_more = true;
@@ -166,18 +171,20 @@
BOOST_AUTO_TEST_CASE(MutexTest)
{
{
- int fd = open("/tmp/test_fmutex", O_CREAT | O_RDONLY, 0666);
- flock(fd, LOCK_EX);
- printf("lock 1");
+ int sem_id = semget(100, 1, 0666 | IPC_CREAT);
+ auto P = [&]() {
+ sembuf op = {0, -1, SEM_UNDO};
+ semop(sem_id, &op, 1);
+ };
+ auto V = [&]() {
+ sembuf op = {0, 1, SEM_UNDO};
+ semop(sem_id, &op, 1);
+ };
+ for (int i = 0; i < 10; ++i) {
+ V();
+ }
Sleep(10s);
- flock(fd, LOCK_EX);
- printf("lock 2");
- Sleep(10s);
- flock(fd, LOCK_UN);
- printf("un lock 2");
- Sleep(10s);
- flock(fd, LOCK_UN);
- printf("un lock 1");
+
return;
}
@@ -204,7 +211,7 @@
std::mutex m;
typedef std::chrono::steady_clock Clock;
- auto Now = []() { return Clock::now().time_since_epoch(); };
+
if (pi) {
auto old = *pi;
printf("int : %d, add1: %d\n", old, ++*pi);
--
Gitblit v1.8.0