You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nuttx.apache.org by ma...@apache.org on 2022/01/05 12:34:39 UTC
[incubator-nuttx-apps] branch master updated: ostest: sighand.c: add sem_wait in signal handler
This is an automated email from the ASF dual-hosted git repository.
masayuki pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-nuttx-apps.git
The following commit(s) were added to refs/heads/master by this push:
new 614b73d ostest: sighand.c: add sem_wait in signal handler
614b73d is described below
commit 614b73d3215b267f100d75463933a6dc41072225
Author: Zeng Zhaoxiu <zh...@gmail.com>
AuthorDate: Tue Jan 4 15:53:16 2022 +0800
ostest: sighand.c: add sem_wait in signal handler
task is blocked by semphore1, signal handler is blocked by semphore2,
after post semphore2, the task must get -EINTR.
Signed-off-by: Zeng Zhaoxiu <zh...@gmail.com>
---
testing/ostest/sighand.c | 68 +++++++++++++++++++++++++++++++++++++++++++-----
1 file changed, 61 insertions(+), 7 deletions(-)
diff --git a/testing/ostest/sighand.c b/testing/ostest/sighand.c
index 134c9b5..890ba7d 100644
--- a/testing/ostest/sighand.c
+++ b/testing/ostest/sighand.c
@@ -43,9 +43,11 @@
* Private Data
****************************************************************************/
-static sem_t sem;
+static sem_t sem1;
+static sem_t sem2;
static bool sigreceived = false;
-static bool threadexited = false;
+static bool thread1exited = false;
+static bool thread2exited = false;
/****************************************************************************
* 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",
(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[])
@@ -179,7 +194,7 @@ static int waiter_main(int argc, char *argv[])
printf("waiter_main: Waiting on semaphore\n");
FFLUSH();
- status = sem_wait(&sem);
+ status = sem_wait(&sem1);
if (status != 0)
{
int error = errno;
@@ -206,7 +221,27 @@ static int waiter_main(int argc, char *argv[])
printf("waiter_main: done\n");
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;
}
@@ -223,11 +258,12 @@ void sighand_test(void)
#endif
struct sched_param param;
union sigval sigvalue;
- pid_t waiterpid;
+ pid_t waiterpid, posterpid;
int status;
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
printf("sighand_test: Unmasking SIGCHLD\n");
@@ -294,6 +330,19 @@ void sighand_test(void)
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 */
FFLUSH();
@@ -301,11 +350,16 @@ void sighand_test(void)
/* Then check the result */
- if (!threadexited)
+ if (!thread1exited)
{
printf("sighand_test: ERROR waiter task did not exit\n");
}
+ if (!thread2exited)
+ {
+ printf("sighand_test: ERROR poster task did not exit\n");
+ }
+
if (!sigreceived)
{
printf("sighand_test: ERROR signal handler did not run\n");