| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | parker.rs | 34 const IDLE: usize = 0; const
43 state: AtomicUsize::new(IDLE), in new()
79 .compare_exchange(NOTIFIED, IDLE, SeqCst, SeqCst) in park()
102 .compare_exchange(IDLE, PARKED_ON_DRIVER, SeqCst, SeqCst) in park_on_driver()
106 self.state.swap(IDLE, SeqCst); in park_on_driver()
114 match self.state.swap(IDLE, SeqCst) { in park_on_driver()
127 .compare_exchange(IDLE, PARKED_ON_CONDVAR, SeqCst, SeqCst) in park_on_condvar_timeout()
132 self.state.swap(IDLE, SeqCst); in park_on_condvar_timeout()
150 .compare_exchange(NOTIFIED, IDLE, SeqCst, SeqCst) in park_on_condvar_timeout()
158 self.state.store(IDLE, SeqCst); in park_on_condvar_timeout()
[all …]
|
| H A D | current_thread.rs | 30 const IDLE: usize = 0; const
90 state: AtomicUsize::new(IDLE), in new()
113 .compare_exchange(IDLE, PARKED_ON_DRIVER, AcqRel, Acquire) in park_on_driver()
117 return match self.state.swap(IDLE, AcqRel) { in park_on_driver()
134 match self.state.swap(IDLE, AcqRel) { in park_on_driver()
146 .compare_exchange(IDLE, PARKED_ON_CONDVAR, AcqRel, Acquire) in park_on_condvar()
150 return match self.state.swap(IDLE, AcqRel) { in park_on_condvar()
166 match self.state.swap(IDLE, AcqRel) { in park_on_condvar()
176 IDLE | NOTIFIED | NOTIFIED_BLOCK => {} in unpark()
188 IDLE | NOTIFIED => {} in unpark()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | atomic_waker.rs | 26 const IDLE: u8 = 0; const
37 state: AtomicU8::new(IDLE), in new()
45 .compare_exchange(IDLE, REGISTERING, Acquire, Acquire) in register_by_ref()
47 Ok(IDLE) => { in register_by_ref()
52 .compare_exchange(REGISTERING, IDLE, AcqRel, Acquire) in register_by_ref()
57 self.state.store(IDLE, Release); in register_by_ref()
78 IDLE => { in take_waker()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_sync/src/media_cloud_asset_download/ |
| H A D | cloud_media_asset_manager.cpp | 54 std::atomic<TaskDeleteState> CloudMediaAssetManager::doDeleteTask_ = TaskDeleteState::IDLE;
91 case CloudMediaAssetTaskStatus::IDLE: { in StartDownloadCloudAsset()
119 if (operation_ == nullptr || operation_->GetTaskStatus() == CloudMediaAssetTaskStatus::IDLE) { in RecoverDownloadCloudAsset()
133 if (operation_ == nullptr || operation_->GetTaskStatus() == CloudMediaAssetTaskStatus::IDLE) { in PauseDownloadCloudAsset()
156 TaskDeleteState expect = TaskDeleteState::IDLE; in StartDeleteCloudMediaAssets()
166 if (!doDeleteTask_.compare_exchange_strong(expect, TaskDeleteState::IDLE)) { in StopDeleteCloudMediaAssets()
230 while (doDeleteTask_.load() > TaskDeleteState::IDLE && cycleNumber <= CYCLE_NUMBER) { in DeleteAllCloudMediaAssetsOperation()
255 doDeleteTask_.store(TaskDeleteState::IDLE); in DeleteAllCloudMediaAssetsOperation()
317 TaskDeleteState expect = TaskDeleteState::IDLE; in ForceRetainDownloadCloudMedia()
332 return to_string(static_cast<int32_t>(CloudMediaAssetTaskStatus::IDLE)) + ",0,0,0,0,0"; in GetCloudMediaAssetTaskStatus()
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/common/ |
| H A D | power_spec.cpp | 24 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_7000_MS)},
32 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_7000_MS)},
40 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_7000_MS)},
48 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_3000_MS)},
56 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_5000_MS)},
64 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_7000_MS)},
72 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_1000_MS)},
80 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_7000_MS)},
88 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_5000_MS)},
104 {RequestStatus::IDLE, PowerInfo(PowerModeLevel::LEVEL_LOW, SNIFF_DELAYSET_TIMEOUT_5000_MS)},
[all …]
|
| /ohos5.0/foundation/multimedia/av_codec/services/engine/codec/audio/ |
| H A D | audio_buffer_info.cpp | 34 status_(BufferStatus::IDLE), in AudioBufferInfo()
65 status_ = BufferStatus::IDLE; in ~AudioBufferInfo()
90 return status_ == BufferStatus::IDLE; in IsAvailable()
169 status_ = BufferStatus::IDLE; in ResetBuffer()
|
| /ohos5.0/foundation/multimedia/player_framework/services/utils/include/ |
| H A D | task_queue.h | 125 if (state_ != TaskState::IDLE) {
165 if (state_ == TaskState::IDLE) {
197 state_ = TaskState::IDLE;
216 IDLE = 0,
222 TaskState state_ = TaskState::IDLE;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_state_machine.cpp | 36 {State::IDLE, Event::START_SYNC_EVENT, State::DO_DOWNLOAD},
37 {State::IDLE, Event::ERROR_EVENT, State::DO_FINISHED},
53 {State::DO_FINISHED, Event::ALL_TASK_FINISHED_EVENT, State::IDLE},
78 } while (SwitchMachineState(event) == E_OK && currentState_ != State::IDLE); in SyncStep()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/scroll/effect/ |
| H A D | scroll_fade_controller.cpp | 94 opacityFloor_ = state_ == OverScrollState::IDLE ? DEFAULT_OPACITY : opacity_; in ProcessAbsorb()
134 if (state_ == OverScrollState::RECEDE || state_ == OverScrollState::IDLE) { in ProcessRecede()
153 state_ = OverScrollState::IDLE; in ChangeState()
160 case OverScrollState::IDLE: in ChangeState()
|
| H A D | scroll_fade_controller.h | 31 IDLE = 0, enumerator
67 OverScrollState state_ = OverScrollState::IDLE;
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/scroll/ |
| H A D | scroll_fade_controller.cpp | 96 opacityFloor_ = state_ == OverScrollState::IDLE ? DEFAULT_OPACITY : opacity_; in ProcessAbsorb()
136 if (state_ == OverScrollState::RECEDE || state_ == OverScrollState::IDLE) { in ProcessRecede()
155 state_ = OverScrollState::IDLE; in ChangeState()
162 case OverScrollState::IDLE: in ChangeState()
|
| H A D | scroll_fade_controller.h | 32 IDLE = 0, enumerator
68 OverScrollState state_ = OverScrollState::IDLE;
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/pipeline/ |
| H A D | rs_render_node_gc.h | 53 IDLE, enumerator
105 GCLevel nodeGCLevel_ = GCLevel::IDLE;
106 GCLevel drawableGCLevel_ = GCLevel::IDLE;
|
| /ohos5.0/foundation/multimedia/media_foundation/video_processing_engine/framework/capi/video_processing/ |
| H A D | video_processing_native.cpp | 209 state_ = VPEState::IDLE; in Stop()
216 if (state_.load() == VPEState::IDLE) { in Stop()
303 if (state_.load() == VPEState::IDLE) { in OnNewOutputBuffer()
364 if (state_.load() != VPEState::IDLE) { in OnProducerBufferReleased()
452 while (state_.load() != VPEState::IDLE) { in ProcessBuffers()
500 state_ = VPEState::IDLE; in CheckStopping()
512 …return ExecuteWithCheck([this] { return state_.load() != VPEState::IDLE; }, std::move(operation), … in ExecuteWhenIdle()
518 …return ExecuteWithCheck([this] { return state_.load() == VPEState::IDLE; }, std::move(operation), … in ExecuteWhenNotIdle()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_cloud_asset_download_test/src/ |
| H A D | medialibrary_cloud_asset_download_test.cpp | 206 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
224 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
242 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
351 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
415 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
432 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
501 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
521 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
540 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
543 operation->taskStatus_ = CloudMediaAssetTaskStatus::IDLE;
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_tg/ |
| H A D | avrcp_tg_profile.cpp | 346 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendPressButtonRsp()
358 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendReleaseButtonRsp()
609 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendGetCapabilitiesRsp()
643 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendListPlayerApplicationSettingAttributesRsp()
670 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendListPlayerApplicationSettingValuesRsp()
697 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendGetCurrentPlayerApplicationSettingValueRsp()
724 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendSetPlayerApplicationSettingValueRsp()
757 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendGetPlayerApplicationSettingAttributeTextRsp()
791 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendGetPlayerApplicationSettingValueTextRsp()
821 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_TG, rawAddr); in SendGetElementAttributesRsp()
[all …]
|
| /ohos5.0/foundation/communication/nfc/services/src/nci_adapter/nci_native_default/include/ |
| H A D | tag_nci_adapter_rw.h | 35 IDLE = 0, enumerator
41 enum TagState { IDLE = 0, SLEEP, ACTIVE }; enumerator
111 TagState tagState_ = IDLE;
|
| /ohos5.0/foundation/systemabilitymgr/safwk/test/services/safwk/unittest/ |
| H A D | system_ability_test.cpp | 263 sysAby->abilityState_ = SystemAbilityState::IDLE;
277 sysAby->abilityState_ = SystemAbilityState::IDLE;
305 sysAby->abilityState_ = SystemAbilityState::IDLE;
309 EXPECT_EQ(sysAby->abilityState_, SystemAbilityState::IDLE);
326 EXPECT_EQ(sysAby->abilityState_, SystemAbilityState::IDLE);
343 EXPECT_EQ(sysAby->abilityState_, SystemAbilityState::IDLE);
370 sysAby->abilityState_ = SystemAbilityState::IDLE;
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/core/ |
| H A D | version_ctx.cpp | 24 if (version->status == DataStatus::IDLE) { in BuildConsumeRelationship()
66 parentVersion->CreateChildVersion(producer, DataStatus::IDLE); in AddProducer()
126 if (status == DataStatus::IDLE) { in MergeChildVersion()
|
| /ohos5.0/foundation/communication/netstack/test/unittest/http_client/ |
| H A D | HttpClientTest.cpp | 54 while (task->GetStatus() != TaskStatus::IDLE) {
57 EXPECT_EQ(task->GetStatus(), IDLE);
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/ |
| H A D | slide_recognizer.cpp | 31 static uint32_t g_slideState = SlideRecognizeStat::IDLE;
43 g_slideState = SlideRecognizeStat::IDLE; in __anon9c329c500202()
96 g_slideState = SlideRecognizeStat::IDLE; in HandleSlideOFFEvent()
158 g_slideState = SlideRecognizeStat::IDLE; in HandleSendFrameEvent()
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/include/ |
| H A D | slide_recognizer.h | 26 IDLE, enumerator
56 uint32_t state_ = SlideRecognizeStat::IDLE;
|
| /ohos5.0/foundation/multimedia/av_session/services/session/server/test/ |
| H A D | avsession_radar_test.cpp | 108 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
172 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
220 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
284 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
316 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
380 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
460 EXPECT_EQ(info.stageRes_, static_cast<int32_t>(StageResult::IDLE));
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_ct/ |
| H A D | avrcp_ct_profile.cpp | 333 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendPressButtonCmd()
343 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendReleaseButtonCmd()
485 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendUnitCmd()
519 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendSubUnitCmd()
722 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendGetCapabilitiesCmd()
746 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendListPlayerApplicationSettingAttributesCmd()
767 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendListPlayerApplicationSettingValuesCmd()
830 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendGetCurrentPlayerApplicationSettingValueCmd()
898 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendSetPlayerApplicationSettingValueCmd()
919 IPowerManager::GetInstance().StatusUpdate(RequestStatus::IDLE, PROFILE_NAME_AVRCP_CT, rawAddr); in SendGetPlayerApplicationSettingAttributeTextCmd()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | auto_launch.cpp | 183 autoLaunchItemMap_[tmpIdentifier][userId].state = AutoLaunchItemState::IDLE; in EnableKvStoreAutoLaunch()
205 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in GetKVConnectionInEnable()
227 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in GetKVConnectionInEnable()
233 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in GetKVConnectionInEnable()
407 if (autoLaunchItemMap_[identifier][userId].state != AutoLaunchItemState::IDLE) { in DisableKvStoreAutoLaunch()
492 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in ConnectionLifeCycleCallbackTask()
569 } else if (iter.second.state != AutoLaunchItemState::IDLE) { in GetDoOpenMap()
668 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in ReceiveUnknownIdentifierCallBackTask()
679 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in ReceiveUnknownIdentifierCallBackTask()
688 autoLaunchItemMap_[identifier][userId].state = AutoLaunchItemState::IDLE; in ReceiveUnknownIdentifierCallBackTask()
[all …]
|