| /ThreadX-v6.3.0/common/src/ |
| D | tx_queue_create.c | 77 UINT _tx_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _tx_queue_create()
85 TX_QUEUE *next_queue; in _tx_queue_create()
86 TX_QUEUE *previous_queue; in _tx_queue_create()
90 TX_MEMSET(queue_ptr, 0, (sizeof(TX_QUEUE))); in _tx_queue_create()
|
| D | txe_queue_send_notify.c | 74 UINT _txe_queue_send_notify(TX_QUEUE *queue_ptr, VOID (*queue_send_notify)(TX_QUEUE *notify_queue_… in _txe_queue_send_notify()
|
| D | tx_queue_send_notify.c | 75 UINT _tx_queue_send_notify(TX_QUEUE *queue_ptr, VOID (*queue_send_notify)(TX_QUEUE *notify_queue_p… in _tx_queue_send_notify()
|
| D | tx_queue_delete.c | 76 UINT _tx_queue_delete(TX_QUEUE *queue_ptr) in _tx_queue_delete()
84 TX_QUEUE *next_queue; in _tx_queue_delete()
85 TX_QUEUE *previous_queue; in _tx_queue_delete()
|
| D | txe_queue_create.c | 83 UINT _txe_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _txe_queue_create()
91 TX_QUEUE *next_queue; in _txe_queue_create()
109 else if (queue_control_block_size != (sizeof(TX_QUEUE))) in _txe_queue_create()
|
| D | txe_queue_info_get.c | 81 UINT _txe_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_stora… in _txe_queue_info_get()
82 TX_THREAD **first_suspended, ULONG *suspended_count, TX_QUEUE **next_queue) in _txe_queue_info_get()
|
| D | tx_queue_info_get.c | 80 UINT _tx_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storag… in _tx_queue_info_get()
81 TX_THREAD **first_suspended, ULONG *suspended_count, TX_QUEUE **next_queue) in _tx_queue_info_get()
|
| /ThreadX-v6.3.0/common_smp/src/ |
| D | tx_queue_create.c | 77 UINT _tx_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _tx_queue_create()
85 TX_QUEUE *next_queue; in _tx_queue_create()
86 TX_QUEUE *previous_queue; in _tx_queue_create()
90 TX_MEMSET(queue_ptr, 0, (sizeof(TX_QUEUE))); in _tx_queue_create()
|
| D | txe_queue_send_notify.c | 74 UINT _txe_queue_send_notify(TX_QUEUE *queue_ptr, VOID (*queue_send_notify)(TX_QUEUE *notify_queue_… in _txe_queue_send_notify()
|
| D | tx_queue_send_notify.c | 75 UINT _tx_queue_send_notify(TX_QUEUE *queue_ptr, VOID (*queue_send_notify)(TX_QUEUE *notify_queue_p… in _tx_queue_send_notify()
|
| D | txe_queue_create.c | 83 UINT _txe_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _txe_queue_create()
91 TX_QUEUE *next_queue; in _txe_queue_create()
109 else if (queue_control_block_size != (sizeof(TX_QUEUE))) in _txe_queue_create()
|
| D | tx_queue_delete.c | 76 UINT _tx_queue_delete(TX_QUEUE *queue_ptr) in _tx_queue_delete()
84 TX_QUEUE *next_queue; in _tx_queue_delete()
85 TX_QUEUE *previous_queue; in _tx_queue_delete()
|
| D | txe_queue_info_get.c | 81 UINT _txe_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_stora… in _txe_queue_info_get()
82 TX_THREAD **first_suspended, ULONG *suspended_count, TX_QUEUE **next_queue) in _txe_queue_info_get()
|
| D | tx_queue_info_get.c | 80 UINT _tx_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storag… in _tx_queue_info_get()
81 TX_THREAD **first_suspended, ULONG *suspended_count, TX_QUEUE **next_queue) in _tx_queue_info_get()
|
| /ThreadX-v6.3.0/common_modules/module_lib/src/ |
| D | txm_queue_send_notify.c | 69 UINT _txe_queue_send_notify(TX_QUEUE *queue_ptr, VOID (*queue_send_notify)(TX_QUEUE *notify_queue_p… in _txe_queue_send_notify()
|
| D | txm_module_callback_request_thread_entry.c | 90 TX_QUEUE *request_queue; in _txm_module_callback_request_thread_entry()
96 VOID (*queue_send_notify)(TX_QUEUE *); in _txm_module_callback_request_thread_entry()
158 …queue_send_notify = (void (*)(TX_QUEUE *)) callback_message.txm_module_callback_message_applicati… in _txm_module_callback_request_thread_entry()
161 … (queue_send_notify)((TX_QUEUE *) callback_message.txm_module_callback_message_param_1); in _txm_module_callback_request_thread_entry()
|
| D | txm_queue_info_get.c | 76 …fo_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storage, TX_THREAD **fi… in _txe_queue_info_get()
|
| /ThreadX-v6.3.0/common_modules/module_manager/src/ |
| D | txm_module_manager_queue_notify_trampoline.c | 68 VOID _txm_module_manager_queue_notify_trampoline(TX_QUEUE *queue_ptr) in _txm_module_manager_queue_notify_trampoline()
75 TX_QUEUE *module_callback_queue; in _txm_module_manager_queue_notify_trampoline()
|
| /ThreadX-v6.3.0/utility/rtos_compatibility_layers/posix/ |
| D | px_mq_create.c | 92 TX_QUEUE *TheQ; in posix_mq_create()
176 TheQ = (TX_QUEUE * )posix_q; in posix_mq_create()
|
| D | px_int.h | 81 PX_OBJECT_DECLARE TX_QUEUE posix_work_queue;
142 ULONG posix_arrange_msg( TX_QUEUE * Queue, ULONG * pMsgPrio );
166 VOID posix_putback_queue(TX_QUEUE * qid);
|
| D | px_mq_putback_queue.c | 67 VOID posix_putback_queue(TX_QUEUE * qid) in posix_putback_queue()
|
| /ThreadX-v6.3.0/test/tx/regression/ |
| D | threadx_queue_empty_suspension_test.c | 16 static TX_QUEUE queue_0;
17 static TX_QUEUE queue_1;
32 static void queue_notify(TX_QUEUE *queue_ptr) in queue_notify()
|
| D | threadx_queue_suspension_timeout_test.c | 16 static TX_QUEUE queue_0;
17 static TX_QUEUE queue_1;
32 static void queue_notify(TX_QUEUE *queue_ptr) in queue_notify()
|
| /ThreadX-v6.3.0/test/smp/regression/ |
| D | threadx_queue_suspension_timeout_test.c | 16 static TX_QUEUE queue_0;
17 static TX_QUEUE queue_1;
32 static void queue_notify(TX_QUEUE *queue_ptr) in queue_notify()
|
| D | threadx_queue_empty_suspension_test.c | 16 static TX_QUEUE queue_0;
17 static TX_QUEUE queue_1;
32 static void queue_notify(TX_QUEUE *queue_ptr) in queue_notify()
|
