Home
last modified time | relevance | path

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

/ThreadX-v6.3.0/utility/rtos_compatibility_layers/posix/
Dpx_mq_send.c80 INT mq_send( mqd_t mqdes, const CHAR * msg_ptr, size_t msg_len, in mq_send() argument
95 Queue = &(mqdes->f_data->queue); in mq_send()
96 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_send()
130 if(((mqdes->f_flag & O_WRONLY) != O_WRONLY) && ((mqdes->f_flag & O_RDWR) != O_RDWR)) in mq_send()
201 msg[4] = posix_priority_search(mqdes, msg_prio); in mq_send()
206 msg[3] = posix_priority_search(mqdes, msg_prio); in mq_send()
Dpx_mq_receive.c79 ssize_t mq_receive( mqd_t mqdes, VOID * pMsg, size_t msgLen, ULONG *pMsgPrio) in mq_receive() argument
93 Queue = &(mqdes->f_data->queue); in mq_receive()
94 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_receive()
106 if(((mqdes ->f_flag & O_RDONLY) != O_RDONLY ) && ((mqdes->f_flag & O_RDWR) != O_RDWR)) in mq_receive()
138 if ( ( mqdes ->f_flag & O_NONBLOCK ) == O_NONBLOCK ) in mq_receive()
Dpx_mq_close.c71 INT mq_close(mqd_t mqdes) in mq_close() argument
80 Queue = &(mqdes->f_data->queue); in mq_close()
106 if( tx_byte_release( ( VOID *) mqdes )) in mq_close()
Dtx_posix.h484 INT mq_send(mqd_t mqdes, const char * msg_ptr,
486 ssize_t mq_receive(mqd_t mqdes, VOID *pMsg, size_t msgLen,
489 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