Home
last modified time | relevance | path

Searched refs:mqdes (Results 1 – 5 of 5) sorted by relevance

/ThreadX-v6.4.1/utility/rtos_compatibility_layers/posix/
Dpx_mq_send.c79 INT mq_send( mqd_t mqdes, const CHAR * msg_ptr, size_t msg_len, in mq_send() argument
94 Queue = &(mqdes->f_data->queue); in mq_send()
95 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_send()
129 if(((mqdes->f_flag & O_WRONLY) != O_WRONLY) && ((mqdes->f_flag & O_RDWR) != O_RDWR)) in mq_send()
200 msg[4] = posix_priority_search(mqdes, msg_prio); in mq_send()
205 msg[3] = posix_priority_search(mqdes, msg_prio); in mq_send()
Dpx_mq_receive.c78 ssize_t mq_receive( mqd_t mqdes, VOID * pMsg, size_t msgLen, ULONG *pMsgPrio) in mq_receive() argument
92 Queue = &(mqdes->f_data->queue); in mq_receive()
93 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_receive()
105 if(((mqdes ->f_flag & O_RDONLY) != O_RDONLY ) && ((mqdes->f_flag & O_RDWR) != O_RDWR)) in mq_receive()
137 if ( ( mqdes ->f_flag & O_NONBLOCK ) == O_NONBLOCK ) in mq_receive()
Dpx_mq_close.c70 INT mq_close(mqd_t mqdes) in mq_close() argument
79 Queue = &(mqdes->f_data->queue); in mq_close()
105 if( tx_byte_release( ( VOID *) mqdes )) in mq_close()
Dtx_posix.h483 INT mq_send(mqd_t mqdes, const char * msg_ptr,
485 ssize_t mq_receive(mqd_t mqdes, VOID *pMsg, size_t msgLen,
488 INT mq_close(mqd_t mqdes);
Dreadme_threadx_posix.txt94 INT mq_send(mqd_t mqdes, const char * msg_ptr,
96 ssize_t mq_receive(mqd_t mqdes, VOID *pMsg, ssize_t msgLen,
99 INT mq_close(mqd_t mqdes);
292 queue, in such a case mqdes (message queue descriptor) pointer is