sergiotarxz/nuttx-apps
sergiotarxz/nuttx-apps
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

ostest: add semaphore wait case for task restart

Browse Source
This commit is contained in:
zhangyuan21 2022-10-09 16:30:55 +08:00 committed by Xiang Xiao
parent abbe022894
commit 7fcba8a119
1 changed files with 43 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
testing/ostest/restart.c
View File

@ -31,6 +31,7 @@
#include <unistd.h> #include <unistd.h>
#include <sched.h> #include <sched.h>
#include <errno.h> #include <errno.h>
#include <semaphore.h>
#include "ostest.h" #include "ostest.h"
@ -58,7 +59,9 @@ static const char g_varname[] = "VarName";
static const char g_varvalue[] = "VarValue"; static const char g_varvalue[] = "VarValue";
#endif #endif
static bool g_restarted; static uint8_t g_restartstep;
static sem_t g_sem;
/**************************************************************************** /****************************************************************************
* Private Functions * Private Functions
@ -117,19 +120,23 @@ static int restart_main(int argc, char *argv[])
/* Were we restarted? */ /* Were we restarted? */
if (!g_restarted) switch (g_restartstep)
{ {
/* No.. this is the first time we have been here */ case 0:
for (; ; )
g_restarted = true; {
sleep(2);
/* Now just wait to be restarted */ printf("restart_main: I am still here\n");
}
for (; ; ) break;
{ case 1:
sleep(2); if (sem_wait(&g_sem) != 0)
printf("restart_main: I am still here\n"); {
} printf("restart_main: ERROR thread sem_wait failed\n");
}
break;
default:
break;
} }
return 0; /* Won't get here unless we were restarted */ return 0; /* Won't get here unless we were restarted */
@ -146,7 +153,6 @@ void restart_test(void)
/* Start the children and wait for first one to complete */ /* Start the children and wait for first one to complete */
printf("\nTest task_restart()\n"); printf("\nTest task_restart()\n");
g_restarted = false;
/* Set up an environment variables */ /* Set up an environment variables */
@ -155,6 +161,8 @@ void restart_test(void)
setenv(g_varname, g_varvalue, TRUE); /* Variable1=GoodValue1 */ setenv(g_varname, g_varvalue, TRUE); /* Variable1=GoodValue1 */
#endif #endif
sem_init(&g_sem, 0, 0);
/* Start the task */ /* Start the task */
ret = task_create("ostest", PRIORITY, STACKSIZE, restart_main, g_argv); ret = task_create("ostest", PRIORITY, STACKSIZE, restart_main, g_argv);
@ -171,6 +179,25 @@ void restart_test(void)
/* Wait a bit and restart the task */ /* Wait a bit and restart the task */
sleep(5); sleep(5);
g_restartstep = 1;
ret = task_restart(pid);
if (ret < 0)
{
printf("restart_main: ERROR: task_restart failed\n");
}
/* Start the task wait for a semaphore */
printf("restart_main: Started restart_main at PID=%d\n", pid);
/* Wait a bit and restart the task */
sleep(5);
g_restartstep = 2;
ret = task_restart(pid); ret = task_restart(pid);
if (ret < 0) if (ret < 0)
{ {
@ -180,5 +207,7 @@ void restart_test(void)
sleep(1); sleep(1);
} }
sem_destroy(&g_sem);
printf("restart_main: Exiting\n"); printf("restart_main: Exiting\n");
} }