Lines Matching refs:queue

96 mqd_t queue = -1;  variable
186 	if (queue != -1)  in shutdown()
187 		if (mq_close(queue))  in shutdown()
291 	queue = mq_open(queue_path, flags, perms, attr);  in open_queue()
292 	if (queue == -1)  in open_queue()
294 	if (mq_getattr(queue, &result))  in open_queue()
328 		while (mq_send(queue, buff, sizeof(buff), 0) == 0)  in cont_thread()
330 		mq_receive(queue, buff, sizeof(buff), &priority);  in cont_thread()
335 	while (mq_receive(queue, buff, MSG_SIZE, &prio_in) == MSG_SIZE)
339 		if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
346 		if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
349 		if (mq_receive(queue, buff, MSG_SIZE, &prio_in) != MSG_SIZE) \