131     BaseTask *task = (BaseTask *)taskHandle;  in HandleStreamTaskClose_()  local
132     CloseTask(loopHandle, task);  in HandleStreamTaskClose_()
133     if (task->taskId.fd > 0) {  in HandleStreamTaskClose_()
134         close(task->taskId.fd);  in HandleStreamTaskClose_()
171     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,  in LE_CreateStreamServer()  local
173     LE_CHECK(task != NULL, close(fd);  in LE_CreateStreamServer()
175     task->base.handleEvent = HandleServerEvent_;  in LE_CreateStreamServer()
176     task->base.innerClose = HandleStreamTaskClose_;  in LE_CreateStreamServer()
177     task->incommingConnect = info->incommingConnect;  in LE_CreateStreamServer()
178     loop->addEvent(loop, (const BaseTask *)task, Event_Read);  in LE_CreateStreamServer()
179 …int ret = memcpy_s(task->server, strlen(info->server) + 1, info->server, strlen(info->server) + 1);  in LE_CreateStreamServer()
181     *taskHandle = (TaskHandle)task;  in LE_CreateStreamServer()
194 …StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(St…  in LE_CreateStreamClient()  local
195     LE_CHECK(task != NULL, close(fd);  in LE_CreateStreamClient()
197     task->stream.base.handleEvent = HandleClientEvent_;  in LE_CreateStreamClient()
198     task->stream.base.innerClose = HandleStreamTaskClose_;  in LE_CreateStreamClient()
199     OH_ListInit(&task->stream.buffHead);  in LE_CreateStreamClient()
200     LoopMutexInit(&task->stream.mutex);  in LE_CreateStreamClient()
202     task->connectComplete = info->connectComplete;  in LE_CreateStreamClient()
203     task->sendMessageComplete = info->sendMessageComplete;  in LE_CreateStreamClient()
204     task->recvMessage = info->recvMessage;  in LE_CreateStreamClient()
205     task->disConnectComplete = info->disConnectComplete;  in LE_CreateStreamClient()
207     loop->addEvent(loop, (const BaseTask *)task, Event_Read);  in LE_CreateStreamClient()
208     *taskHandle = (TaskHandle)task;  in LE_CreateStreamClient()
223     StreamConnectTask *task = (StreamConnectTask *)CreateTask(  in LE_AcceptStreamClient()  local
225     LE_CHECK(task != NULL, close(fd);  in LE_AcceptStreamClient()
227     task->stream.base.handleEvent = HandleStreamEvent_;  in LE_AcceptStreamClient()
228     task->stream.base.innerClose = HandleStreamTaskClose_;  in LE_AcceptStreamClient()
229     task->disConnectComplete = info->disConnectComplete;  in LE_AcceptStreamClient()
230     task->sendMessageComplete = info->sendMessageComplete;  in LE_AcceptStreamClient()
231     task->recvMessage = info->recvMessage;  in LE_AcceptStreamClient()
232     task->serverTask = (StreamServerTask *)server;  in LE_AcceptStreamClient()
233     OH_ListInit(&task->stream.buffHead);  in LE_AcceptStreamClient()
234     LoopMutexInit(&task->stream.mutex);  in LE_AcceptStreamClient()
237         loop->addEvent(loop, (const BaseTask *)task, Event_Read);  in LE_AcceptStreamClient()
239     *taskHandle = (TaskHandle)task;  in LE_AcceptStreamClient()