/*
|
* 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 */
|
}
|
