Lines Matching refs:queue
135 sane_queue(const char *queue) in sane_queue() argument
139 if (queue[size] != '/') { in sane_queue()
140 warnx("queue name [%-.*s] must start with '/'.", NAME_MAX, queue); in sane_queue()
144 for (size++; queue[size] != 0 && size < NAME_MAX; size++) { in sane_queue()
145 if (queue[size] == '/') { in sane_queue()
147 NAME_MAX, queue); in sane_queue()
152 if (size == NAME_MAX && queue[size] != 0) { in sane_queue()
154 NAME_MAX, queue, NAME_MAX); in sane_queue()
242 parse_queue(const char *queue) in parse_queue() argument
244 if (sane_queue(queue)) { in parse_queue()
247 n1->text = queue; in parse_queue()
253 parse_single_queue(const char *queue) in parse_single_queue() argument
255 if (sane_queue(queue)) { in parse_single_queue()
259 n1->text = queue; in parse_single_queue()
262 warnx("ignoring extra -q queue [%s].", queue); in parse_single_queue()
425 create(const char *queue, struct Creation q_creation) in create() argument
440 mqd_t handle = mq_open(queue, flags); in create()
452 handle = mq_open(queue, flags, q_creation.mode, &stuff); in create()
522 rm(const char *queue) in rm() argument
524 int result = mq_unlink(queue); in rm()
558 info(const char *queue) in info() argument
560 mqd_t handle = mq_open(queue, O_RDONLY); in info()
582 queue, actual.mq_msgsize * actual.mq_curmsgs, actual.mq_msgsize, in info()
615 recv(const char *queue) in recv() argument
617 mqd_t handle = mq_open(queue, O_RDONLY); in recv()
661 send(const char *queue, const char *text, unsigned q_priority) in send() argument
663 mqd_t handle = mq_open(queue, O_WRONLY); in send()
832 const char *queue = itq->text; in main() local
834 int result = create(queue, creation); in main()
850 const char *queue = itq->text; in main() local
851 int result = info(queue); in main()
868 const char *queue = itq->text; in main() local
873 int result = send(queue, content, priority); in main()
887 const char *queue = STAILQ_FIRST(&queues)->text; in main() local
888 int worst = recv(queue); in main()
902 const char *queue = itq->text; in main() local
903 int result = rm(queue); in main()