Lines Matching refs:taskHandle
151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle) in LE_FreeBuffer() argument
153 FreeBuffer(loop, (StreamTask *)taskHandle, (LE_Buffer *)handle); in LE_FreeBuffer()
170 const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen) in LE_Send() argument
173 LE_CHECK(taskHandle != NULL, return LE_INVALID_TASK, "Invalid task"); in LE_Send()
175 if (((BaseTask *)taskHandle)->flags & TASK_FLAGS_INVALID) { in LE_Send()
176 LE_FreeBuffer(loopHandle, taskHandle, buffHandle); in LE_Send()
181 if (CheckTaskFlags((BaseTask *)taskHandle, TASK_STREAM | TASK_CONNECT)) { in LE_Send()
182 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
183 } else if (CheckTaskFlags((BaseTask *)taskHandle, TASK_EVENT | TASK_ASYNC_EVENT)) { in LE_Send()
184 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
186 loop->modEvent(loop, (BaseTask *)taskHandle, EVENT_WRITE); in LE_Send()
190 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask() argument
192 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters"); in LE_CloseTask()
193 if (((LoopBase*)taskHandle)->flags & TASK_TIME) { in LE_CloseTask()
194 LE_StopTimer(loopHandle, taskHandle); in LE_CloseTask()
197 LE_LOGV("LE_CloseTask %d", GetSocketFd(taskHandle)); in LE_CloseTask()
198 BaseTask *task = (BaseTask *)taskHandle; in LE_CloseTask()
200 task->innerClose(loopHandle, taskHandle); in LE_CloseTask()