Lines Matching full:queue

19 static char queue[16] = "server";  variable
37 mqd = mq_open(queue, O_WRONLY); in sender_thread()
44 "unable to close message queue descriptor."); in sender_thread()
55 mqd = mq_open(queue, O_RDONLY); in receiver_thread()
63 "unable to close message queue descriptor."); in receiver_thread()
80 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
95 "unable to close message queue descriptor."); in ZTEST()
96 zassert_false(mq_unlink(queue), "Not able to unlink Queue"); in ZTEST()
106 mqd = mq_open(queue, O_RDONLY); in notify_function_basic()
112 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in notify_function_basic()
135 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
143 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
144 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
155 mqd = mq_open(queue, O_RDONLY); in notify_function_thread()
161 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in notify_function_thread()
184 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
194 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
195 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
216 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
234 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
235 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
256 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
267 "Unexpected error while asigning notification to the queue."); 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()
276 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()