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

ostest/wqueue: Check return value for pthread ops.

Browse Source 
Signed-off-by: Zhe Weng <wengzhe@xiaomi.com>
This commit is contained in:
Zhe Weng 2023-08-21 14:57:06 +08:00 committed by Xiang Xiao
parent 8757c6934c
commit 87838bb62c
1 changed files with 54 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
testing/ostest/wqueue.c
View File

@ -143,27 +143,72 @@ static void run_once(int interval, int priority_test, int priority_verify)
pthread_t thread;
pthread_attr_t attr;
struct sched_param sparam;
int status;
status = pthread_attr_init(&attr);
if (status != 0)
{
printf("wqueue_test: pthread_attr_init failed, status=%d\n", status);
}
pthread_attr_init(&attr);
memset(&sparam, 0, sizeof(sparam));
/* Tester: try race conditions. */
sparam.sched_priority = priority_test;
pthread_attr_setschedparam(&attr, &sparam);
status = pthread_attr_setschedparam(&attr, &sparam);
if (status != 0)
{
printf("wqueue_test: pthread_attr_setschedparam failed for tester, "
"status=%d\n", status);
}
pthread_create(&thread, &attr, tester, (FAR void *)(intptr_t)interval);
pthread_join(thread, NULL);
status = pthread_create(&thread, &attr, tester,
(FAR void *)(intptr_t)interval);
if (status != 0)
{
printf("wqueue_test: pthread_create failed for tester, "
"status=%d\n", status);
}
status = pthread_join(thread, NULL);
if (status != 0)
{
printf("wqueue_test: pthread_join failed for tester, "
"status=%d\n", status);
}
/* Verifier: make sure queue is still working properly. */
sparam.sched_priority = priority_verify;
pthread_attr_setschedparam(&attr, &sparam);
pthread_attr_setstacksize(&attr,
VERIFY_COUNT * sizeof(struct work_s) + CONFIG_PTHREAD_STACK_DEFAULT);
status = pthread_attr_setschedparam(&attr, &sparam);
if (status != 0)
{
printf("wqueue_test: pthread_attr_setschedparam failed for verifier, "
"status=%d\n", status);
}
pthread_create(&thread, &attr, verifier, NULL);
pthread_join(thread, NULL);
status = pthread_attr_setstacksize(&attr,
VERIFY_COUNT * sizeof(struct work_s) + CONFIG_PTHREAD_STACK_DEFAULT);
if (status != 0)
{
printf("wqueue_test: pthread_attr_setstacksize failed for verifier, "
"status=%d\n", status);
}
status = pthread_create(&thread, &attr, verifier, NULL);
if (status != 0)
{
printf("wqueue_test: pthread_create failed for verifier, "
"status=%d\n", status);
}
status = pthread_join(thread, NULL);
if (status != 0)
{
printf("wqueue_test: pthread_join failed for verifier, "
"status=%d\n", status);
}
}
/****************************************************************************