le_streamtask.c - OpenGrok cross reference for /base/startup/init/services/loopevent/task/le

Lines Matching defs:loopHandle
25 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle,

28     EventLoop *loop = (EventLoop *)loopHandle;

42         FreeBuffer(loopHandle, stream, buffer);

53 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle,

82         FreeBuffer(loopHandle, NULL, buffer);

88     FreeBuffer(loopHandle, NULL, buffer);

92 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper)

99         status = HandleSendMsg_(loopHandle, handle, stream->sendMessageComplete);

102         status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage, stream->handleRecvMsg);

108         LE_CloseStreamTask(loopHandle, handle);

113 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper)

122         status = HandleSendMsg_(loopHandle, handle, client->sendMessageComplete);

125         status = HandleRecvMsg_(loopHandle, handle, client->recvMessage, client->handleRecvMsg);

132         LE_CloseStreamTask(loopHandle, handle);

137 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)

140     DelTask((EventLoop *)loopHandle, task);

141     CloseTask(loopHandle, task);

183 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint32_t oper)

192     int ret = server->incommingConnect(loopHandle, serverTask);

196     EventLoop *loop = (EventLoop *)loopHandle;

201 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,

204     LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");

219     EventLoop *loop = (EventLoop *)loopHandle;

220     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,

235 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle,

238     LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");

244     StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(StreamClientTask));

257     EventLoop *loop = (EventLoop *)loopHandle;

263 LE_STATUS LE_AcceptStreamClient(const LoopHandle loopHandle, const TaskHandle server,

266     LE_CHECK(loopHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");

275         loopHandle, fd, &info->baseInfo, sizeof(StreamConnectTask));

289         EventLoop *loop = (EventLoop *)loopHandle;

296 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle)

298     LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters");

299     LE_CloseTask(loopHandle, taskHandle);