25 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle,  in HandleSendMsg_()  argument
28     EventLoop *loop = (EventLoop *)loopHandle;  in HandleSendMsg_()
42         FreeBuffer(loopHandle, stream, buffer);  in HandleSendMsg_()
53 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle,  in HandleRecvMsg_()  argument
81         FreeBuffer(loopHandle, NULL, buffer);  in HandleRecvMsg_()
87     FreeBuffer(loopHandle, NULL, buffer);  in HandleRecvMsg_()
91 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t …  in HandleStreamEvent_()  argument
98         status = HandleSendMsg_(loopHandle, handle, stream->sendMessageComplete);  in HandleStreamEvent_()
101         status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage, stream->handleRecvMsg);  in HandleStreamEvent_()
107         LE_CloseStreamTask(loopHandle, handle);  in HandleStreamEvent_()
112 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t …  in HandleClientEvent_()  argument
121         status = HandleSendMsg_(loopHandle, handle, client->sendMessageComplete);  in HandleClientEvent_()
124         status = HandleRecvMsg_(loopHandle, handle, client->recvMessage, client->handleRecvMsg);  in HandleClientEvent_()
131         LE_CloseStreamTask(loopHandle, handle);  in HandleClientEvent_()
136 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)  in HandleStreamTaskClose_()  argument
139     DelTask((EventLoop *)loopHandle, task);  in HandleStreamTaskClose_()
140     CloseTask(loopHandle, task);  in HandleStreamTaskClose_()
182 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3…  in HandleServerEvent_()  argument
191     int ret = server->incommingConnect(loopHandle, serverTask);  in HandleServerEvent_()
195     EventLoop *loop = (EventLoop *)loopHandle;  in HandleServerEvent_()
200 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,  in LE_CreateStreamServer()  argument
203 …LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Inval…  in LE_CreateStreamServer()
218     EventLoop *loop = (EventLoop *)loopHandle;  in LE_CreateStreamServer()
219     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,  in LE_CreateStreamServer()
234 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle,  in LE_CreateStreamClient()  argument
237 …LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Inval…  in LE_CreateStreamClient()
243 …StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(St…  in LE_CreateStreamClient()
256     EventLoop *loop = (EventLoop *)loopHandle;  in LE_CreateStreamClient()
262 LE_STATUS LE_AcceptStreamClient(const LoopHandle loopHandle, const TaskHandle server,  in LE_AcceptStreamClient()  argument
265     LE_CHECK(loopHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");  in LE_AcceptStreamClient()
274         loopHandle, fd, &info->baseInfo, sizeof(StreamConnectTask));  in LE_AcceptStreamClient()
288         EventLoop *loop = (EventLoop *)loopHandle;  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()