Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 16 of 16) sorted by relevance

/ThreadX-v6.4.1/utility/rtos_compatibility_layers/posix/
Dpx_mq_priority_search.c73 TX_QUEUE *queue; in posix_priority_search() local
81 queue = &(msgQId->f_data->queue); in posix_priority_search()
82 q_ptr = (POSIX_MSG_QUEUE * )queue; in posix_priority_search()
85 numMsgs = q_ptr -> queue.tx_queue_enqueued; in posix_priority_search()
88 source = q_ptr->queue.tx_queue_read; in posix_priority_search()
98 if(source == q_ptr->queue.tx_queue_end) in posix_priority_search()
99 source = q_ptr->queue.tx_queue_start; in posix_priority_search()
Dpx_mq_queue_delete.c72 TX_QUEUE *queue; in posix_queue_delete() local
74 queue = &(q_ptr->queue); in posix_queue_delete()
77 if(tx_queue_delete(queue)) in posix_queue_delete()
Dpx_mq_send.c94 Queue = &(mqdes->f_data->queue); in mq_send()
120 if ( (!q_ptr) || ( (q_ptr->queue.tx_queue_id) != TX_QUEUE_ID)) in mq_send()
Dpx_mq_close.c79 Queue = &(mqdes->f_data->queue); in mq_close()
Dreadme_threadx_posix.txt54 (WORK_QUEUE_DEPTH * WORK_REQ_SIZE) + /* system queue size */
71 PATH_MAX 10 /* maximum length of name of a message queue */
274 b.) If pAttr is NULL, the message queue is created with
275 implementation-defined default message queue attributes.
276 The default message queue attributes selected are :
287 a.) In POSIX : If more than one mq_send() is blocked on a queue and
288 space becomes available in that queue, the message with the highest
291 b.) If a message is sent (or received) to a queue with out opening the named
292 queue, in such a case mqdes (message queue descriptor) pointer is
298 a.) If a receive (or send) message from queue with out it being opened, erratic
Dpx_mq_create.c126 temp1 = tx_queue_create((&(posix_q->queue)), in posix_mq_create()
Dtx_posix.h59 #define MAKE_POSIX_QUEUE(queue) ((POSIX_MSG_QUEUE *)queue) argument
390 TX_QUEUE queue; member
Dpx_mq_receive.c92 Queue = &(mqdes->f_data->queue); in mq_receive()
/ThreadX-v6.4.1/test/tx/regression/
Dthreadx_queue_basic_two_word_test.c12 TX_QUEUE queue; member
121 …status = tx_queue_create(&queue_memory.queue, "queue memory", TX_2_ULONG, &queue_memory.queue_are… in thread_0_entry()
122 tx_queue_delete(&queue_memory.queue); in thread_0_entry()
/ThreadX-v6.4.1/test/smp/regression/
Dthreadx_queue_basic_two_word_test.c12 TX_QUEUE queue; member
121 …status = tx_queue_create(&queue_memory.queue, "queue memory", TX_2_ULONG, &queue_memory.queue_are… in thread_0_entry()
122 tx_queue_delete(&queue_memory.queue); in thread_0_entry()
/ThreadX-v6.4.1/utility/benchmarks/thread_metric/
Dthread_metric_readme.txt63 queue and retrieving the same 16 byte message from the queue.
160 This function creates a queue with a capacity to hold at least
165 This function sends a message to the previously created queue.
171 queue. If successful, a TM_SUCCESS is returned.
/ThreadX-v6.4.1/utility/rtos_compatibility_layers/FreeRTOS/
Dtx_freertos.c1398 ret = tx_queue_send(&xSemaphore->p_set->queue, &xSemaphore, TX_NO_WAIT); in xSemaphoreGive()
1640 ret = tx_queue_send(&xQueue->p_set->queue, &xQueue, TX_NO_WAIT); in xQueueSend()
1736 ret = tx_queue_send(&xQueue->p_set->queue, &xQueue, TX_NO_WAIT); in xQueueSendToFront()
2724 ret = tx_queue_create(&p_set->queue, "", sizeof(void *) / sizeof(UINT), p_mem, queue_size); in xQueueCreateSet()
2834 ret = tx_queue_receive(&xQueueSet->queue, &p_ptr, timeout); in xQueueSelectFromSet()
DFreeRTOS.h250 TX_QUEUE queue; member
Dreadme.md13 - queue.h
239 The FreeRTOS queue API is implemented with the help of ThreadX semaphores and is designed to mimic …
/ThreadX-v6.4.1/ports/c667x/ccs/example_build/include/
DC66XX_FUNCTIONS.hxx1665 int32_t C66XX_SRIO_map_tx_queue(uint32_t queue, C66XX_SRIO_TX_QUEUE_SCH_DD *tx_queue_sch_dd);
/ThreadX-v6.4.1/docs/
Drevision_history.txt63 … and added macro for extending queue delete.
918 tx_queue.h Added macro for copying queue message.
1278 … from the queue in order to avoid losing messages
1281 … tx_queue_receive.c Check for queue front send suspension request