Denislam Valeev
/
Nucleo_rtos_basic
1
mbed-os/TESTS/mbedmicro-rtos-mbed/signals/main.cpp@0:e056ac8fecf8, 2018-03-13 (annotated)
- Committer:
- valeyev
- Date:
- Tue Mar 13 07:17:50 2018 +0000
- Revision:
- 0:e056ac8fecf8
looking for...
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
valeyev | 0:e056ac8fecf8 | 1 | /* mbed Microcontroller Library |
valeyev | 0:e056ac8fecf8 | 2 | * Copyright (c) 2017 ARM Limited |
valeyev | 0:e056ac8fecf8 | 3 | * |
valeyev | 0:e056ac8fecf8 | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
valeyev | 0:e056ac8fecf8 | 5 | * you may not use this file except in compliance with the License. |
valeyev | 0:e056ac8fecf8 | 6 | * You may obtain a copy of the License at |
valeyev | 0:e056ac8fecf8 | 7 | * |
valeyev | 0:e056ac8fecf8 | 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
valeyev | 0:e056ac8fecf8 | 9 | * |
valeyev | 0:e056ac8fecf8 | 10 | * Unless required by applicable law or agreed to in writing, software |
valeyev | 0:e056ac8fecf8 | 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
valeyev | 0:e056ac8fecf8 | 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
valeyev | 0:e056ac8fecf8 | 13 | * See the License for the specific language governing permissions and |
valeyev | 0:e056ac8fecf8 | 14 | * limitations under the License. |
valeyev | 0:e056ac8fecf8 | 15 | */ |
valeyev | 0:e056ac8fecf8 | 16 | #include "mbed.h" |
valeyev | 0:e056ac8fecf8 | 17 | #include "greentea-client/test_env.h" |
valeyev | 0:e056ac8fecf8 | 18 | #include "utest/utest.h" |
valeyev | 0:e056ac8fecf8 | 19 | #include "unity/unity.h" |
valeyev | 0:e056ac8fecf8 | 20 | |
valeyev | 0:e056ac8fecf8 | 21 | using utest::v1::Case; |
valeyev | 0:e056ac8fecf8 | 22 | |
valeyev | 0:e056ac8fecf8 | 23 | |
valeyev | 0:e056ac8fecf8 | 24 | #if defined(MBED_RTOS_SINGLE_THREAD) |
valeyev | 0:e056ac8fecf8 | 25 | #error [NOT_SUPPORTED] test not supported |
valeyev | 0:e056ac8fecf8 | 26 | #endif |
valeyev | 0:e056ac8fecf8 | 27 | |
valeyev | 0:e056ac8fecf8 | 28 | #define TEST_STACK_SIZE 512 |
valeyev | 0:e056ac8fecf8 | 29 | #define MAX_FLAG_POS 30 |
valeyev | 0:e056ac8fecf8 | 30 | |
valeyev | 0:e056ac8fecf8 | 31 | #define ALL_SIGNALS 0x7fffffff |
valeyev | 0:e056ac8fecf8 | 32 | #define NO_SIGNALS 0x0 |
valeyev | 0:e056ac8fecf8 | 33 | #define PROHIBITED_SIGNAL 0x80000000 |
valeyev | 0:e056ac8fecf8 | 34 | #define SIGNAL1 0x1 |
valeyev | 0:e056ac8fecf8 | 35 | #define SIGNAL2 0x2 |
valeyev | 0:e056ac8fecf8 | 36 | #define SIGNAL3 0x4 |
valeyev | 0:e056ac8fecf8 | 37 | |
valeyev | 0:e056ac8fecf8 | 38 | struct Sync { |
valeyev | 0:e056ac8fecf8 | 39 | Sync(Semaphore &parent, Semaphore &child): sem_parent(parent), sem_child(child) |
valeyev | 0:e056ac8fecf8 | 40 | {} |
valeyev | 0:e056ac8fecf8 | 41 | |
valeyev | 0:e056ac8fecf8 | 42 | Semaphore &sem_parent; |
valeyev | 0:e056ac8fecf8 | 43 | Semaphore &sem_child; |
valeyev | 0:e056ac8fecf8 | 44 | }; |
valeyev | 0:e056ac8fecf8 | 45 | |
valeyev | 0:e056ac8fecf8 | 46 | |
valeyev | 0:e056ac8fecf8 | 47 | /* In order to successfully run this test suite when compiled with --profile=debug |
valeyev | 0:e056ac8fecf8 | 48 | * error() has to be redefined as noop. |
valeyev | 0:e056ac8fecf8 | 49 | * |
valeyev | 0:e056ac8fecf8 | 50 | * ThreadFlags calls RTX API which uses Event Recorder functionality. When compiled |
valeyev | 0:e056ac8fecf8 | 51 | * with MBED_TRAP_ERRORS_ENABLED=1 (set in debug profile) EvrRtxEventFlagsError() calls error() |
valeyev | 0:e056ac8fecf8 | 52 | * which aborts test program. |
valeyev | 0:e056ac8fecf8 | 53 | */ |
valeyev | 0:e056ac8fecf8 | 54 | #if defined(MBED_TRAP_ERRORS_ENABLED) && MBED_TRAP_ERRORS_ENABLED |
valeyev | 0:e056ac8fecf8 | 55 | void error(const char* format, ...) { |
valeyev | 0:e056ac8fecf8 | 56 | (void) format; |
valeyev | 0:e056ac8fecf8 | 57 | } |
valeyev | 0:e056ac8fecf8 | 58 | #endif |
valeyev | 0:e056ac8fecf8 | 59 | |
valeyev | 0:e056ac8fecf8 | 60 | |
valeyev | 0:e056ac8fecf8 | 61 | template <int32_t signals, uint32_t timeout, int32_t test_val> |
valeyev | 0:e056ac8fecf8 | 62 | void run_signal_wait(void) |
valeyev | 0:e056ac8fecf8 | 63 | { |
valeyev | 0:e056ac8fecf8 | 64 | osEvent ev = Thread::signal_wait(signals, timeout); |
valeyev | 0:e056ac8fecf8 | 65 | TEST_ASSERT_EQUAL(test_val, ev.status); |
valeyev | 0:e056ac8fecf8 | 66 | } |
valeyev | 0:e056ac8fecf8 | 67 | |
valeyev | 0:e056ac8fecf8 | 68 | template <int32_t signals, uint32_t timeout, int32_t test_val> |
valeyev | 0:e056ac8fecf8 | 69 | void run_release_signal_wait(Semaphore *sem) |
valeyev | 0:e056ac8fecf8 | 70 | { |
valeyev | 0:e056ac8fecf8 | 71 | sem->release(); |
valeyev | 0:e056ac8fecf8 | 72 | osEvent ev = Thread::signal_wait(signals, timeout); |
valeyev | 0:e056ac8fecf8 | 73 | TEST_ASSERT_EQUAL(test_val, ev.status); |
valeyev | 0:e056ac8fecf8 | 74 | } |
valeyev | 0:e056ac8fecf8 | 75 | |
valeyev | 0:e056ac8fecf8 | 76 | template <int32_t signals, uint32_t timeout, int32_t test_val> |
valeyev | 0:e056ac8fecf8 | 77 | void run_release_wait_signal_wait(Sync *sync) |
valeyev | 0:e056ac8fecf8 | 78 | { |
valeyev | 0:e056ac8fecf8 | 79 | sync->sem_parent.release(); |
valeyev | 0:e056ac8fecf8 | 80 | sync->sem_child.wait(); |
valeyev | 0:e056ac8fecf8 | 81 | osEvent ev = Thread::signal_wait(signals, timeout); |
valeyev | 0:e056ac8fecf8 | 82 | TEST_ASSERT_EQUAL(test_val, ev.status); |
valeyev | 0:e056ac8fecf8 | 83 | } |
valeyev | 0:e056ac8fecf8 | 84 | |
valeyev | 0:e056ac8fecf8 | 85 | template <int32_t signals, int32_t test_val> |
valeyev | 0:e056ac8fecf8 | 86 | void run_clear(void) |
valeyev | 0:e056ac8fecf8 | 87 | { |
valeyev | 0:e056ac8fecf8 | 88 | int32_t ret = Thread::signal_clr(signals); |
valeyev | 0:e056ac8fecf8 | 89 | TEST_ASSERT_EQUAL(test_val, ret); |
valeyev | 0:e056ac8fecf8 | 90 | } |
valeyev | 0:e056ac8fecf8 | 91 | |
valeyev | 0:e056ac8fecf8 | 92 | template <int32_t signals, int32_t test_val> |
valeyev | 0:e056ac8fecf8 | 93 | void run_wait_clear(Sync *sync) |
valeyev | 0:e056ac8fecf8 | 94 | { |
valeyev | 0:e056ac8fecf8 | 95 | sync->sem_parent.release(); |
valeyev | 0:e056ac8fecf8 | 96 | sync->sem_child.wait(); |
valeyev | 0:e056ac8fecf8 | 97 | int32_t ret = Thread::signal_clr(signals); |
valeyev | 0:e056ac8fecf8 | 98 | TEST_ASSERT_EQUAL(test_val, ret); |
valeyev | 0:e056ac8fecf8 | 99 | } |
valeyev | 0:e056ac8fecf8 | 100 | |
valeyev | 0:e056ac8fecf8 | 101 | template <int32_t signals1, int32_t signals2, int32_t test_val1, int32_t test_val2> |
valeyev | 0:e056ac8fecf8 | 102 | void run_double_wait_clear(Sync *sync) |
valeyev | 0:e056ac8fecf8 | 103 | { |
valeyev | 0:e056ac8fecf8 | 104 | int32_t ret; |
valeyev | 0:e056ac8fecf8 | 105 | |
valeyev | 0:e056ac8fecf8 | 106 | sync->sem_parent.release(); |
valeyev | 0:e056ac8fecf8 | 107 | sync->sem_child.wait(); |
valeyev | 0:e056ac8fecf8 | 108 | ret = Thread::signal_clr(signals1); |
valeyev | 0:e056ac8fecf8 | 109 | TEST_ASSERT_EQUAL(test_val1, ret); |
valeyev | 0:e056ac8fecf8 | 110 | |
valeyev | 0:e056ac8fecf8 | 111 | ret = Thread::signal_clr(signals2); |
valeyev | 0:e056ac8fecf8 | 112 | TEST_ASSERT_EQUAL(test_val2, ret); |
valeyev | 0:e056ac8fecf8 | 113 | } |
valeyev | 0:e056ac8fecf8 | 114 | |
valeyev | 0:e056ac8fecf8 | 115 | void run_loop_wait_clear(Sync *sync) |
valeyev | 0:e056ac8fecf8 | 116 | { |
valeyev | 0:e056ac8fecf8 | 117 | int32_t signals = NO_SIGNALS; |
valeyev | 0:e056ac8fecf8 | 118 | for (int i = 0; i <= MAX_FLAG_POS; i++) { |
valeyev | 0:e056ac8fecf8 | 119 | int32_t signal = 1 << i; |
valeyev | 0:e056ac8fecf8 | 120 | signals |= signal; |
valeyev | 0:e056ac8fecf8 | 121 | sync->sem_child.wait(); |
valeyev | 0:e056ac8fecf8 | 122 | int32_t ret = Thread::signal_clr(NO_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 123 | TEST_ASSERT_EQUAL(signals, ret); |
valeyev | 0:e056ac8fecf8 | 124 | sync->sem_parent.release(); |
valeyev | 0:e056ac8fecf8 | 125 | } |
valeyev | 0:e056ac8fecf8 | 126 | } |
valeyev | 0:e056ac8fecf8 | 127 | |
valeyev | 0:e056ac8fecf8 | 128 | |
valeyev | 0:e056ac8fecf8 | 129 | /** Validate that call signal_clr(NO_SIGNALS) doesn't change thread signals and return actual signals |
valeyev | 0:e056ac8fecf8 | 130 | |
valeyev | 0:e056ac8fecf8 | 131 | Given two threads A & B are started, B with all signals already set |
valeyev | 0:e056ac8fecf8 | 132 | When thread B calls @a signal_clr(NO_SIGNALS) |
valeyev | 0:e056ac8fecf8 | 133 | Then thread B @a signal_clr status should be ALL_SIGNALS indicating that thread B state is unchanged |
valeyev | 0:e056ac8fecf8 | 134 | */ |
valeyev | 0:e056ac8fecf8 | 135 | void test_clear_no_signals(void) |
valeyev | 0:e056ac8fecf8 | 136 | { |
valeyev | 0:e056ac8fecf8 | 137 | Semaphore sem_parent(0, 1); |
valeyev | 0:e056ac8fecf8 | 138 | Semaphore sem_child(0, 1); |
valeyev | 0:e056ac8fecf8 | 139 | Sync sync(sem_parent, sem_child); |
valeyev | 0:e056ac8fecf8 | 140 | |
valeyev | 0:e056ac8fecf8 | 141 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 142 | t.start(callback(run_double_wait_clear<NO_SIGNALS, NO_SIGNALS, ALL_SIGNALS, ALL_SIGNALS>, &sync)); |
valeyev | 0:e056ac8fecf8 | 143 | sem_parent.wait(); |
valeyev | 0:e056ac8fecf8 | 144 | t.signal_set(ALL_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 145 | sem_child.release(); |
valeyev | 0:e056ac8fecf8 | 146 | t.join(); |
valeyev | 0:e056ac8fecf8 | 147 | } |
valeyev | 0:e056ac8fecf8 | 148 | |
valeyev | 0:e056ac8fecf8 | 149 | /** Validate if any signals are set on just created thread |
valeyev | 0:e056ac8fecf8 | 150 | |
valeyev | 0:e056ac8fecf8 | 151 | Given the thread is running |
valeyev | 0:e056ac8fecf8 | 152 | When thread execute @a signal_clr(NO_SIGNALS) |
valeyev | 0:e056ac8fecf8 | 153 | Then thread @a signal_clr return status should be NO_SIGNALS(0) indicating no signals set |
valeyev | 0:e056ac8fecf8 | 154 | */ |
valeyev | 0:e056ac8fecf8 | 155 | void test_init_state(void) |
valeyev | 0:e056ac8fecf8 | 156 | { |
valeyev | 0:e056ac8fecf8 | 157 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 158 | t.start(callback(run_clear<NO_SIGNALS, NO_SIGNALS>)); |
valeyev | 0:e056ac8fecf8 | 159 | t.join(); |
valeyev | 0:e056ac8fecf8 | 160 | } |
valeyev | 0:e056ac8fecf8 | 161 | |
valeyev | 0:e056ac8fecf8 | 162 | /** Validate all signals set in one shot |
valeyev | 0:e056ac8fecf8 | 163 | |
valeyev | 0:e056ac8fecf8 | 164 | Given two threads A & B are started |
valeyev | 0:e056ac8fecf8 | 165 | When thread A call @a signal_set(ALL_SIGNALS) with all possible signals |
valeyev | 0:e056ac8fecf8 | 166 | Then thread B @a signal_clr(NO_SIGNALS) status should be ALL_SIGNALS indicating all signals set correctly |
valeyev | 0:e056ac8fecf8 | 167 | */ |
valeyev | 0:e056ac8fecf8 | 168 | void test_set_all(void) |
valeyev | 0:e056ac8fecf8 | 169 | { |
valeyev | 0:e056ac8fecf8 | 170 | int32_t ret; |
valeyev | 0:e056ac8fecf8 | 171 | Semaphore sem_parent(0, 1); |
valeyev | 0:e056ac8fecf8 | 172 | Semaphore sem_child(0, 1); |
valeyev | 0:e056ac8fecf8 | 173 | Sync sync(sem_parent, sem_child); |
valeyev | 0:e056ac8fecf8 | 174 | |
valeyev | 0:e056ac8fecf8 | 175 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 176 | t.start(callback(run_wait_clear<NO_SIGNALS, ALL_SIGNALS>, &sync)); |
valeyev | 0:e056ac8fecf8 | 177 | |
valeyev | 0:e056ac8fecf8 | 178 | sem_parent.wait(); |
valeyev | 0:e056ac8fecf8 | 179 | ret = t.signal_set(ALL_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 180 | TEST_ASSERT_EQUAL(ALL_SIGNALS, ret); |
valeyev | 0:e056ac8fecf8 | 181 | |
valeyev | 0:e056ac8fecf8 | 182 | sem_child.release(); |
valeyev | 0:e056ac8fecf8 | 183 | t.join(); |
valeyev | 0:e056ac8fecf8 | 184 | } |
valeyev | 0:e056ac8fecf8 | 185 | |
valeyev | 0:e056ac8fecf8 | 186 | /** Validate that call signal_set with prohibited signal doesn't change thread signals |
valeyev | 0:e056ac8fecf8 | 187 | |
valeyev | 0:e056ac8fecf8 | 188 | Given two threads A & B are started, B with all signals set |
valeyev | 0:e056ac8fecf8 | 189 | When thread A executes @a signal_set(PROHIBITED_SIGNAL) with prohibited signal |
valeyev | 0:e056ac8fecf8 | 190 | Then thread B @a signal_clr(NO_SIGNALS) status should be ALL_SIGNALS indicating that thread B signals are unchanged |
valeyev | 0:e056ac8fecf8 | 191 | |
valeyev | 0:e056ac8fecf8 | 192 | @note Each signal has up to 31 event flags 0x1, 0x2, 0x4, 0x8, ..., 0x40000000 |
valeyev | 0:e056ac8fecf8 | 193 | Most significant bit is reserved and thereby flag 0x80000000 is prohibited |
valeyev | 0:e056ac8fecf8 | 194 | */ |
valeyev | 0:e056ac8fecf8 | 195 | void test_set_prohibited(void) |
valeyev | 0:e056ac8fecf8 | 196 | { |
valeyev | 0:e056ac8fecf8 | 197 | int32_t ret; |
valeyev | 0:e056ac8fecf8 | 198 | Semaphore sem_parent(0, 1); |
valeyev | 0:e056ac8fecf8 | 199 | Semaphore sem_child(0, 1); |
valeyev | 0:e056ac8fecf8 | 200 | Sync sync(sem_parent, sem_child); |
valeyev | 0:e056ac8fecf8 | 201 | |
valeyev | 0:e056ac8fecf8 | 202 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 203 | t.start(callback(run_wait_clear<NO_SIGNALS, ALL_SIGNALS>, &sync)); |
valeyev | 0:e056ac8fecf8 | 204 | |
valeyev | 0:e056ac8fecf8 | 205 | sem_parent.wait(); |
valeyev | 0:e056ac8fecf8 | 206 | t.signal_set(ALL_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 207 | |
valeyev | 0:e056ac8fecf8 | 208 | ret = t.signal_set(PROHIBITED_SIGNAL); |
valeyev | 0:e056ac8fecf8 | 209 | TEST_ASSERT_EQUAL(osErrorParameter, ret); |
valeyev | 0:e056ac8fecf8 | 210 | |
valeyev | 0:e056ac8fecf8 | 211 | sem_child.release(); |
valeyev | 0:e056ac8fecf8 | 212 | t.join(); |
valeyev | 0:e056ac8fecf8 | 213 | } |
valeyev | 0:e056ac8fecf8 | 214 | |
valeyev | 0:e056ac8fecf8 | 215 | /** Validate all signals clear in one shot |
valeyev | 0:e056ac8fecf8 | 216 | |
valeyev | 0:e056ac8fecf8 | 217 | Given two threads A & B are started, B with all signals set |
valeyev | 0:e056ac8fecf8 | 218 | When thread B execute @a signal_clr(ALL_SIGNALS) with all possible signals |
valeyev | 0:e056ac8fecf8 | 219 | Then thread B @a signal_clr(NO_SIGNALS) status should be NO_SIGNALS(0) indicating all signals cleared correctly |
valeyev | 0:e056ac8fecf8 | 220 | */ |
valeyev | 0:e056ac8fecf8 | 221 | void test_clear_all(void) |
valeyev | 0:e056ac8fecf8 | 222 | { |
valeyev | 0:e056ac8fecf8 | 223 | Semaphore sem_parent(0, 1); |
valeyev | 0:e056ac8fecf8 | 224 | Semaphore sem_child(0, 1); |
valeyev | 0:e056ac8fecf8 | 225 | Sync sync(sem_parent, sem_child); |
valeyev | 0:e056ac8fecf8 | 226 | |
valeyev | 0:e056ac8fecf8 | 227 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 228 | t.start(callback(run_double_wait_clear<ALL_SIGNALS, NO_SIGNALS, ALL_SIGNALS, NO_SIGNALS>, &sync)); |
valeyev | 0:e056ac8fecf8 | 229 | sem_parent.wait(); |
valeyev | 0:e056ac8fecf8 | 230 | t.signal_set(ALL_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 231 | sem_child.release(); |
valeyev | 0:e056ac8fecf8 | 232 | t.join(); |
valeyev | 0:e056ac8fecf8 | 233 | } |
valeyev | 0:e056ac8fecf8 | 234 | |
valeyev | 0:e056ac8fecf8 | 235 | /** Validate all signals set one by one in loop |
valeyev | 0:e056ac8fecf8 | 236 | |
valeyev | 0:e056ac8fecf8 | 237 | Given two threads A & B are started |
valeyev | 0:e056ac8fecf8 | 238 | When thread A executes @a signal_set(signal) in loop with all possible signals |
valeyev | 0:e056ac8fecf8 | 239 | */ |
valeyev | 0:e056ac8fecf8 | 240 | void test_set_all_loop(void) |
valeyev | 0:e056ac8fecf8 | 241 | { |
valeyev | 0:e056ac8fecf8 | 242 | int32_t ret; |
valeyev | 0:e056ac8fecf8 | 243 | Semaphore sem_parent(0, 1); |
valeyev | 0:e056ac8fecf8 | 244 | Semaphore sem_child(0, 1); |
valeyev | 0:e056ac8fecf8 | 245 | Sync sync(sem_parent, sem_child); |
valeyev | 0:e056ac8fecf8 | 246 | |
valeyev | 0:e056ac8fecf8 | 247 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 248 | t.start(callback(run_loop_wait_clear, &sync)); |
valeyev | 0:e056ac8fecf8 | 249 | |
valeyev | 0:e056ac8fecf8 | 250 | int32_t signals = 0; |
valeyev | 0:e056ac8fecf8 | 251 | for (int i = 0; i <= MAX_FLAG_POS; i++) { |
valeyev | 0:e056ac8fecf8 | 252 | int32_t signal = 1 << i; |
valeyev | 0:e056ac8fecf8 | 253 | |
valeyev | 0:e056ac8fecf8 | 254 | ret = t.signal_set(signal); |
valeyev | 0:e056ac8fecf8 | 255 | signals |= signal; |
valeyev | 0:e056ac8fecf8 | 256 | TEST_ASSERT_EQUAL(signals, ret); |
valeyev | 0:e056ac8fecf8 | 257 | sem_child.release(); |
valeyev | 0:e056ac8fecf8 | 258 | sem_parent.wait(); |
valeyev | 0:e056ac8fecf8 | 259 | } |
valeyev | 0:e056ac8fecf8 | 260 | t.join(); |
valeyev | 0:e056ac8fecf8 | 261 | } |
valeyev | 0:e056ac8fecf8 | 262 | |
valeyev | 0:e056ac8fecf8 | 263 | /** Validate signal_wait return status if timeout specified |
valeyev | 0:e056ac8fecf8 | 264 | |
valeyev | 0:e056ac8fecf8 | 265 | Given the thread is running |
valeyev | 0:e056ac8fecf8 | 266 | When thread executes @a signal_wait(signals, timeout) with specified signals and timeout |
valeyev | 0:e056ac8fecf8 | 267 | Then thread @a signal_wait status should be osEventTimeout indicating a timeout |
valeyev | 0:e056ac8fecf8 | 268 | thread @a signal_wait status should be osOK indicating 0[ms] timeout set |
valeyev | 0:e056ac8fecf8 | 269 | */ |
valeyev | 0:e056ac8fecf8 | 270 | template <int32_t signals, uint32_t timeout, int32_t status> |
valeyev | 0:e056ac8fecf8 | 271 | void test_wait_timeout(void) |
valeyev | 0:e056ac8fecf8 | 272 | { |
valeyev | 0:e056ac8fecf8 | 273 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 274 | t.start(callback(run_signal_wait<signals, timeout, status>)); |
valeyev | 0:e056ac8fecf8 | 275 | t.join(); |
valeyev | 0:e056ac8fecf8 | 276 | } |
valeyev | 0:e056ac8fecf8 | 277 | |
valeyev | 0:e056ac8fecf8 | 278 | /** Validate that call of signal_wait return correctly when thread has all signals already set |
valeyev | 0:e056ac8fecf8 | 279 | |
valeyev | 0:e056ac8fecf8 | 280 | Given two threads A & B are started, B with all signals already set |
valeyev | 0:e056ac8fecf8 | 281 | When thread B executes @a signal_wait(ALL_SIGNALS, osWaitForever), |
valeyev | 0:e056ac8fecf8 | 282 | Then thread B @a signal_wait return immediately with status osEventSignal indicating all wait signals was already set |
valeyev | 0:e056ac8fecf8 | 283 | */ |
valeyev | 0:e056ac8fecf8 | 284 | void test_wait_all_already_set(void) |
valeyev | 0:e056ac8fecf8 | 285 | { |
valeyev | 0:e056ac8fecf8 | 286 | Semaphore sem_parent(0, 1); |
valeyev | 0:e056ac8fecf8 | 287 | Semaphore sem_child(0, 1); |
valeyev | 0:e056ac8fecf8 | 288 | Sync sync(sem_parent, sem_child); |
valeyev | 0:e056ac8fecf8 | 289 | |
valeyev | 0:e056ac8fecf8 | 290 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 291 | t.start(callback(run_release_wait_signal_wait<ALL_SIGNALS, osWaitForever, osEventSignal>, &sync)); |
valeyev | 0:e056ac8fecf8 | 292 | |
valeyev | 0:e056ac8fecf8 | 293 | sem_parent.wait(); |
valeyev | 0:e056ac8fecf8 | 294 | TEST_ASSERT_EQUAL(Thread::WaitingSemaphore, t.get_state()); |
valeyev | 0:e056ac8fecf8 | 295 | t.signal_set(ALL_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 296 | sem_child.release(); |
valeyev | 0:e056ac8fecf8 | 297 | t.join(); |
valeyev | 0:e056ac8fecf8 | 298 | } |
valeyev | 0:e056ac8fecf8 | 299 | |
valeyev | 0:e056ac8fecf8 | 300 | /** Validate if signal_wait return correctly when all signals set |
valeyev | 0:e056ac8fecf8 | 301 | |
valeyev | 0:e056ac8fecf8 | 302 | Given two threads A & B are started and B waiting for a thread flag to be set |
valeyev | 0:e056ac8fecf8 | 303 | When thread A executes @a signal_set(ALL_SIGNALS) with all possible signals |
valeyev | 0:e056ac8fecf8 | 304 | Then thread B @a signal_wait status is osEventSignal indicating all wait signals was set |
valeyev | 0:e056ac8fecf8 | 305 | */ |
valeyev | 0:e056ac8fecf8 | 306 | void test_wait_all(void) |
valeyev | 0:e056ac8fecf8 | 307 | { |
valeyev | 0:e056ac8fecf8 | 308 | Semaphore sem(0, 1); |
valeyev | 0:e056ac8fecf8 | 309 | |
valeyev | 0:e056ac8fecf8 | 310 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 311 | t.start(callback(run_release_signal_wait<ALL_SIGNALS, osWaitForever, osEventSignal>, &sem)); |
valeyev | 0:e056ac8fecf8 | 312 | |
valeyev | 0:e056ac8fecf8 | 313 | sem.wait(); |
valeyev | 0:e056ac8fecf8 | 314 | TEST_ASSERT_EQUAL(Thread::WaitingThreadFlag, t.get_state()); |
valeyev | 0:e056ac8fecf8 | 315 | |
valeyev | 0:e056ac8fecf8 | 316 | t.signal_set(ALL_SIGNALS); |
valeyev | 0:e056ac8fecf8 | 317 | t.join(); |
valeyev | 0:e056ac8fecf8 | 318 | } |
valeyev | 0:e056ac8fecf8 | 319 | |
valeyev | 0:e056ac8fecf8 | 320 | /** Validate if signal_wait accumulate signals and return correctly when all signals set |
valeyev | 0:e056ac8fecf8 | 321 | |
valeyev | 0:e056ac8fecf8 | 322 | Given two threads A & B are started and B waiting for a thread signals to be set |
valeyev | 0:e056ac8fecf8 | 323 | When thread A executes @a signal_set setting all signals in loop |
valeyev | 0:e056ac8fecf8 | 324 | Then thread B @a signal_wait status is osEventSignal indicating that all wait signals was set |
valeyev | 0:e056ac8fecf8 | 325 | */ |
valeyev | 0:e056ac8fecf8 | 326 | void test_wait_all_loop(void) |
valeyev | 0:e056ac8fecf8 | 327 | { |
valeyev | 0:e056ac8fecf8 | 328 | int32_t ret; |
valeyev | 0:e056ac8fecf8 | 329 | Semaphore sem(0, 1); |
valeyev | 0:e056ac8fecf8 | 330 | |
valeyev | 0:e056ac8fecf8 | 331 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 332 | t.start(callback(run_release_signal_wait<ALL_SIGNALS, osWaitForever, osEventSignal>, &sem)); |
valeyev | 0:e056ac8fecf8 | 333 | |
valeyev | 0:e056ac8fecf8 | 334 | sem.wait(); |
valeyev | 0:e056ac8fecf8 | 335 | TEST_ASSERT_EQUAL(Thread::WaitingThreadFlag, t.get_state()); |
valeyev | 0:e056ac8fecf8 | 336 | |
valeyev | 0:e056ac8fecf8 | 337 | for (int i = 0; i < MAX_FLAG_POS; i++) { |
valeyev | 0:e056ac8fecf8 | 338 | int32_t signal = 1 << i; |
valeyev | 0:e056ac8fecf8 | 339 | ret = t.signal_set(signal); |
valeyev | 0:e056ac8fecf8 | 340 | } |
valeyev | 0:e056ac8fecf8 | 341 | ret = t.signal_set(1 << MAX_FLAG_POS); |
valeyev | 0:e056ac8fecf8 | 342 | TEST_ASSERT_EQUAL(NO_SIGNALS, ret); |
valeyev | 0:e056ac8fecf8 | 343 | t.join(); |
valeyev | 0:e056ac8fecf8 | 344 | } |
valeyev | 0:e056ac8fecf8 | 345 | |
valeyev | 0:e056ac8fecf8 | 346 | /** Validate if setting same signal twice cause any unwanted behaviour |
valeyev | 0:e056ac8fecf8 | 347 | |
valeyev | 0:e056ac8fecf8 | 348 | Given two threads A & B are started and B waiting for a thread signals to be set |
valeyev | 0:e056ac8fecf8 | 349 | When thread A executes @a signal_set twice for the same signal |
valeyev | 0:e056ac8fecf8 | 350 | Then thread A @a signal_set status is current signal set |
valeyev | 0:e056ac8fecf8 | 351 | thread B @a signal_wait status is osEventSignal indicating that all wait signals was set |
valeyev | 0:e056ac8fecf8 | 352 | */ |
valeyev | 0:e056ac8fecf8 | 353 | void test_set_double(void) |
valeyev | 0:e056ac8fecf8 | 354 | { |
valeyev | 0:e056ac8fecf8 | 355 | int32_t ret; |
valeyev | 0:e056ac8fecf8 | 356 | Semaphore sem(0, 1); |
valeyev | 0:e056ac8fecf8 | 357 | |
valeyev | 0:e056ac8fecf8 | 358 | Thread t(osPriorityNormal, TEST_STACK_SIZE); |
valeyev | 0:e056ac8fecf8 | 359 | t.start(callback(run_release_signal_wait<SIGNAL1|SIGNAL2|SIGNAL3, osWaitForever, osEventSignal>, &sem)); |
valeyev | 0:e056ac8fecf8 | 360 | |
valeyev | 0:e056ac8fecf8 | 361 | sem.wait(); |
valeyev | 0:e056ac8fecf8 | 362 | TEST_ASSERT_EQUAL(Thread::WaitingThreadFlag, t.get_state()); |
valeyev | 0:e056ac8fecf8 | 363 | |
valeyev | 0:e056ac8fecf8 | 364 | ret = t.signal_set(SIGNAL1); |
valeyev | 0:e056ac8fecf8 | 365 | TEST_ASSERT_EQUAL(SIGNAL1, ret); |
valeyev | 0:e056ac8fecf8 | 366 | |
valeyev | 0:e056ac8fecf8 | 367 | ret = t.signal_set(SIGNAL2); |
valeyev | 0:e056ac8fecf8 | 368 | TEST_ASSERT_EQUAL(SIGNAL1 | SIGNAL2, ret); |
valeyev | 0:e056ac8fecf8 | 369 | |
valeyev | 0:e056ac8fecf8 | 370 | ret = t.signal_set(SIGNAL2); |
valeyev | 0:e056ac8fecf8 | 371 | TEST_ASSERT_EQUAL(SIGNAL1 | SIGNAL2, ret); |
valeyev | 0:e056ac8fecf8 | 372 | TEST_ASSERT_EQUAL(Thread::WaitingThreadFlag, t.get_state()); |
valeyev | 0:e056ac8fecf8 | 373 | |
valeyev | 0:e056ac8fecf8 | 374 | ret = t.signal_set(SIGNAL3); |
valeyev | 0:e056ac8fecf8 | 375 | TEST_ASSERT_EQUAL(NO_SIGNALS, ret); |
valeyev | 0:e056ac8fecf8 | 376 | t.join(); |
valeyev | 0:e056ac8fecf8 | 377 | } |
valeyev | 0:e056ac8fecf8 | 378 | |
valeyev | 0:e056ac8fecf8 | 379 | |
valeyev | 0:e056ac8fecf8 | 380 | utest::v1::status_t test_setup(const size_t number_of_cases) |
valeyev | 0:e056ac8fecf8 | 381 | { |
valeyev | 0:e056ac8fecf8 | 382 | GREENTEA_SETUP(10, "default_auto"); |
valeyev | 0:e056ac8fecf8 | 383 | return utest::v1::verbose_test_setup_handler(number_of_cases); |
valeyev | 0:e056ac8fecf8 | 384 | } |
valeyev | 0:e056ac8fecf8 | 385 | |
valeyev | 0:e056ac8fecf8 | 386 | Case cases[] = { |
valeyev | 0:e056ac8fecf8 | 387 | Case("Validate that call signal_clr(NO_SIGNALS) doesn't change thread signals and return actual signals", test_clear_no_signals), |
valeyev | 0:e056ac8fecf8 | 388 | Case("Validate if any signals are set on just created thread", test_init_state), |
valeyev | 0:e056ac8fecf8 | 389 | Case("Validate all signals set in one shot", test_set_all), |
valeyev | 0:e056ac8fecf8 | 390 | Case("Validate that call signal_set with prohibited signal doesn't change thread signals", test_set_prohibited), |
valeyev | 0:e056ac8fecf8 | 391 | Case("Validate all signals clear in one shot", test_clear_all), |
valeyev | 0:e056ac8fecf8 | 392 | Case("Validate all signals set one by one in loop", test_set_all_loop), |
valeyev | 0:e056ac8fecf8 | 393 | Case("Validate signal_wait return status if timeout specified: 0[ms] no signals", test_wait_timeout<0, 0, osOK>), |
valeyev | 0:e056ac8fecf8 | 394 | Case("Validate signal_wait return status if timeout specified: 0[ms] all signals", test_wait_timeout<ALL_SIGNALS, 0, osOK>), |
valeyev | 0:e056ac8fecf8 | 395 | Case("Validate signal_wait return status if timeout specified: 1[ms] no signals", test_wait_timeout<0, 1, osEventTimeout>), |
valeyev | 0:e056ac8fecf8 | 396 | Case("Validate signal_wait return status if timeout specified: 1[ms] all signals", test_wait_timeout<ALL_SIGNALS, 1, osEventTimeout>), |
valeyev | 0:e056ac8fecf8 | 397 | Case("Validate that call of signal_wait return correctly when thread has all signals already set", test_wait_all_already_set), |
valeyev | 0:e056ac8fecf8 | 398 | Case("Validate if signal_wait return correctly when all signals set", test_wait_all), |
valeyev | 0:e056ac8fecf8 | 399 | Case("Validate if signal_wait accumulate signals and return correctly when all signals set", test_wait_all_loop), |
valeyev | 0:e056ac8fecf8 | 400 | Case("Validate if setting same signal twice cause any unwanted behaviour", test_set_double) |
valeyev | 0:e056ac8fecf8 | 401 | }; |
valeyev | 0:e056ac8fecf8 | 402 | |
valeyev | 0:e056ac8fecf8 | 403 | utest::v1::Specification specification(test_setup, cases); |
valeyev | 0:e056ac8fecf8 | 404 | |
valeyev | 0:e056ac8fecf8 | 405 | int main() |
valeyev | 0:e056ac8fecf8 | 406 | { |
valeyev | 0:e056ac8fecf8 | 407 | return !utest::v1::Harness::run(specification); |
valeyev | 0:e056ac8fecf8 | 408 | } |