summaryrefslogtreecommitdiff
path: root/test/pkev.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'test/pkev.cpp')
-rw-r--r--test/pkev.cpp54
1 files changed, 33 insertions, 21 deletions
diff --git a/test/pkev.cpp b/test/pkev.cpp
index 61835df..a577e66 100644
--- a/test/pkev.cpp
+++ b/test/pkev.cpp
@@ -6,6 +6,9 @@
#include "../pkev.h"
+#define PK_IMPL_TST
+#include "../pktst.h"
+
#include <csetjmp>
#include <future>
#include <stdatomic.h>
@@ -103,11 +106,13 @@ int main(int argc, char *argv[])
pk_ev_emit(evmgr, ev_two.evid, &handle_ev_two);
PK_LOGV_INF("%s: ev_one: %lu, ev_two: %lu\n", __FILE__, ev_one.evid, ev_two.evid);
PK_LOGV_INF("%s: ev_one: %s, ev_two: %s\n", __FILE__, ev_one.handled ? "true" : "false", ev_two.handled ? "true" : "false");
- pk_ev_teardown();
+ test_teardown();
fflush(stdout);
fflush(stderr);
- if (ev_one.evid != 0 || ev_two.evid != 1) exit(1);
- if (ev_one.handled == false || ev_two.handled == false) exit(1);
+ PK_TEST_ASSERT_EQ_EXIT(0, ev_one.evid);
+ PK_TEST_ASSERT_EQ_EXIT(1, ev_two.evid);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_one.handled);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_two.handled);
}
// register, emit, clear
@@ -125,10 +130,11 @@ int main(int argc, char *argv[])
pk_ev_emit(evmgr, ev_one.evid, &handle_ev_one);
pk_ev_emit(evmgr, ev_two.evid, &handle_ev_two);
PK_LOGV_INF("%s: ev_one: %s, ev_two: %s\n", __FILE__, ev_one.handled ? "true" : "false", ev_two.handled ? "true" : "false");
- pk_ev_teardown();
+ test_teardown();
fflush(stdout);
fflush(stderr);
- if (ev_one.handled == true || ev_two.handled == false) exit(1);
+ PK_TEST_ASSERT_NEQ_EXIT(true, ev_one.handled);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_two.handled);
}
// register, emit, clear, register
@@ -145,7 +151,8 @@ int main(int argc, char *argv[])
PK_LOGV_INF("%s: ev_one: %lu, ev_two: %lu\n", __FILE__, ev_one.evid, ev_two.evid);
fflush(stdout);
fflush(stderr);
- if (ev_one.evid != 0 || ev_two.evid != 1) exit(1);
+ PK_TEST_ASSERT_EQ_EXIT(0, ev_one.evid);
+ PK_TEST_ASSERT_EQ_EXIT(1, ev_two.evid);
pk_ev_unregister_ev(ev_one.evmgr, ev_one.evid);
pk_ev_emit(evmgr, ev_one.evid, &handle_ev_one);
@@ -153,7 +160,8 @@ int main(int argc, char *argv[])
PK_LOGV_INF("%s: ev_one: %s, ev_two: %s\n", __FILE__, ev_one.handled ? "true" : "false", ev_two.handled ? "true" : "false");
fflush(stdout);
fflush(stderr);
- if (ev_one.handled == true || ev_two.handled == false) exit(1);
+ PK_TEST_ASSERT_NEQ_EXIT(true, ev_one.handled);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_two.handled);
pk_ev_unregister_ev(ev_two.evmgr, ev_two.evid);
std::packaged_task<void()> handle_ev_thr([](){ ev_one.handled = true; });
@@ -167,16 +175,18 @@ int main(int argc, char *argv[])
PK_LOGV_INF("%s: ev_one: %lu, ev_two: %lu\n", __FILE__, ev_one.evid, ev_two.evid);
fflush(stdout);
fflush(stderr);
- if (ev_one.evid != 0 || ev_two.evid != 1) exit(1);
+ PK_TEST_ASSERT_EQ_EXIT(0, ev_one.evid);
+ PK_TEST_ASSERT_EQ_EXIT(1, ev_two.evid);
pk_ev_emit(evmgr, ev_one.evid, &handle_ev_thr);
pk_ev_emit(evmgr, ev_two.evid, &handle_ev_for);
PK_LOGV_INF("%s: ev_one: %s, ev_two: %s\n", __FILE__, ev_one.handled ? "true" : "false", ev_two.handled ? "true" : "false");
fflush(stdout);
fflush(stderr);
- if (ev_one.handled == false || ev_two.handled == false) exit(1);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_one.handled);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_two.handled);
- pk_ev_teardown();
+ test_teardown();
}
// threaded register, emit
@@ -198,11 +208,13 @@ int main(int argc, char *argv[])
t2.join();
PK_LOGV_INF("%s: ev_one: %lu, ev_two: %lu\n", __FILE__, ev_one.evid, ev_two.evid);
PK_LOGV_INF("%s: ev_one: %s, ev_two: %s\n", __FILE__, ev_one.handled ? "true" : "false", ev_two.handled ? "true" : "false");
- pk_ev_teardown();
+ test_teardown();
fflush(stdout);
fflush(stderr);
- if (ev_one.evid != 0 || ev_two.evid != 1) exit(1);
- if (ev_one.handled == false || ev_two.handled == false) exit(1);
+ PK_TEST_ASSERT_EQ_EXIT(0, ev_one.evid);
+ PK_TEST_ASSERT_EQ_EXIT(1, ev_two.evid);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_one.handled);
+ PK_TEST_ASSERT_NEQ_EXIT(false, ev_two.handled);
}
// overload cbs and evs (grow once)
@@ -232,16 +244,16 @@ int main(int argc, char *argv[])
PK_LOGV_INF("%s: ev# %.2zu: %s, called count: %i\n", __FILE__, i, evs[i].handled ? "true" : "false", atomic_load(&evs[i].count));
any_false = any_false || !evs[i].handled;
}
- pk_ev_teardown();
+ test_teardown();
fflush(stdout);
fflush(stderr);
- if (any_false == true) exit(1);
+ PK_TEST_ASSERT_NEQ_EXIT(true, any_false);
}
// overload cbs and evs (test limits)
{
const uint64_t cb_count = 255;
- const uint64_t ev_count = 255;
+ const uint64_t ev_count = 64;
struct ev evs[ev_count] = {};
const pk_ev_mgr_id_T evmgr = test_setup();
for (i = 0; i < ev_count; ++i) {
@@ -271,10 +283,10 @@ int main(int argc, char *argv[])
any_false = any_false || !evs[i].handled;
}
PK_LOGV_INF("%s: #valid: %lu, #partial_valid: %lu, called count: %i\n", __FILE__, valid_count, partial_valid_count, atomic_load(&evs[0].count));
- pk_ev_teardown();
+ test_teardown();
fflush(stdout);
fflush(stderr);
- if (any_false == true) exit(1);
+ PK_TEST_ASSERT_NEQ_EXIT(true, any_false);
}
// overload cbs and evs (enforce uint8_t limits)
@@ -291,7 +303,7 @@ int main(int argc, char *argv[])
if (expected_exit == true && caught == true) {
expected_exit = false;
caught = false;
- pk_ev_teardown();
+ test_teardown();
PK_LOGV_INF("%s: successfully caught err.\n", __FILE__);
fflush(stdout);
fflush(stderr);
@@ -330,7 +342,7 @@ int main(int argc, char *argv[])
if (expected_exit == true && caught == true) {
expected_exit = false;
caught = false;
- pk_ev_teardown();
+ test_teardown();
PK_LOGV_INF("%s: successfully caught err.\n", __FILE__);
fflush(stdout);
fflush(stderr);
@@ -377,7 +389,7 @@ int main(int argc, char *argv[])
pk_ev_destroy_mgr(pk_ev_mgr_id_T{i});
}
- pk_ev_teardown();
+ test_teardown();
}
while (false);
generated by cgit v1.2.3 (git 2.39.1) at 2026-01-03 14:46:32 +0000