Lines Matching full:queue
19 static char queue[16] = "server"; variable
37 mqd = mq_open(queue, O_WRONLY); in sender_thread()
43 zassert_false(mq_close(mqd), "unable to close message queue descriptor."); in sender_thread()
53 mqd = mq_open(queue, O_RDONLY); in receiver_thread()
60 zassert_false(mq_close(mqd), "unable to close message queue descriptor."); in receiver_thread()
77 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
91 zassert_false(mq_close(mqd), "unable to close message queue descriptor."); in ZTEST()
92 zassert_false(mq_unlink(queue), "Not able to unlink Queue"); in ZTEST()
102 mqd = mq_open(queue, O_RDONLY); in notify_function_basic()
108 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in notify_function_basic()
131 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
139 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
140 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
151 mqd = mq_open(queue, O_RDONLY); in notify_function_thread()
157 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in notify_function_thread()
180 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
190 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
191 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
212 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
230 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
231 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
252 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
263 "Unexpected error while asigning notification to the queue."); in ZTEST()
269 zassert_ok(mq_notify(mqd, NULL), "Unable to remove notification from the message queue."); in ZTEST()
271 zassert_ok(mq_close(mqd), "Unable to close message queue descriptor."); in ZTEST()
272 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
297 zassert_ok(mq_close(mqd1), "Unable to close message queue 1 descriptor."); in ZTEST()
298 zassert_ok(mq_close(mqd2), "Unable to close message queue 2 descriptor."); in ZTEST()