131     BaseTask *task = (BaseTask *)taskHandle;  in HandleStreamTaskClose_()  local
132     CloseTask(loopHandle, task);  in HandleStreamTaskClose_()
133     DelTask((EventLoop *)loopHandle, task);  in HandleStreamTaskClose_()
134     if (task->taskId.fd > 0) {  in HandleStreamTaskClose_()
135         close(task->taskId.fd);  in HandleStreamTaskClose_()
172     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,  in LE_CreateStreamServer()  local
174     LE_CHECK(task != NULL, close(fd);  in LE_CreateStreamServer()
176     task->base.handleEvent = HandleServerEvent_;  in LE_CreateStreamServer()
177     task->base.innerClose = HandleStreamTaskClose_;  in LE_CreateStreamServer()
178     task->incommingConnect = info->incommingConnect;  in LE_CreateStreamServer()
179     loop->addEvent(loop, (const BaseTask *)task, Event_Read);  in LE_CreateStreamServer()
180 …int ret = memcpy_s(task->server, strlen(info->server) + 1, info->server, strlen(info->server) + 1);  in LE_CreateStreamServer()
182     *taskHandle = (TaskHandle)task;  in LE_CreateStreamServer()
195 …StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(St…  in LE_CreateStreamClient()  local
196     LE_CHECK(task != NULL, close(fd);  in LE_CreateStreamClient()
198     task->stream.base.handleEvent = HandleClientEvent_;  in LE_CreateStreamClient()
199     task->stream.base.innerClose = HandleStreamTaskClose_;  in LE_CreateStreamClient()
200     OH_ListInit(&task->stream.buffHead);  in LE_CreateStreamClient()
201     LoopMutexInit(&task->stream.mutex);  in LE_CreateStreamClient()
203     task->connectComplete = info->connectComplete;  in LE_CreateStreamClient()
204     task->sendMessageComplete = info->sendMessageComplete;  in LE_CreateStreamClient()
205     task->recvMessage = info->recvMessage;  in LE_CreateStreamClient()
206     task->disConnectComplete = info->disConnectComplete;  in LE_CreateStreamClient()
208     loop->addEvent(loop, (const BaseTask *)task, Event_Read);  in LE_CreateStreamClient()
209     *taskHandle = (TaskHandle)task;  in LE_CreateStreamClient()
224     StreamConnectTask *task = (StreamConnectTask *)CreateTask(  in LE_AcceptStreamClient()  local
226     LE_CHECK(task != NULL, close(fd);  in LE_AcceptStreamClient()
228     task->stream.base.handleEvent = HandleStreamEvent_;  in LE_AcceptStreamClient()
229     task->stream.base.innerClose = HandleStreamTaskClose_;  in LE_AcceptStreamClient()
230     task->disConnectComplete = info->disConnectComplete;  in LE_AcceptStreamClient()
231     task->sendMessageComplete = info->sendMessageComplete;  in LE_AcceptStreamClient()
232     task->recvMessage = info->recvMessage;  in LE_AcceptStreamClient()
233     task->serverTask = (StreamServerTask *)server;  in LE_AcceptStreamClient()
234     OH_ListInit(&task->stream.buffHead);  in LE_AcceptStreamClient()
235     LoopMutexInit(&task->stream.mutex);  in LE_AcceptStreamClient()
238         loop->addEvent(loop, (const BaseTask *)task, Event_Read);  in LE_AcceptStreamClient()
240     *taskHandle = (TaskHandle)task;  in LE_AcceptStreamClient()