| /ThreadX-v6.4.1/ports_smp/linux/gnu/src/ |
| D | tx_thread_smp_protect.c | 83 TX_THREAD *current_thread; in _tx_thread_smp_protect() local
105 current_thread = _tx_thread_current_ptr[core]; in _tx_thread_smp_protect()
110 … ((!current_thread) || (current_thread -> tx_thread_linux_thread_id != current_thread_id))) in _tx_thread_smp_protect()
126 if ((current_thread) && (_tx_thread_preempt_disable == 0)) in _tx_thread_smp_protect()
130 current_state = current_thread -> tx_thread_state; in _tx_thread_smp_protect()
137 current_thread -> tx_thread_linux_deferred_preempt = TX_FALSE; in _tx_thread_smp_protect()
140 current_thread -> tx_thread_linux_suspension_type = 1; in _tx_thread_smp_protect()
146 current_thread -> tx_thread_time_slice = _tx_timer_time_slice[core]; in _tx_thread_smp_protect()
158 current_thread -> tx_thread_smp_core_control = 1; in _tx_thread_smp_protect()
176 if ((current_thread) && (current_thread -> tx_thread_linux_deferred_preempt)) in _tx_thread_smp_protect()
[all …]
|
| D | tx_thread_context_restore.c | 84 TX_THREAD *current_thread; in _tx_thread_context_restore() local
97 current_thread = _tx_thread_current_ptr[0]; in _tx_thread_context_restore()
101 if ((!_tx_thread_system_state[0]) && (current_thread)) in _tx_thread_context_restore()
107 if ((_tx_thread_preempt_disable == 0) && (current_thread != _tx_thread_execute_ptr[0])) in _tx_thread_context_restore()
114 current_thread -> tx_thread_linux_suspension_type = 1; in _tx_thread_context_restore()
120 current_thread -> tx_thread_time_slice = _tx_timer_time_slice[0]; in _tx_thread_context_restore()
132 current_thread -> tx_thread_smp_core_control = 1; in _tx_thread_context_restore()
168 _tx_linux_thread_resume(current_thread -> tx_thread_linux_thread_id); in _tx_thread_context_restore()
|
| D | tx_thread_smp_current_thread_get.c | 78 TX_THREAD *current_thread; in _tx_thread_smp_current_thread_get() local
107 current_thread = _tx_thread_current_ptr[core]; in _tx_thread_smp_current_thread_get()
113 return(current_thread); in _tx_thread_smp_current_thread_get()
|
| D | tx_thread_schedule.c | 85 TX_THREAD *current_thread; in _tx_thread_schedule() local
113 current_thread = _tx_thread_current_ptr[core]; in _tx_thread_schedule()
116 if ((current_thread) && (current_thread -> tx_thread_linux_deferred_preempt)) in _tx_thread_schedule()
126 if (current_thread -> tx_thread_state != TX_TERMINATED) in _tx_thread_schedule()
131 _tx_linux_thread_suspend(current_thread -> tx_thread_linux_thread_id); in _tx_thread_schedule()
134 current_thread -> tx_thread_linux_deferred_preempt = TX_FALSE; in _tx_thread_schedule()
137 current_thread -> tx_thread_linux_suspension_type = 1; in _tx_thread_schedule()
143 current_thread -> tx_thread_time_slice = _tx_timer_time_slice[core]; in _tx_thread_schedule()
156 current_thread -> tx_thread_smp_core_control = 1; in _tx_thread_schedule()
|
| /ThreadX-v6.4.1/common/src/ |
| D | txe_thread_relinquish.c | 74 TX_THREAD *current_thread; in _txe_thread_relinquish() local
78 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_relinquish()
81 if (current_thread != TX_NULL) in _txe_thread_relinquish()
|
| D | tx_thread_system_preempt_check.c | 76 TX_THREAD *current_thread; in _tx_thread_system_preempt_check() local
90 TX_THREAD_GET_CURRENT(current_thread) in _tx_thread_system_preempt_check()
96 if (current_thread != thread_ptr) in _tx_thread_system_preempt_check()
|
| D | tx_thread_time_slice_change.c | 82 TX_THREAD *current_thread; in _tx_thread_time_slice_change() local
102 TX_THREAD_GET_CURRENT(current_thread) in _tx_thread_time_slice_change()
105 if (thread_ptr == current_thread) in _tx_thread_time_slice_change()
|
| D | txe_thread_reset.c | 78 TX_THREAD *current_thread; in _txe_thread_reset() local
106 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_reset()
109 if (current_thread == &_tx_timer_thread) in _txe_thread_reset()
|
| D | txe_semaphore_get.c | 81 TX_THREAD *current_thread; in _txe_semaphore_get() local
124 TX_THREAD_GET_CURRENT(current_thread) in _txe_semaphore_get()
127 if (current_thread == &_tx_timer_thread) in _txe_semaphore_get()
|
| D | txe_block_allocate.c | 86 TX_THREAD *current_thread; in _txe_block_allocate() local
136 TX_THREAD_GET_CURRENT(current_thread) in _txe_block_allocate()
139 if (current_thread == &_tx_timer_thread) in _txe_block_allocate()
|
| D | txe_queue_front_send.c | 83 TX_THREAD *current_thread; in _txe_queue_front_send() local
134 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_front_send()
137 if (current_thread == &_tx_timer_thread) in _txe_queue_front_send()
|
| D | txe_queue_receive.c | 85 TX_THREAD *current_thread; in _txe_queue_receive() local
136 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_receive()
139 if (current_thread == &_tx_timer_thread) in _txe_queue_receive()
|
| D | txe_queue_send.c | 83 TX_THREAD *current_thread; in _txe_queue_send() local
134 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_send()
137 if (current_thread == &_tx_timer_thread) in _txe_queue_send()
|
| D | txe_mutex_get.c | 83 TX_THREAD *current_thread; in _txe_mutex_get() local
126 TX_THREAD_GET_CURRENT(current_thread) in _txe_mutex_get()
129 if (current_thread == &_tx_timer_thread) in _txe_mutex_get()
|
| D | tx_thread_reset.c | 79 TX_THREAD *current_thread; in _tx_thread_reset() local
90 TX_THREAD_GET_CURRENT(current_thread) in _tx_thread_reset()
93 if (current_thread == thread_ptr) in _tx_thread_reset()
|
| D | txe_event_flags_get.c | 90 TX_THREAD *current_thread; in _txe_event_flags_get() local
140 TX_THREAD_GET_CURRENT(current_thread) in _txe_event_flags_get()
143 if (current_thread == &_tx_timer_thread) in _txe_event_flags_get()
|
| /ThreadX-v6.4.1/common_smp/src/ |
| D | txe_thread_relinquish.c | 74 TX_THREAD *current_thread; in _txe_thread_relinquish() local
78 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_relinquish()
81 if (current_thread != TX_NULL) in _txe_thread_relinquish()
|
| D | txe_thread_reset.c | 78 TX_THREAD *current_thread; in _txe_thread_reset() local
106 TX_THREAD_GET_CURRENT(current_thread) in _txe_thread_reset()
109 if (current_thread == &_tx_timer_thread) in _txe_thread_reset()
|
| D | txe_semaphore_get.c | 81 TX_THREAD *current_thread; in _txe_semaphore_get() local
124 TX_THREAD_GET_CURRENT(current_thread) in _txe_semaphore_get()
127 if (current_thread == &_tx_timer_thread) in _txe_semaphore_get()
|
| D | txe_block_allocate.c | 86 TX_THREAD *current_thread; in _txe_block_allocate() local
136 TX_THREAD_GET_CURRENT(current_thread) in _txe_block_allocate()
139 if (current_thread == &_tx_timer_thread) in _txe_block_allocate()
|
| D | txe_queue_front_send.c | 83 TX_THREAD *current_thread; in _txe_queue_front_send() local
134 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_front_send()
137 if (current_thread == &_tx_timer_thread) in _txe_queue_front_send()
|
| D | txe_queue_receive.c | 85 TX_THREAD *current_thread; in _txe_queue_receive() local
136 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_receive()
139 if (current_thread == &_tx_timer_thread) in _txe_queue_receive()
|
| D | txe_queue_send.c | 83 TX_THREAD *current_thread; in _txe_queue_send() local
134 TX_THREAD_GET_CURRENT(current_thread) in _txe_queue_send()
137 if (current_thread == &_tx_timer_thread) in _txe_queue_send()
|
| D | txe_mutex_get.c | 83 TX_THREAD *current_thread; in _txe_mutex_get() local
126 TX_THREAD_GET_CURRENT(current_thread) in _txe_mutex_get()
129 if (current_thread == &_tx_timer_thread) in _txe_mutex_get()
|
| /ThreadX-v6.4.1/utility/rtos_compatibility_layers/posix/ |
| D | px_sig_signal.c | 74 POSIX_TCB *current_thread; in signal() local
95 current_thread = (POSIX_TCB *) tx_thread_identify(); in signal()
98 current_thread -> signals.signal_func[signo] = func; in signal()
|
