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

apps: update mqueue_open usage

Browse Source 
As the mqd_t change to int

Change-Id: I16a9c137b6308eeec0badd241a101359e5f751b4
Signed-off-by: ligd <liguiding1@xiaomi.com>
This commit is contained in:
ligd 2021-01-03 20:13:39 +08:00 committed by Xiang Xiao
parent 135c5f61e1
commit ef0c6b30c4
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
testing/ostest/mqueue.c
View File

@ -180,7 +180,7 @@ static void *receiver_thread(void *arg)
*/ */
g_recv_mqfd = mq_open("mqueue", O_RDONLY | O_CREAT, 0666, &attr); g_recv_mqfd = mq_open("mqueue", O_RDONLY | O_CREAT, 0666, &attr);
if (g_recv_mqfd < 0) if (g_recv_mqfd == (mqd_t)-1)
{ {
printf("receiver_thread: ERROR mq_open failed\n"); printf("receiver_thread: ERROR mq_open failed\n");
pthread_exit((pthread_addr_t)1); pthread_exit((pthread_addr_t)1);
@ -259,7 +259,7 @@ static void *receiver_thread(void *arg)
} }
else else
{ {
g_recv_mqfd = NULL; g_recv_mqfd = 0;
} }
printf("receiver_thread: returning nerrors=%d\n", nerrors); printf("receiver_thread: returning nerrors=%d\n", nerrors);

4
testing/ostest/timedmqueue.c
View File

@ -188,7 +188,7 @@ static void *sender_thread(void *arg)
} }
else else
{ {
g_send_mqfd = NULL; g_send_mqfd = 0;
} }
printf("sender_thread: returning nerrors=%d\n", nerrors); printf("sender_thread: returning nerrors=%d\n", nerrors);
@ -314,7 +314,7 @@ static void *receiver_thread(void *arg)
} }
else else
{ {
g_recv_mqfd = NULL; g_recv_mqfd = 0;
} }
printf("receiver_thread: returning nerrors=%d\n", nerrors); printf("receiver_thread: returning nerrors=%d\n", nerrors);