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

ostest: sighand.c: add sem_wait in signal handler

Browse Source 
task is blocked by semphore1, signal handler is blocked by semphore2,
after post semphore2, the task must get -EINTR.

Signed-off-by: Zeng Zhaoxiu <zhaoxiu.zeng@gmail.com>
This commit is contained in:
Zeng Zhaoxiu 2022-01-04 15:53:16 +08:00 committed by Masayuki Ishikawa
parent 4a14126d76
commit 614b73d321
1 changed files with 61 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
testing/ostest/sighand.c
View File

@ -43,9 +43,11 @@
* Private Data * Private Data
****************************************************************************/ ****************************************************************************/
static sem_t sem; static sem_t sem1;
static sem_t sem2;
static bool sigreceived = false; static bool sigreceived = false;
static bool threadexited = false; static bool thread1exited = false;
static bool thread2exited = false;
/**************************************************************************** /****************************************************************************
* Private Functions * Private Functions
@ -134,6 +136,19 @@ static void wakeup_action(int signo, siginfo_t *info, void *ucontext)
printf("wakeup_action: ERROR sigprocmask=%jx expected=%jx\n", printf("wakeup_action: ERROR sigprocmask=%jx expected=%jx\n",
(uintmax_t)oldset, (uintmax_t)allsigs); (uintmax_t)oldset, (uintmax_t)allsigs);
} }
/* Checkout sem_wait */
status = sem_wait(&sem2);
if (status != 0)
{
int error = errno;
printf("wakeup_action: ERROR sem_wait failed, errno=%d\n" , error);
}
else
{
printf("wakeup_action: sem_wait() successfully!\n");
}
} }
static int waiter_main(int argc, char *argv[]) static int waiter_main(int argc, char *argv[])
@ -179,7 +194,7 @@ static int waiter_main(int argc, char *argv[])
printf("waiter_main: Waiting on semaphore\n"); printf("waiter_main: Waiting on semaphore\n");
FFLUSH(); FFLUSH();
status = sem_wait(&sem); status = sem_wait(&sem1);
if (status != 0) if (status != 0)
{ {
int error = errno; int error = errno;
@ -206,7 +221,27 @@ static int waiter_main(int argc, char *argv[])
printf("waiter_main: done\n"); printf("waiter_main: done\n");
FFLUSH(); FFLUSH();
threadexited = true; thread1exited = true;
return 0;
}
static int poster_main(int argc, char *argv[])
{
int status;
printf("poster_main: Poster started\n");
status = sem_post(&sem2);
if (status != 0)
{
int error = errno;
printf("poster_main: sem_post failed error=%d\n", error);
}
printf("poster_main: done\n");
FFLUSH();
thread2exited = true;
return 0; return 0;
} }
@ -223,11 +258,12 @@ void sighand_test(void)
#endif #endif
struct sched_param param; struct sched_param param;
union sigval sigvalue; union sigval sigvalue;
pid_t waiterpid; pid_t waiterpid, posterpid;
int status; int status;
printf("sighand_test: Initializing semaphore to 0\n"); printf("sighand_test: Initializing semaphore to 0\n");
sem_init(&sem, 0, 0); sem_init(&sem1, 0, 0);
sem_init(&sem2, 0, 0);
#ifdef CONFIG_SCHED_HAVE_PARENT #ifdef CONFIG_SCHED_HAVE_PARENT
printf("sighand_test: Unmasking SIGCHLD\n"); printf("sighand_test: Unmasking SIGCHLD\n");
@ -294,6 +330,19 @@ void sighand_test(void)
task_delete(waiterpid); task_delete(waiterpid);
} }
/* Start poster thread */
posterpid = task_create("poster", param.sched_priority,
STACKSIZE, poster_main, NULL);
if (posterpid == ERROR)
{
printf("sighand_test: ERROR failed to start poster_main\n");
}
else
{
printf("sighand_test: Started poster_main pid=%d\n", posterpid);
}
/* Wait a bit */ /* Wait a bit */
FFLUSH(); FFLUSH();
@ -301,11 +350,16 @@ void sighand_test(void)
/* Then check the result */ /* Then check the result */
if (!threadexited) if (!thread1exited)
{ {
printf("sighand_test: ERROR waiter task did not exit\n"); printf("sighand_test: ERROR waiter task did not exit\n");
} }
if (!thread2exited)
{
printf("sighand_test: ERROR poster task did not exit\n");
}
if (!sigreceived) if (!sigreceived)
{ {
printf("sighand_test: ERROR signal handler did not run\n"); printf("sighand_test: ERROR signal handler did not run\n");