| /ThreadX-v6.3.0/common/src/ |
| D | tx_thread_priority_change.c | 89 UINT _tx_thread_priority_change(TX_THREAD *thread_ptr, UINT new_priority, UINT *old_priority) in _tx_thread_priority_change() argument
103 *old_priority = thread_ptr -> tx_thread_user_priority; in _tx_thread_priority_change()
106 …_INSERT(TX_TRACE_THREAD_PRIORITY_CHANGE, thread_ptr, new_priority, thread_ptr -> tx_thread_priorit… in _tx_thread_priority_change()
112 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_thread_priority_change()
117 thread_ptr -> tx_thread_user_priority = new_priority; in _tx_thread_priority_change()
118 thread_ptr -> tx_thread_user_preempt_threshold = new_priority; in _tx_thread_priority_change()
122 if (new_priority < thread_ptr -> tx_thread_inherit_priority) in _tx_thread_priority_change()
126 thread_ptr -> tx_thread_priority = new_priority; in _tx_thread_priority_change()
127 thread_ptr -> tx_thread_preempt_threshold = new_priority; in _tx_thread_priority_change()
133 thread_ptr -> tx_thread_priority = thread_ptr -> tx_thread_inherit_priority; in _tx_thread_priority_change()
[all …]
|
| D | tx_mutex_priority_change.c | 87 VOID _tx_mutex_priority_change(TX_THREAD *thread_ptr, UINT new_priority) in _tx_mutex_priority_change() argument
114 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_mutex_priority_change()
118 thread_ptr -> tx_thread_priority = new_priority; in _tx_mutex_priority_change()
121 if (thread_ptr -> tx_thread_user_preempt_threshold < new_priority) in _tx_mutex_priority_change()
125 … thread_ptr -> tx_thread_preempt_threshold = thread_ptr -> tx_thread_user_preempt_threshold; in _tx_mutex_priority_change()
131 thread_ptr -> tx_thread_preempt_threshold = new_priority; in _tx_mutex_priority_change()
146 original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_priority_change()
154 thread_ptr -> tx_thread_state = TX_PRIORITY_CHANGE; in _tx_mutex_priority_change()
157 _tx_thread_system_ni_suspend(thread_ptr, ((ULONG) 0)); in _tx_mutex_priority_change()
163 thread_ptr -> tx_thread_priority = new_priority; in _tx_mutex_priority_change()
[all …]
|
| D | tx_thread_create.c | 97 UINT _tx_thread_create(TX_THREAD *thread_ptr, CHAR *name_ptr, VOID (*entry_function)(ULONG id), UL… in _tx_thread_create() argument
119 thread_ptr -> tx_thread_stack_fill_value = ((ULONG) TX_RAND()) & 0xFFUL; in _tx_thread_create()
122 thread_ptr -> tx_thread_stack_fill_value = thread_ptr -> tx_thread_stack_fill_value | in _tx_thread_create()
123 (thread_ptr -> tx_thread_stack_fill_value << 8) | in _tx_thread_create()
124 (thread_ptr -> tx_thread_stack_fill_value << 16) | in _tx_thread_create()
125 (thread_ptr -> tx_thread_stack_fill_value << 24); in _tx_thread_create()
169 TX_MEMSET(thread_ptr, 0, (sizeof(TX_THREAD))); in _tx_thread_create()
172 thread_ptr -> tx_thread_name = name_ptr; in _tx_thread_create()
173 thread_ptr -> tx_thread_entry = entry_function; in _tx_thread_create()
174 thread_ptr -> tx_thread_entry_parameter = entry_input; in _tx_thread_create()
[all …]
|
| D | tx_mutex_get.c | 82 TX_THREAD *thread_ptr; in _tx_mutex_get() local
110 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_mutex_get()
120 mutex_ptr -> tx_mutex_owner = thread_ptr; in _tx_mutex_get()
123 if (thread_ptr != TX_NULL) in _tx_mutex_get()
131 mutex_ptr -> tx_mutex_original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_get()
138 next_mutex = thread_ptr -> tx_thread_owned_mutex_list; in _tx_mutex_get()
161 thread_ptr -> tx_thread_owned_mutex_list = mutex_ptr; in _tx_mutex_get()
167 thread_ptr -> tx_thread_owned_mutex_count++; in _tx_mutex_get()
178 else if (mutex_ptr -> tx_mutex_owner == thread_ptr) in _tx_mutex_get()
225 if (thread_ptr -> tx_thread_priority < mutex_owner -> tx_thread_priority) in _tx_mutex_get()
[all …]
|
| D | tx_thread_system_resume.c | 81 VOID _tx_thread_system_resume(TX_THREAD *thread_ptr) in _tx_thread_system_resume() argument
108 TX_THREAD_STACK_CHECK(thread_ptr) in _tx_thread_system_resume()
117 if (thread_ptr -> tx_thread_timer.tx_timer_internal_list_head != TX_NULL) in _tx_thread_system_resume()
121 _tx_timer_system_deactivate(&(thread_ptr -> tx_thread_timer)); in _tx_thread_system_resume()
127 thread_ptr -> tx_thread_timer.tx_timer_internal_remaining_ticks = ((ULONG) 0); in _tx_thread_system_resume()
138 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_RESUME, thread_ptr, thread_ptr -> tx_thread_state, TX_POIN… in _tx_thread_system_resume()
158 if (thread_ptr -> tx_thread_suspending == TX_FALSE) in _tx_thread_system_resume()
163 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_thread_system_resume()
167 if (thread_ptr -> tx_thread_delayed_suspend == TX_FALSE) in _tx_thread_system_resume()
175 thread_ptr -> tx_thread_state = TX_READY; in _tx_thread_system_resume()
[all …]
|
| D | tx_thread_terminate.c | 80 UINT _tx_thread_terminate(TX_THREAD *thread_ptr) in _tx_thread_terminate() argument
100 _tx_timer_system_deactivate(&thread_ptr -> tx_thread_timer); in _tx_thread_terminate()
103 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_TERMINATE, thread_ptr, thread_ptr -> tx_thread_state, TX_P… in _tx_thread_terminate()
109 if (thread_ptr -> tx_thread_state == TX_TERMINATED) in _tx_thread_terminate()
120 else if (thread_ptr -> tx_thread_state != TX_COMPLETED) in _tx_thread_terminate()
129 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_terminate()
133 if (thread_ptr -> tx_thread_state == TX_READY) in _tx_thread_terminate()
137 thread_ptr -> tx_thread_state = TX_TERMINATED; in _tx_thread_terminate()
140 TX_THREAD_STATE_CHANGE(thread_ptr, TX_TERMINATED) in _tx_thread_terminate()
151 (entry_exit_notify)(thread_ptr, TX_THREAD_EXIT); in _tx_thread_terminate()
[all …]
|
| D | tx_thread_preemption_change.c | 77 UINT _tx_thread_preemption_change(TX_THREAD *thread_ptr, UINT new_threshold, UINT *old_threshold) in _tx_thread_preemption_change() argument
99 if (thread_ptr -> tx_thread_user_priority != new_threshold) in _tx_thread_preemption_change()
117 …(TX_TRACE_THREAD_PREEMPTION_CHANGE, thread_ptr, new_threshold, thread_ptr -> tx_thread_preempt_thr… in _tx_thread_preemption_change()
123 if (new_threshold > thread_ptr -> tx_thread_user_priority) in _tx_thread_preemption_change()
135 if (thread_ptr -> tx_thread_user_priority == new_threshold) in _tx_thread_preemption_change()
139 if (_tx_thread_priority_list[thread_ptr -> tx_thread_priority] == thread_ptr) in _tx_thread_preemption_change()
145 map_index = (thread_ptr -> tx_thread_priority)/((UINT) 32); in _tx_thread_preemption_change()
150 TX_MOD32_BIT_SET(thread_ptr -> tx_thread_priority, priority_bit) in _tx_thread_preemption_change()
160 TX_DIV32_BIT_SET(thread_ptr -> tx_thread_priority, priority_bit) in _tx_thread_preemption_change()
169 *old_threshold = thread_ptr -> tx_thread_user_preempt_threshold; in _tx_thread_preemption_change()
[all …]
|
| D | tx_thread_shell_entry.c | 81 TX_THREAD *thread_ptr; in _tx_thread_shell_entry() local
88 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_shell_entry()
91 TX_THREAD_STARTED_EXTENSION(thread_ptr) in _tx_thread_shell_entry()
99 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
109 (entry_exit_notify)(thread_ptr, TX_THREAD_ENTRY); in _tx_thread_shell_entry()
114 (thread_ptr -> tx_thread_entry) (thread_ptr -> tx_thread_entry_parameter); in _tx_thread_shell_entry()
124 (_tx_thread_mutex_release)(thread_ptr); in _tx_thread_shell_entry()
133 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
138 thread_ptr -> tx_thread_state = TX_COMPLETED; in _tx_thread_shell_entry()
141 TX_THREAD_STATE_CHANGE(thread_ptr, TX_COMPLETED) in _tx_thread_shell_entry()
[all …]
|
| D | tx_thread_wait_abort.c | 79 UINT _tx_thread_wait_abort(TX_THREAD *thread_ptr) in _tx_thread_wait_abort() argument
93 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_WAIT_ABORT, thread_ptr, thread_ptr -> tx_thread_state, 0, … in _tx_thread_wait_abort()
99 if (thread_ptr -> tx_thread_state < TX_SLEEP) in _tx_thread_wait_abort()
116 if (thread_ptr -> tx_thread_state == TX_SLEEP) in _tx_thread_wait_abort()
120 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
124 thread_ptr -> tx_thread_suspend_status = TX_WAIT_ABORTED; in _tx_thread_wait_abort()
127 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_thread_wait_abort()
138 else if(thread_ptr -> tx_thread_suspend_cleanup == TX_NULL) in _tx_thread_wait_abort()
156 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
159 suspend_cleanup = thread_ptr -> tx_thread_suspend_cleanup; in _tx_thread_wait_abort()
[all …]
|
| D | tx_semaphore_get.c | 81 TX_THREAD *thread_ptr; in _tx_semaphore_get() local
103 …ion, semaphore_ptr -> tx_semaphore_count, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr), TX_TRACE_SEMAP… in _tx_semaphore_get()
148 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_semaphore_get()
151 thread_ptr -> tx_thread_suspend_cleanup = &(_tx_semaphore_cleanup); in _tx_semaphore_get()
155 thread_ptr -> tx_thread_suspend_control_block = (VOID *) semaphore_ptr; in _tx_semaphore_get()
161 thread_ptr -> tx_thread_suspension_sequence++; in _tx_semaphore_get()
170 semaphore_ptr -> tx_semaphore_suspension_list = thread_ptr; in _tx_semaphore_get()
171 thread_ptr -> tx_thread_suspended_next = thread_ptr; in _tx_semaphore_get()
172 thread_ptr -> tx_thread_suspended_previous = thread_ptr; in _tx_semaphore_get()
179 thread_ptr -> tx_thread_suspended_next = next_thread; in _tx_semaphore_get()
[all …]
|
| D | tx_thread_relinquish.c | 84 TX_THREAD *thread_ptr; in _tx_thread_relinquish() local
88 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_relinquish()
93 TX_THREAD_STACK_CHECK(thread_ptr) in _tx_thread_relinquish()
102 _tx_timer_time_slice = thread_ptr -> tx_thread_new_time_slice; in _tx_thread_relinquish()
106 priority = thread_ptr -> tx_thread_priority; in _tx_thread_relinquish()
109 if (thread_ptr -> tx_thread_ready_next != thread_ptr) in _tx_thread_relinquish()
114 _tx_thread_priority_list[priority] = thread_ptr -> tx_thread_ready_next; in _tx_thread_relinquish()
117 _tx_thread_execute_ptr = thread_ptr -> tx_thread_ready_next; in _tx_thread_relinquish()
133 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_RELINQUISH, &thread_ptr, TX_POINTER_TO_ULONG_CONVERT(_tx_t… in _tx_thread_relinquish()
142 if (_tx_thread_execute_ptr != thread_ptr) in _tx_thread_relinquish()
[all …]
|
| D | tx_thread_time_slice.c | 84 TX_THREAD *thread_ptr; in _tx_thread_time_slice() local
94 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_time_slice()
99 TX_THREAD_STACK_CHECK(thread_ptr) in _tx_thread_time_slice()
112 if (thread_ptr != TX_NULL) in _tx_thread_time_slice()
116 if (thread_ptr -> tx_thread_state == TX_READY) in _tx_thread_time_slice()
120 thread_ptr -> tx_thread_time_slice = thread_ptr -> tx_thread_new_time_slice; in _tx_thread_time_slice()
123 _tx_timer_time_slice = thread_ptr -> tx_thread_time_slice; in _tx_thread_time_slice()
127 if (thread_ptr -> tx_thread_ready_next != thread_ptr) in _tx_thread_time_slice()
131 if (thread_ptr -> tx_thread_priority == thread_ptr -> tx_thread_preempt_threshold) in _tx_thread_time_slice()
138 … _tx_thread_priority_list[thread_ptr -> tx_thread_priority] = thread_ptr -> tx_thread_ready_next; in _tx_thread_time_slice()
[all …]
|
| D | tx_queue_receive.c | 87 TX_THREAD *thread_ptr; in _tx_queue_receive() local
167 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_receive()
172 if (thread_ptr -> tx_thread_suspend_option == TX_TRUE) in _tx_queue_receive()
180 … source = TX_VOID_TO_ULONG_POINTER_CONVERT(thread_ptr -> tx_thread_additional_suspend_info); in _tx_queue_receive()
205 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
209 … previous_thread = thread_ptr -> tx_thread_suspended_previous; in _tx_queue_receive()
220 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_queue_receive()
223 thread_ptr -> tx_thread_suspend_status = TX_SUCCESS; in _tx_queue_receive()
228 _tx_thread_system_ni_resume(thread_ptr); in _tx_queue_receive()
241 _tx_thread_system_resume(thread_ptr); in _tx_queue_receive()
[all …]
|
| /ThreadX-v6.3.0/common_smp/src/ |
| D | tx_thread_priority_change.c | 85 UINT _tx_thread_priority_change(TX_THREAD *thread_ptr, UINT new_priority, UINT *old_priority) in _tx_thread_priority_change() argument
113 …_INSERT(TX_TRACE_THREAD_PRIORITY_CHANGE, thread_ptr, new_priority, thread_ptr -> tx_thread_priorit… in _tx_thread_priority_change()
119 *old_priority = thread_ptr -> tx_thread_user_priority; in _tx_thread_priority_change()
122 if ((thread_ptr -> tx_thread_user_priority == new_priority) && in _tx_thread_priority_change()
123 (thread_ptr -> tx_thread_user_preempt_threshold == new_priority)) in _tx_thread_priority_change()
136 else if ((thread_ptr -> tx_thread_inherit_priority < new_priority) && in _tx_thread_priority_change()
137 … (thread_ptr -> tx_thread_user_preempt_threshold == thread_ptr -> tx_thread_user_priority)) in _tx_thread_priority_change()
143 thread_ptr -> tx_thread_user_priority = new_priority; in _tx_thread_priority_change()
144 thread_ptr -> tx_thread_user_preempt_threshold = new_priority; in _tx_thread_priority_change()
159 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_thread_priority_change()
[all …]
|
| D | tx_mutex_priority_change.c | 82 VOID _tx_mutex_priority_change(TX_THREAD *thread_ptr, UINT new_priority) in _tx_mutex_priority_change() argument
116 if (thread_ptr -> tx_thread_priority == new_priority) in _tx_mutex_priority_change()
119 if (thread_ptr -> tx_thread_preempt_threshold == new_priority) in _tx_mutex_priority_change()
135 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_mutex_priority_change()
139 thread_ptr -> tx_thread_priority = new_priority; in _tx_mutex_priority_change()
142 if (thread_ptr -> tx_thread_user_preempt_threshold < new_priority) in _tx_mutex_priority_change()
146 … thread_ptr -> tx_thread_preempt_threshold = thread_ptr -> tx_thread_user_preempt_threshold; in _tx_mutex_priority_change()
152 thread_ptr -> tx_thread_preempt_threshold = new_priority; in _tx_mutex_priority_change()
160 core_index = thread_ptr -> tx_thread_smp_core_mapped; in _tx_mutex_priority_change()
163 original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_priority_change()
[all …]
|
| D | tx_thread_create.c | 98 UINT _tx_thread_create(TX_THREAD *thread_ptr, CHAR *name_ptr, in _tx_thread_create() argument
120 thread_ptr -> tx_thread_stack_fill_value = ((ULONG) TX_RAND()) & 0xFFUL; in _tx_thread_create()
123 thread_ptr -> tx_thread_stack_fill_value = thread_ptr -> tx_thread_stack_fill_value | in _tx_thread_create()
124 (thread_ptr -> tx_thread_stack_fill_value << 8) | in _tx_thread_create()
125 (thread_ptr -> tx_thread_stack_fill_value << 16) | in _tx_thread_create()
126 (thread_ptr -> tx_thread_stack_fill_value << 24); in _tx_thread_create()
162 TX_MEMSET(thread_ptr, 0, sizeof(TX_THREAD)); in _tx_thread_create()
165 thread_ptr -> tx_thread_name = name_ptr; in _tx_thread_create()
166 thread_ptr -> tx_thread_entry = entry_function; in _tx_thread_create()
167 thread_ptr -> tx_thread_entry_parameter = entry_input; in _tx_thread_create()
[all …]
|
| D | tx_mutex_get.c | 82 TX_THREAD *thread_ptr; in _tx_mutex_get() local
110 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_mutex_get()
120 mutex_ptr -> tx_mutex_owner = thread_ptr; in _tx_mutex_get()
123 if (thread_ptr != TX_NULL) in _tx_mutex_get()
131 mutex_ptr -> tx_mutex_original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_get()
138 next_mutex = thread_ptr -> tx_thread_owned_mutex_list; in _tx_mutex_get()
161 thread_ptr -> tx_thread_owned_mutex_list = mutex_ptr; in _tx_mutex_get()
167 thread_ptr -> tx_thread_owned_mutex_count++; in _tx_mutex_get()
178 else if (mutex_ptr -> tx_mutex_owner == thread_ptr) in _tx_mutex_get()
225 if (thread_ptr -> tx_thread_priority < mutex_owner -> tx_thread_priority) in _tx_mutex_get()
[all …]
|
| D | tx_thread_terminate.c | 80 UINT _tx_thread_terminate(TX_THREAD *thread_ptr) in _tx_thread_terminate() argument
100 _tx_timer_system_deactivate(&thread_ptr -> tx_thread_timer); in _tx_thread_terminate()
103 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_TERMINATE, thread_ptr, thread_ptr -> tx_thread_state, TX_P… in _tx_thread_terminate()
109 if (thread_ptr -> tx_thread_state == TX_TERMINATED) in _tx_thread_terminate()
120 else if (thread_ptr -> tx_thread_state != TX_COMPLETED) in _tx_thread_terminate()
129 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_terminate()
133 if (thread_ptr -> tx_thread_state == TX_READY) in _tx_thread_terminate()
137 thread_ptr -> tx_thread_state = TX_TERMINATED; in _tx_thread_terminate()
140 TX_THREAD_STATE_CHANGE(thread_ptr, TX_TERMINATED) in _tx_thread_terminate()
151 (entry_exit_notify)(thread_ptr, TX_THREAD_EXIT); in _tx_thread_terminate()
[all …]
|
| D | tx_thread_shell_entry.c | 81 TX_THREAD *thread_ptr; in _tx_thread_shell_entry() local
88 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_shell_entry()
91 TX_THREAD_STARTED_EXTENSION(thread_ptr) in _tx_thread_shell_entry()
99 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
109 (entry_exit_notify)(thread_ptr, TX_THREAD_ENTRY); in _tx_thread_shell_entry()
114 (thread_ptr -> tx_thread_entry) (thread_ptr -> tx_thread_entry_parameter); in _tx_thread_shell_entry()
124 (_tx_thread_mutex_release)(thread_ptr); in _tx_thread_shell_entry()
133 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
138 thread_ptr -> tx_thread_state = TX_COMPLETED; in _tx_thread_shell_entry()
141 TX_THREAD_STATE_CHANGE(thread_ptr, TX_COMPLETED) in _tx_thread_shell_entry()
[all …]
|
| D | tx_thread_wait_abort.c | 79 UINT _tx_thread_wait_abort(TX_THREAD *thread_ptr) in _tx_thread_wait_abort() argument
93 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_WAIT_ABORT, thread_ptr, thread_ptr -> tx_thread_state, 0, … in _tx_thread_wait_abort()
99 if (thread_ptr -> tx_thread_state < TX_SLEEP) in _tx_thread_wait_abort()
116 if (thread_ptr -> tx_thread_state == TX_SLEEP) in _tx_thread_wait_abort()
120 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
124 thread_ptr -> tx_thread_suspend_status = TX_WAIT_ABORTED; in _tx_thread_wait_abort()
127 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_thread_wait_abort()
138 else if(thread_ptr -> tx_thread_suspend_cleanup == TX_NULL) in _tx_thread_wait_abort()
156 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
159 suspend_cleanup = thread_ptr -> tx_thread_suspend_cleanup; in _tx_thread_wait_abort()
[all …]
|
| D | tx_semaphore_get.c | 81 TX_THREAD *thread_ptr; in _tx_semaphore_get() local
103 …ion, semaphore_ptr -> tx_semaphore_count, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr), TX_TRACE_SEMAP… in _tx_semaphore_get()
148 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_semaphore_get()
151 thread_ptr -> tx_thread_suspend_cleanup = &(_tx_semaphore_cleanup); in _tx_semaphore_get()
155 thread_ptr -> tx_thread_suspend_control_block = (VOID *) semaphore_ptr; in _tx_semaphore_get()
161 thread_ptr -> tx_thread_suspension_sequence++; in _tx_semaphore_get()
170 semaphore_ptr -> tx_semaphore_suspension_list = thread_ptr; in _tx_semaphore_get()
171 thread_ptr -> tx_thread_suspended_next = thread_ptr; in _tx_semaphore_get()
172 thread_ptr -> tx_thread_suspended_previous = thread_ptr; in _tx_semaphore_get()
179 thread_ptr -> tx_thread_suspended_next = next_thread; in _tx_semaphore_get()
[all …]
|
| D | tx_thread_smp_utilities.c | 302 VOID _tx_thread_smp_core_interrupt(TX_THREAD *thread_ptr, UINT current_core, UINT target_core) in _tx_thread_smp_core_interrupt() argument
319 if ((current_thread != TX_NULL) && (thread_ptr != current_thread)) in _tx_thread_smp_core_interrupt()
471 TX_THREAD *thread_ptr; in _tx_thread_smp_possible_cores_get() local
474 thread_ptr = _tx_thread_execute_ptr[0]; in _tx_thread_smp_possible_cores_get()
475 if (thread_ptr != TX_NULL) in _tx_thread_smp_possible_cores_get()
477 possible_cores = thread_ptr -> tx_thread_smp_cores_allowed; in _tx_thread_smp_possible_cores_get()
480 thread_ptr = _tx_thread_execute_ptr[1]; in _tx_thread_smp_possible_cores_get()
481 if (thread_ptr != TX_NULL) in _tx_thread_smp_possible_cores_get()
483 possible_cores = possible_cores | thread_ptr -> tx_thread_smp_cores_allowed; in _tx_thread_smp_possible_cores_get()
486 thread_ptr = _tx_thread_execute_ptr[2]; in _tx_thread_smp_possible_cores_get()
[all …]
|
| D | tx_queue_receive.c | 87 TX_THREAD *thread_ptr; in _tx_queue_receive() local
167 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_receive()
172 if (thread_ptr -> tx_thread_suspend_option == TX_TRUE) in _tx_queue_receive()
180 … source = TX_VOID_TO_ULONG_POINTER_CONVERT(thread_ptr -> tx_thread_additional_suspend_info); in _tx_queue_receive()
205 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
209 … previous_thread = thread_ptr -> tx_thread_suspended_previous; in _tx_queue_receive()
220 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_queue_receive()
223 thread_ptr -> tx_thread_suspend_status = TX_SUCCESS; in _tx_queue_receive()
228 _tx_thread_system_ni_resume(thread_ptr); in _tx_queue_receive()
241 _tx_thread_system_resume(thread_ptr); in _tx_queue_receive()
[all …]
|
| /ThreadX-v6.3.0/common_modules/module_manager/src/ |
| D | txm_module_manager_thread_create.c | 105 UINT _txm_module_manager_thread_create(TX_THREAD *thread_ptr, CHAR *name_ptr, in _txm_module_manager_thread_create() argument
132 if (thread_ptr == TX_NULL) in _txm_module_manager_thread_create()
163 if (thread_ptr == next_thread) in _txm_module_manager_thread_create()
195 if (thread_ptr == next_thread) in _txm_module_manager_thread_create()
284 thread_ptr -> tx_thread_stack_fill_value = ((ULONG) TX_RAND()) & 0xFFUL; in _txm_module_manager_thread_create()
287 thread_ptr -> tx_thread_stack_fill_value = thread_ptr -> tx_thread_stack_fill_value | in _txm_module_manager_thread_create()
288 (thread_ptr -> tx_thread_stack_fill_value << 8) | in _txm_module_manager_thread_create()
289 (thread_ptr -> tx_thread_stack_fill_value << 16) | in _txm_module_manager_thread_create()
290 (thread_ptr -> tx_thread_stack_fill_value << 24); in _txm_module_manager_thread_create()
330 TX_MEMSET(thread_ptr, 0, sizeof(TX_THREAD)); in _txm_module_manager_thread_create()
[all …]
|
| /ThreadX-v6.3.0/ports/win32/vs_2019/src/ |
| D | tx_thread_stack_build.c | 82 VOID _tx_thread_stack_build(TX_THREAD *thread_ptr, VOID (*function_ptr)(VOID)) in _tx_thread_stack_build() argument
86 thread_ptr -> tx_thread_win32_thread_handle = in _tx_thread_stack_build()
87 CreateThread(NULL, 0, _tx_win32_thread_entry, (LPVOID) thread_ptr, CREATE_SUSPENDED, in _tx_thread_stack_build()
88 &(thread_ptr -> tx_thread_win32_thread_id)); in _tx_thread_stack_build()
91 if (!thread_ptr -> tx_thread_win32_thread_handle) in _tx_thread_stack_build()
103 SetThreadPriority(thread_ptr -> tx_thread_win32_thread_handle, THREAD_PRIORITY_LOWEST); in _tx_thread_stack_build()
107 thread_ptr -> tx_thread_win32_thread_run_semaphore = CreateSemaphore(NULL, 0, 1, NULL); in _tx_thread_stack_build()
110 if (!thread_ptr -> tx_thread_win32_thread_run_semaphore) in _tx_thread_stack_build()
122 thread_ptr -> tx_thread_win32_suspension_type = 0; in _tx_thread_stack_build()
126 thread_ptr -> tx_thread_win32_int_disabled_flag = 0; in _tx_thread_stack_build()
[all …]
|
