Home
last modified time | relevance | path

Searched refs:load (Results 1 - 25 of 652) sorted by relevance

12345678910>>...27

/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_thread_task.cpp43 if (state_.load() == RunningState::STOPPING) { in Start()
44 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Start()
46 if (state_.load() == RunningState::STOPPED) { in Start()
67 if (state_.load() != RunningState::STOPPED) { in Stop()
70 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Stop()
82 return state_.load() == RunningState::STARTED;
88 if (state_.load() != RunningState::STOPPING && state_.load() != RunningState::STOPPED) { in StopAsync()
97 switch (state_.load()) { in Pause()
101 return state_.load() in Pause()
[all...]
/foundation/multimedia/av_codec/services/utils/
H A Dtask_thread.cpp53 if (runningState_.load() == RunningState::STOPPING) { in Start()
54 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Start()
56 if (runningState_.load() == RunningState::STOPPED) { in Start()
76 AVCODEC_LOGD("task %{public}s stop entered, current state: %{public}d", name_.data(), runningState_.load()); in Stop()
78 if (runningState_.load() != RunningState::STOPPED) { in Stop()
81 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
96 if (runningState_.load() != RunningState::STOPPING && runningState_.load() != RunningState::STOPPED) { in StopAsync()
106 switch (runningState_.load()) { in Pause()
110 return runningState_.load() in Pause()
[all...]
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dtask.cpp83 name_.c_str(), runningState_.load()); in Stop()
85 if (runningState_.load() != RunningState::STOPPED) { in Stop()
88 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
103 if (runningState_.load() != RunningState::STOPPED) { in StopAsync()
111 RunningState state = runningState_.load(); in Pause()
117 return runningState_.load() == RunningState::PAUSED || runningState_.load() == RunningState::STOPPED; in Pause()
122 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Pause()
126 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
139 if (runningState_.load() in PauseAsync()
[all...]
/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dtask.cpp66 name_.c_str(), runningState_.load()); in Stop()
68 if (runningState_.load() != RunningState::STOPPED) { in Stop()
71 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
83 if (runningState_.load() != RunningState::STOPPED) { in StopAsync()
91 RunningState state = runningState_.load(); in Pause()
97 return runningState_.load() == RunningState::PAUSED || runningState_.load() == RunningState::STOPPED; in Pause()
102 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Pause()
106 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
119 if (runningState_.load() in PauseAsync()
[all...]
/foundation/multimedia/av_codec/services/services/codec/server/post_processing/
H A Dlock_free_queue.h71 if (!active_.load()) { in PushWait()
80 currentTail = tail_.load(); in PushWait()
83 if (newTail == head_.load()) { in PushWait()
85 canPushCv_.wait(lock, [&newTail, this]() { return newTail != head_.load() || !active_.load(); }); in PushWait()
88 if (!active_.load()) { in PushWait()
104 if (!active_.load()) { in PopWait()
114 currentHead = head_.load(); in PopWait()
117 if (currentHead == tail_.load()) { in PopWait()
119 canPopCv_.wait(lock, [&currentHead, this]() { return currentHead != tail_.load() || !active in PopWait()
[all...]
/foundation/resourceschedule/ffrt/src/util/
H A Dspmc_queue.cpp47 return tail_.load() - head_.load(); in GetLength()
62 unsigned int head = head_.load(); in PopHead()
63 unsigned int tail = tail_.load(); in PopHead()
81 unsigned int head = head_.load(); in PushTail()
82 unsigned int tail = tail_.load(); in PushTail()
97 unsigned int head = head_.load(); in FindElement()
98 unsigned int tail = tail_.load(); in FindElement()
116 while ((dstQueue.GetLength() < dstQueue.GetCapacity()) && (head_.load() != tail_.load())) { in PopHeadToAnotherQueue()
[all...]
H A Dtoken.h38 unsigned int v = count.load(std::memory_order_relaxed); in try_acquire()
55 unsigned int load() in load() function in ffrt::Token
57 return count.load(); in load()
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/
H A Dcast_timer.cpp25 CLOGD("%s In, exit_ = %d.", __FUNCTION__, exit_.load()); in ~CastTimer()
26 if (exit_.load()) { in ~CastTimer()
34 CLOGD("%s In, exit_ = %d.", __FUNCTION__, exit_.load()); in Start()
38 while (!exit_.load()) { in Start()
42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
45 if (exit_.load()) { in Start()
58 CLOGD("%s In, exit_ = %d.", __FUNCTION__, exit_.load()); in Stop()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/
H A Dcast_timer.cpp25 CLOGD("%s In, exit_ = %d.", __FUNCTION__, exit_.load()); in ~CastTimer()
26 if (exit_.load()) { in ~CastTimer()
34 CLOGD("%s In, exit_ = %d.", __FUNCTION__, exit_.load()); in Start()
38 while (!exit_.load()) { in Start()
42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
45 if (exit_.load()) { in Start()
58 CLOGD("%s In, exit_ = %d.", __FUNCTION__, exit_.load()); in Stop()
/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/src/
H A Ddaudio_hdf_operate.cpp40 if (audioServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START && in LoadDaudioHDFImpl()
41 audioextServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START) { in LoadDaudioHDFImpl()
73 DHLOGE("Wait load audio service failed!"); in LoadDaudioHDFImpl()
81 DHLOGE("Wait load provider service failed!"); in LoadDaudioHDFImpl()
95 DHLOGD("WaitLoadService start service %s, status %hu", servName.c_str(), this->audioServStatus_.load()); in WaitLoadService()
97 return (this->audioServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START); in WaitLoadService()
100 if (this->audioServStatus_.load() != OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START) { in WaitLoadService()
101 DHLOGE("Wait load service %{public}s failed, status %{public}hu", servName.c_str(), in WaitLoadService()
102 this->audioServStatus_.load()); in WaitLoadService()
108 DHLOGD("WaitLoadService start service %s, status %hu", servName.c_str(), this->audioextServStatus_.load()); in WaitLoadService()
[all...]
/foundation/graphic/graphic_2d/rosen/test/hyper_graphic_manager/unittest/
H A Dhgm_xml_parser_test.cpp57 int32_t load = parser->LoadConfiguration(invalidConfig); in HWTEST_F() local
58 STEP_ASSERT_EQ(load, static_cast<int32_t>(HgmErrCode::XML_FILE_LOAD_FAIL)); in HWTEST_F()
62 load = parser->LoadConfiguration(config); in HWTEST_F()
63 STEP_ASSERT_GE(load, 0); in HWTEST_F()
65 load = parser->LoadConfiguration(config); in HWTEST_F()
66 STEP_ASSERT_GE(load, 0); in HWTEST_F()
/foundation/resourceschedule/ffrt/src/sched/
H A Dinterval.cpp70 void PerfCtrl::Update(uint64_t deadlineNs, uint64_t load, bool force) in Update() argument
75 predUtil = (load << SCHED_CAPACITY_SHIFT) / deadlineNs; in Update()
81 FFRT_LOGI("Update Load %lu, Deadline %lu, Util %lu\n", load, deadlineNs, predUtil); in Update()
86 void IntervalLoadPredictor::UpdateTotalLoad(uint64_t load) in UpdateTotalLoad() argument
88 totalLoad.UpdateLoad(load); in UpdateTotalLoad()
91 void IntervalLoadPredictor::UpdateCPLoad(uint64_t load) in UpdateCPLoad() argument
97 cpLoad[cpLoadIndex++].UpdateLoad(load); in UpdateCPLoad()
107 uint64_t load = cpLoad[cpLoadIndex].GetPredictLoad(); in GetCPLoad() local
108 if (load == 0) { in GetCPLoad()
113 return (predictLoad < load) in GetCPLoad()
[all...]
H A Dload_predictor.h33 void UpdateLoad(uint64_t load) in UpdateLoad() argument
35 static_cast<T*>(this)->UpdateLoadImpl(load); in UpdateLoad()
59 void UpdateLoadImpl(uint64_t load) in UpdateLoadImpl() argument
61 uint64_t sum = load; in UpdateLoadImpl()
68 *end = load; in UpdateLoadImpl()
H A Dtask_manager.cpp58 count, avgWaitingTime.load(), maxWaitingTime.load(), avgRunningTime.load(), maxRunningTime.load()); in CalcTaskTime()
/foundation/graphic/graphic_surface/utils/frame_report/test/unittest/
H A Dframe_report_test.cpp63 ASSERT_TRUE(Rosen::FrameReport::GetInstance().activelyPid_.load() == FR_DEFAULT_PID); in HWTEST_F()
68 ASSERT_TRUE(Rosen::FrameReport::GetInstance().activelyPid_.load() == FRT_GAME_PID); in HWTEST_F()
71 ASSERT_TRUE(Rosen::FrameReport::GetInstance().activelyPid_.load() == FR_DEFAULT_PID); in HWTEST_F()
74 ASSERT_TRUE(Rosen::FrameReport::GetInstance().activelyPid_.load() == FR_DEFAULT_PID); in HWTEST_F()
141 ASSERT_TRUE(Rosen::FrameReport::GetInstance().lastSwapBufferTime_.load() == FRT_GAME_BUFFER_TIME); in HWTEST_F()
155 ASSERT_TRUE(Rosen::FrameReport::GetInstance().dequeueBufferTime_.load() == FRT_GAME_BUFFER_TIME); in HWTEST_F()
158 ASSERT_TRUE(Rosen::FrameReport::GetInstance().dequeueBufferTime_.load() == FRT_GAME_BUFFER_TIME); in HWTEST_F()
173 ASSERT_TRUE(Rosen::FrameReport::GetInstance().queueBufferTime_.load() == FRT_GAME_BUFFER_TIME); in HWTEST_F()
176 ASSERT_TRUE(Rosen::FrameReport::GetInstance().queueBufferTime_.load() == FRT_GAME_BUFFER_TIME); in HWTEST_F()
190 ASSERT_TRUE(Rosen::FrameReport::GetInstance().pendingBufferNum_.load() in HWTEST_F()
[all...]
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcamerahdf/
H A Ddcamera_hdf_operate.cpp39 if (cameraServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START && in LoadDcameraHDFImpl()
40 providerServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START) { in LoadDcameraHDFImpl()
98 return (this->cameraServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START); in WaitLoadCameraService()
101 if (cameraServStatus_.load() != OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START) { in WaitLoadCameraService()
102 DHLOGE("wait load cameraService failed, status %{public}d", cameraServStatus_.load()); in WaitLoadCameraService()
114 return (this->providerServStatus_.load() == OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START); in WaitLoadProviderService()
117 if (providerServStatus_.load() != OHOS::HDI::ServiceManager::V1_0::SERVIE_STATUS_START) { in WaitLoadProviderService()
118 DHLOGE("wait load providerService failed, status %{public}d", providerServStatus_.load()); in WaitLoadProviderService()
[all...]
/foundation/filemanagement/file_api/interfaces/kits/native/task_signal/
H A Dtask_signal.cpp29 if (remoteTask_.load()) { in Cancel()
50 return needCancel_.load() || remoteTask_.load(); in IsCanceled()
69 if (!needCancel_.load()) { in CheckCancelIfNeed()
/foundation/graphic/graphic_surface/utils/frame_report/src/
H A Dframe_report.cpp92 return activelyPid_.load() != FR_DEFAULT_PID; in HasGameScene()
100 return pid == activelyPid_.load(); in IsActiveGameWithPid()
108 return uniqueId == activelyUniqueId_.load(); in IsActiveGameWithUniqueId()
200 static_cast<int32_t>(dequeueBufferTime_.load() / THOUSAND_COUNT), in Report()
201 static_cast<int32_t>(queueBufferTime_.load() / THOUSAND_COUNT), in Report()
202 pendingBufferNum_.load(), in Report()
203 static_cast<int32_t>(lastSwapBufferTime_.load() / THOUSAND_COUNT), in Report()
209 NotifyFrameInfo(activelyPid_.load(), layerName, timeStamp, bufferMsg); in Report()
/foundation/communication/netstack/frameworks/cj/http/src/
H A Dnet_http_cache_proxy.cpp52 if (!cj_cacheIsRunning.load()) { in ReadResponseFromCache()
92 if (!cj_cacheIsRunning.load()) { in WriteResponseToCache()
117 if (cj_cacheIsRunning.load()) { in RunCacheWithSize()
128 while (cj_cacheNeedRun.load()) { in RunCacheWithSize()
131 [] { return !cj_cacheNeedRun.load(); }); in RunCacheWithSize()
143 if (!cj_cacheIsRunning.load()) { in FlushCache()
151 if (!cj_cacheIsRunning.load()) { in StopCacheAndDelete()
158 cj_cacheThreadCondition.wait(lock, [] { return !cj_cacheIsRunning.load(); }); in StopCacheAndDelete()
/foundation/communication/netstack/frameworks/js/napi/http/cache/cache_proxy/src/
H A Dcache_proxy.cpp63 if (!g_cacheIsRunning.load()) { in ReadResponseFromCache()
103 if (!g_cacheIsRunning.load()) { in WriteResponseToCache()
128 if (g_cacheIsRunning.load()) { in RunCacheWithSize()
139 while (g_cacheNeedRun.load()) { in RunCacheWithSize()
142 [] { return !g_cacheNeedRun.load(); }); in RunCacheWithSize()
154 if (!g_cacheIsRunning.load()) { in FlushCache()
162 if (!g_cacheIsRunning.load()) { in StopCacheAndDelete()
169 g_cacheThreadCondition.wait(lock, [] { return !g_cacheIsRunning.load(); }); in StopCacheAndDelete()
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A DtaskInner.cpp109 MEDIA_LOG_I_FALSE_D_T(isStateLogEnabled_.load(), PUBLIC_LOG_S " Start", name_.c_str()); in Start()
122 MEDIA_LOG_I_FALSE_D(isStateLogEnabled_.load(), "task " PUBLIC_LOG_S " Start done", name_.c_str()); in Start()
137 if (runningState_.load() == RunningState::STOPPED) { in Stop()
159 if (runningState_.load() != RunningState::STOPPED) { in StopAsync()
170 RunningState state = runningState_.load(); in Pause()
172 MEDIA_LOG_I_FALSE_D_T(isStateLogEnabled_.load(), in Pause()
178 MEDIA_LOG_I_FALSE_D_T(isStateLogEnabled_.load(), in Pause()
183 MEDIA_LOG_I_FALSE_D_T(isStateLogEnabled_.load(), PUBLIC_LOG_S " Pause", name_.c_str()); in Pause()
187 RunningState state = runningState_.load(); in Pause()
195 MEDIA_LOG_I_FALSE_D_T(isStateLogEnabled_.load(), PUBLIC_LOG_ in Pause()
[all...]
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/event_monitor/
H A Devents_monitor.cpp45 DP_CHECK_RETURN(initialized_.load()); in Initialize()
69 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyThermalLevel()
82 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyCameraSessionStatus()
86 DP_INFO_LOG("numActiveSessions_: %{public}d", static_cast<int>(numActiveSessions_.load())); in NotifyCameraSessionStatus()
106 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyMediaLibraryStatus()
117 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyImageEnhanceStatus()
128 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyScreenStatus()
139 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyChargingStatus()
150 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialized events monitor!"); in NotifyBatteryStatus()
161 DP_CHECK_ERROR_RETURN_LOG(!initialized_.load(), "uninitialize in NotifyBatteryLevel()
[all...]
/foundation/resourceschedule/device_standby/services/core/src/
H A Dstandby_service.cpp69 if (state_.load() == ServiceRunningState::STATE_RUNNING) { in OnStart()
187 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in SubscribeStandbyCallback()
196 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in UnsubscribeStandbyCallback()
205 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in ApplyAllowResource()
214 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in UnapplyAllowResource()
224 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in GetAllowList()
233 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in IsDeviceInStandby()
281 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in ReportWorkSchedulerStatus()
291 if (state_.load() != ServiceRunningState::STATE_RUNNING) { in GetRestrictList()
300 if (state_.load() ! in IsStrategyEnabled()
[all...]
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_toolkit/config/
H A Dwifi_config_center.cpp92 return mWifiSelfcureReset.load(); in GetWifiSelfcureReset()
102 return mWifiSelfcureResetEntered.load(); in GetWifiSelfcureResetEntered()
112 return mLastNetworkId.load(); in GetLastNetworkId()
122 return mSelectedCandidateNetworkId.load(); in GetSelectedCandidateNetworkId()
136 return mWifiAllowSemiActive.load(); in GetWifiAllowSemiActive()
146 return mWifiStoping.load(); in GetWifiStopState()
168 return iter->second.load(); in GetWifiState()
171 return mWifiState[instId].load(); in GetWifiState()
204 return iter->second.load(); in GetWifiMidState()
207 return mStaMidState[instId].load(); in GetWifiMidState()
[all...]
/foundation/multimedia/camera_framework/services/camera_service/src/
H A Dcamera_timer.cpp45 MEDIA_INFO_LOG("entered, num of user: %d + 1", static_cast<int>(userCount_.load())); in IncreaseUserCount()
57 MEDIA_INFO_LOG("entered, num of user: %u - 1", userCount_.load()); in DecreaseUserCount()
59 if (userCount_.load() == 0 && timer_ != nullptr) { in DecreaseUserCount()

Completed in 10 milliseconds

12345678910>>...27