Lines Matching defs:task
33 StreamTask *task = &asyncTask->stream;
34 ListNode *node = task->buffHead.next;
35 if (node != &task->buffHead) {
93 BaseTask *task = (BaseTask *)taskHandle;
94 DelTask((EventLoop *)loopHandle, task);
95 CloseTask(loopHandle, task);
96 close(task->taskId.fd);
99 static void DumpEventTaskInfo_(const TaskHandle task)
101 INIT_CHECK(task != NULL, return);
102 BaseTask *baseTask = (BaseTask *)task;
117 AsyncEventTask *task = (AsyncEventTask *)CreateTask(loopHandle, fd, &baseInfo, sizeof(AsyncEventTask));
118 LE_CHECK(task != NULL, close(fd);
119 return LE_NO_MEMORY, "Failed to create task");
120 task->stream.base.handleEvent = HandleAsyncEvent_;
121 task->stream.base.innerClose = HandleAsyncTaskClose_;
122 task->stream.base.dumpTaskInfo = DumpEventTaskInfo_;
123 OH_ListInit(&task->stream.buffHead);
124 LoopMutexInit(&task->stream.mutex);
125 task->processAsyncEvent = processAsyncEvent;
127 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
128 *taskHandle = (TaskHandle)task;