Lines Matching defs:queue
10 * Test that mq_open() does not add messages to the queue or remove
11 * messages from the queue.
14 * - Call mq_open() for non-blocking queue
15 * - Verify mq_receive() fails (because nothing should be in the queue yet)
16 * - Call mq_send() to put something in the queue
17 * - Call mq_open() again for non-blocking queue
19 * still be in the queue).
42 mqd_t queue;
52 queue = mq_open(qname, O_CREAT | O_RDWR | O_NONBLOCK,
54 if (queue == (mqd_t) - 1) {
60 if (mq_receive(queue, msgrcd, BUFFER, &pri) != -1) {
62 printf("mq_open() may have placed a message in the queue\n");
66 if (mq_send(queue, msgptr, strlen(msgptr), 1) == -1) {
69 /* close queue and exit */
70 mq_close(queue);
75 queue = mq_open(qname, O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, NULL);
76 if (queue == (mqd_t) - 1) {
79 /* close queue and exit */
80 mq_close(queue);
85 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) {
87 printf("mq_open() may have removed a msg from the queue\n");
91 mq_close(queue);
