Searched refs:serverTask (Results 1 - 11 of 11) sorted by relevance
| /base/startup/init/services/loopevent/task/ |
| H A D | le_streamtask.c | 151 StreamServerTask *serverTask = (StreamServerTask *)baseTask;
in DumpStreamServerTaskInfo_() local
152 printf("\tfd: %d \n", serverTask->base.taskId.fd);
in DumpStreamServerTaskInfo_()
154 if (strlen(serverTask->server) > 0) {
in DumpStreamServerTaskInfo_()
155 printf("\t Server socket:%s \n", serverTask->server);
in DumpStreamServerTaskInfo_()
183 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint32_t oper)
in HandleServerEvent_() argument
185 LE_LOGV("HandleServerEvent_ fd %d oper 0x%x", GetSocketFd(serverTask), oper);
in HandleServerEvent_()
189 StreamServerTask *server = (StreamServerTask *)serverTask;
in HandleServerEvent_()
192 int ret = server->incommingConnect(loopHandle, serverTask);
in HandleServerEvent_()
194 LE_LOGE("HandleServerEvent_ fd %d do not accept socket", GetSocketFd(serverTask));
in HandleServerEvent_()
197 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_REA in HandleServerEvent_()
[all...] |
| H A D | le_task.h | 96 StreamServerTask *serverTask;
member
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopevent_unittest.cpp | 219 ParamTaskPtr serverTask = nullptr;
226 LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask, &info);
227 EXPECT_NE(serverTask, nullptr);
228 if (serverTask == nullptr) {
231 ((StreamServerTask *)serverTask)->base.taskId.fd = -1;
232 OnIncomingConnect(LE_GetDefaultLoop(), serverTask);
233 LE_GetSocketFd(serverTask);
|
| /base/startup/init/test/unittest/param/ |
| H A D | param_unittest.cpp | 628 ParamTaskPtr serverTask = nullptr; in HWTEST_F() local
636 ret = ParamServerCreate(&serverTask, nullptr); in HWTEST_F()
638 ret = ParamServerCreate(&serverTask, &info); in HWTEST_F()
654 ret = ParamStreamCreate(&client, GetParamService()->serverTask, nullptr, sizeof(ParamWatcher)); in HWTEST_F()
657 ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher)); in HWTEST_F()
661 ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher)); in HWTEST_F()
671 ret = ParamTaskSendMsg(GetParamService()->serverTask, nullptr); in HWTEST_F()
|
| H A D | paramservice_unittest.cpp | 303 OnIncomingConnect(LE_GetDefaultLoop(), GetParamService()->serverTask); in CreateAndGetStreamTask()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| H A D | control_fd.h | 45 TaskHandle serverTask; member
|
| H A D | control_fd_service.c | 163 (void)LE_CreateStreamServer(g_controlFdLoop, &g_cmdService.serverTask, &info); in CmdServiceInit()
|
| /base/startup/init/interfaces/innerkits/include/ |
| H A D | loop_event.h | 103 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandle, const TaskHandle serverTask);
130 const TaskHandle serverTask, TaskHandle *taskHandle, const LE_StreamInfo *info);
|
| /base/startup/init/services/param/linux/ |
| H A D | param_service.c | 415 if (g_paramService.serverTask == NULL) {
in InitParamService()
421 ret = ParamServerCreate(&g_paramService.serverTask, &info);
in InitParamService()
462 ParamTaskClose(g_paramService.serverTask);
in StopParamService()
463 g_paramService.serverTask = NULL;
in StopParamService()
|
| /base/startup/init/services/param/include/ |
| H A D | param_manager.h | 87 ParamTaskPtr serverTask;
member
|
| /base/startup/init/test/systest/ |
| H A D | loopserver_systest.c | 59 TaskHandle serverTask; member
305 int ret = LE_CreateStreamServer(loop, &g_service.serverTask, &info); in ServerInit()
|
Completed in 8 milliseconds