| /base/startup/init/test/unittest/init/ |
| D | SignalInitUnitTest.cpp | 46 LE_CreateSignalTask(LE_GetDefaultLoop(), &g_sigHandler, ProcessSignal);
48 int ret = LE_AddSignal(LE_GetDefaultLoop(), g_sigHandler, SIGUSR1);
50 LE_AddSignal(LE_GetDefaultLoop(), g_sigHandler, SIGUSR1);
51 LE_AddSignal(LE_GetDefaultLoop(), g_sigHandler, SIGUSR2);
52 ret = LE_RemoveSignal(LE_GetDefaultLoop(), g_sigHandler, SIGUSR1);
54 LE_RemoveSignal(LE_GetDefaultLoop(), g_sigHandler, SIGUSR1);
55 LE_RemoveSignal(LE_GetDefaultLoop(), g_sigHandler, SIGUSR2);
56 …((BaseTask *)g_sigHandler)->handleEvent(LE_GetDefaultLoop(), (TaskHandle)&g_sigHandler, Event_Writ…
57 LE_CloseSignalTask(LE_GetDefaultLoop(), g_sigHandler);
|
| D | loopevent_unittest.cpp | 113 …LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo… in StreamTaskTest()
117 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
119 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
122 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
128 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandleb, &streamInfo); in StreamTaskTest()
132 ((StreamClientTask *)clientTaskHandleb)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
134 ((StreamClientTask *)clientTaskHandleb)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
136 …((StreamClientTask *)clientTaskHandleb)->stream.base.innerClose(LE_GetDefaultLoop(), clientTaskHan… in StreamTaskTest()
141 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandlec, &streamInfo); in StreamTaskTest()
148 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandled, &streamInfo); in StreamTaskTest()
[all …]
|
| D | service_socket_unittest.cpp | 64 LE_GetDefaultLoop(), 0, &eventid, service);
|
| D | group_unittest.cpp | 215 …((TimerTask *)service->timer)->base.handleEvent(LE_GetDefaultLoop(), (LoopBase *)service->timer, E…
|
| /base/startup/init/services/param/linux/ |
| 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()
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(), timer, timeout, repeat); in ParamTimerStart()
[all …]
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.c | 102 LE_StopLoop(LE_GetDefaultLoop()); in ProcessTimer()
119 … int ret = LE_CreateTimer(LE_GetDefaultLoop(), &g_appSpawnContent->timer, ProcessTimer, NULL); in RemoveAppInfo()
121 LE_StartTimer(LE_GetDefaultLoop(), g_appSpawnContent->timer, 60000, 1); // 60000 60s in RemoveAppInfo()
155 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendResponse()
159 return LE_Send(LE_GetDefaultLoop(), client->stream, handle, buffSize); in SendResponse()
214 LE_StopLoop(LE_GetDefaultLoop()); in SignalHandler()
345 …ECK(buffer != NULL && buffLen >= sizeof(AppParameter), LE_CloseTask(LE_GetDefaultLoop(), taskHandl… in OnReceiveRequest()
348 APPSPAWN_CHECK(appProperty != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
352 …APPSPAWN_CHECK(ret == 0, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); return, "Invalid buffLen %… in OnReceiveRequest()
363 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
[all …]
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd_client.c | 83 LE_StopLoop(LE_GetDefaultLoop()); in CmdOnClose()
112 LE_STATUS status = LE_CreateStreamClient(LE_GetDefaultLoop(), &task, &info); in CmdAgentCreate()
128 handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendCmdMessage()
135 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), agent->task, handle); in SendCmdMessage()
138 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), agent->task, handle); in SendCmdMessage()
140 ret = LE_Send(LE_GetDefaultLoop(), agent->task, handle, bufferSize); in SendCmdMessage()
177 …BEGET_ERROR_CHECK(LE_StartWatcher(LE_GetDefaultLoop(), &agent->reader, &info, agent) == LE_SUCCESS, in InitPtyInterface()
181 … BEGET_ERROR_CHECK(LE_StartWatcher(LE_GetDefaultLoop(), &agent->input, &info, agent) == LE_SUCCESS, in InitPtyInterface()
202 LE_RunLoop(LE_GetDefaultLoop()); in CmdClientInit()
203 LE_CloseLoop(LE_GetDefaultLoop()); in CmdClientInit()
|
| D | control_fd_service.c | 112 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), task, handle); in SendMessage()
133 int ret = LE_AcceptStreamClient(LE_GetDefaultLoop(), server, &client, &info); in CmdOnIncommingConnect()
139 ret = SendMessage(LE_GetDefaultLoop(), agent->task, "connect success."); in CmdOnIncommingConnect()
162 (void)LE_CreateStreamServer(LE_GetDefaultLoop(), &g_cmdService.serverTask, &info); in CmdServiceInit()
179 LE_CloseTask(LE_GetDefaultLoop(), agent->task); in CmdServiceProcessDelClient()
|
| /base/startup/init/services/init/standard/ |
| D | init_signal_handler.c | 74 if (LE_CreateSignalTask(LE_GetDefaultLoop(), &g_sigHandle, ProcessSignal) != 0) { in SignalInit()
78 if (LE_AddSignal(LE_GetDefaultLoop(), g_sigHandle, SIGCHLD) != 0) { in SignalInit()
81 if (LE_AddSignal(LE_GetDefaultLoop(), g_sigHandle, SIGTERM) != 0) { in SignalInit()
|
| D | fd_holder_service.c | 248 LE_StartWatcher(LE_GetDefaultLoop(), &watcher, &info, NULL); in RegisterFdHoldWatcher()
|
| /base/startup/init/services/init/lite/ |
| D | init.c | 96 LE_RunLoop(LE_GetDefaultLoop()); in SystemRun()
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 49 CloseTask(LE_GetDefaultLoop(), task); in TaskNodeFree()
132 LoopHandle LE_GetDefaultLoop(void) in LE_GetDefaultLoop() function
|
| /base/startup/init/test/unittest/param/ |
| 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()
|
| /base/startup/init/services/init/ |
| D | init_service_socket.c | 194 int ret = LE_StartWatcher(LE_GetDefaultLoop(), &handle, &info, service); in SocketAddWatcher()
202 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)watcherHandle); in SocketDelWatcher()
|
| D | init_common_service.c | 630 LE_StopTimer(LE_GetDefaultLoop(), service->timer); in ServiceStopTimer()
667 … LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerStartProcess, in ServiceStartTimer()
676 status = LE_StartTimer(LE_GetDefaultLoop(), service->timer, timeout, 1); in ServiceStartTimer()
|
| D | init_service_manager.c | 904 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)handler); in ProcessConsoleEvent()
948 int ret = LE_StartWatcher(LE_GetDefaultLoop(), &watcher, &info, service); in AddFileDescriptorToWatcher()
|
| /base/startup/init/test/moduletest/ |
| D | param_test_cmds.c | 257 LE_RunLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
258 LE_CloseLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
|
| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 66 LoopHandle LE_GetDefaultLoop(void);
|
| /base/startup/init/test/unittest/innerkits/ |
| D | innerkits_unittest.cpp | 372 (void)LE_CreateStreamServer(LE_GetDefaultLoop(), &testServer, &info);
373 CmdOnIncommingConnect(LE_GetDefaultLoop(), testServer);
|
| /base/startup/appspawn/test/unittest/app_spawn_standard_test/ |
| D | app_spawn_standard_test.cpp | 293 OnConnection(LE_GetDefaultLoop(), content->server); in TestClient()
317 LE_CloseTask(LE_GetDefaultLoop(), GetTestClientHandle()); in TestClient()
|