24 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle,  in HandleSendMsg_()  argument
27     EventLoop *loop = (EventLoop *)loopHandle;  in HandleSendMsg_()
37         FreeBuffer(loopHandle, stream, buffer);  in HandleSendMsg_()
48 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle,  in HandleRecvMsg_()  argument
72         FreeBuffer(loopHandle, NULL, buffer);  in HandleRecvMsg_()
78     FreeBuffer(loopHandle, NULL, buffer);  in HandleRecvMsg_()
82 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t …  in HandleStreamEvent_()  argument
84     EventLoop *loop = (EventLoop *)loopHandle;  in HandleStreamEvent_()
90         status = HandleSendMsg_(loopHandle, handle, stream->sendMessageComplete);  in HandleStreamEvent_()
93         status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage);  in HandleStreamEvent_()
100         LE_CloseStreamTask(loopHandle, handle);  in HandleStreamEvent_()
105 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t …  in HandleClientEvent_()  argument
114         status = HandleSendMsg_(loopHandle, handle, client->sendMessageComplete);  in HandleClientEvent_()
117         status = HandleRecvMsg_(loopHandle, handle, client->recvMessage);  in HandleClientEvent_()
124         LE_CloseStreamTask(loopHandle, handle);  in HandleClientEvent_()
129 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)  in HandleStreamTaskClose_()  argument
132     CloseTask(loopHandle, task);  in HandleStreamTaskClose_()
133     DelTask((EventLoop *)loopHandle, task);  in HandleStreamTaskClose_()
139 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3…  in HandleServerEvent_()  argument
148     int ret = server->incommingConnect(loopHandle, serverTask);  in HandleServerEvent_()
152     EventLoop *loop = (EventLoop *)loopHandle;  in HandleServerEvent_()
157 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,  in LE_CreateStreamServer()  argument
160 …LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Inval…  in LE_CreateStreamServer()
171     EventLoop *loop = (EventLoop *)loopHandle;  in LE_CreateStreamServer()
172     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,  in LE_CreateStreamServer()
186 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle,  in LE_CreateStreamClient()  argument
189 …LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Inval…  in LE_CreateStreamClient()
195 …StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(St…  in LE_CreateStreamClient()
207     EventLoop *loop = (EventLoop *)loopHandle;  in LE_CreateStreamClient()
213 LE_STATUS LE_AcceptStreamClient(const LoopHandle loopHandle, const TaskHandle server,  in LE_AcceptStreamClient()  argument
216     LE_CHECK(loopHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");  in LE_AcceptStreamClient()
225         loopHandle, fd, &info->baseInfo, sizeof(StreamConnectTask));  in LE_AcceptStreamClient()
237         EventLoop *loop = (EventLoop *)loopHandle;  in LE_AcceptStreamClient()
244 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle)  in LE_CloseStreamTask()  argument
246     LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters");  in LE_CloseStreamTask()
247     LE_CloseTask(loopHandle, taskHandle);  in LE_CloseStreamTask()