26     const TaskHandle taskHandle, const LE_SendMessageComplete complete)  in HandleSendMsg_()  argument
29     StreamTask *stream = (StreamTask *)taskHandle;  in HandleSendMsg_()
32         int ret = write(GetSocketFd(taskHandle), buffer->data, buffer->dataSize);  in HandleSendMsg_()
34             LE_LOGE("HandleSendMsg_ fd:%d send data size %d %d, err:%d", GetSocketFd(taskHandle),  in HandleSendMsg_()
37 …LE_LOGV("HandleSendMsg_ fd:%d send data size %d %d", GetSocketFd(taskHandle), buffer->dataSize, re…  in HandleSendMsg_()
40             complete(taskHandle, buffer);  in HandleSendMsg_()
46         LE_LOGV("HandleSendMsg_ fd:%d empty wait read", GetSocketFd(taskHandle));  in HandleSendMsg_()
47         loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);  in HandleSendMsg_()
54 …const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMs…  in HandleRecvMsg_()  argument
61             readLen = handleRecvMsg(taskHandle, buffer->data, LOOP_DEFAULT_BUFFER, 0);  in HandleRecvMsg_()
63             readLen = recv(GetSocketFd(taskHandle), buffer->data, LOOP_DEFAULT_BUFFER, 0);  in HandleRecvMsg_()
65         LE_LOGV("HandleRecvMsg fd:%d read msg len %d", GetSocketFd(taskHandle), readLen);  in HandleRecvMsg_()
85         recvMessage(taskHandle, buffer->data, readLen);  in HandleRecvMsg_()
136 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)  in HandleStreamTaskClose_()  argument
138     BaseTask *task = (BaseTask *)taskHandle;  in HandleStreamTaskClose_()
165     TaskHandle taskHandle = (TaskHandle)connectTask;  in DumpStreamConnectTaskInfo_()  local
171     if (getsockopt(LE_GetSocketFd(taskHandle), SOL_SOCKET, SO_PEERCRED, &cred, &credSize) == 0) {  in DumpStreamConnectTaskInfo_()
201     TaskHandle *taskHandle, const LE_StreamServerInfo *info)  in LE_CreateStreamServer()  argument
203 …LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Inval…  in LE_CreateStreamServer()
230     *taskHandle = (TaskHandle)task;  in LE_CreateStreamServer()
235     TaskHandle *taskHandle, const LE_StreamInfo *info)  in LE_CreateStreamClient()  argument
237 …LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Inval…  in LE_CreateStreamClient()
258     *taskHandle = (TaskHandle)task;  in LE_CreateStreamClient()
263     TaskHandle *taskHandle, const LE_StreamInfo *info)  in LE_AcceptStreamClient()  argument
266     LE_CHECK(server != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");  in LE_AcceptStreamClient()
291     *taskHandle = (TaskHandle)task;  in LE_AcceptStreamClient()
295 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle)  in LE_CloseStreamTask()  argument
297     LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters");  in LE_CloseStreamTask()
298     LE_CloseTask(loopHandle, taskHandle);  in LE_CloseStreamTask()
301 int LE_GetSocketFd(const TaskHandle taskHandle)  in LE_GetSocketFd()  argument
303     LE_CHECK(taskHandle != NULL, return -1, "Invalid parameters");  in LE_GetSocketFd()
304     return GetSocketFd(taskHandle);  in LE_GetSocketFd()