Home
last modified time | relevance | path

Searched refs:loop_ (Results 1 - 25 of 99) sorted by relevance

1234

/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_thread_task.cpp24 AudioThreadTask::AudioThreadTask(const std::string &name) : name_(name), state_(RunningState::STOPPED), loop_(nullptr) in AudioThreadTask()
32 if (loop_) { in ~AudioThreadTask()
33 if (loop_->joinable()) { in ~AudioThreadTask()
34 loop_->join(); in ~AudioThreadTask()
36 loop_ = nullptr; in ~AudioThreadTask()
47 if (loop_) { in Start()
48 if (loop_->joinable()) { in Start()
49 loop_->join(); in Start()
51 loop_ = nullptr; in Start()
57 if (!loop_) { in Start()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Devent_impl.cpp27 loop_(nullptr), in EventImpl()
53 loop_(nullptr), in EventImpl()
78 if (loop_ != nullptr) { in ~EventImpl()
79 loop_->DecObjRef(loop_); in ~EventImpl()
80 loop_ = nullptr; in ~EventImpl()
116 if (loop_ == nullptr) { in AddEvents()
120 loop = loop_; in AddEvents()
147 if (loop_ == nullptr) { in RemoveEvents()
151 loop = loop_; in RemoveEvents()
[all...]
/foundation/multimedia/av_codec/services/utils/
H A Dtask_thread.cpp25 TaskThread::TaskThread(std::string_view name) : name_(name), runningState_(RunningState::STOPPED), loop_(nullptr) in TaskThread()
33 loop_ = std::make_unique<std::thread>(&TaskThread::Run, this); in TaskThread()
42 if (loop_ != nullptr) { in ~TaskThread()
43 if (loop_->joinable()) { in ~TaskThread()
44 loop_->join(); in ~TaskThread()
46 loop_ = nullptr; in ~TaskThread()
57 if (loop_ != nullptr) { in Start()
58 if (loop_->joinable()) { in Start()
59 loop_->join(); in Start()
61 loop_ in Start()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/
H A Depoll_io_waiter_mingw.cpp43 uv_stop(&loop_); in ~EpollIoWaiter()
44 uv_loop_close(&loop_); in ~EpollIoWaiter()
49 UVCALL(uv_loop_init, &loop_); in Init()
50 UVCALL(uv_signal_init, &loop_, &signal_); in Init()
52 UVCALL(uv_timer_init, &loop_, &timer_); in Init()
60 uv_run(&loop_, UV_RUN_DEFAULT); in WaitFor()
88 UVCALL(uv_poll_init, &loop_, &pollMap_[fd], fd); in AddFileDescriptor()
114 uv_stop(&that.loop_); in OnPoll()
133 uv_stop(&that.loop_); in OnTimer()
/foundation/arkui/napi/native_engine/
H A Dnative_engine.cpp169 loop_ = new (std::nothrow)uv_loop_t; in Init()
170 if (loop_ == nullptr) { in Init()
174 if (uv_loop_init(loop_) != EOK) { in Init()
176 delete loop_; in Init()
177 loop_ = nullptr; in Init()
180 uv_async_init(loop_, &uvAsync_, nullptr); in Init()
188 if (loop_ != nullptr) { in Deinit()
202 if (loop_ == nullptr) { in Deinit()
205 if (uv_loop_close(loop_) != EOK) { in Deinit()
208 uv_run(loop_, UV_RUN_DEFAUL in Deinit()
[all...]
/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dtask.cpp28 loop_ = CppExt::make_unique<OSAL::Thread>(priority); in Task()
29 loop_->SetName(name_); in Task()
52 if (!loop_) { // thread not exist in Start()
53 loop_ = CppExt::make_unique<OSAL::Thread>(priority_); in Start()
55 if (!loop_->HasThread() && !loop_->CreateThread([this] { Run(); })) { in Start()
72 if (loop_ && loop_->HasThread()) { in Stop()
73 loop_ = nullptr; in Stop()
/foundation/resourceschedule/ffrt/src/queue/
H A Dconcurrent_queue.cpp41 if (loop_ != nullptr) { in Push()
44 loop_->WakeUp(); in Push()
75 if (loop_ != nullptr) { in Pull()
114 if (loop_ == nullptr) { in Stop()
123 if (loop == nullptr || loop_ != nullptr) { in SetLoop()
128 loop_ = loop; in SetLoop()
137 if (loop_->TimerStart(timeout, task, DelayTaskCb, false) < 0) { in PushDelayTaskToTimer()
H A Dconcurrent_queue.h47 if (loop_ == nullptr) { in ClearLoop()
51 loop_ = nullptr; in ClearLoop()
63 Loop* loop_ { nullptr };
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dtask.cpp70 if (!loop_) { in Start()
71 loop_ = std::make_unique<ffrt::thread>(name_.c_str(), ConvertPriorityType(priority_), [this] { Run(); }); in Start()
73 if (!loop_) { in Start()
89 if (loop_) { in Stop()
90 if (loop_->joinable()) { in Stop()
91 loop_->join(); in Stop()
93 loop_ = nullptr; in Stop()
/foundation/arkui/ace_engine/adapter/ohos/entrance/dynamic_component/
H A Duv_task_wrapper_impl.cpp31 loop_ = engine->GetUVLoop(); in UVTaskWrapperImpl()
42 if (loop_ == nullptr) { in Call()
48 loop_, workWrapper, [](uv_work_t* req) {}, in Call()
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dpipeline_threadpool.cpp119 loop_ = CppExt::make_unique<Thread>(ConvertPriorityType(priority)); in PipeLineThread()
121 loop_->SetName(name_); in PipeLineThread()
123 if (loop_->CreateThread([this] { Run(); })) { in PipeLineThread()
127 loop_ = nullptr; in PipeLineThread()
141 FALSE_RETURN_W(!threadExit_.load() && loop_); in Exit()
153 // loop_ destroy will wait thread join in Exit()
154 loop_ = nullptr; in Exit()
232 return loop_ ? loop_->IsRunningInSelf() : false; in IsRunningInSelf()
/foundation/multimedia/av_session/frameworks/js/napi/session/src/
H A Dnapi_async_callback.cpp26 napi_get_uv_event_loop(env, &loop_); in NapiAsyncCallback()
170 CHECK_RETURN_VOID(loop_ != nullptr, "loop_ is nullptr"); in Call()
177 int res = uv_queue_work_with_qos(loop_, work, [](uv_work_t* work) {}, AfterWorkCallback, uv_qos_user_initiated); in Call()
183 CHECK_RETURN_VOID(loop_ != nullptr, "loop_ is nullptr"); in CallWithFlag()
190 int res = uv_queue_work_with_qos(loop_, work, [](uv_work_t* work) {}, AfterWorkCallbackWithFlag, in CallWithFlag()
198 CHECK_RETURN_VOID(loop_ != nullptr, "loop_ is nullptr"); in CallWithFunc()
205 int res = uv_queue_work_with_qos(loop_, wor in CallWithFunc()
[all...]
/foundation/CastEngine/castengine_cast_framework/interfaces/kits/js/src/
H A Dnapi_callback.cpp31 NAPI_CALL_RETURN_VOID(env, napi_get_uv_event_loop(env, &loop_)); in NapiCallback()
84 if (loop_ == nullptr) { in Call()
85 CLOGE("loop_ is nullptr"); in Call()
101 loop_, work, [](uv_work_t *work) {}, AfterWorkCallback); in Call()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Duv_queue.cpp26 napi_get_uv_event_loop(env, &loop_); in UvQueue()
38 if (loop_ == nullptr || !getter) { in AsyncCall()
39 ZLOGE("loop_ or callback is nullptr"); in AsyncCall()
56 loop_, work, [](uv_work_t* work) { in AsyncCall()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/
H A Duv_queue.cpp26 napi_get_uv_event_loop(env, &loop_); in UvQueue()
38 if (loop_ == nullptr || !getter) { in AsyncCall()
39 ZLOGE("loop_ or callback is nullptr"); in AsyncCall()
56 loop_, work, [](uv_work_t* work) { in AsyncCall()
/foundation/distributeddatamgr/preferences/frameworks/js/napi/common/src/
H A Duv_queue.cpp27 napi_get_uv_event_loop(env, &loop_); in UvQueue()
39 if (loop_ == nullptr || !getter) { in AsyncCall()
40 LOG_ERROR("loop_ or callback is nullptr"); in AsyncCall()
53 int ret = uv_queue_work(loop_, work, [](uv_work_t* work) {}, UvQueue::Work); in AsyncCall()
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/common/src/
H A Djs_uv_queue.cpp27 napi_get_uv_event_loop(env, &loop_); in UvQueue()
41 if (loop_ == nullptr || callback.IsNull()) { in AsyncCall()
42 LOG_ERROR("loop_ or callback is nullptr."); in AsyncCall()
64 int ret = uv_queue_work(loop_, work, DoWork, DoUvCallback); in AsyncCall()
97 if (loop_ == nullptr || promise.IsNull()) { in AsyncPromise()
98 LOG_ERROR("loop_ or promise is nullptr."); in AsyncPromise()
116 int ret = uv_queue_work(loop_, work, DoWork, DoUvPromise); in AsyncPromise()
126 if (loop_ == nullptr || !task) { in Execute()
127 LOG_ERROR("loop_ or task is nullptr."); in Execute()
143 int ret = uv_queue_work(loop_, wor in Execute()
[all...]
/foundation/arkui/ui_lite/frameworks/components/
H A Dui_swipe_view.cpp23 : swipeListener_(nullptr), curIndex_(0), blankSize_(DEFAULT_BLANK_SIZE), curView_(nullptr), loop_(false) in UISwipeView()
72 if (loop_ && (childrenNum_ != 1)) { in MoveHeadOrTailChild()
105 if (!loop_) { in DragXInner()
132 if (!loop_) { in DragYInner()
339 bool tmpLoop = loop_; in SortChild()
340 loop_ = false; in SortChild()
342 loop_ = tmpLoop; in SortChild()
485 if (!loop_ || (childrenHead_ == nullptr) || (childrenTail_ == nullptr)) { in IsNeedLoop()
581 if (!loop_ && (curIndex_ == 0 || curIndex_ == childrenNum_ - 1)) { in Vibrator()
/foundation/ai/intelligent_voice_framework/frameworks/js/napi/
H A Dservice_change_callback_napi.cpp36 napi_get_uv_event_loop(env_, &loop_); in ServiceChangeCallbackNapi()
62 CHECK_CONDITION_RETURN_VOID((loop_ == nullptr), "loop is nullptr"); in OnJsCallbackServiceChange()
68 int32_t ret = uv_queue_work_with_qos(loop_, work, [](uv_work_t *work) {}, [](uv_work_t *work, int uvStatus) { in OnJsCallbackServiceChange()
H A Dintell_voice_update_callback_napi.cpp30 napi_get_uv_event_loop(env_, &loop_); in IntellVoiceUpdateCallbackNapi()
102 if (loop_ != nullptr) { in OnJsCallBack()
107 loop_, work, [](uv_work_t *work) {}, UvWorkCallBack); in OnJsCallBack()
/foundation/arkui/ace_engine/frameworks/core/components/marquee/
H A Dmarquee_component.h117 return loop_; in GetLoop()
122 loop_ = loop; in SetLoop()
187 int32_t loop_ = DEFAULT_MARQUEE_LOOP; member in OHOS::Ace::MarqueeComponent
/foundation/arkui/ui_lite/interfaces/kits/components/
H A Dui_image_animator.h433 ImageAnimatorCallback() : tickNum_(0), loop_(1), drawingImage_(0), repeat_(0), imageSrc_(nullptr), imageNum_(0) in ImageAnimatorCallback()
444 loop_ = 1; in Reset()
450 uint8_t loop_; member in OHOS::UIImageAnimatorView::ImageAnimatorCallback
/foundation/graphic/graphic_3d/3d_widget_adapter/src/
H A Dgraphics_task.cpp105 if (loop_.joinable()) { in ~GraphicsTask()
106 loop_.join(); in ~GraphicsTask()
118 loop_ = std::thread(std::bind(&GraphicsTask::EngineThread, this)); in Start()
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_observer.cpp26 napi_get_uv_event_loop(env, &loop_); in NapiObserver()
115 loop_, work, [](uv_work_t *work) {}, CallbackFunc); in OnChange()
148 loop_, work, [](uv_work_t *work) {}, CallbackFunc); in OnChange()
/foundation/arkui/napi/sample/native_module_netserver/
H A Dnet_server.cpp26 loop_ = nullptr; in NetServer()
27 napi_get_uv_event_loop(env, &loop_); in NetServer()
43 result = uv_tcp_init(loop_, &tcpServer_); in Start()
106 uv_tcp_init(that->loop_, (uv_tcp_t*)&that->clients_->tcp); in OnConnection()

Completed in 10 milliseconds

1234