Lines Matching refs:loopHandle
24 static void DoAsyncEvent_(const LoopHandle loopHandle, AsyncEventTask *asyncTask)
26 LE_CHECK(loopHandle != NULL && asyncTask != NULL, return, "Invalid parameters");
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle)
62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle);
67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
69 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");
71 EventLoop *loop = (EventLoop *)loopHandle;
77 DoAsyncEvent_(loopHandle, asyncTask);
91 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)
94 DelTask((EventLoop *)loopHandle, task);
95 CloseTask(loopHandle, task);
108 LE_STATUS LE_CreateAsyncTask(const LoopHandle loopHandle,
111 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");
117 AsyncEventTask *task = (AsyncEventTask *)CreateTask(loopHandle, fd, &baseInfo, sizeof(AsyncEventTask));
126 EventLoop *loop = (EventLoop *)loopHandle;
132 LE_STATUS LE_StartAsyncEvent(const LoopHandle loopHandle,
135 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");
136 BufferHandle handle = LE_CreateBuffer(loopHandle, buffLen + 1 + sizeof(eventId));
146 return LE_Send(loopHandle, taskHandle, handle, buffLen);
149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle)
151 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters");
152 LE_CloseTask(loopHandle, taskHandle);