| /ThreadX-v6.3.0/ports_smp/linux/gnu/src/ |
| D | tx_thread_smp_protect.c | 84 TX_THREAD *current_thread; in _tx_thread_smp_protect() local
106 current_thread = _tx_thread_current_ptr[core]; in _tx_thread_smp_protect()
111 … ((!current_thread) || (current_thread -> tx_thread_linux_thread_id != current_thread_id))) in _tx_thread_smp_protect()
127 if ((current_thread) && (_tx_thread_preempt_disable == 0)) in _tx_thread_smp_protect()
131 current_state = current_thread -> tx_thread_state; in _tx_thread_smp_protect()
138 current_thread -> tx_thread_linux_deferred_preempt = TX_FALSE; in _tx_thread_smp_protect()
141 current_thread -> tx_thread_linux_suspension_type = 1; in _tx_thread_smp_protect()
147 current_thread -> tx_thread_time_slice = _tx_timer_time_slice[core]; in _tx_thread_smp_protect()
159 current_thread -> tx_thread_smp_core_control = 1; in _tx_thread_smp_protect()
177 if ((current_thread) && (current_thread -> tx_thread_linux_deferred_preempt)) in _tx_thread_smp_protect()
[all …]
|
| D | tx_thread_context_restore.c | 85 TX_THREAD *current_thread; in _tx_thread_context_restore() local
98 current_thread = _tx_thread_current_ptr[0]; in _tx_thread_context_restore()
102 if ((!_tx_thread_system_state[0]) && (current_thread)) in _tx_thread_context_restore()
108 if ((_tx_thread_preempt_disable == 0) && (current_thread != _tx_thread_execute_ptr[0])) in _tx_thread_context_restore()
115 current_thread -> tx_thread_linux_suspension_type = 1; in _tx_thread_context_restore()
121 current_thread -> tx_thread_time_slice = _tx_timer_time_slice[0]; in _tx_thread_context_restore()
133 current_thread -> tx_thread_smp_core_control = 1; in _tx_thread_context_restore()
169 _tx_linux_thread_resume(current_thread -> tx_thread_linux_thread_id); in _tx_thread_context_restore()
|
| D | tx_thread_smp_current_thread_get.c | 79 TX_THREAD *current_thread; in _tx_thread_smp_current_thread_get() local
108 current_thread = _tx_thread_current_ptr[core]; in _tx_thread_smp_current_thread_get()
114 return(current_thread); in _tx_thread_smp_current_thread_get()
|
| D | tx_thread_schedule.c | 86 TX_THREAD *current_thread; in _tx_thread_schedule() local
114 current_thread = _tx_thread_current_ptr[core]; in _tx_thread_schedule()
117 if ((current_thread) && (current_thread -> tx_thread_linux_deferred_preempt)) in _tx_thread_schedule()
127 if (current_thread -> tx_thread_state != TX_TERMINATED) in _tx_thread_schedule()
132 _tx_linux_thread_suspend(current_thread -> tx_thread_linux_thread_id); in _tx_thread_schedule()
135 current_thread -> tx_thread_linux_deferred_preempt = TX_FALSE; in _tx_thread_schedule()
138 current_thread -> tx_thread_linux_suspension_type = 1; in _tx_thread_schedule()
144 current_thread -> tx_thread_time_slice = _tx_timer_time_slice[core]; in _tx_thread_schedule()
157 current_thread -> tx_thread_smp_core_control = 1; in _tx_thread_schedule()
|
| /ThreadX-v6.3.0/common/src/ |
| D | txe_thread_relinquish.c | 75 TX_THREAD *current_thread; in _txe_thread_relinquish() local
79 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_relinquish()
82 if (current_thread != TX_NULL) in _txe_thread_relinquish()
|
| D | tx_thread_system_preempt_check.c | 77 TX_THREAD *current_thread; in _tx_thread_system_preempt_check() local
91 TX_THREAD_GET_CURRENT(current_thread) in _tx_thread_system_preempt_check()
97 if (current_thread != thread_ptr) in _tx_thread_system_preempt_check()
|
| D | tx_thread_time_slice_change.c | 83 TX_THREAD *current_thread; in _tx_thread_time_slice_change() local
103 TX_THREAD_GET_CURRENT(current_thread) in _tx_thread_time_slice_change()
106 if (thread_ptr == current_thread) in _tx_thread_time_slice_change()
|
| D | txe_thread_reset.c | 79 TX_THREAD *current_thread; in _txe_thread_reset() local
107 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_reset()
110 if (current_thread == &_tx_timer_thread) in _txe_thread_reset()
|
| D | txe_semaphore_get.c | 82 TX_THREAD *current_thread; in _txe_semaphore_get() local
125 TX_THREAD_GET_CURRENT(current_thread) in _txe_semaphore_get()
128 if (current_thread == &_tx_timer_thread) in _txe_semaphore_get()
|
| D | txe_block_allocate.c | 87 TX_THREAD *current_thread; in _txe_block_allocate() local
137 TX_THREAD_GET_CURRENT(current_thread) in _txe_block_allocate()
140 if (current_thread == &_tx_timer_thread) in _txe_block_allocate()
|
| D | txe_queue_front_send.c | 84 TX_THREAD *current_thread; in _txe_queue_front_send() local
135 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_front_send()
138 if (current_thread == &_tx_timer_thread) in _txe_queue_front_send()
|
| D | txe_queue_receive.c | 86 TX_THREAD *current_thread; in _txe_queue_receive() local
137 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_receive()
140 if (current_thread == &_tx_timer_thread) in _txe_queue_receive()
|
| D | txe_queue_send.c | 84 TX_THREAD *current_thread; in _txe_queue_send() local
135 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_send()
138 if (current_thread == &_tx_timer_thread) in _txe_queue_send()
|
| D | txe_mutex_get.c | 84 TX_THREAD *current_thread; in _txe_mutex_get() local
127 TX_THREAD_GET_CURRENT(current_thread) in _txe_mutex_get()
130 if (current_thread == &_tx_timer_thread) in _txe_mutex_get()
|
| D | tx_thread_reset.c | 80 TX_THREAD *current_thread; in _tx_thread_reset() local
91 TX_THREAD_GET_CURRENT(current_thread) in _tx_thread_reset()
94 if (current_thread == thread_ptr) in _tx_thread_reset()
|
| D | txe_event_flags_get.c | 91 TX_THREAD *current_thread; in _txe_event_flags_get() local
141 TX_THREAD_GET_CURRENT(current_thread) in _txe_event_flags_get()
144 if (current_thread == &_tx_timer_thread) in _txe_event_flags_get()
|
| /ThreadX-v6.3.0/common_smp/src/ |
| D | txe_thread_relinquish.c | 75 TX_THREAD *current_thread; in _txe_thread_relinquish() local
79 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_relinquish()
82 if (current_thread != TX_NULL) in _txe_thread_relinquish()
|
| D | txe_thread_reset.c | 79 TX_THREAD *current_thread; in _txe_thread_reset() local
107 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_reset()
110 if (current_thread == &_tx_timer_thread) in _txe_thread_reset()
|
| D | txe_semaphore_get.c | 82 TX_THREAD *current_thread; in _txe_semaphore_get() local
125 TX_THREAD_GET_CURRENT(current_thread) in _txe_semaphore_get()
128 if (current_thread == &_tx_timer_thread) in _txe_semaphore_get()
|
| D | txe_block_allocate.c | 87 TX_THREAD *current_thread; in _txe_block_allocate() local
137 TX_THREAD_GET_CURRENT(current_thread) in _txe_block_allocate()
140 if (current_thread == &_tx_timer_thread) in _txe_block_allocate()
|
| D | txe_queue_receive.c | 86 TX_THREAD *current_thread; in _txe_queue_receive() local
137 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_receive()
140 if (current_thread == &_tx_timer_thread) in _txe_queue_receive()
|
| D | txe_queue_front_send.c | 84 TX_THREAD *current_thread; in _txe_queue_front_send() local
135 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_front_send()
138 if (current_thread == &_tx_timer_thread) in _txe_queue_front_send()
|
| D | txe_queue_send.c | 84 TX_THREAD *current_thread; in _txe_queue_send() local
135 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_send()
138 if (current_thread == &_tx_timer_thread) in _txe_queue_send()
|
| D | txe_mutex_get.c | 84 TX_THREAD *current_thread; in _txe_mutex_get() local
127 TX_THREAD_GET_CURRENT(current_thread) in _txe_mutex_get()
130 if (current_thread == &_tx_timer_thread) in _txe_mutex_get()
|
| /ThreadX-v6.3.0/utility/rtos_compatibility_layers/posix/ |
| D | px_sig_signal.c | 75 POSIX_TCB *current_thread; in signal() local
96 current_thread = (POSIX_TCB *) tx_thread_identify(); in signal()
99 current_thread -> signals.signal_func[signo] = func; in signal()
|
