Home
last modified time | relevance | path

Searched refs:queue_ptr (Results 1 – 25 of 327) sorted by relevance

12345678910>>...14

/ThreadX-v6.3.0/common/src/
Dtx_queue_create.c77 UINT _tx_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _tx_queue_create() argument
90 TX_MEMSET(queue_ptr, 0, (sizeof(TX_QUEUE))); in _tx_queue_create()
93 queue_ptr -> tx_queue_name = name_ptr; in _tx_queue_create()
96 queue_ptr -> tx_queue_message_size = message_size; in _tx_queue_create()
106 queue_ptr -> tx_queue_start = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
107 queue_ptr -> tx_queue_end = TX_ULONG_POINTER_ADD(queue_ptr -> tx_queue_start, used_words); in _tx_queue_create()
111 queue_ptr -> tx_queue_read = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
112 queue_ptr -> tx_queue_write = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
116 queue_ptr -> tx_queue_available_storage = (UINT) capacity; in _tx_queue_create()
117 queue_ptr -> tx_queue_capacity = (UINT) capacity; in _tx_queue_create()
[all …]
Dtx_queue_front_send.c80 UINT _tx_queue_front_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_front_send() argument
110 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_front_send()
114 …LINE_INSERT(TX_TRACE_QUEUE_FRONT_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_front_send()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_front_send()
123 if (queue_ptr -> tx_queue_available_storage != ((UINT) 0)) in _tx_queue_front_send()
138 if (queue_ptr -> tx_queue_read == queue_ptr -> tx_queue_start) in _tx_queue_front_send()
143 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_end, queue_ptr -> tx_queu… in _tx_queue_front_send()
149 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_read, queue_ptr -> tx_que… in _tx_queue_front_send()
155 queue_ptr -> tx_queue_available_storage--; in _tx_queue_front_send()
158 queue_ptr -> tx_queue_enqueued++; in _tx_queue_front_send()
[all …]
Dtx_queue_receive.c82 UINT _tx_queue_receive(TX_QUEUE *queue_ptr, VOID *destination_ptr, ULONG wait_option) in _tx_queue_receive() argument
109 queue_ptr -> tx_queue_performance_messages_received_count++; in _tx_queue_receive()
114 …_LINE_INSERT(TX_TRACE_QUEUE_RECEIVE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(destination_ptr), wait… in _tx_queue_receive()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_receive()
123 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_receive()
133 source = queue_ptr -> tx_queue_read; in _tx_queue_receive()
135 size = queue_ptr -> tx_queue_message_size; in _tx_queue_receive()
142 if (source == queue_ptr -> tx_queue_end) in _tx_queue_receive()
146 source = queue_ptr -> tx_queue_start; in _tx_queue_receive()
150 queue_ptr -> tx_queue_read = source; in _tx_queue_receive()
[all …]
Dtx_queue_send.c80 UINT _tx_queue_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_send() argument
110 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_send()
114 …CE_IN_LINE_INSERT(TX_TRACE_QUEUE_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_send()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_send()
123 if (queue_ptr -> tx_queue_available_storage != TX_NO_MESSAGES) in _tx_queue_send()
135 queue_ptr -> tx_queue_available_storage--; in _tx_queue_send()
138 queue_ptr -> tx_queue_enqueued++; in _tx_queue_send()
142 destination = queue_ptr -> tx_queue_write; in _tx_queue_send()
143 size = queue_ptr -> tx_queue_message_size; in _tx_queue_send()
150 if (destination == queue_ptr -> tx_queue_end) in _tx_queue_send()
[all …]
Dtx_queue_flush.c77 UINT _tx_queue_flush(TX_QUEUE *queue_ptr) in _tx_queue_flush() argument
95 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_FLUSH, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr),… in _tx_queue_flush()
101 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_flush()
107 queue_ptr -> tx_queue_enqueued = TX_NO_MESSAGES; in _tx_queue_flush()
108 queue_ptr -> tx_queue_available_storage = queue_ptr -> tx_queue_capacity; in _tx_queue_flush()
109 queue_ptr -> tx_queue_read = queue_ptr -> tx_queue_start; in _tx_queue_flush()
110 queue_ptr -> tx_queue_write = queue_ptr -> tx_queue_start; in _tx_queue_flush()
113 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_flush()
120 suspension_list = queue_ptr -> tx_queue_suspension_list; in _tx_queue_flush()
121 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_flush()
[all …]
Dtx_queue_cleanup.c85 TX_QUEUE *queue_ptr; in _tx_queue_cleanup() local
105 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
108 if (queue_ptr != TX_NULL) in _tx_queue_cleanup()
112 if (queue_ptr -> tx_queue_id == TX_QUEUE_ID) in _tx_queue_cleanup()
116 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_cleanup()
121 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
130 queue_ptr -> tx_queue_suspended_count--; in _tx_queue_cleanup()
133 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_cleanup()
144 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_cleanup()
158 if (queue_ptr -> tx_queue_suspension_list == thread_ptr) in _tx_queue_cleanup()
[all …]
Dtx_queue_delete.c76 UINT _tx_queue_delete(TX_QUEUE *queue_ptr) in _tx_queue_delete() argument
92 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_DELETE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr)… in _tx_queue_delete()
95 TX_QUEUE_DELETE_EXTENSION(queue_ptr) in _tx_queue_delete()
98 TX_TRACE_OBJECT_UNREGISTER(queue_ptr) in _tx_queue_delete()
104 queue_ptr -> tx_queue_id = TX_CLEAR_ID; in _tx_queue_delete()
120 next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_delete()
121 previous_queue = queue_ptr -> tx_queue_created_previous; in _tx_queue_delete()
126 if (_tx_queue_created_ptr == queue_ptr) in _tx_queue_delete()
138 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_delete()
139 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_delete()
[all …]
Dtx_queue_performance_info_get.c85 UINT _tx_queue_performance_info_get(TX_QUEUE *queue_ptr, ULONG *messages_sent, ULONG *messages_rec… in _tx_queue_performance_info_get() argument
96 if (queue_ptr == TX_NULL) in _tx_queue_performance_info_get()
104 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _tx_queue_performance_info_get()
117 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_PERFORMANCE_INFO_GET, queue_ptr, 0, 0, 0, TX_TRACE_QUEUE_EV… in _tx_queue_performance_info_get()
129 *messages_sent = queue_ptr -> tx_queue_performance_messages_sent_count; in _tx_queue_performance_info_get()
136 *messages_received = queue_ptr -> tx_queue_performance_messages_received_count; in _tx_queue_performance_info_get()
143 *empty_suspensions = queue_ptr -> tx_queue_performance_empty_suspension_count; in _tx_queue_performance_info_get()
150 *full_suspensions = queue_ptr -> tx_queue_performance_full_suspension_count; in _tx_queue_performance_info_get()
157 *full_errors = queue_ptr -> tx_queue_performance_full_error_count; in _tx_queue_performance_info_get()
164 *timeouts = queue_ptr -> tx_queue_performance_timeout_count; in _tx_queue_performance_info_get()
[all …]
Dtx_queue_info_get.c80 UINT _tx_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storag… in _tx_queue_info_get() argument
91 TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_INFO_GET, queue_ptr, 0, 0, 0, TX_TRACE_QUEUE_EVENTS) in _tx_queue_info_get()
103 *name = queue_ptr -> tx_queue_name; in _tx_queue_info_get()
110 *enqueued = (ULONG) queue_ptr -> tx_queue_enqueued; in _tx_queue_info_get()
117 *available_storage = (ULONG) queue_ptr -> tx_queue_available_storage; in _tx_queue_info_get()
124 *first_suspended = queue_ptr -> tx_queue_suspension_list; in _tx_queue_info_get()
131 *suspended_count = (ULONG) queue_ptr -> tx_queue_suspended_count; in _tx_queue_info_get()
138 *next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_info_get()
Dtx_queue_prioritize.c75 UINT _tx_queue_prioritize(TX_QUEUE *queue_ptr) in _tx_queue_prioritize() argument
93 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_PRIORITIZE, queue_ptr, queue_ptr -> tx_queue_suspended_coun… in _tx_queue_prioritize()
99 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
114 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
122 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_prioritize()
132 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
168 if (head_ptr != queue_ptr -> tx_queue_suspension_list) in _tx_queue_prioritize()
178 if (suspended_count != queue_ptr -> tx_queue_suspended_count) in _tx_queue_prioritize()
197 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
198 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
[all …]
Dtxe_queue_flush.c73 UINT _txe_queue_flush(TX_QUEUE *queue_ptr) in _txe_queue_flush() argument
80 if (queue_ptr == TX_NULL) in _txe_queue_flush()
88 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_flush()
98 status = _tx_queue_flush(queue_ptr); in _txe_queue_flush()
Dtxe_queue_prioritize.c71 UINT _txe_queue_prioritize(TX_QUEUE *queue_ptr) in _txe_queue_prioritize() argument
78 if (queue_ptr == TX_NULL) in _txe_queue_prioritize()
85 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_prioritize()
94 status = _tx_queue_prioritize(queue_ptr); in _txe_queue_prioritize()
/ThreadX-v6.3.0/common_smp/src/
Dtx_queue_create.c77 UINT _tx_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _tx_queue_create() argument
90 TX_MEMSET(queue_ptr, 0, (sizeof(TX_QUEUE))); in _tx_queue_create()
93 queue_ptr -> tx_queue_name = name_ptr; in _tx_queue_create()
96 queue_ptr -> tx_queue_message_size = message_size; in _tx_queue_create()
106 queue_ptr -> tx_queue_start = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
107 queue_ptr -> tx_queue_end = TX_ULONG_POINTER_ADD(queue_ptr -> tx_queue_start, used_words); in _tx_queue_create()
111 queue_ptr -> tx_queue_read = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
112 queue_ptr -> tx_queue_write = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
116 queue_ptr -> tx_queue_available_storage = (UINT) capacity; in _tx_queue_create()
117 queue_ptr -> tx_queue_capacity = (UINT) capacity; in _tx_queue_create()
[all …]
Dtx_queue_front_send.c80 UINT _tx_queue_front_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_front_send() argument
110 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_front_send()
114 …LINE_INSERT(TX_TRACE_QUEUE_FRONT_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_front_send()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_front_send()
123 if (queue_ptr -> tx_queue_available_storage != ((UINT) 0)) in _tx_queue_front_send()
138 if (queue_ptr -> tx_queue_read == queue_ptr -> tx_queue_start) in _tx_queue_front_send()
143 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_end, queue_ptr -> tx_queu… in _tx_queue_front_send()
149 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_read, queue_ptr -> tx_que… in _tx_queue_front_send()
155 queue_ptr -> tx_queue_available_storage--; in _tx_queue_front_send()
158 queue_ptr -> tx_queue_enqueued++; in _tx_queue_front_send()
[all …]
Dtx_queue_receive.c82 UINT _tx_queue_receive(TX_QUEUE *queue_ptr, VOID *destination_ptr, ULONG wait_option) in _tx_queue_receive() argument
109 queue_ptr -> tx_queue_performance_messages_received_count++; in _tx_queue_receive()
114 …_LINE_INSERT(TX_TRACE_QUEUE_RECEIVE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(destination_ptr), wait… in _tx_queue_receive()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_receive()
123 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_receive()
133 source = queue_ptr -> tx_queue_read; in _tx_queue_receive()
135 size = queue_ptr -> tx_queue_message_size; in _tx_queue_receive()
142 if (source == queue_ptr -> tx_queue_end) in _tx_queue_receive()
146 source = queue_ptr -> tx_queue_start; in _tx_queue_receive()
150 queue_ptr -> tx_queue_read = source; in _tx_queue_receive()
[all …]
Dtx_queue_send.c80 UINT _tx_queue_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_send() argument
110 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_send()
114 …CE_IN_LINE_INSERT(TX_TRACE_QUEUE_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_send()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_send()
123 if (queue_ptr -> tx_queue_available_storage != TX_NO_MESSAGES) in _tx_queue_send()
135 queue_ptr -> tx_queue_available_storage--; in _tx_queue_send()
138 queue_ptr -> tx_queue_enqueued++; in _tx_queue_send()
142 destination = queue_ptr -> tx_queue_write; in _tx_queue_send()
143 size = queue_ptr -> tx_queue_message_size; in _tx_queue_send()
150 if (destination == queue_ptr -> tx_queue_end) in _tx_queue_send()
[all …]
Dtx_queue_flush.c77 UINT _tx_queue_flush(TX_QUEUE *queue_ptr) in _tx_queue_flush() argument
95 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_FLUSH, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr),… in _tx_queue_flush()
101 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_flush()
107 queue_ptr -> tx_queue_enqueued = TX_NO_MESSAGES; in _tx_queue_flush()
108 queue_ptr -> tx_queue_available_storage = queue_ptr -> tx_queue_capacity; in _tx_queue_flush()
109 queue_ptr -> tx_queue_read = queue_ptr -> tx_queue_start; in _tx_queue_flush()
110 queue_ptr -> tx_queue_write = queue_ptr -> tx_queue_start; in _tx_queue_flush()
113 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_flush()
120 suspension_list = queue_ptr -> tx_queue_suspension_list; in _tx_queue_flush()
121 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_flush()
[all …]
Dtx_queue_cleanup.c85 TX_QUEUE *queue_ptr; in _tx_queue_cleanup() local
105 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
108 if (queue_ptr != TX_NULL) in _tx_queue_cleanup()
112 if (queue_ptr -> tx_queue_id == TX_QUEUE_ID) in _tx_queue_cleanup()
116 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_cleanup()
121 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
130 queue_ptr -> tx_queue_suspended_count--; in _tx_queue_cleanup()
133 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_cleanup()
144 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_cleanup()
158 if (queue_ptr -> tx_queue_suspension_list == thread_ptr) in _tx_queue_cleanup()
[all …]
Dtx_queue_delete.c76 UINT _tx_queue_delete(TX_QUEUE *queue_ptr) in _tx_queue_delete() argument
92 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_DELETE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr)… in _tx_queue_delete()
95 TX_QUEUE_DELETE_EXTENSION(queue_ptr) in _tx_queue_delete()
98 TX_TRACE_OBJECT_UNREGISTER(queue_ptr) in _tx_queue_delete()
104 queue_ptr -> tx_queue_id = TX_CLEAR_ID; in _tx_queue_delete()
120 next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_delete()
121 previous_queue = queue_ptr -> tx_queue_created_previous; in _tx_queue_delete()
126 if (_tx_queue_created_ptr == queue_ptr) in _tx_queue_delete()
138 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_delete()
139 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_delete()
[all …]
Dtx_queue_performance_info_get.c85 UINT _tx_queue_performance_info_get(TX_QUEUE *queue_ptr, ULONG *messages_sent, ULONG *messages_rec… in _tx_queue_performance_info_get() argument
96 if (queue_ptr == TX_NULL) in _tx_queue_performance_info_get()
104 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _tx_queue_performance_info_get()
117 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_PERFORMANCE_INFO_GET, queue_ptr, 0, 0, 0, TX_TRACE_QUEUE_EV… in _tx_queue_performance_info_get()
129 *messages_sent = queue_ptr -> tx_queue_performance_messages_sent_count; in _tx_queue_performance_info_get()
136 *messages_received = queue_ptr -> tx_queue_performance_messages_received_count; in _tx_queue_performance_info_get()
143 *empty_suspensions = queue_ptr -> tx_queue_performance_empty_suspension_count; in _tx_queue_performance_info_get()
150 *full_suspensions = queue_ptr -> tx_queue_performance_full_suspension_count; in _tx_queue_performance_info_get()
157 *full_errors = queue_ptr -> tx_queue_performance_full_error_count; in _tx_queue_performance_info_get()
164 *timeouts = queue_ptr -> tx_queue_performance_timeout_count; in _tx_queue_performance_info_get()
[all …]
Dtx_queue_info_get.c80 UINT _tx_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storag… in _tx_queue_info_get() argument
91 TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_INFO_GET, queue_ptr, 0, 0, 0, TX_TRACE_QUEUE_EVENTS) in _tx_queue_info_get()
103 *name = queue_ptr -> tx_queue_name; in _tx_queue_info_get()
110 *enqueued = (ULONG) queue_ptr -> tx_queue_enqueued; in _tx_queue_info_get()
117 *available_storage = (ULONG) queue_ptr -> tx_queue_available_storage; in _tx_queue_info_get()
124 *first_suspended = queue_ptr -> tx_queue_suspension_list; in _tx_queue_info_get()
131 *suspended_count = (ULONG) queue_ptr -> tx_queue_suspended_count; in _tx_queue_info_get()
138 *next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_info_get()
Dtx_queue_prioritize.c75 UINT _tx_queue_prioritize(TX_QUEUE *queue_ptr) in _tx_queue_prioritize() argument
93 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_PRIORITIZE, queue_ptr, queue_ptr -> tx_queue_suspended_coun… in _tx_queue_prioritize()
99 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
114 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
122 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_prioritize()
132 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
168 if (head_ptr != queue_ptr -> tx_queue_suspension_list) in _tx_queue_prioritize()
178 if (suspended_count != queue_ptr -> tx_queue_suspended_count) in _tx_queue_prioritize()
197 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
198 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
[all …]
Dtxe_queue_flush.c73 UINT _txe_queue_flush(TX_QUEUE *queue_ptr) in _txe_queue_flush() argument
80 if (queue_ptr == TX_NULL) in _txe_queue_flush()
88 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_flush()
98 status = _tx_queue_flush(queue_ptr); in _txe_queue_flush()
Dtxe_queue_prioritize.c71 UINT _txe_queue_prioritize(TX_QUEUE *queue_ptr) in _txe_queue_prioritize() argument
78 if (queue_ptr == TX_NULL) in _txe_queue_prioritize()
85 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_prioritize()
94 status = _tx_queue_prioritize(queue_ptr); in _txe_queue_prioritize()
/ThreadX-v6.3.0/utility/rtos_compatibility_layers/posix/
Dpx_mq_queue_init.c72 POSIX_MSG_QUEUE *queue_ptr; in posix_queue_init() local
74 for (i = 0, queue_ptr = &(posix_queue_pool[0]); in posix_queue_init()
76 i++, queue_ptr++) in posix_queue_init()
79 queue_ptr->in_use = TX_FALSE; in posix_queue_init()
80 queue_ptr->name = ""; in posix_queue_init()
81 queue_ptr->open_count = 0; in posix_queue_init()
82 queue_ptr->storage = NULL; in posix_queue_init()
83 queue_ptr->unlink_flag = TX_FALSE; in posix_queue_init()

12345678910>>...14