Home
last modified time | relevance | path

Searched refs:next_thread (Results 1 – 25 of 84) sorted by relevance

1234

/ThreadX-v6.3.0/common_smp/src/
Dtx_thread_time_slice.c81 TX_THREAD *next_thread; in _tx_thread_time_slice() local
188 next_thread = thread_ptr -> tx_thread_ready_next; in _tx_thread_time_slice()
207 _tx_thread_priority_list[priority] = next_thread; in _tx_thread_time_slice()
218 next_thread -> tx_thread_ready_previous = previous_thread; in _tx_thread_time_slice()
219 previous_thread -> tx_thread_ready_next = next_thread; in _tx_thread_time_slice()
250 … excluded = (next_thread -> tx_thread_smp_cores_excluded >> core_index) & ((ULONG) 1); in _tx_thread_time_slice()
253 … if (next_thread -> tx_thread_preempt_threshold < next_thread -> tx_thread_priority) in _tx_thread_time_slice()
277 … if (next_thread != _tx_thread_execute_ptr[next_thread -> tx_thread_smp_core_mapped]) in _tx_thread_time_slice()
281next_thread -> tx_thread_smp_core_mapped = core_index; in _tx_thread_time_slice()
284 _tx_thread_execute_ptr[core_index] = next_thread; in _tx_thread_time_slice()
[all …]
Dtx_thread_relinquish.c85 TX_THREAD *next_thread; in _tx_thread_relinquish() local
149 next_thread = thread_ptr -> tx_thread_ready_next; in _tx_thread_relinquish()
168 _tx_thread_priority_list[priority] = next_thread; in _tx_thread_relinquish()
179 next_thread -> tx_thread_ready_previous = previous_thread; in _tx_thread_relinquish()
180 previous_thread -> tx_thread_ready_next = next_thread; in _tx_thread_relinquish()
214 … excluded = (next_thread -> tx_thread_smp_cores_excluded >> mapped_core) & ((ULONG) 1); in _tx_thread_relinquish()
218 … if ((next_thread -> tx_thread_preempt_threshold < next_thread -> tx_thread_priority) || in _tx_thread_relinquish()
232 … if (next_thread != _tx_thread_execute_ptr[next_thread -> tx_thread_smp_core_mapped]) in _tx_thread_relinquish()
239 next_thread -> tx_thread_smp_core_mapped = mapped_core; in _tx_thread_relinquish()
242 _tx_thread_execute_ptr[mapped_core] = next_thread; in _tx_thread_relinquish()
[all …]
Dtxe_thread_create.c102 TX_THREAD *next_thread; in _txe_thread_create() local
142 next_thread = _tx_thread_created_ptr; in _txe_thread_create()
150 if (thread_ptr == next_thread) in _txe_thread_create()
166 if (stack_start >= next_thread -> tx_thread_stack_start) in _txe_thread_create()
169 if (stack_start < next_thread -> tx_thread_stack_end) in _txe_thread_create()
182 if (stack_end >= next_thread -> tx_thread_stack_start) in _txe_thread_create()
185 if (stack_end < next_thread -> tx_thread_stack_end) in _txe_thread_create()
198 next_thread = next_thread -> tx_thread_created_next; in _txe_thread_create()
214 if (thread_ptr == next_thread) in _txe_thread_create()
Dtx_thread_delete.c79 TX_THREAD *next_thread; in _tx_thread_delete() local
116 …NSERT(TX_TRACE_THREAD_DELETE, thread_ptr, TX_POINTER_TO_ULONG_CONVERT(&next_thread), 0, 0, TX_TRAC… in _tx_thread_delete()
144 next_thread = thread_ptr -> tx_thread_created_next; in _tx_thread_delete()
146 next_thread -> tx_thread_created_previous = previous_thread; in _tx_thread_delete()
147 previous_thread -> tx_thread_created_next = next_thread; in _tx_thread_delete()
154 _tx_thread_created_ptr = next_thread; in _tx_thread_delete()
Dtx_queue_receive.c92 TX_THREAD *next_thread; in _tx_queue_receive() local
205 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
206 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_receive()
210 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_queue_receive()
211 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_queue_receive()
329 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
330 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_receive()
334 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_queue_receive()
335 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_queue_receive()
432next_thread = queue_ptr -> tx_queue_suspension_list; in _tx_queue_receive()
[all …]
Dtx_semaphore_prioritize.c84 TX_THREAD *next_thread; in _tx_semaphore_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_semaphore_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_semaphore_prioritize()
122 semaphore_ptr -> tx_semaphore_suspension_list = next_thread; in _tx_semaphore_prioritize()
227next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_semaphore_prioritize()
229 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_semaphore_prioritize()
230 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_semaphore_prioritize()
Dtx_block_pool_prioritize.c84 TX_THREAD *next_thread; in _tx_block_pool_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_block_pool_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_block_pool_prioritize()
122 pool_ptr -> tx_block_pool_suspension_list = next_thread; in _tx_block_pool_prioritize()
225next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_block_pool_prioritize()
227 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_block_pool_prioritize()
228 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_block_pool_prioritize()
Dtx_queue_prioritize.c84 TX_THREAD *next_thread; in _tx_queue_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_queue_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_queue_prioritize()
122 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_prioritize()
225next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_queue_prioritize()
227 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_queue_prioritize()
228 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_queue_prioritize()
Dtx_byte_pool_prioritize.c84 TX_THREAD *next_thread; in _tx_byte_pool_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_byte_pool_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_byte_pool_prioritize()
122 pool_ptr -> tx_byte_pool_suspension_list = next_thread; in _tx_byte_pool_prioritize()
225next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_byte_pool_prioritize()
227 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_byte_pool_prioritize()
228 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_byte_pool_prioritize()
Dtx_mutex_prioritize.c84 TX_THREAD *next_thread; in _tx_mutex_prioritize() local
118 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_mutex_prioritize()
121 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_mutex_prioritize()
125 mutex_ptr -> tx_mutex_suspension_list = next_thread; in _tx_mutex_prioritize()
228next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_mutex_prioritize()
230 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_mutex_prioritize()
231 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_mutex_prioritize()
Dtx_thread_system_suspend.c120 TX_THREAD *next_thread; in _tx_thread_system_suspend() local
424 next_thread = _tx_thread_priority_list[priority]; in _tx_thread_system_suspend()
441 next_thread = thread_ptr -> tx_thread_ready_next; in _tx_thread_system_suspend()
451 next_thread = thread_ptr; in _tx_thread_system_suspend()
653 if (next_thread == thread_ptr) in _tx_thread_system_suspend()
663 next_thread = TX_NULL; in _tx_thread_system_suspend()
690 if (next_thread == TX_NULL) in _tx_thread_system_suspend()
707 next_thread = _tx_thread_priority_list[next_priority]; in _tx_thread_system_suspend()
716 … if (next_thread != _tx_thread_execute_ptr[next_thread -> tx_thread_smp_core_mapped]) in _tx_thread_system_suspend()
722 … if (next_thread -> tx_thread_preempt_threshold != next_thread -> tx_thread_priority) in _tx_thread_system_suspend()
[all …]
Dtx_semaphore_cleanup.c87 TX_THREAD *next_thread; in _tx_semaphore_cleanup() local
153next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_semaphore_cleanup()
155 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_semaphore_cleanup()
156 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_semaphore_cleanup()
163 semaphore_ptr -> tx_semaphore_suspension_list = next_thread; in _tx_semaphore_cleanup()
Dtx_block_pool_cleanup.c87 TX_THREAD *next_thread; in _tx_block_pool_cleanup() local
152next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_block_pool_cleanup()
154 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_block_pool_cleanup()
155 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_block_pool_cleanup()
162 pool_ptr -> tx_block_pool_suspension_list = next_thread; in _tx_block_pool_cleanup()
Dtx_byte_pool_cleanup.c87 TX_THREAD *next_thread; in _tx_byte_pool_cleanup() local
150next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_byte_pool_cleanup()
152 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_byte_pool_cleanup()
153 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_byte_pool_cleanup()
160 pool_ptr -> tx_byte_pool_suspension_list = next_thread; in _tx_byte_pool_cleanup()
/ThreadX-v6.3.0/common/src/
Dtxe_thread_create.c102 TX_THREAD *next_thread; in _txe_thread_create() local
142 next_thread = _tx_thread_created_ptr; in _txe_thread_create()
150 if (thread_ptr == next_thread) in _txe_thread_create()
166 if (stack_start >= next_thread -> tx_thread_stack_start) in _txe_thread_create()
169 if (stack_start < next_thread -> tx_thread_stack_end) in _txe_thread_create()
182 if (stack_end >= next_thread -> tx_thread_stack_start) in _txe_thread_create()
185 if (stack_end < next_thread -> tx_thread_stack_end) in _txe_thread_create()
198 next_thread = next_thread -> tx_thread_created_next; in _txe_thread_create()
214 if (thread_ptr == next_thread) in _txe_thread_create()
Dtx_thread_delete.c79 TX_THREAD *next_thread; in _tx_thread_delete() local
116 …NSERT(TX_TRACE_THREAD_DELETE, thread_ptr, TX_POINTER_TO_ULONG_CONVERT(&next_thread), 0, 0, TX_TRAC… in _tx_thread_delete()
144 next_thread = thread_ptr -> tx_thread_created_next; in _tx_thread_delete()
146 next_thread -> tx_thread_created_previous = previous_thread; in _tx_thread_delete()
147 previous_thread -> tx_thread_created_next = next_thread; in _tx_thread_delete()
154 _tx_thread_created_ptr = next_thread; in _tx_thread_delete()
Dtx_queue_receive.c92 TX_THREAD *next_thread; in _tx_queue_receive() local
205 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
206 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_receive()
210 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_queue_receive()
211 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_queue_receive()
329 next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_queue_receive()
330 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_receive()
334 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_queue_receive()
335 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_queue_receive()
432next_thread = queue_ptr -> tx_queue_suspension_list; in _tx_queue_receive()
[all …]
Dtx_block_pool_prioritize.c84 TX_THREAD *next_thread; in _tx_block_pool_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_block_pool_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_block_pool_prioritize()
122 pool_ptr -> tx_block_pool_suspension_list = next_thread; in _tx_block_pool_prioritize()
225next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_block_pool_prioritize()
227 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_block_pool_prioritize()
228 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_block_pool_prioritize()
Dtx_byte_pool_prioritize.c84 TX_THREAD *next_thread; in _tx_byte_pool_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_byte_pool_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_byte_pool_prioritize()
122 pool_ptr -> tx_byte_pool_suspension_list = next_thread; in _tx_byte_pool_prioritize()
225next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_byte_pool_prioritize()
227 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_byte_pool_prioritize()
228 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_byte_pool_prioritize()
Dtx_queue_prioritize.c84 TX_THREAD *next_thread; in _tx_queue_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_queue_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_queue_prioritize()
122 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_prioritize()
225next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_queue_prioritize()
227 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_queue_prioritize()
228 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_queue_prioritize()
Dtx_semaphore_prioritize.c84 TX_THREAD *next_thread; in _tx_semaphore_prioritize() local
115 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_semaphore_prioritize()
118 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_semaphore_prioritize()
122 semaphore_ptr -> tx_semaphore_suspension_list = next_thread; in _tx_semaphore_prioritize()
227next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_semaphore_prioritize()
229 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_semaphore_prioritize()
230 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_semaphore_prioritize()
Dtx_mutex_prioritize.c84 TX_THREAD *next_thread; in _tx_mutex_prioritize() local
118 next_thread = head_ptr -> tx_thread_suspended_next; in _tx_mutex_prioritize()
121 if ((next_thread -> tx_thread_priority) < (head_ptr -> tx_thread_priority)) in _tx_mutex_prioritize()
125 mutex_ptr -> tx_mutex_suspension_list = next_thread; in _tx_mutex_prioritize()
228next_thread = priority_thread_ptr -> tx_thread_suspended_next; in _tx_mutex_prioritize()
230 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_mutex_prioritize()
231 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_mutex_prioritize()
Dtx_block_pool_cleanup.c87 TX_THREAD *next_thread; in _tx_block_pool_cleanup() local
152next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_block_pool_cleanup()
154 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_block_pool_cleanup()
155 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_block_pool_cleanup()
162 pool_ptr -> tx_block_pool_suspension_list = next_thread; in _tx_block_pool_cleanup()
Dtx_byte_pool_cleanup.c87 TX_THREAD *next_thread; in _tx_byte_pool_cleanup() local
150next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_byte_pool_cleanup()
152 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_byte_pool_cleanup()
153 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_byte_pool_cleanup()
160 pool_ptr -> tx_byte_pool_suspension_list = next_thread; in _tx_byte_pool_cleanup()
Dtx_semaphore_cleanup.c87 TX_THREAD *next_thread; in _tx_semaphore_cleanup() local
153next_thread = thread_ptr -> tx_thread_suspended_next; in _tx_semaphore_cleanup()
155 next_thread -> tx_thread_suspended_previous = previous_thread; in _tx_semaphore_cleanup()
156 previous_thread -> tx_thread_suspended_next = next_thread; in _tx_semaphore_cleanup()
163 semaphore_ptr -> tx_semaphore_suspension_list = next_thread; in _tx_semaphore_cleanup()

1234