| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| /** |
| Unit tests for the Semaphore api (ble_npl_sem): |
| |
| ble_npl_error_t ble_npl_sem_init(struct ble_npl_sem *sem, uint16_t tokens); |
| ble_npl_error_t ble_npl_sem_release(struct ble_npl_sem *sem); |
| ble_npl_error_t ble_npl_sem_pend(struct ble_npl_sem *sem, uint32_t timeout); |
| uint16_t ble_npl_sem_get_count(struct ble_npl_sem *sem); |
| */ |
| |
| #include "test_util.h" |
| #include "nimble/nimble_npl.h" |
| //#include "os/os.h" |
| |
| #define TEST_ITERATIONS 10 |
| |
| #define TASK1_PRIO 1 |
| #define TASK2_PRIO 1 |
| |
| #define TASK1_STACK_SIZE 1028 |
| #define TASK2_STACK_SIZE 1028 |
| |
| static struct ble_npl_task task1; |
| static struct ble_npl_task task2; |
| |
| static ble_npl_stack_t task1_stack[TASK1_STACK_SIZE]; |
| static ble_npl_stack_t task2_stack[TASK2_STACK_SIZE]; |
| |
| struct ble_npl_sem task1_sem; |
| struct ble_npl_sem task2_sem; |
| |
| /* Task 1 handler function */ |
| void * |
| task1_handler(void *arg) |
| { |
| for (int i = 0; i < TEST_ITERATIONS; i++) |
| { |
| /* Release semaphore to task 2 */ |
| SuccessOrQuit(ble_npl_sem_release(&task1_sem), |
| "ble_npl_sem_release: error releasing task2_sem."); |
| |
| /* Wait for semaphore from task 2 */ |
| SuccessOrQuit(ble_npl_sem_pend(&task2_sem, BLE_NPL_TIME_FOREVER), |
| "ble_npl_sem_pend: error waiting for task2_sem."); |
| } |
| |
| printf("All tests passed\n"); |
| exit(PASS); |
| |
| return NULL; |
| } |
| |
| /* Task 2 handler function */ |
| void * |
| task2_handler(void *arg) |
| { |
| while(1) |
| { |
| /* Wait for semaphore from task1 */ |
| SuccessOrQuit(ble_npl_sem_pend(&task1_sem, BLE_NPL_TIME_FOREVER), |
| "ble_npl_sem_pend: error waiting for task1_sem."); |
| |
| /* Release task2 semaphore */ |
| SuccessOrQuit(ble_npl_sem_release(&task2_sem), |
| "ble_npl_sem_release: error releasing task1_sem."); |
| } |
| |
| return NULL; |
| } |
| |
| |
| /* Initialize task 1 exposed data objects */ |
| void |
| task1_init(void) |
| { |
| /* Initialize task1 semaphore */ |
| SuccessOrQuit(ble_npl_sem_init(&task1_sem, 0), |
| "ble_npl_sem_init: task1 returned error."); |
| } |
| |
| /* Initialize task 2 exposed data objects */ |
| void |
| task2_init(void) |
| { |
| /* Initialize task1 semaphore */ |
| SuccessOrQuit(ble_npl_sem_init(&task2_sem, 0), |
| "ble_npl_sem_init: task2 returned error."); |
| } |
| |
| /** |
| * init_app_tasks |
| * |
| * This function performs initializations that are required before tasks run. |
| * |
| * @return int 0 success; error otherwise. |
| */ |
| static int |
| init_app_tasks(void) |
| { |
| /* |
| * Call task specific initialization functions to initialize any shared objects |
| * before initializing the tasks with the OS. |
| */ |
| task1_init(); |
| task2_init(); |
| |
| /* |
| * Initialize tasks 1 and 2 with the OS. |
| */ |
| ble_npl_task_init(&task1, "task1", task1_handler, NULL, TASK1_PRIO, |
| BLE_NPL_TIME_FOREVER, task1_stack, TASK1_STACK_SIZE); |
| |
| ble_npl_task_init(&task2, "task2", task2_handler, NULL, TASK2_PRIO, |
| BLE_NPL_TIME_FOREVER, task2_stack, TASK2_STACK_SIZE); |
| |
| return 0; |
| } |
| |
| /** |
| * main |
| * |
| * The main function for the application. This function initializes the system and packages, |
| * calls the application specific task initialization function, then waits and dispatches |
| * events from the OS default event queue in an infinite loop. |
| */ |
| int |
| main(int argc, char **arg) |
| { |
| /* Initialize application specific tasks */ |
| init_app_tasks(); |
| |
| while (1) |
| { |
| ble_npl_eventq_run(ble_npl_eventq_dflt_get()); |
| } |
| /* main never returns */ |
| } |