/arkcompiler/ets_runtime/ecmascript/checkpoint/ |
H A D | thread_state_transition.h | 23 template<typename T, ThreadState newState> 34 if (oldState_ != newState) { in ThreadStateTransitionScope() 37 if constexpr (newState == ThreadState::RUNNING) { in ThreadStateTransitionScope() 40 self_->UpdateState(newState); in ThreadStateTransitionScope() 51 if (oldState_ != newState) { in ThreadStateTransitionScope() 59 self_->UpdateState(newState); in ThreadStateTransitionScope()
|
/arkcompiler/runtime_core/platforms/unix/libpandabase/futex/ |
H A D | fmutex.cpp | 189 auto newState = HELPERS_TO_UNSIGNED(curState) | HELPERS_TO_UNSIGNED(HELD_MASK); in MutexLock() local 191 ATOMIC_CAS_WEAK(&m->state_and_waiters_, curState, newState, memory_order_acquire, memory_order_relaxed); in MutexLock() 276 auto newState = HELPERS_TO_UNSIGNED(curState) & ~HELPERS_TO_UNSIGNED(HELD_MASK); // State without holding bit in MutexUnlock() local 284 done = ATOMIC_CAS_WEAK(&m->state_and_waiters_, curState, newState, memory_order_release, memory_order_relaxed); in MutexUnlock() 287 if (UNLIKELY(newState != 0)) { in MutexUnlock()
|
/arkcompiler/runtime_core/static_core/platforms/unix/libpandabase/futex/ |
H A D | mutex.h | 150 auto newState = curState + READ_INCREMENT; in ACQUIRE_SHARED() local 151 done = state_.compare_exchange_weak(curState, newState, std::memory_order_acquire); in ACQUIRE_SHARED() 186 auto newState = curState - READ_INCREMENT; in RELEASE_SHARED() local 189 done = state_.compare_exchange_weak(curState, newState, std::memory_order_seq_cst); in RELEASE_SHARED() 190 if (done && newState == UNLOCKED) { in RELEASE_SHARED()
|
H A D | fmutex.cpp | 211 auto newState = HELPERS_TO_UNSIGNED(curState) | HELPERS_TO_UNSIGNED(HELD_MASK); in MutexLock() local 212 done = ATOMIC_CAS_WEAK(&m->stateAndWaiters, curState, newState, memory_order_acquire, memory_order_relaxed); in MutexLock() 283 auto newState = HELPERS_TO_UNSIGNED(curState) & ~HELPERS_TO_UNSIGNED(HELD_MASK); // State without holding bit in MutexUnlock() local 291 done = ATOMIC_CAS_WEAK(&m->stateAndWaiters, curState, newState, memory_order_release, memory_order_relaxed); in MutexUnlock() 297 if (UNLIKELY(newState != 0)) { in MutexUnlock()
|
H A D | mutex.cpp | 215 auto newState = curState + READ_INCREMENT; in TryReadLock() local 217 done = state_.compare_exchange_weak(curState, newState, std::memory_order_acquire); in TryReadLock()
|
/arkcompiler/ets_runtime/ecmascript/ |
H A D | mutator_lock.cpp | 72 void MutatorLock::SetState(MutatorLock::MutatorLockState newState) in SetState() argument 74 JSThread::GetCurrent()->SetMutatorLockState(newState); in SetState()
|
H A D | js_thread.cpp | 1140 void JSThread::UpdateState(ThreadState newState) in UpdateState() argument 1143 if (oldState == ThreadState::RUNNING && newState != ThreadState::RUNNING) { in UpdateState() 1144 TransferFromRunningToSuspended(newState); in UpdateState() 1145 } else if (oldState != ThreadState::RUNNING && newState == ThreadState::RUNNING) { in UpdateState() 1149 StoreState(newState); in UpdateState() 1219 void JSThread::TransferFromRunningToSuspended(ThreadState newState) in TransferFromRunningToSuspended() argument 1222 StoreSuspendedState(newState); in TransferFromRunningToSuspended() 1247 inline void JSThread::StoreState(ThreadState newState) in StoreState() argument 1255 newStateAndFlags.asNonvolatileStruct.state = newState; in StoreState() 1266 void JSThread::StoreRunningState(ThreadState newState) in StoreRunningState() argument 1298 StoreSuspendedState(ThreadState newState) StoreSuspendedState() argument 1329 SetMutatorLockState(MutatorLock::MutatorLockState newState) SetMutatorLockState() argument [all...] |
H A D | mutator_lock.h | 36 void SetState(MutatorLockState newState);
|
H A D | js_thread.h | 1367 void PUBLIC_API UpdateState(ThreadState newState); 1377 void SetMutatorLockState(MutatorLock::MutatorLockState newState); 1525 void TransferFromRunningToSuspended(ThreadState newState); 1529 inline void StoreState(ThreadState newState); 1531 void StoreRunningState(ThreadState newState); 1533 void StoreSuspendedState(ThreadState newState);
|
/arkcompiler/toolchain/websocket/ |
H A D | websocket_base.cpp | 273 WebSocketBase::ConnectionState WebSocketBase::SetConnectionState(ConnectionState newState) in SetConnectionState() argument 275 return connectionState_.exchange(newState); in SetConnectionState() 278 bool WebSocketBase::CompareExchangeConnectionState(ConnectionState& expected, ConnectionState newState) in CompareExchangeConnectionState() argument 280 return connectionState_.compare_exchange_strong(expected, newState); in CompareExchangeConnectionState()
|
H A D | websocket_base.h | 145 ConnectionState SetConnectionState(ConnectionState newState); 146 bool CompareExchangeConnectionState(ConnectionState& expected, ConnectionState newState);
|
/arkcompiler/ets_runtime/ecmascript/daemon/ |
H A D | daemon_thread.cpp | 177 void DaemonThread::SetMutatorLockState(MutatorLock::MutatorLockState newState) in SetMutatorLockState() argument 179 mutatorLockState_ = newState; in SetMutatorLockState()
|
H A D | daemon_thread.h | 78 void SetMutatorLockState(MutatorLock::MutatorLockState newState);
|
/arkcompiler/ets_runtime/ecmascript/compiler/ |
H A D | scheduler.cpp | 319 auto &newState = dfsStack.top(); in CalculateSchedulingUpperBound() local 320 auto &newPredGates = newState.predGates; in CalculateSchedulingUpperBound() 321 newState.curGate = predGate; in CalculateSchedulingUpperBound() 397 auto &newState = dfsVisitStack.top(); in CalculateSchedulingLowerBound() local 398 auto &newPrevGates = newState.prevGates; in CalculateSchedulingLowerBound() 454 auto &newState = dfsFinishStack.top(); in CalculateSchedulingLowerBound() local 455 auto &newPrevGates = newState.prevGates; in CalculateSchedulingLowerBound() 456 newState.curGate = prevGate; in CalculateSchedulingLowerBound()
|
H A D | gate_accessor.h | 482 void ReplaceControlGate(GateRef gate, GateRef newState);
|
H A D | gate_accessor.cpp | 1629 void GateAccessor::ReplaceControlGate(GateRef gate, GateRef newState) in ReplaceControlGate() argument 1638 useIt = ReplaceIn(useIt, newState); in ReplaceControlGate()
|
/arkcompiler/runtime_core/static_core/runtime/mem/ |
H A D | pygote_space_allocator-inl.h | 55 inline void PygoteSpaceAllocator<AllocConfigT>::SetState(PygoteSpaceState newState) in SetState() argument 58 ASSERT(newState > state_); in SetState() 59 state_ = newState; in SetState()
|
H A D | pygote_space_allocator.h | 54 void SetState(PygoteSpaceState newState);
|
/arkcompiler/runtime_core/static_core/compiler/optimizer/optimizations/ |
H A D | escape.cpp | 512 auto newState = parent_->GetLocalAllocator()->New<BasicBlockState>(parent_->GetLocalAllocator()); 513 if (newState == nullptr) { 522 newState->Clear(); 523 ProcessPhis(block, newState); 531 stateChanged = stateChanged || MergeState(inst, block, newState); 536 parent_->blockStates_[block->GetId()] = newState; 541 void EscapeAnalysis::MergeProcessor::ProcessPhis(BasicBlock *block, BasicBlockState *newState) 551 newState->Materialize(phi); 571 bool EscapeAnalysis::MergeProcessor::MergeState(StateOwner inst, BasicBlock *block, BasicBlockState *newState) 592 newState [all...] |
H A D | escape.h | 235 bool MergeState(StateOwner inst, BasicBlock *block, BasicBlockState *newState); 239 void ProcessPhis(BasicBlock *block, BasicBlockState *newState);
|
/arkcompiler/runtime_core/static_core/runtime/ |
H A D | thread.cpp | 586 PandaString ManagedThread::LogThreadStack(ThreadState newState) const in LogThreadStack() 591 auto newStateIt = threadStateToStringMap.find(newState); in LogThreadStack()
|
/arkcompiler/runtime_core/static_core/runtime/include/ |
H A D | managed_thread.h | 817 PandaString LogThreadStack(ThreadState newState) const;
|