| /ThreadX-v6.4.1/common/src/ |
| D | tx_thread_priority_change.c | 88 UINT _tx_thread_priority_change(TX_THREAD *thread_ptr, UINT new_priority, UINT *old_priority) in _tx_thread_priority_change() argument
102 *old_priority = thread_ptr -> tx_thread_user_priority; in _tx_thread_priority_change()
105 …_INSERT(TX_TRACE_THREAD_PRIORITY_CHANGE, thread_ptr, new_priority, thread_ptr -> tx_thread_priorit… in _tx_thread_priority_change()
111 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_thread_priority_change()
116 thread_ptr -> tx_thread_user_priority = new_priority; in _tx_thread_priority_change()
117 thread_ptr -> tx_thread_user_preempt_threshold = new_priority; in _tx_thread_priority_change()
121 if (new_priority < thread_ptr -> tx_thread_inherit_priority) in _tx_thread_priority_change()
125 thread_ptr -> tx_thread_priority = new_priority; in _tx_thread_priority_change()
126 thread_ptr -> tx_thread_preempt_threshold = new_priority; in _tx_thread_priority_change()
132 thread_ptr -> tx_thread_priority = thread_ptr -> tx_thread_inherit_priority; in _tx_thread_priority_change()
[all …]
|
| D | tx_mutex_priority_change.c | 86 VOID _tx_mutex_priority_change(TX_THREAD *thread_ptr, UINT new_priority) in _tx_mutex_priority_change() argument
113 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_mutex_priority_change()
117 thread_ptr -> tx_thread_priority = new_priority; in _tx_mutex_priority_change()
120 if (thread_ptr -> tx_thread_user_preempt_threshold < new_priority) in _tx_mutex_priority_change()
124 … thread_ptr -> tx_thread_preempt_threshold = thread_ptr -> tx_thread_user_preempt_threshold; in _tx_mutex_priority_change()
130 thread_ptr -> tx_thread_preempt_threshold = new_priority; in _tx_mutex_priority_change()
145 original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_priority_change()
153 thread_ptr -> tx_thread_state = TX_PRIORITY_CHANGE; in _tx_mutex_priority_change()
156 _tx_thread_system_ni_suspend(thread_ptr, ((ULONG) 0)); in _tx_mutex_priority_change()
162 thread_ptr -> tx_thread_priority = new_priority; in _tx_mutex_priority_change()
[all …]
|
| D | tx_thread_create.c | 96 UINT _tx_thread_create(TX_THREAD *thread_ptr, CHAR *name_ptr, VOID (*entry_function)(ULONG id), UL… in _tx_thread_create() argument
118 thread_ptr -> tx_thread_stack_fill_value = ((ULONG) TX_RAND()) & 0xFFUL; in _tx_thread_create()
121 thread_ptr -> tx_thread_stack_fill_value = thread_ptr -> tx_thread_stack_fill_value | in _tx_thread_create()
122 (thread_ptr -> tx_thread_stack_fill_value << 8) | in _tx_thread_create()
123 (thread_ptr -> tx_thread_stack_fill_value << 16) | in _tx_thread_create()
124 (thread_ptr -> tx_thread_stack_fill_value << 24); in _tx_thread_create()
168 TX_MEMSET(thread_ptr, 0, (sizeof(TX_THREAD))); in _tx_thread_create()
171 thread_ptr -> tx_thread_name = name_ptr; in _tx_thread_create()
172 thread_ptr -> tx_thread_entry = entry_function; in _tx_thread_create()
173 thread_ptr -> tx_thread_entry_parameter = entry_input; in _tx_thread_create()
[all …]
|
| D | tx_mutex_get.c | 81 TX_THREAD *thread_ptr; in _tx_mutex_get() local
109 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_mutex_get()
119 mutex_ptr -> tx_mutex_owner = thread_ptr; in _tx_mutex_get()
122 if (thread_ptr != TX_NULL) in _tx_mutex_get()
130 mutex_ptr -> tx_mutex_original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_get()
137 next_mutex = thread_ptr -> tx_thread_owned_mutex_list; in _tx_mutex_get()
160 thread_ptr -> tx_thread_owned_mutex_list = mutex_ptr; in _tx_mutex_get()
166 thread_ptr -> tx_thread_owned_mutex_count++; in _tx_mutex_get()
177 else if (mutex_ptr -> tx_mutex_owner == thread_ptr) in _tx_mutex_get()
224 if (thread_ptr -> tx_thread_priority < mutex_owner -> tx_thread_priority) in _tx_mutex_get()
[all …]
|
| D | tx_thread_system_resume.c | 80 VOID _tx_thread_system_resume(TX_THREAD *thread_ptr) in _tx_thread_system_resume() argument
107 TX_THREAD_STACK_CHECK(thread_ptr) in _tx_thread_system_resume()
116 if (thread_ptr -> tx_thread_timer.tx_timer_internal_list_head != TX_NULL) in _tx_thread_system_resume()
120 _tx_timer_system_deactivate(&(thread_ptr -> tx_thread_timer)); in _tx_thread_system_resume()
126 thread_ptr -> tx_thread_timer.tx_timer_internal_remaining_ticks = ((ULONG) 0); in _tx_thread_system_resume()
137 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_RESUME, thread_ptr, thread_ptr -> tx_thread_state, TX_POIN… in _tx_thread_system_resume()
157 if (thread_ptr -> tx_thread_suspending == TX_FALSE) in _tx_thread_system_resume()
162 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_thread_system_resume()
166 if (thread_ptr -> tx_thread_delayed_suspend == TX_FALSE) in _tx_thread_system_resume()
174 thread_ptr -> tx_thread_state = TX_READY; in _tx_thread_system_resume()
[all …]
|
| D | tx_thread_terminate.c | 79 UINT _tx_thread_terminate(TX_THREAD *thread_ptr) in _tx_thread_terminate() argument
99 _tx_timer_system_deactivate(&thread_ptr -> tx_thread_timer); in _tx_thread_terminate()
102 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_TERMINATE, thread_ptr, thread_ptr -> tx_thread_state, TX_P… in _tx_thread_terminate()
108 if (thread_ptr -> tx_thread_state == TX_TERMINATED) in _tx_thread_terminate()
119 else if (thread_ptr -> tx_thread_state != TX_COMPLETED) in _tx_thread_terminate()
128 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_terminate()
132 if (thread_ptr -> tx_thread_state == TX_READY) in _tx_thread_terminate()
136 thread_ptr -> tx_thread_state = TX_TERMINATED; in _tx_thread_terminate()
139 TX_THREAD_STATE_CHANGE(thread_ptr, TX_TERMINATED) in _tx_thread_terminate()
150 (entry_exit_notify)(thread_ptr, TX_THREAD_EXIT); in _tx_thread_terminate()
[all …]
|
| D | tx_thread_preemption_change.c | 76 UINT _tx_thread_preemption_change(TX_THREAD *thread_ptr, UINT new_threshold, UINT *old_threshold) in _tx_thread_preemption_change() argument
98 if (thread_ptr -> tx_thread_user_priority != new_threshold) in _tx_thread_preemption_change()
116 …(TX_TRACE_THREAD_PREEMPTION_CHANGE, thread_ptr, new_threshold, thread_ptr -> tx_thread_preempt_thr… in _tx_thread_preemption_change()
122 if (new_threshold > thread_ptr -> tx_thread_user_priority) in _tx_thread_preemption_change()
134 if (thread_ptr -> tx_thread_user_priority == new_threshold) in _tx_thread_preemption_change()
138 if (_tx_thread_priority_list[thread_ptr -> tx_thread_priority] == thread_ptr) in _tx_thread_preemption_change()
144 map_index = (thread_ptr -> tx_thread_priority)/((UINT) 32); in _tx_thread_preemption_change()
149 TX_MOD32_BIT_SET(thread_ptr -> tx_thread_priority, priority_bit) in _tx_thread_preemption_change()
159 TX_DIV32_BIT_SET(thread_ptr -> tx_thread_priority, priority_bit) in _tx_thread_preemption_change()
168 *old_threshold = thread_ptr -> tx_thread_user_preempt_threshold; in _tx_thread_preemption_change()
[all …]
|
| D | tx_thread_shell_entry.c | 80 TX_THREAD *thread_ptr; in _tx_thread_shell_entry() local
87 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_shell_entry()
90 TX_THREAD_STARTED_EXTENSION(thread_ptr) in _tx_thread_shell_entry()
98 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
108 (entry_exit_notify)(thread_ptr, TX_THREAD_ENTRY); in _tx_thread_shell_entry()
113 (thread_ptr -> tx_thread_entry) (thread_ptr -> tx_thread_entry_parameter); in _tx_thread_shell_entry()
123 (_tx_thread_mutex_release)(thread_ptr); in _tx_thread_shell_entry()
132 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
137 thread_ptr -> tx_thread_state = TX_COMPLETED; in _tx_thread_shell_entry()
140 TX_THREAD_STATE_CHANGE(thread_ptr, TX_COMPLETED) in _tx_thread_shell_entry()
[all …]
|
| D | tx_thread_wait_abort.c | 78 UINT _tx_thread_wait_abort(TX_THREAD *thread_ptr) in _tx_thread_wait_abort() argument
92 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_WAIT_ABORT, thread_ptr, thread_ptr -> tx_thread_state, 0, … in _tx_thread_wait_abort()
98 if (thread_ptr -> tx_thread_state < TX_SLEEP) in _tx_thread_wait_abort()
115 if (thread_ptr -> tx_thread_state == TX_SLEEP) in _tx_thread_wait_abort()
119 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
123 thread_ptr -> tx_thread_suspend_status = TX_WAIT_ABORTED; in _tx_thread_wait_abort()
126 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_thread_wait_abort()
137 else if(thread_ptr -> tx_thread_suspend_cleanup == TX_NULL) in _tx_thread_wait_abort()
155 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
158 suspend_cleanup = thread_ptr -> tx_thread_suspend_cleanup; in _tx_thread_wait_abort()
[all …]
|
| D | tx_semaphore_get.c | 80 TX_THREAD *thread_ptr; in _tx_semaphore_get() local
102 …ion, semaphore_ptr -> tx_semaphore_count, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr), TX_TRACE_SEMAP… in _tx_semaphore_get()
147 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_semaphore_get()
150 thread_ptr -> tx_thread_suspend_cleanup = &(_tx_semaphore_cleanup); in _tx_semaphore_get()
154 thread_ptr -> tx_thread_suspend_control_block = (VOID *) semaphore_ptr; in _tx_semaphore_get()
160 thread_ptr -> tx_thread_suspension_sequence++; in _tx_semaphore_get()
169 semaphore_ptr -> tx_semaphore_suspension_list = thread_ptr; in _tx_semaphore_get()
170 thread_ptr -> tx_thread_suspended_next = thread_ptr; in _tx_semaphore_get()
171 thread_ptr -> tx_thread_suspended_previous = thread_ptr; in _tx_semaphore_get()
178 thread_ptr -> tx_thread_suspended_next = next_thread; in _tx_semaphore_get()
[all …]
|
| D | tx_thread_relinquish.c | 83 TX_THREAD *thread_ptr; in _tx_thread_relinquish() local
87 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_relinquish()
92 TX_THREAD_STACK_CHECK(thread_ptr) in _tx_thread_relinquish()
101 _tx_timer_time_slice = thread_ptr -> tx_thread_new_time_slice; in _tx_thread_relinquish()
105 priority = thread_ptr -> tx_thread_priority; in _tx_thread_relinquish()
108 if (thread_ptr -> tx_thread_ready_next != thread_ptr) in _tx_thread_relinquish()
113 _tx_thread_priority_list[priority] = thread_ptr -> tx_thread_ready_next; in _tx_thread_relinquish()
116 _tx_thread_execute_ptr = thread_ptr -> tx_thread_ready_next; in _tx_thread_relinquish()
132 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_RELINQUISH, &thread_ptr, TX_POINTER_TO_ULONG_CONVERT(_tx_t… in _tx_thread_relinquish()
141 if (_tx_thread_execute_ptr != thread_ptr) in _tx_thread_relinquish()
[all …]
|
| D | tx_thread_time_slice.c | 83 TX_THREAD *thread_ptr; in _tx_thread_time_slice() local
93 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_time_slice()
98 TX_THREAD_STACK_CHECK(thread_ptr) in _tx_thread_time_slice()
111 if (thread_ptr != TX_NULL) in _tx_thread_time_slice()
115 if (thread_ptr -> tx_thread_state == TX_READY) in _tx_thread_time_slice()
119 thread_ptr -> tx_thread_time_slice = thread_ptr -> tx_thread_new_time_slice; in _tx_thread_time_slice()
122 _tx_timer_time_slice = thread_ptr -> tx_thread_time_slice; in _tx_thread_time_slice()
126 if (thread_ptr -> tx_thread_ready_next != thread_ptr) in _tx_thread_time_slice()
130 if (thread_ptr -> tx_thread_priority == thread_ptr -> tx_thread_preempt_threshold) in _tx_thread_time_slice()
137 … _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 | 86 TX_THREAD *thread_ptr; in _tx_queue_receive() local
166 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_receive()
171 if (thread_ptr -> tx_thread_suspend_option == TX_TRUE) in _tx_queue_receive()
179 … source = TX_VOID_TO_ULONG_POINTER_CONVERT(thread_ptr -> tx_thread_additional_suspend_info); in _tx_queue_receive()
204 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
208 … previous_thread = thread_ptr -> tx_thread_suspended_previous; in _tx_queue_receive()
219 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_queue_receive()
222 thread_ptr -> tx_thread_suspend_status = TX_SUCCESS; in _tx_queue_receive()
227 _tx_thread_system_ni_resume(thread_ptr); in _tx_queue_receive()
240 _tx_thread_system_resume(thread_ptr); in _tx_queue_receive()
[all …]
|
| /ThreadX-v6.4.1/common_smp/src/ |
| D | tx_thread_priority_change.c | 84 UINT _tx_thread_priority_change(TX_THREAD *thread_ptr, UINT new_priority, UINT *old_priority) in _tx_thread_priority_change() argument
112 …_INSERT(TX_TRACE_THREAD_PRIORITY_CHANGE, thread_ptr, new_priority, thread_ptr -> tx_thread_priorit… in _tx_thread_priority_change()
118 *old_priority = thread_ptr -> tx_thread_user_priority; in _tx_thread_priority_change()
121 if ((thread_ptr -> tx_thread_user_priority == new_priority) && in _tx_thread_priority_change()
122 (thread_ptr -> tx_thread_user_preempt_threshold == new_priority)) in _tx_thread_priority_change()
135 else if ((thread_ptr -> tx_thread_inherit_priority < new_priority) && in _tx_thread_priority_change()
136 … (thread_ptr -> tx_thread_user_preempt_threshold == thread_ptr -> tx_thread_user_priority)) in _tx_thread_priority_change()
142 thread_ptr -> tx_thread_user_priority = new_priority; in _tx_thread_priority_change()
143 thread_ptr -> tx_thread_user_preempt_threshold = new_priority; in _tx_thread_priority_change()
158 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_thread_priority_change()
[all …]
|
| D | tx_mutex_priority_change.c | 81 VOID _tx_mutex_priority_change(TX_THREAD *thread_ptr, UINT new_priority) in _tx_mutex_priority_change() argument
115 if (thread_ptr -> tx_thread_priority == new_priority) in _tx_mutex_priority_change()
118 if (thread_ptr -> tx_thread_preempt_threshold == new_priority) in _tx_mutex_priority_change()
134 if (thread_ptr -> tx_thread_state != TX_READY) in _tx_mutex_priority_change()
138 thread_ptr -> tx_thread_priority = new_priority; in _tx_mutex_priority_change()
141 if (thread_ptr -> tx_thread_user_preempt_threshold < new_priority) in _tx_mutex_priority_change()
145 … thread_ptr -> tx_thread_preempt_threshold = thread_ptr -> tx_thread_user_preempt_threshold; in _tx_mutex_priority_change()
151 thread_ptr -> tx_thread_preempt_threshold = new_priority; in _tx_mutex_priority_change()
159 core_index = thread_ptr -> tx_thread_smp_core_mapped; in _tx_mutex_priority_change()
162 original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_priority_change()
[all …]
|
| D | tx_thread_create.c | 97 UINT _tx_thread_create(TX_THREAD *thread_ptr, CHAR *name_ptr, 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()
161 TX_MEMSET(thread_ptr, 0, sizeof(TX_THREAD)); in _tx_thread_create()
164 thread_ptr -> tx_thread_name = name_ptr; in _tx_thread_create()
165 thread_ptr -> tx_thread_entry = entry_function; in _tx_thread_create()
166 thread_ptr -> tx_thread_entry_parameter = entry_input; in _tx_thread_create()
[all …]
|
| D | tx_mutex_get.c | 81 TX_THREAD *thread_ptr; in _tx_mutex_get() local
109 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_mutex_get()
119 mutex_ptr -> tx_mutex_owner = thread_ptr; in _tx_mutex_get()
122 if (thread_ptr != TX_NULL) in _tx_mutex_get()
130 mutex_ptr -> tx_mutex_original_priority = thread_ptr -> tx_thread_priority; in _tx_mutex_get()
137 next_mutex = thread_ptr -> tx_thread_owned_mutex_list; in _tx_mutex_get()
160 thread_ptr -> tx_thread_owned_mutex_list = mutex_ptr; in _tx_mutex_get()
166 thread_ptr -> tx_thread_owned_mutex_count++; in _tx_mutex_get()
177 else if (mutex_ptr -> tx_mutex_owner == thread_ptr) in _tx_mutex_get()
224 if (thread_ptr -> tx_thread_priority < mutex_owner -> tx_thread_priority) in _tx_mutex_get()
[all …]
|
| D | tx_thread_terminate.c | 79 UINT _tx_thread_terminate(TX_THREAD *thread_ptr) in _tx_thread_terminate() argument
99 _tx_timer_system_deactivate(&thread_ptr -> tx_thread_timer); in _tx_thread_terminate()
102 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_TERMINATE, thread_ptr, thread_ptr -> tx_thread_state, TX_P… in _tx_thread_terminate()
108 if (thread_ptr -> tx_thread_state == TX_TERMINATED) in _tx_thread_terminate()
119 else if (thread_ptr -> tx_thread_state != TX_COMPLETED) in _tx_thread_terminate()
128 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_terminate()
132 if (thread_ptr -> tx_thread_state == TX_READY) in _tx_thread_terminate()
136 thread_ptr -> tx_thread_state = TX_TERMINATED; in _tx_thread_terminate()
139 TX_THREAD_STATE_CHANGE(thread_ptr, TX_TERMINATED) in _tx_thread_terminate()
150 (entry_exit_notify)(thread_ptr, TX_THREAD_EXIT); in _tx_thread_terminate()
[all …]
|
| D | tx_thread_shell_entry.c | 80 TX_THREAD *thread_ptr; in _tx_thread_shell_entry() local
87 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_thread_shell_entry()
90 TX_THREAD_STARTED_EXTENSION(thread_ptr) in _tx_thread_shell_entry()
98 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
108 (entry_exit_notify)(thread_ptr, TX_THREAD_ENTRY); in _tx_thread_shell_entry()
113 (thread_ptr -> tx_thread_entry) (thread_ptr -> tx_thread_entry_parameter); in _tx_thread_shell_entry()
123 (_tx_thread_mutex_release)(thread_ptr); in _tx_thread_shell_entry()
132 entry_exit_notify = thread_ptr -> tx_thread_entry_exit_notify; in _tx_thread_shell_entry()
137 thread_ptr -> tx_thread_state = TX_COMPLETED; in _tx_thread_shell_entry()
140 TX_THREAD_STATE_CHANGE(thread_ptr, TX_COMPLETED) in _tx_thread_shell_entry()
[all …]
|
| D | tx_thread_wait_abort.c | 78 UINT _tx_thread_wait_abort(TX_THREAD *thread_ptr) in _tx_thread_wait_abort() argument
92 …TX_TRACE_IN_LINE_INSERT(TX_TRACE_THREAD_WAIT_ABORT, thread_ptr, thread_ptr -> tx_thread_state, 0, … in _tx_thread_wait_abort()
98 if (thread_ptr -> tx_thread_state < TX_SLEEP) in _tx_thread_wait_abort()
115 if (thread_ptr -> tx_thread_state == TX_SLEEP) in _tx_thread_wait_abort()
119 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
123 thread_ptr -> tx_thread_suspend_status = TX_WAIT_ABORTED; in _tx_thread_wait_abort()
126 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_thread_wait_abort()
137 else if(thread_ptr -> tx_thread_suspend_cleanup == TX_NULL) in _tx_thread_wait_abort()
155 thread_ptr -> tx_thread_state = TX_SUSPENDED; in _tx_thread_wait_abort()
158 suspend_cleanup = thread_ptr -> tx_thread_suspend_cleanup; in _tx_thread_wait_abort()
[all …]
|
| D | tx_semaphore_get.c | 80 TX_THREAD *thread_ptr; in _tx_semaphore_get() local
102 …ion, semaphore_ptr -> tx_semaphore_count, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr), TX_TRACE_SEMAP… in _tx_semaphore_get()
147 TX_THREAD_GET_CURRENT(thread_ptr) in _tx_semaphore_get()
150 thread_ptr -> tx_thread_suspend_cleanup = &(_tx_semaphore_cleanup); in _tx_semaphore_get()
154 thread_ptr -> tx_thread_suspend_control_block = (VOID *) semaphore_ptr; in _tx_semaphore_get()
160 thread_ptr -> tx_thread_suspension_sequence++; in _tx_semaphore_get()
169 semaphore_ptr -> tx_semaphore_suspension_list = thread_ptr; in _tx_semaphore_get()
170 thread_ptr -> tx_thread_suspended_next = thread_ptr; in _tx_semaphore_get()
171 thread_ptr -> tx_thread_suspended_previous = thread_ptr; in _tx_semaphore_get()
178 thread_ptr -> tx_thread_suspended_next = next_thread; in _tx_semaphore_get()
[all …]
|
| D | tx_thread_smp_utilities.c | 301 VOID _tx_thread_smp_core_interrupt(TX_THREAD *thread_ptr, UINT current_core, UINT target_core) in _tx_thread_smp_core_interrupt() argument
318 if ((current_thread != TX_NULL) && (thread_ptr != current_thread)) in _tx_thread_smp_core_interrupt()
470 TX_THREAD *thread_ptr; in _tx_thread_smp_possible_cores_get() local
473 thread_ptr = _tx_thread_execute_ptr[0]; in _tx_thread_smp_possible_cores_get()
474 if (thread_ptr != TX_NULL) in _tx_thread_smp_possible_cores_get()
476 possible_cores = thread_ptr -> tx_thread_smp_cores_allowed; in _tx_thread_smp_possible_cores_get()
479 thread_ptr = _tx_thread_execute_ptr[1]; in _tx_thread_smp_possible_cores_get()
480 if (thread_ptr != TX_NULL) in _tx_thread_smp_possible_cores_get()
482 possible_cores = possible_cores | thread_ptr -> tx_thread_smp_cores_allowed; in _tx_thread_smp_possible_cores_get()
485 thread_ptr = _tx_thread_execute_ptr[2]; in _tx_thread_smp_possible_cores_get()
[all …]
|
| D | tx_queue_receive.c | 86 TX_THREAD *thread_ptr; in _tx_queue_receive() local
166 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_receive()
171 if (thread_ptr -> tx_thread_suspend_option == TX_TRUE) in _tx_queue_receive()
179 … source = TX_VOID_TO_ULONG_POINTER_CONVERT(thread_ptr -> tx_thread_additional_suspend_info); in _tx_queue_receive()
204 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
208 … previous_thread = thread_ptr -> tx_thread_suspended_previous; in _tx_queue_receive()
219 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _tx_queue_receive()
222 thread_ptr -> tx_thread_suspend_status = TX_SUCCESS; in _tx_queue_receive()
227 _tx_thread_system_ni_resume(thread_ptr); in _tx_queue_receive()
240 _tx_thread_system_resume(thread_ptr); in _tx_queue_receive()
[all …]
|
| /ThreadX-v6.4.1/common_modules/module_manager/src/ |
| D | txm_module_manager_thread_create.c | 104 UINT _txm_module_manager_thread_create(TX_THREAD *thread_ptr, CHAR *name_ptr, in _txm_module_manager_thread_create() argument
131 if (thread_ptr == TX_NULL) in _txm_module_manager_thread_create()
162 if (thread_ptr == next_thread) in _txm_module_manager_thread_create()
194 if (thread_ptr == next_thread) in _txm_module_manager_thread_create()
283 thread_ptr -> tx_thread_stack_fill_value = ((ULONG) TX_RAND()) & 0xFFUL; in _txm_module_manager_thread_create()
286 thread_ptr -> tx_thread_stack_fill_value = thread_ptr -> tx_thread_stack_fill_value | in _txm_module_manager_thread_create()
287 (thread_ptr -> tx_thread_stack_fill_value << 8) | in _txm_module_manager_thread_create()
288 (thread_ptr -> tx_thread_stack_fill_value << 16) | in _txm_module_manager_thread_create()
289 (thread_ptr -> tx_thread_stack_fill_value << 24); in _txm_module_manager_thread_create()
329 TX_MEMSET(thread_ptr, 0, sizeof(TX_THREAD)); in _txm_module_manager_thread_create()
[all …]
|
| /ThreadX-v6.4.1/ports/win32/vs_2019/src/ |
| D | tx_thread_stack_build.c | 81 VOID _tx_thread_stack_build(TX_THREAD *thread_ptr, VOID (*function_ptr)(VOID)) in _tx_thread_stack_build() argument
85 thread_ptr -> tx_thread_win32_thread_handle = in _tx_thread_stack_build()
86 CreateThread(NULL, 0, _tx_win32_thread_entry, (LPVOID) thread_ptr, CREATE_SUSPENDED, in _tx_thread_stack_build()
87 &(thread_ptr -> tx_thread_win32_thread_id)); in _tx_thread_stack_build()
90 if (!thread_ptr -> tx_thread_win32_thread_handle) in _tx_thread_stack_build()
102 SetThreadPriority(thread_ptr -> tx_thread_win32_thread_handle, THREAD_PRIORITY_LOWEST); in _tx_thread_stack_build()
106 thread_ptr -> tx_thread_win32_thread_run_semaphore = CreateSemaphore(NULL, 0, 1, NULL); in _tx_thread_stack_build()
109 if (!thread_ptr -> tx_thread_win32_thread_run_semaphore) in _tx_thread_stack_build()
121 thread_ptr -> tx_thread_win32_suspension_type = 0; in _tx_thread_stack_build()
125 thread_ptr -> tx_thread_win32_int_disabled_flag = 0; in _tx_thread_stack_build()
[all …]
|
