Searched refs:serverTask (Results 1 – 9 of 9) sorted by relevance
| /base/startup/init/test/unittest/init/ |
| D | loopevent_unittest.cpp | 237 ParamTaskPtr serverTask = nullptr; in CreateSocketTest() local
244 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask, &info); in CreateSocketTest()
245 EXPECT_NE(serverTask, nullptr); in CreateSocketTest()
246 if (serverTask == nullptr) { in CreateSocketTest()
249 ((StreamServerTask *)serverTask)->base.taskId.fd = -1; in CreateSocketTest()
250 OnIncomingConnect(LE_GetDefaultLoop(), serverTask); in CreateSocketTest()
251 LE_GetSocketFd(serverTask); in CreateSocketTest()
|
| /base/startup/init/services/loopevent/task/ |
| D | le_streamtask.c | 138 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3… in HandleServerEvent_() argument
140 LE_LOGV("HandleServerEvent_ fd %d oper 0x%x", GetSocketFd(serverTask), oper); in HandleServerEvent_()
144 StreamServerTask *server = (StreamServerTask *)serverTask; in HandleServerEvent_()
147 int ret = server->incommingConnect(loopHandle, serverTask); in HandleServerEvent_()
149 LE_LOGE("HandleServerEvent_ fd %d do not accept socket", GetSocketFd(serverTask)); in HandleServerEvent_()
152 loop->modEvent(loop, (const BaseTask *)serverTask, Event_Read); in HandleServerEvent_()
232 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 | 162 (void)LE_CreateStreamServer(LE_GetDefaultLoop(), &g_cmdService.serverTask, &info); in CmdServiceInit()
|
| /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 | 391 if (g_paramService.serverTask == NULL) { in InitParamService()
397 ret = ParamServerCreate(&g_paramService.serverTask, &info); in InitParamService()
431 ParamTaskClose(g_paramService.serverTask); in StopParamService()
432 g_paramService.serverTask = NULL; in StopParamService()
|
| /base/startup/init/services/param/include/ |
| D | param_manager.h | 70 ParamTaskPtr serverTask; member
|
| /base/startup/init/test/unittest/param/ |
| D | paramservice_unittest.cpp | 311 … int ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher)); in CreateAndGetStreamTask()
|