mirror of
https://github.com/ByteWelder/Tactility.git
synced 2026-02-18 19:03:16 +00:00
79e43b093a
* **New Features** * Added public accessors for querying module/device start and ready state. * **Refactor** * Internal state moved to opaque internal objects; module/device/driver initializers now explicitly initialize internal pointers. * Lifecycle handling updated to construct/destruct internal state and use accessors. * **Tests** * Tests updated to use public accessors and explicit construct/destruct lifecycle calls. * **Chores** * Test build/include paths and small metadata updated.
113 lines
3.1 KiB
C++
113 lines
3.1 KiB
C++
#include "doctest.h"
|
|
|
|
#include <tactility/delay.h>
|
|
#include <tactility/concurrent/thread.h>
|
|
|
|
TEST_CASE("when a thread is started then its callback should be called") {
|
|
bool has_called = false;
|
|
auto* thread = thread_alloc_full(
|
|
"immediate return task",
|
|
4096,
|
|
[](void* context) {
|
|
auto* has_called_ptr = static_cast<bool*>(context);
|
|
*has_called_ptr = true;
|
|
return 0;
|
|
},
|
|
&has_called,
|
|
-1
|
|
);
|
|
|
|
CHECK(!has_called);
|
|
CHECK_EQ(thread_start(thread), ERROR_NONE);
|
|
CHECK_EQ(thread_join(thread, 2, 1), ERROR_NONE);
|
|
thread_free(thread);
|
|
CHECK(has_called);
|
|
}
|
|
|
|
TEST_CASE("a thread can be started and stopped") {
|
|
bool interrupted = false;
|
|
auto* thread = thread_alloc_full(
|
|
"interruptable thread",
|
|
4096,
|
|
[](void* context) {
|
|
auto* interrupted_ptr = static_cast<bool*>(context);
|
|
while (!*interrupted_ptr) {
|
|
delay_millis(1);
|
|
}
|
|
return 0;
|
|
},
|
|
&interrupted,
|
|
-1
|
|
);
|
|
|
|
CHECK(thread);
|
|
CHECK_EQ(thread_start(thread), ERROR_NONE);
|
|
interrupted = true;
|
|
CHECK_EQ(thread_join(thread, 2, 1), ERROR_NONE);
|
|
thread_free(thread);
|
|
}
|
|
|
|
TEST_CASE("thread id should only be set at when thread is started") {
|
|
bool interrupted = false;
|
|
auto* thread = thread_alloc_full(
|
|
"interruptable thread",
|
|
4096,
|
|
[](void* context) {
|
|
auto* interrupted_ptr = static_cast<bool*>(context);
|
|
while (!*interrupted_ptr) {
|
|
delay_millis(1);
|
|
}
|
|
return 0;
|
|
},
|
|
&interrupted,
|
|
-1
|
|
);
|
|
CHECK_EQ(thread_get_task_handle(thread), nullptr);
|
|
CHECK_EQ(thread_start(thread), ERROR_NONE);
|
|
CHECK_NE(thread_get_task_handle(thread), nullptr);
|
|
interrupted = true;
|
|
CHECK_EQ(thread_join(thread, 2, 1), ERROR_NONE);
|
|
CHECK_EQ(thread_get_task_handle(thread), nullptr);
|
|
thread_free(thread);
|
|
}
|
|
|
|
TEST_CASE("thread state should be correct") {
|
|
bool interrupted = false;
|
|
auto* thread = thread_alloc_full(
|
|
"interruptable thread",
|
|
4096,
|
|
[](void* context) {
|
|
auto* interrupted_ptr = static_cast<bool*>(context);
|
|
while (!*interrupted_ptr) {
|
|
delay_millis(1);
|
|
}
|
|
return 0;
|
|
},
|
|
&interrupted,
|
|
-1
|
|
|
|
);
|
|
CHECK_EQ(thread_get_state(thread), THREAD_STATE_STOPPED);
|
|
thread_start(thread);
|
|
auto state = thread_get_state(thread);
|
|
CHECK((state == THREAD_STATE_STARTING || state == THREAD_STATE_RUNNING));
|
|
interrupted = true;
|
|
CHECK_EQ(thread_join(thread, 10, 1), ERROR_NONE);
|
|
CHECK_EQ(thread_get_state(thread), THREAD_STATE_STOPPED);
|
|
thread_free(thread);
|
|
}
|
|
|
|
TEST_CASE("thread id should only be set at when thread is started") {
|
|
auto* thread = thread_alloc_full(
|
|
"return code",
|
|
4096,
|
|
[](void* context) { return 123; },
|
|
nullptr,
|
|
-1
|
|
);
|
|
CHECK_EQ(thread_start(thread), ERROR_NONE);
|
|
CHECK_EQ(thread_join(thread, 1, 1), ERROR_NONE);
|
|
CHECK_EQ(thread_get_return_code(thread), 123);
|
|
thread_free(thread);
|
|
}
|