Lines Matching refs:mq
60 rt_mq_t mq; in mq_getattr() local
63 mq = (rt_mq_t)mq_file->data; in mq_getattr()
64 if ((mq == RT_NULL) || mqstat == RT_NULL) in mq_getattr()
70 mqstat->mq_maxmsg = mq->max_msgs; in mq_getattr()
71 mqstat->mq_msgsize = mq->msg_size; in mq_getattr()
195 rt_mq_t mq; in mq_receive() local
199 mq = (rt_mq_t)mq_file->data; in mq_receive()
200 if ((mq == RT_NULL) || (msg_ptr == RT_NULL)) in mq_receive()
206 …result = rt_mq_recv_prio(mq, msg_ptr, msg_len, (rt_int32_t *)msg_prio, RT_WAITING_FOREVER, RT_UNIN… in mq_receive()
237 rt_mq_t mq; in mq_send() local
241 mq = (rt_mq_t)mq_file->data; in mq_send()
243 if ((mq == RT_NULL) || (msg_ptr == RT_NULL)) in mq_send()
248 result = rt_mq_send_wait_prio(mq, (void *)msg_ptr, msg_len, msg_prio, 0, RT_UNINTERRUPTIBLE); in mq_send()
289 rt_mq_t mq; in mq_timedreceive() local
294 mq = (rt_mq_t)mq_file->data; in mq_timedreceive()
296 if ((mq == RT_NULL) || (msg_ptr == RT_NULL)) in mq_timedreceive()
306 … result = rt_mq_recv_prio(mq, msg_ptr, msg_len, (rt_int32_t *)msg_prio, tick, RT_UNINTERRUPTIBLE); in mq_timedreceive()
364 rt_mq_t mq; in mq_notify() local
367 mq = (rt_mq_t)mq_file->data; in mq_notify()
368 if (mq == RT_NULL) in mq_notify()