From 25fe38c33eebfc5ecf1b4ed8be6bfd74ee0736cf Mon Sep 17 00:00:00 2001
From: Mitya Selivanov <0x7fffff@guattari.ru>
Date: Thu, 18 Aug 2022 19:07:35 +0400
Subject: [test] Cond var
---
source/test/unittests/condition_variable.test.c | 67 ++++++++++++++++---------
1 file changed, 43 insertions(+), 24 deletions(-)
(limited to 'source/test/unittests')
diff --git a/source/test/unittests/condition_variable.test.c b/source/test/unittests/condition_variable.test.c
index 079cf2d..b7fc7db 100644
--- a/source/test/unittests/condition_variable.test.c
+++ b/source/test/unittests/condition_variable.test.c
@@ -7,6 +7,8 @@
typedef struct {
mtx_t m;
+ int in;
+ int out;
cnd_t send;
cnd_t receive;
int value;
@@ -17,13 +19,17 @@ static int test_run(void *p) {
mtx_lock(&data->m);
data->value = 20;
+ data->out = 1;
mtx_unlock(&data->m);
cnd_broadcast(&data->send);
mtx_lock(&data->m);
- cnd_wait(&data->receive, &data->m);
+ if (data->in == 0)
+ cnd_wait(&data->receive, &data->m);
+ data->in = 0;
data->value = 22;
+ data->out = 1;
mtx_unlock(&data->m);
cnd_broadcast(&data->send);
@@ -32,34 +38,47 @@ static int test_run(void *p) {
}
TEST("condition variable") {
- /*
- test_data_t data;
- REQUIRE(mtx_init(&data.m, mtx_plain) == thrd_success);
- REQUIRE(cnd_init(&data.send) == thrd_success);
- REQUIRE(cnd_init(&data.receive) == thrd_success);
- data.value = 0;
+ int ok = 1;
- thrd_t t;
- REQUIRE(thrd_create(&t, test_run, &data) == thrd_success);
+ for (int i = 0; i < 10; i++) {
+ test_data_t data;
- REQUIRE(mtx_lock(&data.m) == thrd_success);
- REQUIRE(cnd_wait(&data.send, &data.m) == thrd_success);
- int x = data.value;
- REQUIRE(mtx_unlock(&data.m) == thrd_success);
+ data.in = 0;
+ data.out = 0;
+ data.value = 0;
- REQUIRE(cnd_broadcast(&data.receive) == thrd_success);
+ ok = ok && (mtx_init(&data.m, mtx_plain) == thrd_success);
+ ok = ok && (cnd_init(&data.send) == thrd_success);
+ ok = ok && (cnd_init(&data.receive) == thrd_success);
- REQUIRE(mtx_lock(&data.m) == thrd_success);
- REQUIRE(cnd_wait(&data.send, &data.m) == thrd_success);
- x += data.value;
- REQUIRE(mtx_unlock(&data.m) == thrd_success);
+ thrd_t t;
+ ok = ok && (thrd_create(&t, test_run, &data) == thrd_success);
- REQUIRE(thrd_join(t, NULL) == thrd_success);
+ ok = ok && (mtx_lock(&data.m) == thrd_success);
+ if (data.out == 0)
+ ok = ok && (cnd_wait(&data.send, &data.m) == thrd_success);
+ data.out = 0;
+ int x = data.value;
+ data.in = 1;
+ ok = ok && (mtx_unlock(&data.m) == thrd_success);
- mtx_destroy(&data.m);
- cnd_destroy(&data.send);
- cnd_destroy(&data.receive);
+ ok = ok && (cnd_broadcast(&data.receive) == thrd_success);
- REQUIRE(x == 42);
- */
+ ok = ok && (mtx_lock(&data.m) == thrd_success);
+ if (data.out == 0)
+ ok = ok && (cnd_wait(&data.send, &data.m) == thrd_success);
+ data.out = 0;
+ x += data.value;
+ ok = ok && (mtx_unlock(&data.m) == thrd_success);
+
+ ok = ok && (thrd_join(t, NULL) == thrd_success);
+
+ mtx_destroy(&data.m);
+ cnd_destroy(&data.send);
+ cnd_destroy(&data.receive);
+
+ ok = ok && (x == 42);
+ }
+
+ REQUIRE(ok);
}
--
cgit v1.2.3