| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 53 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_()
59 (*loop)->maxevents = maxevents; in CreateLoop_()
60 (*loop)->timeout = timeout; in CreateLoop_()
61 (*loop)->stop = 0; in CreateLoop_()
62 LoopMutexInit(&(*loop)->mutex); in CreateLoop_()
72 return OH_HashMapCreate(&(*loop)->taskMap, &info); in CreateLoop_()
75 LE_STATUS CloseLoop(EventLoop *loop) in CloseLoop() argument
77 if (!loop->stop) { in CloseLoop()
80 OH_HashMapDestory(loop->taskMap, loop); in CloseLoop()
[all …]
|
| D | le_epoll.c | 20 static int IsValid_(const EventEpoll *loop) in IsValid_() argument
22 return loop->epollFd >= 0; in IsValid_()
36 static LE_STATUS Close_(const EventLoop *loop) in Close_() argument
38 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop"); in Close_()
39 EventEpoll *epoll = (EventEpoll *)loop; in Close_()
46 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op) in AddEvent_() argument
49 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop"); in AddEvent_()
50 EventEpoll *epoll = (EventEpoll *)loop; in AddEvent_()
62 static LE_STATUS ModEvent_(const EventLoop *loop, const BaseTask *task, int op) in ModEvent_() argument
65 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop"); in ModEvent_()
[all …]
|
| D | le_loop.h | 31 LE_STATUS (*close)(const struct EventLoop_ *loop);
32 LE_STATUS (*runLoop)(const struct EventLoop_ *loop);
33 LE_STATUS (*addEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
34 LE_STATUS (*modEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
35 LE_STATUS (*delEvent)(const struct EventLoop_ *loop, int fd, int op);
48 LE_STATUS CloseLoop(EventLoop *loop);
49 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
50 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
51 void DelTask(EventLoop *loop, BaseTask *task);
52 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper);
|
| D | le_epoll.h | 23 EventLoop loop; member
28 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout);
|
| /base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/ |
| D | event_logger_plugin_test.cpp | 68 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); variable
69 loop->StartLoop();
70 eventLogger.BindWorkLoop(loop);
82 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); variable
83 loop->StartLoop();
84 eventLogger.BindWorkLoop(loop);
98 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); variable
99 loop->StartLoop();
100 eventLogger.BindWorkLoop(loop);
115 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); variable
[all …]
|
| /base/startup/init/services/loopevent/task/ |
| D | le_watchtask.c | 21 EventLoop *loop = (EventLoop *)loopHandle; in HandleWatcherEvent_() local
32 loop->delEvent(loop, fd, watcher->events); in HandleWatcherEvent_()
36 loop->delEvent(loop, fd, watcher->events); in HandleWatcherEvent_()
41 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events); in HandleWatcherEvent_()
67 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartWatcher() local
68 loop->addEvent(loop, (const BaseTask *)task, info->events); in LE_StartWatcher()
|
| D | le_streamtask.c | 27 EventLoop *loop = (EventLoop *)loopHandle; in HandleSendMsg_() local
42 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleSendMsg_()
84 EventLoop *loop = (EventLoop *)loopHandle; in HandleStreamEvent_() local
96 loop->delEvent(loop, GetSocketFd(handle), Event_Read | Event_Write); in HandleStreamEvent_()
152 EventLoop *loop = (EventLoop *)loopHandle; in HandleServerEvent_() local
153 loop->modEvent(loop, (const BaseTask *)serverTask, Event_Read); in HandleServerEvent_()
171 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamServer() local
179 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateStreamServer()
207 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamClient() local
208 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateStreamClient()
[all …]
|
| D | le_asynctask.c | 69 EventLoop *loop = (EventLoop *)loopHandle; in HandleAsyncEvent_() local
77 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Write); in HandleAsyncEvent_()
83 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleAsyncEvent_()
115 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateAsyncTask() local
116 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateAsyncTask()
|
| /base/theme/wallpaper_mgr/frameworks/native/src/ |
| D | uv_queue.cpp | 20 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, uv_qos_user_initiated); in Call()
|
| /base/theme/screenlock_mgr/frameworks/js/napi/src/ |
| D | uv_queue.cpp | 22 uv_loop_s *loop = nullptr; in Call() local
23 napi_get_uv_event_loop(env, &loop); in Call()
24 if (loop == nullptr) { in Call()
37 loop, work, [](uv_work_t *work) {}, afterCallback, uv_qos_user_initiated); in Call()
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 27 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_() argument
73 EventLoop *loop = (EventLoop *)loopHandle; in LE_AddSignal() local
84 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_AddSignal()
86 loop->modEvent(loop, (const BaseTask *)task, Event_Read); in LE_AddSignal()
95 EventLoop *loop = (EventLoop *)loopHandle; in LE_RemoveSignal() local
106 loop->delEvent(loop, GetSocketFd(signalHandle), Event_Read); in LE_RemoveSignal()
|
| /base/time/time_service/services/time/src/ |
| D | sntp_client.cpp | 151 for (int loop = offset; loop < offset + _len; loop++) { in GetNtpTimestamp64() local
152 valueRx[numOfBit] = buffer[loop]; in GetNtpTimestamp64()
240 for (int loop = ORIGINATE_TIMESTAMP_OFFSET; loop < offsetEnd; loop++) { in CreateMessage() local
241 buffer[loop] = value[numOfBit]; in CreateMessage()
272 for (int loop = ORIGINATE_TIMESTAMP_OFFSET; loop < offsetEnd; loop++) { in WriteTimeStamp() local
273 buffer[loop] = value[numOfBit]; in WriteTimeStamp()
346 for (int loop = offset; loop < offset + _len; loop++) { in GetNtpField32() local
347 valueRx[numOfBit] = buffer[loop]; in GetNtpField32()
366 for (int loop = offset; loop < offset + _len; loop++) { in GetReferenceId() local
367 _outArray[num] = buffer[loop]; in GetReferenceId()
|
| /base/print/print_fwk/frameworks/kits/extension/src/ |
| D | js_print_callback.cpp | 41 uv_loop_s* loop = nullptr; in GetJsLoop() local
42 napi_get_uv_event_loop(reinterpret_cast<napi_env>(nativeEngine), &loop); in GetJsLoop()
43 if (loop == nullptr) { in GetJsLoop()
46 return loop; in GetJsLoop()
88 uv_loop_s *loop = GetJsLoop(jsRuntime_); in Exec() local
89 if (loop == nullptr) { in Exec()
98 loop, jsWorker_, [](uv_work_t *work) {}, in Exec()
|
| /base/request/request/frameworks/js/napi/src/ |
| D | uv_queue.cpp | 20 uv_loop_s *loop = nullptr; in Call() local
21 napi_get_uv_event_loop(env, &loop); in Call()
22 if (loop == nullptr) { in Call()
30 uv_queue_work(loop, work, [](uv_work_t *work) {}, afterCallback); in Call()
|
| /base/web/webview/interfaces/kits/napi/webfunction/ |
| D | webview_web_inited_callback.cpp | 24 uv_loop_s *loop = nullptr; in RunInitedCallback() local
26 napi_get_uv_event_loop(param_->env_, &loop); in RunInitedCallback()
28 if (loop == nullptr) { in RunInitedCallback()
38 int ret = uv_queue_work(loop, work, [](uv_work_t *work) {}, [](uv_work_t *work, int status) { in RunInitedCallback()
|
| /base/location/frameworks/native/source/ |
| D | locator_callback_host.cpp | 98 void LocatorCallbackHost::DoSendWork(uv_loop_s*& loop, uv_work_t*& work) in DoSendWork() argument
100 uv_queue_work(loop, work, [](uv_work_t* work) {}, [](uv_work_t* work, int status) { in DoSendWork()
147 void LocatorCallbackHost::DoSendErrorCode(uv_loop_s *&loop, uv_work_t *&work) in DoSendErrorCode() argument
149 uv_queue_work(loop, work, [](uv_work_t *work) {}, in DoSendErrorCode()
202 uv_loop_s *loop = nullptr; in SendErrorCode() local
203 NAPI_CALL_BASE(env_, napi_get_uv_event_loop(env_, &loop), false); in SendErrorCode()
204 if (loop == nullptr) { in SendErrorCode()
224 DoSendErrorCode(loop, work); in SendErrorCode()
231 uv_loop_s *loop = nullptr; in OnLocationReport() local
236 NAPI_CALL_RETURN_VOID(env_, napi_get_uv_event_loop(env_, &loop)); in OnLocationReport()
[all …]
|
| D | gnss_status_callback_host.cpp | 74 uv_loop_s *loop = nullptr; in Send() local
75 NAPI_CALL_BASE(env_, napi_get_uv_event_loop(env_, &loop), false); in Send()
76 if (loop == nullptr) { in Send()
94 UvQueueWork(loop, work); in Send()
98 void GnssStatusCallbackHost::UvQueueWork(uv_loop_s* loop, uv_work_t* work) in UvQueueWork() argument
101 loop, in UvQueueWork()
|
| D | location_switch_callback_host.cpp | 75 uv_loop_s *loop = nullptr; in Send() local
76 NAPI_CALL_BASE(env_, napi_get_uv_event_loop(env_, &loop), false); in Send()
77 if (loop == nullptr) { in Send()
95 UvQueueWork(loop, work); in Send()
99 void LocationSwitchCallbackHost::UvQueueWork(uv_loop_s* loop, uv_work_t* work) in UvQueueWork() argument
102 loop, in UvQueueWork()
|
| D | nmea_message_callback_host.cpp | 81 uv_loop_s *loop = nullptr; in Send() local
82 NAPI_CALL_BASE(env_, napi_get_uv_event_loop(env_, &loop), false); in Send()
83 if (loop == nullptr) { in Send()
101 UvQueueWork(loop, work); in Send()
106 void NmeaMessageCallbackHost::UvQueueWork(uv_loop_s* loop, uv_work_t* work) in UvQueueWork() argument
109 loop, in UvQueueWork()
|
| D | cached_locations_callback_host.cpp | 79 uv_loop_s *loop = nullptr; in Send() local
80 NAPI_CALL_BASE(env_, napi_get_uv_event_loop(env_, &loop), false); in Send()
81 if (loop == nullptr) { in Send()
99 UvQueueWork(loop, work); in Send()
103 void CachedLocationsCallbackHost::UvQueueWork(uv_loop_s* loop, uv_work_t* work) in UvQueueWork() argument
106 loop, in UvQueueWork()
|
| D | country_code_callback_host.cpp | 62 uv_loop_s *loop = nullptr; in Send() local
71 NAPI_CALL_BASE(env_, napi_get_uv_event_loop(env_, &loop), false); in Send()
72 if (loop == nullptr) { in Send()
90 UvQueueWork(loop, work); in Send()
94 void CountryCodeCallbackHost::UvQueueWork(uv_loop_s* loop, uv_work_t* work) in UvQueueWork() argument
97 loop, in UvQueueWork()
|
| /base/hiviewdfx/hiappevent/frameworks/js/napi/src/ |
| D | napi_app_event_watcher.cpp | 65 uv_loop_t* loop = nullptr; in ~NapiAppEventWatcher() local
66 napi_get_uv_event_loop(context_->env, &loop); in ~NapiAppEventWatcher()
70 loop, in ~NapiAppEventWatcher()
101 uv_loop_t* loop = nullptr; in OnTrigger() local
102 napi_get_uv_event_loop(context_->env, &loop); in OnTrigger()
106 loop, in OnTrigger()
|
| /base/inputmethod/imf/frameworks/js/napi/common/ |
| D | js_callback_object.cpp | 40 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/ |
| D | napi_app_account_authenticator.cpp | 89 ErrCode NapiAppAccountAuthenticator::InitWorkEnv(uv_loop_s **loop, uv_work_t **work, JsAuthenticato… in InitWorkEnv() argument
91 napi_get_uv_event_loop(env_, loop); in InitWorkEnv()
92 if (*loop == nullptr) { in InitWorkEnv()
119 uv_loop_s *loop = nullptr; in AddAccountImplicitly() local
122 ErrCode result = InitWorkEnv(&loop, &work, ¶m); in AddAccountImplicitly()
132 …uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, AddAccountImplicitlyWork, uv_qos_defaul… in AddAccountImplicitly()
142 uv_loop_s *loop = nullptr; in Authenticate() local
145 ErrCode result = InitWorkEnv(&loop, &work, ¶m); in Authenticate()
155 …uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, AuthenticateWork, uv_qos_user_initiated… in Authenticate()
165 uv_loop_s *loop = nullptr; in CreateAccountImplicitly() local
[all …]
|
| /base/telephony/call_manager/frameworks/js/napi/src/ |
| D | napi_call_ability_callback.cpp | 323 uv_loop_s *loop = nullptr; in ReportStartRttInfo() local
325 napi_get_uv_event_loop(startRttCallback_.env, &loop); in ReportStartRttInfo()
340 …uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, ReportStartRttInfoWork, uv_qos_default); in ReportStartRttInfo()
353 uv_loop_s *loop = nullptr; in ReportStopRttInfo() local
355 napi_get_uv_event_loop(stopRttCallback_.env, &loop); in ReportStopRttInfo()
370 … uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, ReportStopRttInfoWork, uv_qos_default); in ReportStopRttInfo()
383 uv_loop_s *loop = nullptr; in ReportCallMediaModeInfo() local
385 napi_get_uv_event_loop(updateCallMediaModeCallback_.env, &loop); in ReportCallMediaModeInfo()
400 …uv_queue_work_with_qos(loop, work, [](uv_work_t *work) {}, ReportCallMediaModeInfoWork, uv_qos_def… in ReportCallMediaModeInfo()
413 uv_loop_s *loop = nullptr; in UpdateCallStateInfo() local
[all …]
|