Home
last modified time | relevance | path

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

/ThreadX-v6.3.0/utility/rtos_compatibility_layers/posix/
Dpx_mq_priority_search.c74 TX_QUEUE *queue; in posix_priority_search() local
82 queue = &(msgQId->f_data->queue); in posix_priority_search()
83 q_ptr = (POSIX_MSG_QUEUE * )queue; in posix_priority_search()
86 numMsgs = q_ptr -> queue.tx_queue_enqueued; in posix_priority_search()
89 source = q_ptr->queue.tx_queue_read; in posix_priority_search()
99 if(source == q_ptr->queue.tx_queue_end) in posix_priority_search()
100 source = q_ptr->queue.tx_queue_start; in posix_priority_search()
Dpx_mq_queue_delete.c73 TX_QUEUE *queue; in posix_queue_delete() local
75 queue = &(q_ptr->queue); in posix_queue_delete()
78 if(tx_queue_delete(queue)) in posix_queue_delete()
Dpx_mq_send.c95 Queue = &(mqdes->f_data->queue); in mq_send()
121 if ( (!q_ptr) || ( (q_ptr->queue.tx_queue_id) != TX_QUEUE_ID)) in mq_send()
Dpx_mq_close.c80 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.c127 temp1 = tx_queue_create((&(posix_q->queue)), in posix_mq_create()
Dtx_posix.h60 #define MAKE_POSIX_QUEUE(queue) ((POSIX_MSG_QUEUE *)queue) argument
391 TX_QUEUE queue; member
Dpx_mq_receive.c93 Queue = &(mqdes->f_data->queue); in mq_receive()
/ThreadX-v6.3.0/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.3.0/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.3.0/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.3.0/utility/rtos_compatibility_layers/FreeRTOS/
Dtx_freertos.c1395 ret = tx_queue_send(&xSemaphore->p_set->queue, &xSemaphore, TX_NO_WAIT); in xSemaphoreGive()
1630 ret = tx_queue_send(&xQueue->p_set->queue, &xQueue, TX_NO_WAIT); in xQueueSend()
1726 ret = tx_queue_send(&xQueue->p_set->queue, &xQueue, TX_NO_WAIT); in xQueueSendToFront()
2707 ret = tx_queue_create(&p_set->queue, "", sizeof(void *) / sizeof(UINT), p_mem, queue_size); in xQueueCreateSet()
2817 ret = tx_queue_receive(&xQueueSet->queue, &p_ptr, timeout); in xQueueSelectFromSet()
DFreeRTOS.h251 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.3.0/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);