Home
last modified time | relevance | path

Searched refs:serverTask (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/base/startup/init/services/loopevent/task/
H A Dle_streamtask.c150 StreamServerTask *serverTask = (StreamServerTask *)baseTask; in DumpStreamServerTaskInfo_() local
151 printf("\tfd: %d \n", serverTask->base.taskId.fd); in DumpStreamServerTaskInfo_()
153 if (strlen(serverTask->server) > 0) { in DumpStreamServerTaskInfo_()
154 printf("\t Server socket:%s \n", serverTask->server); in DumpStreamServerTaskInfo_()
182 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3… in HandleServerEvent_() argument
184 LE_LOGV("HandleServerEvent_ fd %d oper 0x%x", GetSocketFd(serverTask), oper); in HandleServerEvent_()
188 StreamServerTask *server = (StreamServerTask *)serverTask; in HandleServerEvent_()
191 int ret = server->incommingConnect(loopHandle, serverTask); in HandleServerEvent_()
193 LE_LOGE("HandleServerEvent_ fd %d do not accept socket", GetSocketFd(serverTask)); in HandleServerEvent_()
196 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_READ); in HandleServerEvent_()
[all …]
H A Dle_task.h96 StreamServerTask *serverTask; member
/ohos5.0/base/startup/init/test/unittest/loopevent/
H A Dloopevent_unittest.cpp219 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()
/ohos5.0/base/startup/init/test/unittest/param/
H A Dparam_unittest.cpp609 ParamTaskPtr serverTask = nullptr; variable
617 ret = ParamServerCreate(&serverTask, nullptr);
619 ret = ParamServerCreate(&serverTask, &info);
635 ret = ParamStreamCreate(&client, GetParamService()->serverTask, nullptr, sizeof(ParamWatcher));
638 ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher));
642 ret = ParamStreamCreate(&client, GetParamService()->serverTask, &info, sizeof(ParamWatcher));
652 ret = ParamTaskSendMsg(GetParamService()->serverTask, nullptr);
H A Dparamservice_unittest.cpp303 OnIncomingConnect(LE_GetDefaultLoop(), GetParamService()->serverTask); in CreateAndGetStreamTask()
/ohos5.0/base/startup/init/interfaces/innerkits/include/
H A Dloop_event.h103 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandle, const TaskHandle serverTask);
130 const TaskHandle serverTask, TaskHandle *taskHandle, const LE_StreamInfo *info);
/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_service.c415 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()
/ohos5.0/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd.h45 TaskHandle serverTask; member
H A Dcontrol_fd_service.c163 (void)LE_CreateStreamServer(g_controlFdLoop, &g_cmdService.serverTask, &info); in CmdServiceInit()
/ohos5.0/base/startup/init/services/param/include/
H A Dparam_manager.h87 ParamTaskPtr serverTask; member