Home
last modified time | relevance | path

Searched refs:LE_GetDefaultLoop (Results 1 - 25 of 34) sorted by relevance

12

/base/startup/init/test/unittest/loopevent/
H A Dloopevent_unittest.cpp111 LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo);
115 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(),
117 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(),
123 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandlec, &streamInfo);
130 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandled, &streamInfo);
142 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask_, &info);
146 ((StreamServerTask *)serverTask_)->base.handleEvent(LE_GetDefaultLoop(), serverTask_, EVENT_READ);
159 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), 1 + sizeof(eventId));
162 ((StreamConnectTask *)client)->stream.base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)(client), EVENT_WRITE);
166 ((StreamConnectTask *)client)->recvMessage(LE_GetDefaultLoop(), reinterpret_cas
[all...]
/base/startup/init/services/param/linux/
H A Dparam_msgadp.c56 return LE_CreateStreamServer(LE_GetDefaultLoop(), stream, &info); in ParamServerCreate()
76 LE_STATUS status = LE_AcceptStreamClient(LE_GetDefaultLoop(), server, stream, &info); in ParamStreamCreate()
93 BufferHandle bufferHandle = LE_CreateBuffer(LE_GetDefaultLoop(), dataSize); in ParamTaskSendMsg()
98 PARAM_CHECK(ret == EOK, LE_FreeBuffer(LE_GetDefaultLoop(), NULL, bufferHandle); in ParamTaskSendMsg()
100 return LE_Send(LE_GetDefaultLoop(), stream, bufferHandle, dataSize); in ParamTaskSendMsg()
106 return LE_CreateAsyncTask(LE_GetDefaultLoop(), stream, eventProcess); in ParamEventTaskCreate()
113 return LE_StartAsyncEvent(LE_GetDefaultLoop(), stream, eventId, (const uint8_t *)content, size); in ParamEventSend()
119 LE_CloseTask(LE_GetDefaultLoop(), stream); in ParamTaskClose()
127 LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), timer, (LE_ProcessTimer)process, context); in ParamTimerCreate()
134 return LE_StartTimer(LE_GetDefaultLoop(), time in ParamTimerStart()
[all...]
/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd_client.c66 LE_StopLoop(LE_GetDefaultLoop()); in ProcessPtyRead()
92 LE_StopLoop(LE_GetDefaultLoop()); in CmdOnClose()
121 LE_STATUS status = LE_CreateStreamClient(LE_GetDefaultLoop(), &task, &info); in CmdAgentCreate()
137 handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendCmdMessage()
144 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), agent->task, handle); in SendCmdMessage()
147 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), agent->task, handle); in SendCmdMessage()
149 ret = LE_Send(LE_GetDefaultLoop(), agent->task, handle, bufferSize); in SendCmdMessage()
189 BEGET_ERROR_CHECK(LE_StartWatcher(LE_GetDefaultLoop(), &agent->reader, &info, agent) == LE_SUCCESS, in InitPtyInterface()
193 BEGET_ERROR_CHECK(LE_StartWatcher(LE_GetDefaultLoop(), &agent->input, &info, agent) == LE_SUCCESS, in InitPtyInterface()
218 LE_RunLoop(LE_GetDefaultLoop()); in CmdClientInit()
[all...]
/base/startup/init/services/init/standard/
H A Dinit_signal_handler.c82 if (LE_CreateSignalTask(LE_GetDefaultLoop(), &g_sigHandle, ProcessSignal) == 0) { in SignalInit()
83 if (LE_AddSignal(LE_GetDefaultLoop(), g_sigHandle, SIGCHLD) != 0) { in SignalInit()
86 if (LE_AddSignal(LE_GetDefaultLoop(), g_sigHandle, SIGTERM) != 0) { in SignalInit()
H A Dinit_control_fd_service.c50 OH_HashMapTraverse(((EventLoop *)LE_GetDefaultLoop())->taskMap, DumpLoopNodeInfo, NULL); in DumpLoop()
291 CmdServiceInit(INIT_CONTROL_FD_SOCKET_PATH, ProcessControlFd, LE_GetDefaultLoop()); in InitControlFd()
/base/startup/appspawn/test/unittest/app_spawn_standard_test/
H A Dapp_spawn_cgroup_test.cpp150 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
151 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
175 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
176 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
212 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
213 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
237 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
238 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
285 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
286 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
[all...]
H A Dapp_spawn_child_test.cpp350 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
351 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
391 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
392 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
432 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
433 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
473 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
474 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
516 LE_StopLoop(LE_GetDefaultLoop()); in HWTEST_F()
517 LE_CloseLoop(LE_GetDefaultLoop()); in HWTEST_F()
[all...]
/base/startup/init/test/unittest/init/
H A Dinit_unittest.cpp113 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TestProcessTimer()
114 LE_StopLoop(LE_GetDefaultLoop()); in TestProcessTimer()
123 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &timer, TestProcessTimer, nullptr); in HWTEST_F()
125 ret = LE_StartTimer(LE_GetDefaultLoop(), timer, 500, 4); in HWTEST_F()
H A Dservice_socket_unittest.cpp65 LE_GetDefaultLoop(), 0, &eventid, service); in HWTEST_F()
/base/startup/appspawn/standard/
H A Dappspawn_service.c139 LE_StopLoop(LE_GetDefaultLoop()); in StopAppSpawn()
197 LE_StopLoop(LE_GetDefaultLoop()); in ProcessSignal()
232 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer); in OnClose()
277 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendResponse()
280 APPSPAWN_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), NULL, handle); in SendResponse()
284 return LE_Send(LE_GetDefaultLoop(), connection->stream, handle, bufferSize); in SendResponse()
293 LE_CloseStreamTask(LE_GetDefaultLoop(), connection->stream); in WaitMsgCompleteTimeOut()
301 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeOut, connection); in StartTimerForCheckMsg()
303 ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer, MAX_WAIT_MSG_COMPLETE, 1); in StartTimerForCheckMsg()
390 LE_CloseStreamTask(LE_GetDefaultLoop(), strea in OnConnection()
[all...]
H A Dappspawn_kickdog.c91 LoopHandle loop = LE_GetDefaultLoop(); in CreateTimerLoopTask()
/base/startup/init/test/systest/
H A Dloopserver_systest.c140 ret = LE_CreateStreamServer(LE_GetDefaultLoop(), server, &info); in CreatePipeServer()
168 ret = LE_CreateStreamServer(LE_GetDefaultLoop(), server, &info); in CreateTcpServer()
180 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeOut, connection); in StartTimerForCheckMsg()
182 ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer, MAX_WAIT_MSG_COMPLETE, 1); in StartTimerForCheckMsg()
420 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendResponse()
424 LE_FreeBuffer(LE_GetDefaultLoop(), NULL, handle); in SendResponse()
431 return LE_Send(LE_GetDefaultLoop(), task->stream, handle, bufferSize); in SendResponse()
669 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
675 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
701 LE_StopTimer(LE_GetDefaultLoop(), tas in OnReceiveRequest()
[all...]
H A Dclient_systest.cpp52 EventLoop *loop = (EventLoop *)LE_GetDefaultLoop(); in main()
/base/startup/init/test/fuzztest/cmdserviceinit_fuzzer/
H A Dcmdserviceinit_fuzzer.cpp31 CmdServiceInit(str.c_str(), Func, LE_GetDefaultLoop()); in FuzzCmdServiceInit()
/base/startup/appspawn/test/unittest/
H A Dapp_spawn_test_helper.cpp78 LE_StopTimer(LE_GetDefaultLoop(), timer_); in CloseCheckHandler()
92 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &timer_, ProcessIdle, this); in StartCheckHandler()
94 ret = LE_StartTimer(LE_GetDefaultLoop(), timer_, 100, 10000000); // 100 10000000 repeat in StartCheckHandler()
97 LE_AddIdle(LE_GetDefaultLoop(), &idle_, ProcessIdle, this, 10000000); // 10000000 repeat in StartCheckHandler()
342 APPSPAWN_CHECK(connection != nullptr, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
364 ret = LE_CreateStreamServer(LE_GetDefaultLoop(), &serverHandle_, &info); in Run()
372 LE_RunLoop(LE_GetDefaultLoop()); in Run()
373 LE_CloseStreamTask(LE_GetDefaultLoop(), serverHandle_); in Run()
374 LE_StopLoop(LE_GetDefaultLoop()); in Run()
375 LE_CloseLoop(LE_GetDefaultLoop()); in Run()
[all...]
/base/startup/init/services/begetctl/
H A Ddump_service.c82 LE_RunLoop(LE_GetDefaultLoop()); in DumpAppspawnClientInit()
83 LE_CloseLoop(LE_GetDefaultLoop()); in DumpAppspawnClientInit()
H A Dsandbox.cpp164 LE_RunLoop(LE_GetDefaultLoop()); in CmdAppspawnClientInit()
165 LE_CloseLoop(LE_GetDefaultLoop()); in CmdAppspawnClientInit()
/base/startup/init/services/init/lite/
H A Dinit.c100 LE_RunLoop(LE_GetDefaultLoop()); in SystemRun()
/base/startup/init/test/unittest/param/
H A Dparamservice_unittest.cpp303 OnIncomingConnect(LE_GetDefaultLoop(), GetParamService()->serverTask); in CreateAndGetStreamTask()
374 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWait1()
386 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWait2()
398 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWait3()
411 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWatch1()
422 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWatch2()
H A Dtrigger_unittest.cpp113 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestLoadTrigger()
369 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestExecuteParamTrigger1()
390 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestExecuteParamTrigger2()
417 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestExecuteParamTrigger3()
449 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestExecuteParamTrigger4()
485 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestExecuteParamTrigger5()
/base/startup/init/interfaces/innerkits/init_module_engine/
H A Dinit_modulemgr.c59 LE_DelayProc(LE_GetDefaultLoop(), DelayedUninstall, context); in AutorunModuleMgrUnInstall()
/base/startup/init/test/unittest/innerkits/
H A Dinnerkits_unittest.cpp376 }, LE_GetDefaultLoop()); in HWTEST_F()
388 (void)LE_CreateStreamServer(LE_GetDefaultLoop(), &testServer, &info); in HWTEST_F()
389 CmdOnIncommingConnect(LE_GetDefaultLoop(), testServer); in HWTEST_F()
/base/startup/init/services/init/
H A Dinit_service_socket.c188 int ret = LE_StartWatcher(LE_GetDefaultLoop(), &handle, &info, service); in AddSocketWatcher()
196 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)watcherHandle); in RemoveSocketWatcher()
/base/startup/init/test/moduletest/
H A Dparam_test_cmds.c259 LE_RunLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
260 LE_CloseLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
/base/startup/init/services/loopevent/loop/
H A Dle_loop.c140 LoopHandle LE_GetDefaultLoop(void) in LE_GetDefaultLoop() function

Completed in 15 milliseconds

12