Lines Matching refs:queue
97 mqd_t queue = -1; variable
187 if (queue != -1) in shutdown()
188 if (mq_close(queue)) in shutdown()
292 queue = mq_open(queue_path, flags, perms, attr); in open_queue()
293 if (queue == -1) in open_queue()
295 if (mq_getattr(queue, &result)) in open_queue()
329 while (mq_send(queue, buff, sizeof(buff), 0) == 0) in cont_thread()
331 mq_receive(queue, buff, sizeof(buff), &priority); in cont_thread()
336 while (mq_receive(queue, buff, MSG_SIZE, &prio_in) == MSG_SIZE)
340 if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
347 if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
350 if (mq_receive(queue, buff, MSG_SIZE, &prio_in) != MSG_SIZE) \