| /ohos5.0/base/startup/init/test/unittest/loopevent/ |
| H A D | loopevent_unittest.cpp | 142 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask_, &info); in LeTaskTest()
179 ProcessEvent((EventLoop *)LE_GetDefaultLoop(), 1, EVENT_READ); in ProcessEventTest()
197 LE_StopAsyncTask(LE_GetDefaultLoop(), asynHandle); in ProcessasynEvent()
207 LE_StartWatcher(LE_GetDefaultLoop(), &handle, &info, nullptr); in ProcessWatcherTask()
215 LE_RemoveWatcher(LE_GetDefaultLoop(), handle); in ProcessWatcherTask()
226 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask, &info); in CreateSocketTest()
232 OnIncomingConnect(LE_GetDefaultLoop(), serverTask); in CreateSocketTest()
288 LE_StartWatcher(LE_GetDefaultLoop(), nullptr, &info, nullptr);
289 LE_StartWatcher(LE_GetDefaultLoop(), nullptr, nullptr, nullptr);
294 int ret = LE_DelayProc(LE_GetDefaultLoop(), nullptr, nullptr);
[all …]
|
| /ohos5.0/base/startup/init/services/param/linux/ |
| H A D | param_msgadp.c | 56 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()
119 LE_CloseTask(LE_GetDefaultLoop(), stream); in ParamTaskClose()
134 return LE_StartTimer(LE_GetDefaultLoop(), timer, timeout, repeat); in ParamTimerStart()
140 LE_CloseTask(LE_GetDefaultLoop(), (ParamTaskPtr)timer); in ParamTimerClose()
145 LE_RunLoop(LE_GetDefaultLoop()); in ParamServiceStart()
[all …]
|
| /ohos5.0/base/startup/appspawn/test/unittest/app_spawn_standard_test/ |
| H A D | app_spawn_cgroup_test.cpp | 150 LE_StopLoop(LE_GetDefaultLoop());
151 LE_CloseLoop(LE_GetDefaultLoop());
175 LE_StopLoop(LE_GetDefaultLoop());
176 LE_CloseLoop(LE_GetDefaultLoop());
212 LE_StopLoop(LE_GetDefaultLoop());
213 LE_CloseLoop(LE_GetDefaultLoop());
237 LE_StopLoop(LE_GetDefaultLoop());
238 LE_CloseLoop(LE_GetDefaultLoop());
285 LE_StopLoop(LE_GetDefaultLoop());
332 LE_StopLoop(LE_GetDefaultLoop());
[all …]
|
| H A D | app_spawn_child_test.cpp | 347 LE_StopLoop(LE_GetDefaultLoop());
348 LE_CloseLoop(LE_GetDefaultLoop());
388 LE_StopLoop(LE_GetDefaultLoop());
389 LE_CloseLoop(LE_GetDefaultLoop());
431 LE_StopLoop(LE_GetDefaultLoop());
432 LE_CloseLoop(LE_GetDefaultLoop());
475 LE_StopLoop(LE_GetDefaultLoop());
476 LE_CloseLoop(LE_GetDefaultLoop());
|
| /ohos5.0/base/startup/init/interfaces/innerkits/control_fd/ |
| H A D | control_fd_client.c | 66 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 …]
|
| /ohos5.0/base/startup/appspawn/standard/ |
| H A D | appspawn_service.c | 127 LE_StopLoop(LE_GetDefaultLoop()); in StopAppSpawn()
188 LE_StopLoop(LE_GetDefaultLoop()); in ProcessSignal()
284 LE_CloseStreamTask(LE_GetDefaultLoop(), connection->stream); in WaitMsgCompleteTimeOut()
381 LE_CloseStreamTask(LE_GetDefaultLoop(), stream); in OnConnection()
452 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); return); in OnReceiveRequest()
468 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
564 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ProcessChildProcessFd()
1063 ret = LE_CreateStreamServer(LE_GetDefaultLoop(), server, &info); in CreateAppSpawnServer()
1092 LE_StopLoop(LE_GetDefaultLoop()); in AppSpawnDestroyContent()
1093 LE_CloseLoop(LE_GetDefaultLoop()); in AppSpawnDestroyContent()
[all …]
|
| H A D | appspawn_kickdog.c | 91 LoopHandle loop = LE_GetDefaultLoop(); in CreateTimerLoopTask()
|
| /ohos5.0/base/startup/init/test/unittest/init/ |
| H A D | init_unittest.cpp | 115 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TestProcessTimer()
116 LE_StopLoop(LE_GetDefaultLoop()); in TestProcessTimer()
125 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &timer, TestProcessTimer, nullptr);
127 ret = LE_StartTimer(LE_GetDefaultLoop(), timer, 500, 4);
|
| H A D | service_socket_unittest.cpp | 65 LE_GetDefaultLoop(), 0, &eventid, service);
|
| /ohos5.0/base/startup/init/services/init/standard/ |
| H A D | init_signal_handler.c | 82 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 D | init_control_fd_service.c | 50 OH_HashMapTraverse(((EventLoop *)LE_GetDefaultLoop())->taskMap, DumpLoopNodeInfo, NULL); in DumpLoop()
291 CmdServiceInit(INIT_CONTROL_FD_SOCKET_PATH, ProcessControlFd, LE_GetDefaultLoop()); in InitControlFd()
|
| H A D | fd_holder_service.c | 185 LE_StartWatcher(LE_GetDefaultLoop(), &watcher, &info, NULL); in RegisterFdHoldWatcher()
|
| /ohos5.0/base/startup/appspawn/test/unittest/ |
| H A D | app_spawn_test_helper.cpp | 78 LE_StopTimer(LE_GetDefaultLoop(), timer_); in CloseCheckHandler()
92 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &timer_, ProcessIdle, this); 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()
383 LE_StopLoop(LE_GetDefaultLoop()); in Stop()
390 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendResponse()
[all …]
|
| /ohos5.0/base/startup/init/test/unittest/param/ |
| H A D | paramservice_unittest.cpp | 303 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 D | trigger_unittest.cpp | 113 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()
|
| /ohos5.0/base/startup/init/services/begetctl/ |
| H A D | dump_service.c | 82 LE_RunLoop(LE_GetDefaultLoop()); in DumpAppspawnClientInit()
83 LE_CloseLoop(LE_GetDefaultLoop()); in DumpAppspawnClientInit()
|
| H A D | sandbox.cpp | 164 LE_RunLoop(LE_GetDefaultLoop()); in CmdAppspawnClientInit()
165 LE_CloseLoop(LE_GetDefaultLoop()); in CmdAppspawnClientInit()
|
| /ohos5.0/base/startup/init/test/fuzztest/cmdserviceinit_fuzzer/ |
| H A D | cmdserviceinit_fuzzer.cpp | 31 CmdServiceInit(str.c_str(), Func, LE_GetDefaultLoop()); in FuzzCmdServiceInit()
|
| /ohos5.0/base/startup/init/services/init/lite/ |
| H A D | init.c | 100 LE_RunLoop(LE_GetDefaultLoop()); in SystemRun()
|
| /ohos5.0/base/startup/init/services/init/ |
| H A D | init_service_socket.c | 188 int ret = LE_StartWatcher(LE_GetDefaultLoop(), &handle, &info, service); in AddSocketWatcher()
196 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)watcherHandle); in RemoveSocketWatcher()
|
| H A D | init_common_service.c | 928 LE_StopTimer(LE_GetDefaultLoop(), service->timer); in ServiceStopTimer()
989 … LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerStartProcess, in ServiceStartTimer()
998 status = LE_StartTimer(LE_GetDefaultLoop(), service->timer, timeout, 1); in ServiceStartTimer()
1014 …LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerReStartProcess, in ServiceReStartTimer()
1023 status = LE_StartTimer(LE_GetDefaultLoop(), service->timer, timeout, 1); in ServiceReStartTimer()
|
| /ohos5.0/base/startup/init/test/unittest/innerkits/ |
| H A D | innerkits_unittest.cpp | 376 }, LE_GetDefaultLoop()); in __anon504fd31b0102()
388 (void)LE_CreateStreamServer(LE_GetDefaultLoop(), &testServer, &info);
389 CmdOnIncommingConnect(LE_GetDefaultLoop(), testServer);
|
| /ohos5.0/base/startup/init/interfaces/innerkits/init_module_engine/ |
| H A D | init_modulemgr.c | 59 LE_DelayProc(LE_GetDefaultLoop(), DelayedUninstall, context); in AutorunModuleMgrUnInstall()
|
| /ohos5.0/base/startup/init/test/moduletest/ |
| H A D | param_test_cmds.c | 259 LE_RunLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
260 LE_CloseLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
|
| /ohos5.0/base/startup/init/interfaces/innerkits/ |
| H A D | libbegetutil.versionscript | 73 LE_GetDefaultLoop;
|