Searched refs:serverTask (Results 1 – 10 of 10) sorted by relevance
| /base/startup/init/test/unittest/loopevent/ |
| D | loopevent_unittest.cpp | 219 ParamTaskPtr serverTask = nullptr; in CreateSocketTest() local
226 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask, &info); in CreateSocketTest()
227 EXPECT_NE(serverTask, nullptr); in CreateSocketTest()
228 if (serverTask == nullptr) { in CreateSocketTest()
231 ((StreamServerTask *)serverTask)->base.taskId.fd = -1; in CreateSocketTest()
232 OnIncomingConnect(LE_GetDefaultLoop(), serverTask); in CreateSocketTest()
233 LE_GetSocketFd(serverTask); in CreateSocketTest()
|
| /base/startup/init/services/loopevent/task/ |
| D | le_streamtask.c | 139 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3… in HandleServerEvent_() argument
141 LE_LOGV("HandleServerEvent_ fd %d oper 0x%x", GetSocketFd(serverTask), oper); in HandleServerEvent_()
145 StreamServerTask *server = (StreamServerTask *)serverTask; in HandleServerEvent_()
148 int ret = server->incommingConnect(loopHandle, serverTask); in HandleServerEvent_()
150 LE_LOGE("HandleServerEvent_ fd %d do not accept socket", GetSocketFd(serverTask)); in HandleServerEvent_()
153 loop->modEvent(loop, (const BaseTask *)serverTask, Event_Read); in HandleServerEvent_()
233 task->serverTask = (StreamServerTask *)server; in LE_AcceptStreamClient()
|
| D | le_task.h | 92 StreamServerTask *serverTask; member
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd.h | 45 TaskHandle serverTask; member
|
| D | control_fd_service.c | 163 (void)LE_CreateStreamServer(g_controlFdLoop, &g_cmdService.serverTask, &info); in CmdServiceInit()
|
| /base/startup/init/test/unittest/param/ |
| D | param_unittest.cpp | 611 ParamTaskPtr serverTask = nullptr; variable
619 ret = ParamServerCreate(&serverTask, nullptr);
621 ret = ParamServerCreate(&serverTask, &info);
637 ret = ParamStreamCreate(&client, GetParamService()->serverTask, nullptr, sizeof(ParamWatcher));
640 ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher));
644 ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher));
654 ret = ParamTaskSendMsg(GetParamService()->serverTask, nullptr);
|
| D | paramservice_unittest.cpp | 304 OnIncomingConnect(LE_GetDefaultLoop(), GetParamService()->serverTask); in CreateAndGetStreamTask()
|
| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 102 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandle, const TaskHandle serverTask);
127 const TaskHandle serverTask, TaskHandle *taskHandle, const LE_StreamInfo *info);
|
| /base/startup/init/services/param/linux/ |
| D | param_service.c | 388 if (g_paramService.serverTask == NULL) { in InitParamService()
394 ret = ParamServerCreate(&g_paramService.serverTask, &info); in InitParamService()
430 ParamTaskClose(g_paramService.serverTask); in StopParamService()
431 g_paramService.serverTask = NULL; in StopParamService()
|
| /base/startup/init/services/param/include/ |
| D | param_manager.h | 79 ParamTaskPtr serverTask; member
|