| /ThreadX-v6.3.0/test/tx/regression/ |
| D | threadx_queue_basic_eight_word_test.c | 91 ULONG dest_message[8]; in thread_0_entry() local
128 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
131 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
132 (source_message[7] != dest_message[7])) in thread_0_entry()
141 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
180 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
183 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
184 (source_message[7] != dest_message[7])) in thread_0_entry()
193 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
244 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_four_word_test.c | 91 ULONG dest_message[4]; in thread_0_entry() local
128 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
131 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
132 (source_message[3] != dest_message[3])) in thread_0_entry()
141 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
180 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
183 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
184 (source_message[3] != dest_message[3])) in thread_0_entry()
193 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
244 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_sixteen_word_test.c | 91 ULONG dest_message[16]; in thread_0_entry() local
128 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
131 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
132 (source_message[15] != dest_message[15])) in thread_0_entry()
141 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
180 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
183 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
184 (source_message[15] != dest_message[15])) in thread_0_entry()
193 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
244 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_front_send_test.c | 159 ULONG dest_message[2]; in thread_0_entry() local
195 status = tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
198 if ((status != TX_SUCCESS) || (dest_message[0] != temp[0])) in thread_0_entry()
207 status = tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
210 if ((status != TX_SUCCESS) || (dest_message[0] != source_message[0])) in thread_0_entry()
219 status = tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
345 status = tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
348 if ((status != TX_SUCCESS) || (dest_message[0] != temp[0])) in thread_0_entry()
357 status = tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
360 if ((status != TX_SUCCESS) || (dest_message[0] != source_message[0])) in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_two_word_test.c | 105 ULONG dest_message[2]; in thread_0_entry() local
168 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
171 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
172 (source_message[1] != dest_message[1])) in thread_0_entry()
181 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
220 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
223 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
224 (source_message[1] != dest_message[1])) in thread_0_entry()
233 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
284 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_one_word_test.c | 279 ULONG dest_message; in thread_0_entry() local
506 status = tx_queue_receive(TX_NULL, &dest_message, TX_NO_WAIT); in thread_0_entry()
519 status = tx_queue_receive(&queue_2, &dest_message, TX_NO_WAIT); in thread_0_entry()
567 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
570 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
579 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
617 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
620 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
629 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
674 status = tx_queue_receive(&queue_1, &dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_full_suspension_test.c | 165 ULONG dest_message[2]; in thread_0_entry() local
191 status += tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
192 status += tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
240 status += tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
241 status += tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
284 ULONG dest_message[2]; in thread_1_entry() local
293 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_1_entry()
295 if ((status != TX_SUCCESS) || (dest_message[0] != expected_message[0]++)) in thread_1_entry()
325 ULONG dest_message[2]; in thread_1a_entry() local
331 status += tx_queue_receive(&queue_0a, &dest_message[0], TX_WAIT_FOREVER); in thread_1a_entry()
[all …]
|
| D | threadx_queue_information_test.c | 92 ULONG dest_message; in thread_0_entry() local
164 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
167 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
176 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
214 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
217 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
226 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
271 status = tx_queue_receive(&queue_1, &dest_message, TX_NO_WAIT); in thread_0_entry()
274 if ((status != TX_SUCCESS) || (expected_message++ != dest_message)) in thread_0_entry()
283 status = tx_queue_receive(&queue_1, &dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_prioritize.c | 400 ULONG dest_message; in thread_1_entry() local
409 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_1_entry()
423 ULONG dest_message; in thread_2_entry() local
432 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_2_entry()
446 ULONG dest_message; in thread_3_entry() local
455 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_3_entry()
469 ULONG dest_message; in thread_4_entry() local
478 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_4_entry()
492 ULONG dest_message; in thread_5_entry() local
501 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_5_entry()
[all …]
|
| D | threadx_queue_empty_suspension_test.c | 226 ULONG dest_message[2]; in thread_1_entry() local
236 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_1_entry()
238 if ((status != TX_SUCCESS) || (dest_message[0] != expected_message[0]++)) in thread_1_entry()
252 ULONG dest_message[2]; in thread_2_entry() local
262 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_2_entry()
264 if ((status != TX_SUCCESS) || (dest_message[0] != expected_message[0]++)) in thread_2_entry()
|
| D | threadx_queue_suspension_timeout_test.c | 212 ULONG dest_message[2]; in thread_1_entry() local
222 status = tx_queue_receive(&queue_1, &dest_message[0], 20); in thread_1_entry()
236 ULONG dest_message[2]; in thread_2_entry() local
246 status = tx_queue_receive(&queue_1, &dest_message[0], 20); in thread_2_entry()
|
| D | threadx_queue_thread_terminate_test.c | 165 ULONG dest_message[2]; in thread_1_entry() local
174 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_1_entry()
|
| /ThreadX-v6.3.0/test/smp/regression/ |
| D | threadx_queue_basic_eight_word_test.c | 91 ULONG dest_message[8]; in thread_0_entry() local
128 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
131 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
132 (source_message[7] != dest_message[7])) in thread_0_entry()
141 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
180 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
183 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
184 (source_message[7] != dest_message[7])) in thread_0_entry()
193 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
244 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_four_word_test.c | 91 ULONG dest_message[4]; in thread_0_entry() local
128 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
131 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
132 (source_message[3] != dest_message[3])) in thread_0_entry()
141 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
180 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
183 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
184 (source_message[3] != dest_message[3])) in thread_0_entry()
193 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
244 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_sixteen_word_test.c | 91 ULONG dest_message[16]; in thread_0_entry() local
128 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
131 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
132 (source_message[15] != dest_message[15])) in thread_0_entry()
141 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
180 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
183 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
184 (source_message[15] != dest_message[15])) in thread_0_entry()
193 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
244 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_front_send_test.c | 159 ULONG dest_message[2]; in thread_0_entry() local
195 status = tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
198 if ((status != TX_SUCCESS) || (dest_message[0] != temp[0])) in thread_0_entry()
207 status = tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
210 if ((status != TX_SUCCESS) || (dest_message[0] != source_message[0])) in thread_0_entry()
219 status = tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
345 status = tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
348 if ((status != TX_SUCCESS) || (dest_message[0] != temp[0])) in thread_0_entry()
357 status = tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
360 if ((status != TX_SUCCESS) || (dest_message[0] != source_message[0])) in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_two_word_test.c | 105 ULONG dest_message[2]; in thread_0_entry() local
168 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
171 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
172 (source_message[1] != dest_message[1])) in thread_0_entry()
181 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
220 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
223 if ((status != TX_SUCCESS) || (source_message[0] != dest_message[0]) || in thread_0_entry()
224 (source_message[1] != dest_message[1])) in thread_0_entry()
233 status = tx_queue_receive(&queue_0, dest_message, TX_NO_WAIT); in thread_0_entry()
284 status = tx_queue_receive(&queue_1, dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_basic_one_word_test.c | 279 ULONG dest_message; in thread_0_entry() local
506 status = tx_queue_receive(TX_NULL, &dest_message, TX_NO_WAIT); in thread_0_entry()
519 status = tx_queue_receive(&queue_2, &dest_message, TX_NO_WAIT); in thread_0_entry()
567 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
570 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
579 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
617 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
620 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
629 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
674 status = tx_queue_receive(&queue_1, &dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_full_suspension_test.c | 165 ULONG dest_message[2]; in thread_0_entry() local
191 status += tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
192 status += tx_queue_receive(&queue_0a, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
240 status += tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
241 status += tx_queue_receive(&queue_0, &dest_message[0], TX_NO_WAIT); in thread_0_entry()
284 ULONG dest_message[2]; in thread_1_entry() local
293 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_1_entry()
295 if ((status != TX_SUCCESS) || (dest_message[0] != expected_message[0]++)) in thread_1_entry()
325 ULONG dest_message[2]; in thread_1a_entry() local
331 status += tx_queue_receive(&queue_0a, &dest_message[0], TX_WAIT_FOREVER); in thread_1a_entry()
[all …]
|
| D | threadx_queue_information_test.c | 92 ULONG dest_message; in thread_0_entry() local
164 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
167 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
176 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
214 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
217 if ((status != TX_SUCCESS) || (source_message != dest_message)) in thread_0_entry()
226 status = tx_queue_receive(&queue_0, &dest_message, TX_NO_WAIT); in thread_0_entry()
271 status = tx_queue_receive(&queue_1, &dest_message, TX_NO_WAIT); in thread_0_entry()
274 if ((status != TX_SUCCESS) || (expected_message++ != dest_message)) in thread_0_entry()
283 status = tx_queue_receive(&queue_1, &dest_message, TX_NO_WAIT); in thread_0_entry()
[all …]
|
| D | threadx_queue_prioritize.c | 400 ULONG dest_message; in thread_1_entry() local
409 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_1_entry()
423 ULONG dest_message; in thread_2_entry() local
432 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_2_entry()
446 ULONG dest_message; in thread_3_entry() local
455 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_3_entry()
469 ULONG dest_message; in thread_4_entry() local
478 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_4_entry()
492 ULONG dest_message; in thread_5_entry() local
501 status = tx_queue_receive(&queue_0, &dest_message, TX_WAIT_FOREVER); in thread_5_entry()
[all …]
|
| D | threadx_queue_empty_suspension_test.c | 226 ULONG dest_message[2]; in thread_1_entry() local
236 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_1_entry()
238 if ((status != TX_SUCCESS) || (dest_message[0] != expected_message[0]++)) in thread_1_entry()
252 ULONG dest_message[2]; in thread_2_entry() local
262 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_2_entry()
264 if ((status != TX_SUCCESS) || (dest_message[0] != expected_message[0]++)) in thread_2_entry()
|
| D | threadx_queue_suspension_timeout_test.c | 212 ULONG dest_message[2]; in thread_1_entry() local
222 status = tx_queue_receive(&queue_1, &dest_message[0], 20); in thread_1_entry()
236 ULONG dest_message[2]; in thread_2_entry() local
246 status = tx_queue_receive(&queue_1, &dest_message[0], 20); in thread_2_entry()
|
| D | threadx_queue_thread_terminate_test.c | 165 ULONG dest_message[2]; in thread_1_entry() local
174 status = tx_queue_receive(&queue_0, &dest_message[0], TX_WAIT_FOREVER); in thread_1_entry()
|
