Home
last modified time | relevance | path

Searched refs:loop_ (Results 1 – 25 of 117) sorted by relevance

12345

/ohos5.0/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()
79 loop_->DecObjRef(loop_); in ~EventImpl()
80 loop_ = nullptr; in ~EventImpl()
120 loop = loop_; in AddEvents()
151 loop = loop_; in RemoveEvents()
176 loop = loop_; in SetTimeout()
196 loop = loop_; in Detach()
260 loop_->DecObjRef(loop_); in SetLoop()
268 loop_ = loop; in SetLoop()
[all …]
/ohos5.0/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_thread_task.cpp32 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()
49 loop_->join(); in Start()
51 loop_ = nullptr; in Start()
57 if (!loop_) { in Start()
71 if (loop_) { in Stop()
73 loop_->join(); in Stop()
[all …]
/ohos5.0/foundation/multimedia/av_codec/services/utils/
H A Dtask_thread.cpp42 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_ = nullptr; in Start()
82 if (loop_ != nullptr) { in Stop()
84 loop_->join(); in Stop()
[all …]
/ohos5.0/foundation/arkui/napi/native_engine/
H A Dnative_engine.cpp162 if (loop_ == nullptr) { in Init()
168 delete loop_; in Init()
169 loop_ = nullptr; in Init()
180 if (loop_ != nullptr) { in Deinit()
206 delete loop_; in Deinit()
207 loop_ = nullptr; in Deinit()
227 return loop_; in GetUVLoop()
249 loop_ = nullptr; in ReinitUVLoop()
262 delete loop_; in ReinitUVLoop()
263 loop_ = nullptr; in ReinitUVLoop()
[all …]
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/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()
115 if (loop_ == nullptr) { in Stop()
124 if (loop == nullptr || loop_ != nullptr) { in SetLoop()
129 loop_ = loop; in SetLoop()
138 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 };
/ohos5.0/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dpipeline_threadpool.cpp120 loop_ = CppExt::make_unique<Thread>(ConvertPriorityType(priority)); in PipeLineThread()
122 loop_->SetName(name_); in PipeLineThread()
124 if (loop_->CreateThread([this] { Run(); })) { in PipeLineThread()
128 loop_ = nullptr; in PipeLineThread()
142 FALSE_RETURN_W(!threadExit_.load() && loop_); in Exit()
155 loop_ = nullptr; in Exit()
233 return loop_ ? loop_->IsRunningInSelf() : false; in IsRunningInSelf()
/ohos5.0/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()
/ohos5.0/foundation/multimedia/av_session/frameworks/js/napi/session/src/
H A Dnapi_async_callback.cpp26 napi_get_uv_event_loop(env, &loop_); in NapiAsyncCallback()
164 CHECK_RETURN_VOID(loop_ != nullptr, "loop_ is nullptr"); in Call()
171 …int res = uv_queue_work_with_qos(loop_, work, [](uv_work_t* work) {}, AfterWorkCallback, uv_qos_us… in Call()
177 CHECK_RETURN_VOID(loop_ != nullptr, "loop_ is nullptr"); in CallWithFlag()
184 int res = uv_queue_work_with_qos(loop_, work, [](uv_work_t* work) {}, AfterWorkCallbackWithFlag, in CallWithFlag()
192 CHECK_RETURN_VOID(loop_ != nullptr, "loop_ is nullptr"); in CallWithFunc()
199 int res = uv_queue_work_with_qos(loop_, work, [](uv_work_t* work) {}, AfterWorkCallbackWithFunc, in CallWithFunc()
/ohos5.0/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()
/ohos5.0/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()
64 int ret = uv_queue_work(loop_, work, DoWork, DoUvCallback); in AsyncCall()
97 if (loop_ == nullptr || promise.IsNull()) { in AsyncPromise()
116 int ret = uv_queue_work(loop_, work, DoWork, DoUvPromise); in AsyncPromise()
126 if (loop_ == nullptr || !task) { in Execute()
143 … int ret = uv_queue_work(loop_, work, DoExecute, [](uv_work_t *work, int status) { delete work; }); in Execute()
/ohos5.0/foundation/arkui/ui_lite/frameworks/components/
H A Dui_swipe_view.cpp23 …peListener_(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()
/ohos5.0/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()
53 int ret = uv_queue_work(loop_, work, [](uv_work_t* work) {}, UvQueue::Work); in AsyncCall()
/ohos5.0/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()
56 loop_, work, [](uv_work_t* work) { in AsyncCall()
/ohos5.0/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()
56 loop_, work, [](uv_work_t* work) { in AsyncCall()
/ohos5.0/foundation/arkui/ui_lite/interfaces/kits/components/
H A Dui_image_animator.h433 …ImageAnimatorCallback() : tickNum_(0), loop_(1), drawingImage_(0), repeat_(0), imageSrc_(nullptr),… in ImageAnimatorCallback()
444 loop_ = 1; in Reset()
450 uint8_t loop_; variable
/ohos5.0/foundation/ai/intelligent_voice_framework/frameworks/js/napi/
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()
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 … in OnJsCallbackServiceChange()
/ohos5.0/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; variable
H A Drender_marquee.cpp154 if (loop_ <= 0) { in OnAnimationStop()
158 if (currentLoop_ < loop_) { in OnAnimationStop()
210 loop_ = marquee->GetLoop(); in Update()
211 if (loop_ <= 0) { in Update()
212 loop_ = ANIMATION_REPEAT_INFINITE; in Update()
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/foundation/filemanagement/dfs_service/utils/system/include/
H A Ddfsu_actor.h46 loop_ = std::thread([this]() { this->Main(); }); in StartActor()
55 loop_.join(); in StopActor()
68 std::thread loop_; variable

12345