Lines Matching refs:taskHandle
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
60 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in LE_DoAsyncEvent()
62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle); in LE_DoAsyncEvent()
67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32… in HandleAsyncEvent_() argument
69 … LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in HandleAsyncEvent_()
70 LE_LOGV("HandleAsyncEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleAsyncEvent_()
72 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in HandleAsyncEvent_()
75 int ret = read(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
76 …LE_LOGV("HandleAsyncEvent_ read fd:%d ret: %d eventId %llu", GetSocketFd(taskHandle), ret, eventId… in HandleAsyncEvent_()
79 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_WRITE); in HandleAsyncEvent_()
84 (void)write(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
85 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleAsyncEvent_()
91 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleAsyncTaskClose_() argument
93 BaseTask *task = (BaseTask *)taskHandle; in HandleAsyncTaskClose_()
109 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent) in LE_CreateAsyncTask() argument
111 … LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in LE_CreateAsyncTask()
128 *taskHandle = (TaskHandle)task; in LE_CreateAsyncTask()
133 const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen) in LE_StartAsyncEvent() argument
135 … LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in LE_StartAsyncEvent()
146 return LE_Send(loopHandle, taskHandle, handle, buffLen); in LE_StartAsyncEvent()
149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask() argument
151 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters"); in LE_StopAsyncTask()
152 LE_CloseTask(loopHandle, taskHandle); in LE_StopAsyncTask()