34 	mqd_t mqd;  in sender_thread()  local
37 	mqd = mq_open(queue, O_WRONLY);  in sender_thread()
40 	zassert_false(mq_timedsend(mqd, send_data, MESSAGE_SIZE, 0, &curtime),  in sender_thread()
43 	zassert_false(mq_close(mqd),  in sender_thread()
52 	mqd_t mqd;  in receiver_thread()  local
55 	mqd = mq_open(queue, O_RDONLY);  in receiver_thread()
58 	mq_timedreceive(mqd, rec_data, MESSAGE_SIZE, 0, &curtime);  in receiver_thread()
62 	zassert_false(mq_close(mqd),  in receiver_thread()
70 	mqd_t mqd;  in ZTEST()  local
80 	mqd = mq_open(queue, flags, mode, &attrs);  in ZTEST()
94 	zassert_false(mq_close(mqd),  in ZTEST()
103 	mqd_t mqd;  in notify_function_basic()  local
106 	mqd = mq_open(queue, O_RDONLY);  in notify_function_basic()
108 	mq_receive(mqd, rec_data, MESSAGE_SIZE, 0);  in notify_function_basic()
112 	zassert_ok(mq_close(mqd), "Unable to close message queue descriptor.");  in notify_function_basic()
119 	mqd_t mqd;  in ZTEST()  local
135 	mqd = mq_open(queue, flags, mode, &attrs);  in ZTEST()
137 	zassert_ok(mq_notify(mqd, &not), "Unable to set notification.");  in ZTEST()
139 	zassert_ok(mq_send(mqd, send_data, MESSAGE_SIZE, 0), "Unable to send message");  in ZTEST()
143 	zassert_ok(mq_close(mqd), "Unable to close message queue descriptor.");  in ZTEST()
149 	mqd_t mqd;  in notify_function_thread()  local
155 	mqd = mq_open(queue, O_RDONLY);  in notify_function_thread()
157 	mq_receive(mqd, rec_data, MESSAGE_SIZE, 0);  in notify_function_thread()
161 	zassert_ok(mq_close(mqd), "Unable to close message queue descriptor.");  in notify_function_thread()
168 	mqd_t mqd;  in ZTEST()  local
184 	mqd = mq_open(queue, flags, mode, &attrs);  in ZTEST()
186 	zassert_ok(mq_notify(mqd, &not), "Unable to set notification.");  in ZTEST()
188 	zassert_ok(mq_send(mqd, send_data, MESSAGE_SIZE, 0), "Unable to send message");  in ZTEST()
194 	zassert_ok(mq_close(mqd), "Unable to close message queue descriptor.");  in ZTEST()
200 	mqd_t mqd;  in ZTEST()  local
216 	mqd = mq_open(queue, flags, mode, &attrs);  in ZTEST()
218 	zassert_ok(mq_send(mqd, send_data, MESSAGE_SIZE, 0), "Unable to send message");  in ZTEST()
220 	zassert_ok(mq_notify(mqd, &not), "Unable to set notification.");  in ZTEST()
224 	mq_receive(mqd, rec_data, MESSAGE_SIZE, 0);  in ZTEST()
230 	zassert_ok(mq_send(mqd, send_data, MESSAGE_SIZE, 0), "Unable to send message");  in ZTEST()
234 	zassert_ok(mq_close(mqd), "Unable to close message queue descriptor.");  in ZTEST()
240 	mqd_t mqd;  in ZTEST()  local
256 	mqd = mq_open(queue, flags, mode, &attrs);  in ZTEST()
258 	zassert_not_ok(mq_notify(mqd, NULL), "Should return -1 and set errno to EINVAL.");  in ZTEST()
261 	zassert_not_ok(mq_notify(mqd, &not), "SIGEV_SIGNAL not supported should return -1.");  in ZTEST()
266 	zassert_ok(mq_notify(mqd, &not),  in ZTEST()
269 	zassert_not_ok(mq_notify(mqd, &not),  in ZTEST()
273 	zassert_ok(mq_notify(mqd, NULL), "Unable to remove notification from the message queue.");  in ZTEST()
275 	zassert_ok(mq_close(mqd), "Unable to close message queue descriptor.");  in ZTEST()