| /base/startup/init/test/unittest/loopevent/ |
| D | loopevent_unittest.cpp | 111 …LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo… in StreamTaskTest()
115 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
117 ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), in StreamTaskTest()
123 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandlec, &streamInfo); in StreamTaskTest()
130 LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandled, &streamInfo); in StreamTaskTest()
142 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask_, &info); in LeTaskTest()
146 … ((StreamServerTask *)serverTask_)->base.handleEvent(LE_GetDefaultLoop(), serverTask_, Event_Read); in LeTaskTest()
159 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), 1 + sizeof(eventId)); in LeTaskTest()
162 …((StreamConnectTask *)client)->stream.base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)(client), … in LeTaskTest()
166 …((StreamConnectTask *)client)->recvMessage(LE_GetDefaultLoop(), reinterpret_cast<uint8_t *>(reques… in LeTaskTest()
[all …]
|
| /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 | 166 BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendResponse()
170 return LE_Send(LE_GetDefaultLoop(), client->stream, handle, buffSize); in SendResponse()
233 LE_StopLoop(LE_GetDefaultLoop()); in SignalHandler()
256 LE_StopLoop(LE_GetDefaultLoop()); in SignalHandlerNweb()
326 … APPSPAWN_CHECK(dataGroupInfoList->data != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToDataGroup()
331 …APPSPAWN_CHECK(dataGroupInfoList->totalLength >= buffLen, LE_CloseTask(LE_GetDefaultLoop(), taskHa… in ReceiveRequestDataToDataGroup()
335 APPSPAWN_CHECK(ret == 0, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToDataGroup()
348 APPSPAWN_CHECK(overlayInfo->data != NULL, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToOverlay()
354 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToOverlay()
358 APPSPAWN_CHECK(ret == 0, LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in ReceiveRequestDataToOverlay()
[all …]
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd_client.c | 84 LE_StopLoop(LE_GetDefaultLoop()); in CmdOnClose()
113 LE_STATUS status = LE_CreateStreamClient(LE_GetDefaultLoop(), &task, &info); in CmdAgentCreate()
129 handle = LE_CreateBuffer(LE_GetDefaultLoop(), bufferSize); in SendCmdMessage()
136 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), agent->task, handle); in SendCmdMessage()
139 BEGET_ERROR_CHECK(ret == 0, LE_FreeBuffer(LE_GetDefaultLoop(), agent->task, handle); in SendCmdMessage()
141 ret = LE_Send(LE_GetDefaultLoop(), agent->task, handle, bufferSize); in SendCmdMessage()
180 …BEGET_ERROR_CHECK(LE_StartWatcher(LE_GetDefaultLoop(), &agent->reader, &info, agent) == LE_SUCCESS, in InitPtyInterface()
184 … BEGET_ERROR_CHECK(LE_StartWatcher(LE_GetDefaultLoop(), &agent->input, &info, agent) == LE_SUCCESS, in InitPtyInterface()
205 LE_RunLoop(LE_GetDefaultLoop()); in CmdClientInit()
206 LE_CloseLoop(LE_GetDefaultLoop()); in CmdClientInit()
|
| /base/startup/init/services/init/standard/ |
| D | init_signal_handler.c | 77 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 | 182 LE_StartWatcher(LE_GetDefaultLoop(), &watcher, &info, NULL); in RegisterFdHoldWatcher()
|
| D | init_control_fd_service.c | 245 CmdServiceInit(INIT_CONTROL_FD_SOCKET_PATH, ProcessControlFd, LE_GetDefaultLoop()); in InitControlFd()
|
| /base/startup/init/test/unittest/init/ |
| D | init_unittest.cpp | 118 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TestProcessTimer()
119 LE_StopLoop(LE_GetDefaultLoop()); in TestProcessTimer()
128 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &timer, TestProcessTimer, nullptr);
130 ret = LE_StartTimer(LE_GetDefaultLoop(), timer, 500, 4);
|
| D | service_socket_unittest.cpp | 65 LE_GetDefaultLoop(), 0, &eventid, service);
|
| D | group_unittest.cpp | 234 …((TimerTask *)service->timer)->base.handleEvent(LE_GetDefaultLoop(), (LoopBase *)service->timer, E…
|
| /base/startup/init/test/fuzztest/cmdserviceinit_fuzzer/ |
| D | cmdserviceinit_fuzzer.cpp | 31 CmdServiceInit(str.c_str(), Func, LE_GetDefaultLoop()); in FuzzCmdServiceInit()
|
| /base/startup/init/services/init/lite/ |
| D | init.c | 96 LE_RunLoop(LE_GetDefaultLoop()); in SystemRun()
|
| /base/startup/init/test/unittest/param/ |
| D | paramservice_unittest.cpp | 304 OnIncomingConnect(LE_GetDefaultLoop(), GetParamService()->serverTask); in CreateAndGetStreamTask()
375 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWait1()
387 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWait2()
399 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWait3()
412 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWatch1()
423 LE_DoAsyncEvent(LE_GetDefaultLoop(), GetTriggerWorkSpace()->eventHandle); in TestAddParamWatch2()
|
| 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()
|
| D | param_stub.cpp | 622 LE_CloseLoop(LE_GetDefaultLoop()); in ParamTestStubExit()
|
| /base/startup/appspawn/test/unittest/app_spawn_standard_test/ |
| D | app_spawn_standard_test.cpp | 129 LE_StopLoop(LE_GetDefaultLoop()); in ProcessTimer()
528 TaskHandle stream = AcceptClient(LE_GetDefaultLoop(), content->server, TASK_TEST); in RunClient()
592 task->incommingConnect(LE_GetDefaultLoop(), nullptr); in TestClient()
596 ret = LE_CreateTimer(LE_GetDefaultLoop(), &content->timer, ProcessTimer, nullptr); in TestClient()
598 ret = LE_StartTimer(LE_GetDefaultLoop(), content->timer, 500, 1); // 500 ms is timeout in TestClient()
605 ret = LE_CreateTimer(LE_GetDefaultLoop(), &content->timer, ProcessTimer, nullptr); in TestClient()
607 ret = LE_StartTimer(LE_GetDefaultLoop(), content->timer, 500, 1); // 500 ms is timeout in TestClient()
|
| /base/startup/init/services/init/ |
| D | init_service_socket.c | 194 int ret = LE_StartWatcher(LE_GetDefaultLoop(), &handle, &info, service); in AddSocketWatcher()
202 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)watcherHandle); in RemoveSocketWatcher()
|
| D | init_common_service.c | 821 LE_StopTimer(LE_GetDefaultLoop(), service->timer); in ServiceStopTimer()
858 … LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerStartProcess, in ServiceStartTimer()
867 status = LE_StartTimer(LE_GetDefaultLoop(), service->timer, timeout, 1); in ServiceStartTimer()
|
| D | init_service_manager.c | 924 LE_RemoveWatcher(LE_GetDefaultLoop(), (WatcherHandle)handler); in ProcessConsoleEvent()
955 int ret = LE_StartWatcher(LE_GetDefaultLoop(), &watcher, &info, service); in AddFileDescriptorToWatcher()
|
| /base/startup/init/interfaces/innerkits/ |
| D | libbegetutil.versionscript | 76 LE_GetDefaultLoop;
|
| /base/startup/init/test/unittest/innerkits/ |
| D | innerkits_unittest.cpp | 365 }, LE_GetDefaultLoop()); in __anon4bdbd1420102()
377 (void)LE_CreateStreamServer(LE_GetDefaultLoop(), &testServer, &info);
378 CmdOnIncommingConnect(LE_GetDefaultLoop(), testServer);
|
| /base/startup/init/test/moduletest/ |
| D | param_test_cmds.c | 258 LE_RunLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
259 LE_CloseLoop(LE_GetDefaultLoop()); in BShellParamCmdGroupTest()
|
| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 66 LoopHandle LE_GetDefaultLoop(void);
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 138 LoopHandle LE_GetDefaultLoop(void) in LE_GetDefaultLoop() function
|