Searched refs:mqd (Results 1 – 2 of 2) sorted by relevance
| /Zephyr-latest/tests/posix/common/src/ |
| D | mqueue.c | 34 mqd_t mqd; in sender_thread() local
37 mqd = mq_open(queue, O_WRONLY); in sender_thread()
40 zassert_false(mq_timedsend(mqd, send_data, MESSAGE_SIZE, 0, &curtime), in sender_thread()
43 zassert_false(mq_close(mqd), in sender_thread()
52 mqd_t mqd; in receiver_thread() local
55 mqd = mq_open(queue, O_RDONLY); in receiver_thread()
58 mq_timedreceive(mqd, rec_data, MESSAGE_SIZE, 0, &curtime); in receiver_thread()
62 zassert_false(mq_close(mqd), in receiver_thread()
70 mqd_t mqd; in ZTEST() local
80 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
[all …]
|
| /Zephyr-latest/lib/posix/options/ |
| D | mqueue.c | 39 static int32_t send_message(mqueue_desc *mqd, const char *msg_ptr, size_t msg_len,
41 static int32_t receive_message(mqueue_desc *mqd, char *msg_ptr, size_t msg_len,
62 mqueue_desc *msg_queue_desc = NULL, *mqd = (mqueue_desc *)(-1); in mq_open() local
81 return (mqd_t)mqd; in mq_open()
86 return (mqd_t)mqd; in mq_open()
98 return (mqd_t)mqd; in mq_open()
103 return (mqd_t)mqd; in mq_open()
179 return (mqd_t)mqd; in mq_open()
189 mqueue_desc *mqd = (mqueue_desc *)mqdes; in mq_close() local
191 if (mqd == NULL) { in mq_close()
[all …]
|
