fly316/PX4-Autopilot
7
0
Fork 0
mirror of https://gitee.com/mirrors_PX4/PX4-Autopilot.git synced 2026-10-30 03:03:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

Tests: Move to semaphore abstraction

Browse Source
This commit is contained in:
Lorenz Meier
2015-09-20 00:29:38 +02:00
parent b3a8ba4e92
commit 3599b577df
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/systemcmds/tests/test_dataman.c
+7 -7
View File
@@ -59,7 +59,7 @@
#include "dataman/dataman.h" #include "dataman/dataman.h"
static sem_t *sems; static px4_sem_t *sems;
static int static int
task_main(int argc, char *argv[]) task_main(int argc, char *argv[])
@@ -137,12 +137,12 @@ task_main(int argc, char *argv[])
rend = hrt_absolute_time(); rend = hrt_absolute_time();
warnx("Test %d pass, hit %d, miss %d, io time read %llums. write %llums.", warnx("Test %d pass, hit %d, miss %d, io time read %llums. write %llums.",
my_id, hit, miss, (rend - rstart) / NUM_MISSIONS_SUPPORTED / 1000, (wend - wstart) / NUM_MISSIONS_SUPPORTED / 1000); my_id, hit, miss, (rend - rstart) / NUM_MISSIONS_SUPPORTED / 1000, (wend - wstart) / NUM_MISSIONS_SUPPORTED / 1000);
sem_post(sems + my_id); px4_sem_post(sems + my_id);
return 0; return 0;
fail: fail:
warnx("Test %d fail, buffer %02x %02x %02x %02x %02x %02x", warnx("Test %d fail, buffer %02x %02x %02x %02x %02x %02x",
my_id, buffer[0], buffer[1], buffer[2], buffer[3], buffer[4], buffer[5]); my_id, buffer[0], buffer[1], buffer[2], buffer[3], buffer[4], buffer[5]);
sem_post(sems + my_id); px4_sem_post(sems + my_id);
return -1; return -1;
} }
@@ -155,7 +155,7 @@ int test_dataman(int argc, char *argv[])
num_tasks = atoi(argv[1]); num_tasks = atoi(argv[1]);
} }
sems = (sem_t *)malloc(num_tasks * sizeof(sem_t)); sems = (px4_sem_t *)malloc(num_tasks * sizeof(px4_sem_t));
warnx("Running %d tasks", num_tasks); warnx("Running %d tasks", num_tasks);
for (i = 0; i < num_tasks; i++) { for (i = 0; i < num_tasks; i++) {
@@ -165,7 +165,7 @@ int test_dataman(int argc, char *argv[])
const char *av[2]; const char *av[2];
av[0] = a; av[0] = a;
av[1] = 0; av[1] = 0;
sem_init(sems + i, 1, 0); px4_sem_init(sems + i, 1, 0);
/* start the task */ /* start the task */
if ((task = px4_task_spawn_cmd("dataman", SCHED_DEFAULT, SCHED_PRIORITY_MAX - 5, 2048, task_main, av)) <= 0) { if ((task = px4_task_spawn_cmd("dataman", SCHED_DEFAULT, SCHED_PRIORITY_MAX - 5, 2048, task_main, av)) <= 0) {
@@ -174,8 +174,8 @@ int test_dataman(int argc, char *argv[])
} }
for (i = 0; i < num_tasks; i++) { for (i = 0; i < num_tasks; i++) {
sem_wait(sems + i); px4_sem_wait(sems + i);
sem_destroy(sems + i); px4_sem_destroy(sems + i);
} }
free(sems); free(sems);