Lines Matching refs:queue
19 static char queue[16] = "server"; variable
37 mqd = mq_open(queue, O_WRONLY); in sender_thread()
53 mqd = mq_open(queue, O_RDONLY); in receiver_thread()
77 mqd = mq_open(queue, flags, mode, &attrs); 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()
131 mqd = mq_open(queue, flags, mode, &attrs); 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()
180 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
191 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
212 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
231 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
252 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
272 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()