Home
last modified time | relevance | path

Searched refs:wait (Results 1 - 25 of 506) sorted by relevance

12345678910>>...21

/foundation/resourceschedule/ffrt/test/testfunc/
H A Dfunc_pool.cpp38 ffrt::wait({ &val1, &val2 }); in NestedFib()
50 ffrt::wait({ &val }); in NestedAddOne()
99 ffrt::wait(); in NestedWhile()
114 ffrt::wait(); in NestedWhile()
129 ffrt::wait(); in NestedWhile()
144 ffrt::wait(); in NestedWhile()
157 ffrt::wait(); in NestedWhile()
168 ffrt::wait(); in NestedWhile()
178 ffrt::wait(); in NestedWhile()
187 ffrt::wait(); in NestedWhile()
[all...]
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_condition.cpp57 cond.wait(lck, [&] { return a == 1; }); in HWTEST_F()
68 ffrt::wait(); in HWTEST_F()
80 cond.wait(lck, [&] { return a == 1; }); in HWTEST_F()
86 cond.wait(lck, [&] { return a == 1; }); in HWTEST_F()
98 ffrt::wait(); in HWTEST_F()
123 ffrt::wait(); in HWTEST_F()
140 ffrt::wait(); in HWTEST_F()
208 ffrt::wait(); in HWTEST_F()
234 ffrt::wait(); in HWTEST_F()
284 wait(); in HWTEST_F()
[all...]
H A Dut_csync.cpp160 ffrt::wait(); in HWTEST_F()
178 ffrt::wait(); in HWTEST_F()
182 ffrt::wait(); in HWTEST_F()
213 ffrt::wait(); in HWTEST_F()
243 ffrt::wait(); in HWTEST_F()
250 ffrt::wait(); in HWTEST_F()
292 ffrt::wait(); in HWTEST_F()
318 ffrt::wait(); in HWTEST_F()
326 ffrt::wait(); in HWTEST_F()
351 ffrt::wait(); in HWTEST_F()
[all...]
H A Dut_core.cpp92 ffrt_deps_t wait{static_cast<uint32_t>(wait_deps.size()), wait_deps.data()}; in HWTEST_F()
98 ffrt_wait_deps(&wait); in HWTEST_F()
162 ffrt::wait(); in HWTEST_F()
231 ffrt::wait({handle}); in HWTEST_F()
238 * 测试用例描述：构造2个submit_h的任务，验证task_handle转成dependence后，调用ffrt::wait的场景
240 * 操作步骤：创建另外一个task_handle任务，并且先执行ffrt::wait保存的dependence的数组
258 ffrt::wait(deps); in HWTEST_F()
260 ffrt::wait(); in HWTEST_F()
301 ffrt::wait(); in HWTEST_F()
/foundation/multimedia/media_foundation/src/osal/task/
H A Dtask.cpp75 void Task::SubmitJobOnce(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJobOnce() argument
77 taskInner_->SubmitJobOnce(job, delayUs, wait); in SubmitJobOnce()
80 void Task::SubmitJob(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJob() argument
82 taskInner_->SubmitJob(job, delayUs, wait); in SubmitJob()
/foundation/resourceschedule/ffrt/benchmarks/fork_join/
H A Dfork_join.cpp30 ffrt::wait(); in ForkJoin()
46 ffrt::wait(); in ForkJoinWorker()
49 ffrt::wait({&r}); in ForkJoinWorker()
/foundation/resourceschedule/ffrt/examples/
H A Dsubmit.cpp23 ffrt::wait(); in ffrt_submit_example1()
33 ffrt::wait(); in ffrt_submit_example2()
42 ffrt::wait({h}); in ffrt_submit_example3()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dkv_virtual_device.cpp98 int KvVirtualDevice::Subscribe(QuerySyncObject query, bool wait, int id) in Subscribe() argument
100 auto operation = new (std::nothrow) SyncOperation(id, {remoteDeviceId_}, SUBSCRIBE_QUERY, nullptr, wait); in Subscribe()
115 int KvVirtualDevice::UnSubscribe(QuerySyncObject query, bool wait, int id) in UnSubscribe() argument
117 return UnSubscribe(query, wait, id, nullptr); in UnSubscribe()
120 int KvVirtualDevice::UnSubscribe(const QuerySyncObject &query, bool wait, int id, in UnSubscribe() argument
123 auto operation = new (std::nothrow) SyncOperation(id, {remoteDeviceId_}, UNSUBSCRIBE_QUERY, callback, wait); in UnSubscribe()
H A Dkv_virtual_device.h40 int Subscribe(QuerySyncObject query, bool wait, int id);
41 int UnSubscribe(QuerySyncObject query, bool wait, int id);
42 int UnSubscribe(const QuerySyncObject &query, bool wait, int id, const SyncOperation::UserCallback &callback);
H A Dgeneric_virtual_device.h46 virtual int Sync(SyncMode mode, bool wait);
47 virtual int Sync(SyncMode mode, const Query &query, bool wait);
48 virtual int Sync(SyncMode mode, const Query &query, const SyncOperation::UserCallback &callBack, bool wait);
/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_thread_task.cpp44 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Start()
70 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Stop()
100 cond_.wait(lock, [this] { in Pause()
106 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Pause()
110 cond_.wait(lock, [this] { return state_.load() == RunningState::PAUSED; }); in Pause()
/foundation/resourceschedule/ffrt/benchmarks/fib/
H A Dfib.cpp43 ffrt::wait(); in FibFFRTChildWait()
58 ffrt::wait({&y1, &y2}); in FibFFRTDataWait()
78 ffrt::wait({&output}); in FibDataWait()
118 ffrt::wait({&output}); in FibNoWait()
136 ffrt::wait({&output}); in FibChildWait()
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_render_service.cpp140 RS_LOGE("RSRenderService wait SAMGR error, return value [%d].", status); in Init()
360 [this, &dumpString, &layerArg]() { return screenManager_->FpsDump(dumpString, layerArg); }).wait(); in FPSDUMPProcess()
363 [this, &dumpString, &layerArg]() { return screenManager_->FpsDump(dumpString, layerArg); }).wait(); in FPSDUMPProcess()
384 }).wait(); in FPSDUMPClearProcess()
389 }).wait(); in FPSDUMPClearProcess()
435 [this, &dumpString, &layerArg]() { return screenManager_->HitchsDump(dumpString, layerArg); }).wait(); in WindowHitchsDump()
438 [this, &dumpString, &layerArg]() { return screenManager_->HitchsDump(dumpString, layerArg); }).wait(); in WindowHitchsDump()
531 }).wait(); in DumpMem()
548 }).wait(); in DumpNode()
595 [this, &dumpString]() { screenManager_->DisplayDump(dumpString); }).wait(); in DoDump()
[all...]
/foundation/multimedia/av_codec/services/utils/
H A Dtask_thread.cpp54 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Start()
81 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
109 syncCond_.wait(lock, [this] { in Pause()
115 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Pause()
119 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor.h76 void Stop(bool wait = false) noexcept
81 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
91 condition_.wait(lock, [this] { in Run()
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor.h90 void Stop(bool wait = false) noexcept
95 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
105 condition_.wait(lock, [this] { in Run()
/foundation/barrierfree/accessibility/frameworks/aafwk/src/
H A Daccessible_ability_channel_client.cpp93 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo() local
94 if (wait != ffrt::future_status::ready) { in FindFocusedElementInfo()
95 HILOG_ERROR("FindFocusedElementInfo Failed to wait result"); in FindFocusedElementInfo()
149 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition() local
150 if (wait != ffrt::future_status::ready) { in GetCursorPosition()
151 HILOG_ERROR("GetCursorPosition Failed to wait result"); in GetCursorPosition()
193 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction() local
194 if (wait != ffrt::future_status::ready) { in ExecuteAction()
195 HILOG_ERROR("execute action: %{public}d failed to wait result", action); in ExecuteAction()
258 HILOG_ERROR("SearchElementInfosByAccessibilityId windowId :[%{pubic}d] Failed to wait resul in SearchElementInfosByAccessibilityId()
263 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); SearchElementInfosByAccessibilityId() local
351 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); SearchElementInfosByText() local
392 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); FocusMoveSearch() local
[all...]
/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessible_ability_channel.cpp100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByAccessibilityId() local
101 if (wait != ffrt::future_status::ready) { in SearchElementInfoByAccessibilityId()
102 HILOG_ERROR("Failed to wait SearchElementInfoByAccessibilityId result"); in SearchElementInfoByAccessibilityId()
153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText() local
154 if (wait != ffrt::future_status::ready) { in SearchElementInfosByText()
155 HILOG_ERROR("Failed to wait SearchElementInfosByText result"); in SearchElementInfosByText()
206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo() local
207 if (wait != ffrt::future_status::ready) { in FindFocusedElementInfo()
208 HILOG_ERROR("Failed to wait FindFocusedElementInfo result"); in FindFocusedElementInfo()
258 ffrt::future_status wait in FocusMoveSearch() local
372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); ExecuteAction() local
428 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); GetWindow() local
502 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); GetWindows() local
575 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); GetCursorPosition() local
623 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); SendSimulateGesture() local
657 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); SetTargetBundleName() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dkvdb_pragma.h60 bool wait = false) in PragmaSync()
64 wait_(wait), in PragmaSync()
72 bool wait = false) in PragmaSync()
76 wait_(wait), in PragmaSync()
/foundation/arkui/ui_lite/tools/qt/simulator/uitest/
H A Dmain_widget.cpp37 guiThread_->wait(); in ~MainWidget()
42 taskThread_->wait(); in ~MainWidget()
47 socketThread_->wait(); in ~MainWidget()
/foundation/ai/intelligent_voice_framework/tests/unittest/intell_voice_test/include/
H A Dengine_event_callback.h27 EngineEventCallback(sptr<OHOS::IntellVoiceEngine::IIntellVoiceEngine> &engine, WaitForResult *wait) in EngineEventCallback() argument
30 waitForResult_ = wait; in EngineEventCallback()
/foundation/ai/ai_engine/services/common/platform/lock/source/
H A Drw_lock.cpp30 condRead_.wait(guard, [=]()->bool { return writeCnt_ == 0; }); in LockRead()
38 condWrite_.wait(guard, [=]()->bool { return (readCnt_ == 0) && (!writeFlag_); }); in LockWrite()
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/bundlemgr/
H A Dinstaller_callback.cpp38 future.wait(); in GetResultCode()
45 future.wait(); in GetResultMsg()
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Djobutils.cpp32 ffrt::wait({handle}); in WaitForFinish()
40 ffrt::wait({handle}); in SubmitJobOnce()
/foundation/barrierfree/accessibility/services/test/xts/src/asac_register_elemnt_operator_test/
H A Dasac_ability_channel_benchmark.cpp100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByA11yBenchmarkId() local
101 if (wait != ffrt::future_status::ready) { in SearchElementInfoByA11yBenchmarkId()
102 HILOG_ERROR("Failed to wait SearchElementInfoByA11yBenchmarkId result"); in SearchElementInfoByA11yBenchmarkId()
153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText() local
154 if (wait != ffrt::future_status::ready) { in SearchElementInfosByText()
155 HILOG_ERROR("Failed to wait SearchElementInfosByText result"); in SearchElementInfosByText()
206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo() local
207 if (wait != ffrt::future_status::ready) { in FindFocusedElementInfo()
208 HILOG_ERROR("Failed to wait FindFocusedElementInfo result"); in FindFocusedElementInfo()
258 ffrt::future_status wait in FocusMoveSearch() local
372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); ExecuteAction() local
428 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); GetWindow() local
502 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); GetWindows() local
575 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); GetCursorPosition() local
623 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); SendSimulateGesture() local
[all...]

Completed in 11 milliseconds

12345678910>>...21