tests: mbox: fix code style

Signed-off-by: Anas Nashif <anas.nashif@intel.com>
This commit is contained in:
Anas Nashif 2017-06-16 22:02:56 -04:00 committed by Kumar Gala
commit 0f4329780a
2 changed files with 23 additions and 23 deletions

View file

@ -18,13 +18,13 @@ extern void test_mbox_target_source_thread_block(void);
void test_main(void *p1, void *p2, void *p3) void test_main(void *p1, void *p2, void *p3)
{ {
ztest_test_suite(test_mbox_api, ztest_test_suite(test_mbox_api,
ztest_unit_test(test_mbox_kinit),/*keep init first!*/ ztest_unit_test(test_mbox_kinit),/*keep init first!*/
ztest_unit_test(test_mbox_kdefine), ztest_unit_test(test_mbox_kdefine),
ztest_unit_test(test_mbox_put_get_null), ztest_unit_test(test_mbox_put_get_null),
ztest_unit_test(test_mbox_put_get_buffer), ztest_unit_test(test_mbox_put_get_buffer),
ztest_unit_test(test_mbox_async_put_get_buffer), ztest_unit_test(test_mbox_async_put_get_buffer),
ztest_unit_test(test_mbox_async_put_get_block), ztest_unit_test(test_mbox_async_put_get_block),
ztest_unit_test(test_mbox_target_source_thread_buffer), ztest_unit_test(test_mbox_target_source_thread_buffer),
ztest_unit_test(test_mbox_target_source_thread_block)); ztest_unit_test(test_mbox_target_source_thread_block));
ztest_run_test_suite(test_mbox_api); ztest_run_test_suite(test_mbox_api);
} }

View file

@ -76,7 +76,7 @@ static void tmbox_put(struct k_mbox *pmbox)
k_mbox_put(pmbox, &mmsg, K_FOREVER); k_mbox_put(pmbox, &mmsg, K_FOREVER);
break; break;
case PUT_GET_BUFFER: case PUT_GET_BUFFER:
/*fall through*/ /*fall through*/
case TARGET_SOURCE_THREAD_BUFFER: case TARGET_SOURCE_THREAD_BUFFER:
/**TESTPOINT: mbox sync put buffer*/ /**TESTPOINT: mbox sync put buffer*/
mmsg.info = PUT_GET_BUFFER; mmsg.info = PUT_GET_BUFFER;
@ -100,14 +100,14 @@ static void tmbox_put(struct k_mbox *pmbox)
k_sem_take(&sync_sema, K_FOREVER); k_sem_take(&sync_sema, K_FOREVER);
break; break;
case ASYNC_PUT_GET_BLOCK: case ASYNC_PUT_GET_BLOCK:
/*fall through*/ /*fall through*/
case TARGET_SOURCE_THREAD_BLOCK: case TARGET_SOURCE_THREAD_BLOCK:
/**TESTPOINT: mbox async put mem block*/ /**TESTPOINT: mbox async put mem block*/
mmsg.info = ASYNC_PUT_GET_BLOCK; mmsg.info = ASYNC_PUT_GET_BLOCK;
mmsg.size = MAIL_LEN; mmsg.size = MAIL_LEN;
mmsg.tx_data = NULL; mmsg.tx_data = NULL;
zassert_equal(k_mem_pool_alloc(&mpooltx, &mmsg.tx_block, zassert_equal(k_mem_pool_alloc(&mpooltx, &mmsg.tx_block,
MAIL_LEN, K_NO_WAIT), 0, NULL); MAIL_LEN, K_NO_WAIT), 0, NULL);
memcpy(mmsg.tx_block.data, data[info_type], MAIL_LEN); memcpy(mmsg.tx_block.data, data[info_type], MAIL_LEN);
if (info_type == TARGET_SOURCE_THREAD_BLOCK) { if (info_type == TARGET_SOURCE_THREAD_BLOCK) {
mmsg.tx_target_thread = receiver_tid; mmsg.tx_target_thread = receiver_tid;
@ -136,14 +136,14 @@ static void tmbox_get(struct k_mbox *pmbox)
mmsg.rx_source_thread = K_ANY; mmsg.rx_source_thread = K_ANY;
/*verify return value*/ /*verify return value*/
zassert_true(k_mbox_get(pmbox, &mmsg, rxdata, K_FOREVER) == 0, zassert_true(k_mbox_get(pmbox, &mmsg, rxdata, K_FOREVER) == 0,
NULL); NULL);
/*verify .info*/ /*verify .info*/
zassert_equal(mmsg.info, PUT_GET_NULL, NULL); zassert_equal(mmsg.info, PUT_GET_NULL, NULL);
/*verify .size*/ /*verify .size*/
zassert_equal(mmsg.size, 0, NULL); zassert_equal(mmsg.size, 0, NULL);
break; break;
case PUT_GET_BUFFER: case PUT_GET_BUFFER:
/*fall through*/ /*fall through*/
case TARGET_SOURCE_THREAD_BUFFER: case TARGET_SOURCE_THREAD_BUFFER:
/**TESTPOINT: mbox sync get buffer*/ /**TESTPOINT: mbox sync get buffer*/
mmsg.size = sizeof(rxdata); mmsg.size = sizeof(rxdata);
@ -153,27 +153,27 @@ static void tmbox_get(struct k_mbox *pmbox)
mmsg.rx_source_thread = K_ANY; mmsg.rx_source_thread = K_ANY;
} }
zassert_true(k_mbox_get(pmbox, &mmsg, rxdata, K_FOREVER) == 0, zassert_true(k_mbox_get(pmbox, &mmsg, rxdata, K_FOREVER) == 0,
NULL); NULL);
zassert_equal(mmsg.info, PUT_GET_BUFFER, NULL); zassert_equal(mmsg.info, PUT_GET_BUFFER, NULL);
zassert_equal(mmsg.size, sizeof(data[info_type]), NULL); zassert_equal(mmsg.size, sizeof(data[info_type]), NULL);
/*verify rxdata*/ /*verify rxdata*/
zassert_true(memcmp(rxdata, data[info_type], MAIL_LEN) == 0, zassert_true(memcmp(rxdata, data[info_type], MAIL_LEN) == 0,
NULL); NULL);
break; break;
case ASYNC_PUT_GET_BUFFER: case ASYNC_PUT_GET_BUFFER:
/**TESTPOINT: mbox async get buffer*/ /**TESTPOINT: mbox async get buffer*/
mmsg.size = sizeof(rxdata); mmsg.size = sizeof(rxdata);
mmsg.rx_source_thread = K_ANY; mmsg.rx_source_thread = K_ANY;
zassert_true(k_mbox_get(pmbox, &mmsg, NULL, K_FOREVER) == 0, zassert_true(k_mbox_get(pmbox, &mmsg, NULL, K_FOREVER) == 0,
NULL); NULL);
zassert_equal(mmsg.info, ASYNC_PUT_GET_BUFFER, NULL); zassert_equal(mmsg.info, ASYNC_PUT_GET_BUFFER, NULL);
zassert_equal(mmsg.size, sizeof(data[info_type]), NULL); zassert_equal(mmsg.size, sizeof(data[info_type]), NULL);
k_mbox_data_get(&mmsg, rxdata); k_mbox_data_get(&mmsg, rxdata);
zassert_true(memcmp(rxdata, data[info_type], MAIL_LEN) == 0, zassert_true(memcmp(rxdata, data[info_type], MAIL_LEN) == 0,
NULL); NULL);
break; break;
case ASYNC_PUT_GET_BLOCK: case ASYNC_PUT_GET_BLOCK:
/*fall through*/ /*fall through*/
case TARGET_SOURCE_THREAD_BLOCK: case TARGET_SOURCE_THREAD_BLOCK:
/**TESTPOINT: mbox async get mem block*/ /**TESTPOINT: mbox async get mem block*/
mmsg.size = MAIL_LEN; mmsg.size = MAIL_LEN;
@ -183,14 +183,14 @@ static void tmbox_get(struct k_mbox *pmbox)
mmsg.rx_source_thread = K_ANY; mmsg.rx_source_thread = K_ANY;
} }
zassert_true(k_mbox_get(pmbox, &mmsg, NULL, K_FOREVER) == 0, zassert_true(k_mbox_get(pmbox, &mmsg, NULL, K_FOREVER) == 0,
NULL); NULL);
zassert_true(k_mbox_data_block_get zassert_true(k_mbox_data_block_get
(&mmsg, &mpoolrx, &rxblock, K_FOREVER) == 0, NULL); (&mmsg, &mpoolrx, &rxblock, K_FOREVER) == 0, NULL);
zassert_equal(mmsg.info, ASYNC_PUT_GET_BLOCK, NULL); zassert_equal(mmsg.info, ASYNC_PUT_GET_BLOCK, NULL);
zassert_equal(mmsg.size, MAIL_LEN, NULL); zassert_equal(mmsg.size, MAIL_LEN, NULL);
/*verify rxblock*/ /*verify rxblock*/
zassert_true(memcmp(rxblock.data, data[info_type], MAIL_LEN) zassert_true(memcmp(rxblock.data, data[info_type], MAIL_LEN)
== 0, NULL); == 0, NULL);
k_mem_pool_free(&rxblock); k_mem_pool_free(&rxblock);
break; break;
default: default:
@ -214,8 +214,8 @@ static void tmbox(struct k_mbox *pmbox)
/**TESTPOINT: thread-thread data passing via mbox*/ /**TESTPOINT: thread-thread data passing via mbox*/
sender_tid = k_current_get(); sender_tid = k_current_get();
receiver_tid = k_thread_create(&tdata, tstack, STACK_SIZE, receiver_tid = k_thread_create(&tdata, tstack, STACK_SIZE,
tmbox_entry, pmbox, NULL, NULL, tmbox_entry, pmbox, NULL, NULL,
K_PRIO_PREEMPT(0), 0, 0); K_PRIO_PREEMPT(0), 0, 0);
tmbox_put(pmbox); tmbox_put(pmbox);
k_sem_take(&end_sema, K_FOREVER); k_sem_take(&end_sema, K_FOREVER);