| /ThreadX-v6.4.1/common/src/ |
| D | tx_queue_create.c | 76 UINT _tx_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _tx_queue_create() argument
89 TX_MEMSET(queue_ptr, 0, (sizeof(TX_QUEUE))); in _tx_queue_create()
92 queue_ptr -> tx_queue_name = name_ptr; in _tx_queue_create()
95 queue_ptr -> tx_queue_message_size = message_size; in _tx_queue_create()
105 queue_ptr -> tx_queue_start = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
106 queue_ptr -> tx_queue_end = TX_ULONG_POINTER_ADD(queue_ptr -> tx_queue_start, used_words); in _tx_queue_create()
110 queue_ptr -> tx_queue_read = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
111 queue_ptr -> tx_queue_write = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
115 queue_ptr -> tx_queue_available_storage = (UINT) capacity; in _tx_queue_create()
116 queue_ptr -> tx_queue_capacity = (UINT) capacity; in _tx_queue_create()
[all …]
|
| D | tx_queue_front_send.c | 79 UINT _tx_queue_front_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_front_send() argument
109 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_front_send()
113 …LINE_INSERT(TX_TRACE_QUEUE_FRONT_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_front_send()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_front_send()
122 if (queue_ptr -> tx_queue_available_storage != ((UINT) 0)) in _tx_queue_front_send()
137 if (queue_ptr -> tx_queue_read == queue_ptr -> tx_queue_start) in _tx_queue_front_send()
142 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_end, queue_ptr -> tx_queu… in _tx_queue_front_send()
148 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_read, queue_ptr -> tx_que… in _tx_queue_front_send()
154 queue_ptr -> tx_queue_available_storage--; in _tx_queue_front_send()
157 queue_ptr -> tx_queue_enqueued++; in _tx_queue_front_send()
[all …]
|
| D | tx_queue_receive.c | 81 UINT _tx_queue_receive(TX_QUEUE *queue_ptr, VOID *destination_ptr, ULONG wait_option) in _tx_queue_receive() argument
108 queue_ptr -> tx_queue_performance_messages_received_count++; in _tx_queue_receive()
113 …_LINE_INSERT(TX_TRACE_QUEUE_RECEIVE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(destination_ptr), wait… in _tx_queue_receive()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_receive()
122 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_receive()
132 source = queue_ptr -> tx_queue_read; in _tx_queue_receive()
134 size = queue_ptr -> tx_queue_message_size; in _tx_queue_receive()
141 if (source == queue_ptr -> tx_queue_end) in _tx_queue_receive()
145 source = queue_ptr -> tx_queue_start; in _tx_queue_receive()
149 queue_ptr -> tx_queue_read = source; in _tx_queue_receive()
[all …]
|
| D | tx_queue_send.c | 79 UINT _tx_queue_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_send() argument
109 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_send()
113 …CE_IN_LINE_INSERT(TX_TRACE_QUEUE_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_send()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_send()
122 if (queue_ptr -> tx_queue_available_storage != TX_NO_MESSAGES) in _tx_queue_send()
134 queue_ptr -> tx_queue_available_storage--; in _tx_queue_send()
137 queue_ptr -> tx_queue_enqueued++; in _tx_queue_send()
141 destination = queue_ptr -> tx_queue_write; in _tx_queue_send()
142 size = queue_ptr -> tx_queue_message_size; in _tx_queue_send()
149 if (destination == queue_ptr -> tx_queue_end) in _tx_queue_send()
[all …]
|
| D | tx_queue_flush.c | 76 UINT _tx_queue_flush(TX_QUEUE *queue_ptr) in _tx_queue_flush() argument
94 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_FLUSH, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr),… in _tx_queue_flush()
100 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_flush()
106 queue_ptr -> tx_queue_enqueued = TX_NO_MESSAGES; in _tx_queue_flush()
107 queue_ptr -> tx_queue_available_storage = queue_ptr -> tx_queue_capacity; in _tx_queue_flush()
108 queue_ptr -> tx_queue_read = queue_ptr -> tx_queue_start; in _tx_queue_flush()
109 queue_ptr -> tx_queue_write = queue_ptr -> tx_queue_start; in _tx_queue_flush()
112 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_flush()
119 suspension_list = queue_ptr -> tx_queue_suspension_list; in _tx_queue_flush()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_flush()
[all …]
|
| D | tx_queue_cleanup.c | 84 TX_QUEUE *queue_ptr; in _tx_queue_cleanup() local
104 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
107 if (queue_ptr != TX_NULL) in _tx_queue_cleanup()
111 if (queue_ptr -> tx_queue_id == TX_QUEUE_ID) in _tx_queue_cleanup()
115 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_cleanup()
120 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
129 queue_ptr -> tx_queue_suspended_count--; in _tx_queue_cleanup()
132 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_cleanup()
143 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_cleanup()
157 if (queue_ptr -> tx_queue_suspension_list == thread_ptr) in _tx_queue_cleanup()
[all …]
|
| D | tx_queue_delete.c | 75 UINT _tx_queue_delete(TX_QUEUE *queue_ptr) in _tx_queue_delete() argument
91 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_DELETE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr)… in _tx_queue_delete()
94 TX_QUEUE_DELETE_EXTENSION(queue_ptr) in _tx_queue_delete()
97 TX_TRACE_OBJECT_UNREGISTER(queue_ptr) in _tx_queue_delete()
103 queue_ptr -> tx_queue_id = TX_CLEAR_ID; in _tx_queue_delete()
119 next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_delete()
120 previous_queue = queue_ptr -> tx_queue_created_previous; in _tx_queue_delete()
125 if (_tx_queue_created_ptr == queue_ptr) in _tx_queue_delete()
137 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_delete()
138 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_delete()
[all …]
|
| D | tx_queue_performance_info_get.c | 84 UINT _tx_queue_performance_info_get(TX_QUEUE *queue_ptr, ULONG *messages_sent, ULONG *messages_rec… in _tx_queue_performance_info_get() argument
95 if (queue_ptr == TX_NULL) in _tx_queue_performance_info_get()
103 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _tx_queue_performance_info_get()
116 …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()
128 *messages_sent = queue_ptr -> tx_queue_performance_messages_sent_count; in _tx_queue_performance_info_get()
135 *messages_received = queue_ptr -> tx_queue_performance_messages_received_count; in _tx_queue_performance_info_get()
142 *empty_suspensions = queue_ptr -> tx_queue_performance_empty_suspension_count; in _tx_queue_performance_info_get()
149 *full_suspensions = queue_ptr -> tx_queue_performance_full_suspension_count; in _tx_queue_performance_info_get()
156 *full_errors = queue_ptr -> tx_queue_performance_full_error_count; in _tx_queue_performance_info_get()
163 *timeouts = queue_ptr -> tx_queue_performance_timeout_count; in _tx_queue_performance_info_get()
[all …]
|
| D | tx_queue_info_get.c | 79 UINT _tx_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storag… in _tx_queue_info_get() argument
90 TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_INFO_GET, queue_ptr, 0, 0, 0, TX_TRACE_QUEUE_EVENTS) in _tx_queue_info_get()
102 *name = queue_ptr -> tx_queue_name; in _tx_queue_info_get()
109 *enqueued = (ULONG) queue_ptr -> tx_queue_enqueued; in _tx_queue_info_get()
116 *available_storage = (ULONG) queue_ptr -> tx_queue_available_storage; in _tx_queue_info_get()
123 *first_suspended = queue_ptr -> tx_queue_suspension_list; in _tx_queue_info_get()
130 *suspended_count = (ULONG) queue_ptr -> tx_queue_suspended_count; in _tx_queue_info_get()
137 *next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_info_get()
|
| D | tx_queue_prioritize.c | 74 UINT _tx_queue_prioritize(TX_QUEUE *queue_ptr) in _tx_queue_prioritize() argument
92 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_PRIORITIZE, queue_ptr, queue_ptr -> tx_queue_suspended_coun… in _tx_queue_prioritize()
98 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
113 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
121 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_prioritize()
131 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
167 if (head_ptr != queue_ptr -> tx_queue_suspension_list) in _tx_queue_prioritize()
177 if (suspended_count != queue_ptr -> tx_queue_suspended_count) in _tx_queue_prioritize()
196 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
197 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
[all …]
|
| D | txe_queue_flush.c | 72 UINT _txe_queue_flush(TX_QUEUE *queue_ptr) in _txe_queue_flush() argument
79 if (queue_ptr == TX_NULL) in _txe_queue_flush()
87 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_flush()
97 status = _tx_queue_flush(queue_ptr); in _txe_queue_flush()
|
| D | txe_queue_prioritize.c | 70 UINT _txe_queue_prioritize(TX_QUEUE *queue_ptr) in _txe_queue_prioritize() argument
77 if (queue_ptr == TX_NULL) in _txe_queue_prioritize()
84 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_prioritize()
93 status = _tx_queue_prioritize(queue_ptr); in _txe_queue_prioritize()
|
| /ThreadX-v6.4.1/common_smp/src/ |
| D | tx_queue_create.c | 76 UINT _tx_queue_create(TX_QUEUE *queue_ptr, CHAR *name_ptr, UINT message_size, in _tx_queue_create() argument
89 TX_MEMSET(queue_ptr, 0, (sizeof(TX_QUEUE))); in _tx_queue_create()
92 queue_ptr -> tx_queue_name = name_ptr; in _tx_queue_create()
95 queue_ptr -> tx_queue_message_size = message_size; in _tx_queue_create()
105 queue_ptr -> tx_queue_start = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
106 queue_ptr -> tx_queue_end = TX_ULONG_POINTER_ADD(queue_ptr -> tx_queue_start, used_words); in _tx_queue_create()
110 queue_ptr -> tx_queue_read = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
111 queue_ptr -> tx_queue_write = TX_VOID_TO_ULONG_POINTER_CONVERT(queue_start); in _tx_queue_create()
115 queue_ptr -> tx_queue_available_storage = (UINT) capacity; in _tx_queue_create()
116 queue_ptr -> tx_queue_capacity = (UINT) capacity; in _tx_queue_create()
[all …]
|
| D | tx_queue_front_send.c | 79 UINT _tx_queue_front_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_front_send() argument
109 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_front_send()
113 …LINE_INSERT(TX_TRACE_QUEUE_FRONT_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_front_send()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_front_send()
122 if (queue_ptr -> tx_queue_available_storage != ((UINT) 0)) in _tx_queue_front_send()
137 if (queue_ptr -> tx_queue_read == queue_ptr -> tx_queue_start) in _tx_queue_front_send()
142 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_end, queue_ptr -> tx_queu… in _tx_queue_front_send()
148 …queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_read, queue_ptr -> tx_que… in _tx_queue_front_send()
154 queue_ptr -> tx_queue_available_storage--; in _tx_queue_front_send()
157 queue_ptr -> tx_queue_enqueued++; in _tx_queue_front_send()
[all …]
|
| D | tx_queue_receive.c | 81 UINT _tx_queue_receive(TX_QUEUE *queue_ptr, VOID *destination_ptr, ULONG wait_option) in _tx_queue_receive() argument
108 queue_ptr -> tx_queue_performance_messages_received_count++; in _tx_queue_receive()
113 …_LINE_INSERT(TX_TRACE_QUEUE_RECEIVE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(destination_ptr), wait… in _tx_queue_receive()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_receive()
122 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_receive()
132 source = queue_ptr -> tx_queue_read; in _tx_queue_receive()
134 size = queue_ptr -> tx_queue_message_size; in _tx_queue_receive()
141 if (source == queue_ptr -> tx_queue_end) in _tx_queue_receive()
145 source = queue_ptr -> tx_queue_start; in _tx_queue_receive()
149 queue_ptr -> tx_queue_read = source; in _tx_queue_receive()
[all …]
|
| D | tx_queue_send.c | 79 UINT _tx_queue_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_send() argument
109 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_send()
113 …CE_IN_LINE_INSERT(TX_TRACE_QUEUE_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_send()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_send()
122 if (queue_ptr -> tx_queue_available_storage != TX_NO_MESSAGES) in _tx_queue_send()
134 queue_ptr -> tx_queue_available_storage--; in _tx_queue_send()
137 queue_ptr -> tx_queue_enqueued++; in _tx_queue_send()
141 destination = queue_ptr -> tx_queue_write; in _tx_queue_send()
142 size = queue_ptr -> tx_queue_message_size; in _tx_queue_send()
149 if (destination == queue_ptr -> tx_queue_end) in _tx_queue_send()
[all …]
|
| D | tx_queue_flush.c | 76 UINT _tx_queue_flush(TX_QUEUE *queue_ptr) in _tx_queue_flush() argument
94 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_FLUSH, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr),… in _tx_queue_flush()
100 if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES) in _tx_queue_flush()
106 queue_ptr -> tx_queue_enqueued = TX_NO_MESSAGES; in _tx_queue_flush()
107 queue_ptr -> tx_queue_available_storage = queue_ptr -> tx_queue_capacity; in _tx_queue_flush()
108 queue_ptr -> tx_queue_read = queue_ptr -> tx_queue_start; in _tx_queue_flush()
109 queue_ptr -> tx_queue_write = queue_ptr -> tx_queue_start; in _tx_queue_flush()
112 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_flush()
119 suspension_list = queue_ptr -> tx_queue_suspension_list; in _tx_queue_flush()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_flush()
[all …]
|
| D | tx_queue_cleanup.c | 84 TX_QUEUE *queue_ptr; in _tx_queue_cleanup() local
104 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
107 if (queue_ptr != TX_NULL) in _tx_queue_cleanup()
111 if (queue_ptr -> tx_queue_id == TX_QUEUE_ID) in _tx_queue_cleanup()
115 if (queue_ptr -> tx_queue_suspended_count != TX_NO_SUSPENSIONS) in _tx_queue_cleanup()
120 … queue_ptr = TX_VOID_TO_QUEUE_POINTER_CONVERT(thread_ptr -> tx_thread_suspend_control_block); in _tx_queue_cleanup()
129 queue_ptr -> tx_queue_suspended_count--; in _tx_queue_cleanup()
132 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_cleanup()
143 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_cleanup()
157 if (queue_ptr -> tx_queue_suspension_list == thread_ptr) in _tx_queue_cleanup()
[all …]
|
| D | tx_queue_delete.c | 75 UINT _tx_queue_delete(TX_QUEUE *queue_ptr) in _tx_queue_delete() argument
91 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_DELETE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr)… in _tx_queue_delete()
94 TX_QUEUE_DELETE_EXTENSION(queue_ptr) in _tx_queue_delete()
97 TX_TRACE_OBJECT_UNREGISTER(queue_ptr) in _tx_queue_delete()
103 queue_ptr -> tx_queue_id = TX_CLEAR_ID; in _tx_queue_delete()
119 next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_delete()
120 previous_queue = queue_ptr -> tx_queue_created_previous; in _tx_queue_delete()
125 if (_tx_queue_created_ptr == queue_ptr) in _tx_queue_delete()
137 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_delete()
138 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_delete()
[all …]
|
| D | tx_queue_performance_info_get.c | 84 UINT _tx_queue_performance_info_get(TX_QUEUE *queue_ptr, ULONG *messages_sent, ULONG *messages_rec… in _tx_queue_performance_info_get() argument
95 if (queue_ptr == TX_NULL) in _tx_queue_performance_info_get()
103 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _tx_queue_performance_info_get()
116 …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()
128 *messages_sent = queue_ptr -> tx_queue_performance_messages_sent_count; in _tx_queue_performance_info_get()
135 *messages_received = queue_ptr -> tx_queue_performance_messages_received_count; in _tx_queue_performance_info_get()
142 *empty_suspensions = queue_ptr -> tx_queue_performance_empty_suspension_count; in _tx_queue_performance_info_get()
149 *full_suspensions = queue_ptr -> tx_queue_performance_full_suspension_count; in _tx_queue_performance_info_get()
156 *full_errors = queue_ptr -> tx_queue_performance_full_error_count; in _tx_queue_performance_info_get()
163 *timeouts = queue_ptr -> tx_queue_performance_timeout_count; in _tx_queue_performance_info_get()
[all …]
|
| D | tx_queue_info_get.c | 79 UINT _tx_queue_info_get(TX_QUEUE *queue_ptr, CHAR **name, ULONG *enqueued, ULONG *available_storag… in _tx_queue_info_get() argument
90 TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_INFO_GET, queue_ptr, 0, 0, 0, TX_TRACE_QUEUE_EVENTS) in _tx_queue_info_get()
102 *name = queue_ptr -> tx_queue_name; in _tx_queue_info_get()
109 *enqueued = (ULONG) queue_ptr -> tx_queue_enqueued; in _tx_queue_info_get()
116 *available_storage = (ULONG) queue_ptr -> tx_queue_available_storage; in _tx_queue_info_get()
123 *first_suspended = queue_ptr -> tx_queue_suspension_list; in _tx_queue_info_get()
130 *suspended_count = (ULONG) queue_ptr -> tx_queue_suspended_count; in _tx_queue_info_get()
137 *next_queue = queue_ptr -> tx_queue_created_next; in _tx_queue_info_get()
|
| D | tx_queue_prioritize.c | 74 UINT _tx_queue_prioritize(TX_QUEUE *queue_ptr) in _tx_queue_prioritize() argument
92 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_PRIORITIZE, queue_ptr, queue_ptr -> tx_queue_suspended_coun… in _tx_queue_prioritize()
98 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
113 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
121 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_prioritize()
131 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
167 if (head_ptr != queue_ptr -> tx_queue_suspension_list) in _tx_queue_prioritize()
177 if (suspended_count != queue_ptr -> tx_queue_suspended_count) in _tx_queue_prioritize()
196 head_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_prioritize()
197 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_prioritize()
[all …]
|
| D | txe_queue_flush.c | 72 UINT _txe_queue_flush(TX_QUEUE *queue_ptr) in _txe_queue_flush() argument
79 if (queue_ptr == TX_NULL) in _txe_queue_flush()
87 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_flush()
97 status = _tx_queue_flush(queue_ptr); in _txe_queue_flush()
|
| D | txe_queue_prioritize.c | 70 UINT _txe_queue_prioritize(TX_QUEUE *queue_ptr) in _txe_queue_prioritize() argument
77 if (queue_ptr == TX_NULL) in _txe_queue_prioritize()
84 else if (queue_ptr -> tx_queue_id != TX_QUEUE_ID) in _txe_queue_prioritize()
93 status = _tx_queue_prioritize(queue_ptr); in _txe_queue_prioritize()
|
| /ThreadX-v6.4.1/utility/rtos_compatibility_layers/posix/ |
| D | px_mq_queue_init.c | 71 POSIX_MSG_QUEUE *queue_ptr; in posix_queue_init() local
73 for (i = 0, queue_ptr = &(posix_queue_pool[0]); in posix_queue_init()
75 i++, queue_ptr++) in posix_queue_init()
78 queue_ptr->in_use = TX_FALSE; in posix_queue_init()
79 queue_ptr->name = ""; in posix_queue_init()
80 queue_ptr->open_count = 0; in posix_queue_init()
81 queue_ptr->storage = NULL; in posix_queue_init()
82 queue_ptr->unlink_flag = TX_FALSE; in posix_queue_init()
|
