Home
last modified time | relevance | path

Searched refs:loop (Results 1 - 25 of 131) sorted by relevance

123456

/base/startup/init/services/loopevent/loop/
H A Dle_loop.c53 static LE_STATUS CreateLoop_(EventLoop **loop, uint32_t maxevents, uint32_t timeout) in CreateLoop_() argument
56 LE_STATUS ret = CreateEpollLoop(loop, maxevents, timeout); in CreateLoop_()
57 LE_CHECK(ret == LE_SUCCESS, return ret, "Failed to create epoll loop"); in CreateLoop_()
59 (*loop)->maxevents = maxevents; in CreateLoop_()
60 (*loop)->timeout = timeout; in CreateLoop_()
61 (*loop)->stop = 0; in CreateLoop_()
62 LoopMutexInit(&(*loop)->mutex); in CreateLoop_()
64 OH_ListInit(&((*loop)->idleList)); in CreateLoop_()
74 ret = OH_HashMapCreate(&(*loop)->taskMap, &info); in CreateLoop_()
75 LE_CHECK(ret == LE_SUCCESS, return ret, "failed to create hash map loop"); in CreateLoop_()
80 CloseLoop(EventLoop *loop) CloseLoop() argument
92 ProcessEvent(const EventLoop *loop, int fd, uint32_t oper) ProcessEvent() argument
103 AddTask(EventLoop *loop, BaseTask *task) AddTask() argument
116 GetTaskByFd(EventLoop *loop, int fd) GetTaskByFd() argument
129 DelTask(EventLoop *loop, BaseTask *task) DelTask() argument
150 EventLoop *loop = NULL; LE_CreateLoop() local
159 EventLoop *loop = (EventLoop *)handle; LE_RunLoop() local
175 EventLoop *loop = (EventLoop *)handle; LE_StopLoop() local
[all...]
H A Dle_epoll.c22 static int IsValid_(const EventEpoll *loop) in IsValid_() argument
24 return loop->epollFd >= 0; in IsValid_()
38 static LE_STATUS Close_(const EventLoop *loop) in Close_() argument
40 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop"); in Close_()
41 EventEpoll *epoll = (EventEpoll *)loop; in Close_()
48 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op) in AddEvent_() argument
50 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop"); in AddEvent_()
51 EventEpoll *epoll = (EventEpoll *)loop; in AddEvent_()
64 ModEvent_(const EventLoop *loop, const BaseTask *task, int op) ModEvent_() argument
80 DelEvent_(const EventLoop *loop, int fd, int op) DelEvent_() argument
95 RunLoop_(const EventLoop *loop) RunLoop_() argument
145 CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout) CreateEpollLoop() argument
[all...]
H A Dle_loop.h32 LE_STATUS (*close)(const struct EventLoop_ *loop);
33 LE_STATUS (*runLoop)(const struct EventLoop_ *loop);
34 LE_STATUS (*addEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
35 LE_STATUS (*modEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
36 LE_STATUS (*delEvent)(const struct EventLoop_ *loop, int fd, int op);
52 LE_STATUS CloseLoop(EventLoop *loop);
53 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
54 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
55 void DelTask(EventLoop *loop, BaseTask *task);
56 LE_STATUS ProcessEvent(const EventLoop *loop, in
[all...]
H A Dle_epoll.h23 EventLoop loop; member
28 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout);
/base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/
H A Devent_logger_plugin_test.cpp67 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F() local
68 loop->StartLoop(); in HWTEST_F()
69 eventLogger.BindWorkLoop(loop); in HWTEST_F()
81 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F() local
82 loop->StartLoop(); in HWTEST_F()
83 eventLogger.BindWorkLoop(loop); in HWTEST_F()
97 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F() local
98 loop->StartLoop(); in HWTEST_F()
99 eventLogger.BindWorkLoop(loop); in HWTEST_F()
114 std::shared_ptr<EventLoop> loop in HWTEST_F() local
133 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); HWTEST_F() local
[all...]
/base/print/print_fwk/frameworks/kits/extension/src/
H A Djs_print_callback.cpp41 uv_loop_s* loop = nullptr; in GetJsLoop() local
42 napi_get_uv_event_loop(env, &loop); in GetJsLoop()
43 if (loop == nullptr) { in GetJsLoop()
46 return loop; in GetJsLoop()
51 uv_loop_s *loop = nullptr; in Call() local
52 napi_get_uv_event_loop(env, &loop); in Call()
53 if (loop == nullptr) { in Call()
62 loop, work, [](uv_work_t *work) {}, afterCallback, uv_qos_user_initiated); in Call()
107 uv_loop_s *loop = GetJsLoop(jsRuntime_); in Exec() local
108 if (loop in Exec()
[all...]
/base/startup/init/services/loopevent/timer/
H A Dle_timer.c52 static void InsertTimerNode(EventLoop *loop, TimerNode *timer) in InsertTimerNode() argument
58 OH_ListAddWithOrder(&loop->timerList, &timer->node, TimerNodeCompareProc); in InsertTimerNode()
63 void CheckTimeoutOfTimer(EventLoop *loop, uint64_t currTime) in CheckTimeoutOfTimer() argument
68 ListNode *node = loop->timerList.next; in CheckTimeoutOfTimer()
69 while (node != &loop->timerList) { in CheckTimeoutOfTimer()
83 node = loop->timerList.next; in CheckTimeoutOfTimer()
99 InsertTimerNode(loop, timer); in CheckTimeoutOfTimer()
137 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartTimer() local
143 InsertTimerNode(loop, timerNode); in LE_StartTimer()
147 uint64_t GetMinTimeoutPeriod(const EventLoop *loop) in GetMinTimeoutPeriod() argument
166 DestroyTimerList(EventLoop *loop) DestroyTimerList() argument
[all...]
H A Dle_timer.h47 void CheckTimeoutOfTimer(EventLoop *loop, uint64_t currTime);
48 void DestroyTimerList(EventLoop *loop);
49 uint64_t GetMinTimeoutPeriod(const EventLoop *loop);
/base/theme/screenlock_mgr/frameworks/js/napi/src/
H A Duv_queue.cpp22 uv_loop_s *loop = nullptr; in Call() local
23 napi_get_uv_event_loop(env, &loop); in Call()
24 if (loop == nullptr) { in Call()
25 SCLOCK_HILOGE("loop == nullptr."); in Call()
37 loop, work, [](uv_work_t *work) {}, afterCallback, uv_qos_user_initiated); in Call()
/base/theme/wallpaper_mgr/frameworks/native/src/
H A Duv_queue.cpp23 uv_loop_s *loop = nullptr; in Call() local
24 napi_get_uv_event_loop(env, &loop); in Call()
25 if (loop == nullptr) { in Call()
34 auto ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, afterCallback, uv_qos_user_initiated); in Call()
/base/startup/init/services/loopevent/task/
H A Dle_watchtask.c28 EventLoop *loop = (EventLoop *)loopHandle; in HandleWatcherEvent_() local
39 HandleWatcherTaskClose_((LoopHandle)loop, (TaskHandle)watcher); in HandleWatcherEvent_()
43 HandleWatcherTaskClose_((LoopHandle)loop, (TaskHandle)watcher); in HandleWatcherEvent_()
48 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events); in HandleWatcherEvent_()
79 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartWatcher() local
80 loop->addEvent(loop, (const BaseTask *)task, info->events); in LE_StartWatcher()
H A Dle_asynctask.c71 EventLoop *loop = (EventLoop *)loopHandle; in HandleAsyncEvent_() local
79 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_WRITE); in HandleAsyncEvent_()
85 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleAsyncEvent_()
126 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateAsyncTask() local
127 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_CreateAsyncTask()
H A Dle_streamtask.c28 EventLoop *loop = (EventLoop *)loopHandle; in HandleSendMsg_() local
47 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleSendMsg_()
196 EventLoop *loop = (EventLoop *)loopHandle; in HandleServerEvent_() local
197 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_READ); in HandleServerEvent_()
219 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamServer() local
228 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_CreateStreamServer()
257 EventLoop *loop in LE_CreateStreamClient() local
289 EventLoop *loop = (EventLoop *)loopHandle; LE_AcceptStreamClient() local
[all...]
/base/request/request/frameworks/js/napi/src/
H A Duv_queue.cpp20 uv_loop_s *loop = nullptr; in Call() local
21 napi_get_uv_event_loop(env, &loop); in Call()
22 if (loop == nullptr) { in Call()
31 loop, work, [](uv_work_t *work) {}, afterCallback); in Call()
H A Djs_response_listener.cpp51 uv_loop_s *loop = nullptr; in OnResponseReceive() local
52 napi_get_uv_event_loop(this->env_, &loop); in OnResponseReceive()
53 if (loop == nullptr) { in OnResponseReceive()
68 loop, work, [](uv_work_t *work) {}, in OnResponseReceive()
/base/startup/init/services/loopevent/signal/
H A Dle_signal.c28 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_() argument
101 EventLoop *loop = (EventLoop *)loopHandle; in LE_AddSignal() local
112 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_AddSignal()
114 loop->modEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_AddSignal()
123 EventLoop *loop = (EventLoop *)loopHandle; in LE_RemoveSignal() local
134 loop->delEvent(loop, GetSocketFd(signalHandle), EVENT_READ); in LE_RemoveSignal()
/base/web/webview/interfaces/kits/napi/webfunction/
H A Dwebview_web_inited_callback.cpp59 uv_loop_s *loop = nullptr; in RunInitedCallback() local
61 napi_get_uv_event_loop(param_->env_, &loop); in RunInitedCallback()
63 if (loop == nullptr) { in RunInitedCallback()
64 WVLOG_E("get uv event loop failed"); in RunInitedCallback()
74 loop, work, [](uv_work_t* work) {}, UvWebInitedCallbackThreadWoker, uv_qos_user_initiated); in RunInitedCallback()
/base/telephony/call_manager/frameworks/js/napi/src/
H A Dnapi_call_ability_callback.cpp392 uv_loop_s *loop = nullptr; in ReportStartRttInfo() local
394 napi_get_uv_event_loop(startRttCallback_.env, &loop); in ReportStartRttInfo()
396 if (loop == nullptr) { in ReportStartRttInfo()
415 loop, work, [](uv_work_t *work) { in ReportStartRttInfo()
438 uv_loop_s *loop = nullptr; in ReportStopRttInfo() local
440 napi_get_uv_event_loop(stopRttCallback_.env, &loop); in ReportStopRttInfo()
442 if (loop == nullptr) { in ReportStopRttInfo()
461 loop, work, [](uv_work_t *work) { in ReportStopRttInfo()
483 uv_loop_s *loop = nullptr; in UpdateCallStateInfo() local
485 napi_get_uv_event_loop(stateCallback_.env, &loop); in UpdateCallStateInfo()
649 uv_loop_s *loop = nullptr; UpdateCallEvent() local
739 uv_loop_s *loop = nullptr; UpdateCallDisconnectedCause() local
845 uv_loop_s *loop = nullptr; UpdateMmiCodeResultsInfo() local
935 uv_loop_s *loop = nullptr; UpdateAudioDeviceInfo() local
1048 uv_loop_s *loop = nullptr; OttCallRequest() local
1092 uv_loop_s *loop = nullptr; ReportGetWaitingInfo() local
1139 uv_loop_s *loop = nullptr; ReportCloseUnFinishedUssdInfo() local
1186 uv_loop_s *loop = nullptr; ReportSetWaitingInfo() local
1233 uv_loop_s *loop = nullptr; ReportGetRestrictionInfo() local
1279 uv_loop_s *loop = nullptr; ReportSetRestrictionInfo() local
1326 uv_loop_s *loop = nullptr; ReportSetRestrictionPassword() local
1378 uv_loop_s *loop = nullptr; ReportGetTransferInfo() local
1425 uv_loop_s *loop = nullptr; ReportSetTransferInfo() local
1821 uv_loop_s *loop = nullptr; UpdatePostDialDelay() local
1906 uv_loop_s *loop = nullptr; UpdateImsCallModeChange() local
2000 uv_loop_s *loop = nullptr; CallSessionEventChange() local
2091 uv_loop_s *loop = nullptr; PeerDimensionsChange() local
2185 uv_loop_s *loop = nullptr; CallDataUsageChange() local
2271 uv_loop_s *loop = nullptr; UpdateCameraCapabilities() local
[all...]
/base/security/access_token/frameworks/js/napi/accesstoken/src/
H A Dnapi_context_common.cpp88 uv_loop_s *loop = nullptr; in ~AtManagerAsyncWorkData() local
89 napi_get_uv_event_loop(env, &loop); in ~AtManagerAsyncWorkData()
90 if ((loop == nullptr) || (workPtr == nullptr) || (workDataRel == nullptr)) { in ~AtManagerAsyncWorkData()
98 NAPI_CALL_RETURN_VOID(env, uv_queue_work_with_qos(loop, workPtr.get(), [] (uv_work_t *work) {}, in ~AtManagerAsyncWorkData()
/base/startup/init/services/loopevent/idle/
H A Dle_idle.c29 * @param loopHandle the running loop this idle will be attached
44 task->loop = (EventLoop *)loopHandle; in LE_AddIdle()
53 OH_ListAddTail(&(task->loop->idleList), &(task->node)); in LE_AddIdle()
72 * @brief Execute an function once in the next loop
74 * @param loopHandle the running loop this idle will be attached
103 * @param loopHandle the running loop
111 EventLoop *loop = (EventLoop *)loopHandle; in LE_RunIdle() local
113 OH_ListTraversal(&(loop->idleList), NULL, IdleListTraversalProc, 0); in LE_RunIdle()
/base/security/access_token/frameworks/js/napi/privacy/src/
H A Dnapi_context_common.cpp80 uv_loop_s* loop = nullptr; in DeleteNapiRef() local
81 NAPI_CALL_RETURN_VOID(env_, napi_get_uv_event_loop(env_, &loop)); in DeleteNapiRef()
82 if (loop == nullptr) { in DeleteNapiRef()
105 uv_queue_work_with_qos(loop, work, [](uv_work_t* work) {}, UvQueueWorkDeleteRef, uv_qos_default)); in DeleteNapiRef()
123 uv_loop_s* loop = nullptr; in ActiveStatusChangeCallback() local
124 NAPI_CALL_RETURN_VOID(env_, napi_get_uv_event_loop(env_, &loop)); in ActiveStatusChangeCallback()
125 if (loop == nullptr) { in ActiveStatusChangeCallback()
150 uv_queue_work_with_qos(loop, work, [](uv_work_t* work) {}, UvQueueWorkActiveStatusChange, uv_qos_default)); in ActiveStatusChangeCallback()
/base/time/time_service/services/time/src/
H A Dsntp_client.cpp137 for (int loop = offset; loop < offset + _len; loop++) { in GetNtpTimestamp64()
138 valueRx[numOfBit] = buffer[loop]; in GetNtpTimestamp64()
215 for (int loop = ORIGINATE_TIMESTAMP_OFFSET; loop < offsetEnd; loop++) { in CreateMessage()
216 buffer[loop] = value[numOfBit]; in CreateMessage()
285 for (int loop = offset; loop < offse in GetNtpField32()
[all...]
/base/inputmethod/imf/frameworks/js/napi/common/
H A Djs_callback_object.cpp40 uv_loop_s *loop = nullptr; in ~JSCallbackObject() local
41 napi_get_uv_event_loop(env_, &loop); in ~JSCallbackObject()
43 loop, work.get(), [](uv_work_t *work) {}, in ~JSCallbackObject()
/base/account/os_account/interfaces/kits/napi/appaccount/src/
H A Dnapi_app_account_authenticator.cpp89 ErrCode NapiAppAccountAuthenticator::InitWorkEnv(uv_loop_s **loop, uv_work_t **work, JsAuthenticatorParam **param) in InitWorkEnv() argument
91 napi_get_uv_event_loop(env_, loop); in InitWorkEnv()
92 if (*loop == nullptr) { in InitWorkEnv()
93 ACCOUNT_LOGE("failed to get uv event loop"); in InitWorkEnv()
119 uv_loop_s *loop = nullptr; in AddAccountImplicitly() local
122 ErrCode result = InitWorkEnv(&loop, &work, &param); in AddAccountImplicitly()
132 int32_t ret = uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, AddAccountImplicitlyWork, uv_qos_default); in AddAccountImplicitly()
147 uv_loop_s *loop = nullptr; in Authenticate() local
150 ErrCode result = InitWorkEnv(&loop, &work, &param); in Authenticate()
160 int32_t ret = uv_queue_work_with_qos(loop, wor in Authenticate()
175 uv_loop_s *loop = nullptr; CreateAccountImplicitly() local
202 uv_loop_s *loop = nullptr; Auth() local
229 uv_loop_s *loop = nullptr; VerifyCredential() local
255 uv_loop_s *loop = nullptr; SetProperties() local
280 uv_loop_s *loop = nullptr; CheckAccountLabels() local
305 uv_loop_s *loop = nullptr; IsAccountRemovable() local
[all...]
/base/print/print_fwk/frameworks/innerkitsimpl/scan_impl/src/
H A Dscan_callback.cpp39 uv_loop_s *loop = nullptr; in ~ScanCallback() local
40 napi_get_uv_event_loop(env_, &loop); in ~ScanCallback()
41 if (loop == nullptr) { in ~ScanCallback()
56 int retVal = UvQueueWork(loop, work); in ~ScanCallback()
136 bool ScanCallback::ExecuteUvQueueWork(CallbackContext* &context, uv_work_t* &work, uv_loop_s *&loop) in ExecuteUvQueueWork() argument
140 loop, work, [](uv_work_t *work) {}, in ExecuteUvQueueWork()
190 return ExecuteUvQueueWork(context, work, loop); in OnCallback()
214 return ExecuteUvQueueWork(context, work, loop); in OnCallback()
238 return ExecuteUvQueueWork(context, work, loop); in OnCallbackSync()
263 return ExecuteUvQueueWork(context, work, loop); in OnGetFrameResCallback()
325 UvQueueWork(uv_loop_s *loop, uv_work_t *work) UvQueueWork() argument
[all...]

Completed in 11 milliseconds

123456