Lines Matching refs:taskHandle
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle)
60 AsyncEventTask *asyncTask = (AsyncEventTask *)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");
70 LE_LOGV("HandleAsyncEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper);
72 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle;
75 int ret = read(GetSocketFd(taskHandle), &eventId, sizeof(eventId));
76 LE_LOGV("HandleAsyncEvent_ read fd:%d ret: %d eventId %llu", GetSocketFd(taskHandle), ret, eventId);
79 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_WRITE);
84 (void)write(GetSocketFd(taskHandle), &eventId, sizeof(eventId));
85 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);
91 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)
93 BaseTask *task = (BaseTask *)taskHandle;
109 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent)
111 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");
128 *taskHandle = (TaskHandle)task;
133 const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen)
135 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");
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);