Lines Matching refs:task
41 static LE_STATUS HandleTimerEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleTimerEvent_() argument
47 (void)read(GetSocketFd(task), &repeat, sizeof(repeat)); in HandleTimerEvent_()
48 TimerTask *timer = (TimerTask *)task; in HandleTimerEvent_()
49 int fd = GetSocketFd(task); in HandleTimerEvent_()
51 uint64_t userData = *(uint64_t *)LE_GetUserData(task); in HandleTimerEvent_()
52 timer->processTimer(task, (void *)userData); in HandleTimerEvent_()
68 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_() local
69 CloseTask(loopHandle, task); in HandleTimerClose_()
70 DelTask((EventLoop *)loopHandle, task); in HandleTimerClose_()
71 close(task->taskId.fd); in HandleTimerClose_()
86 TimerTask *task = (TimerTask *)CreateTask(loopHandle, fd, &baseInfo, sizeof(TimerTask)); in LE_CreateTimer() local
87 LE_CHECK(task != NULL, close(fd); in LE_CreateTimer()
89 task->base.handleEvent = HandleTimerEvent_; in LE_CreateTimer()
90 task->base.innerClose = HandleTimerClose_; in LE_CreateTimer()
91 task->processTimer = processTimer; in LE_CreateTimer()
92 *(uint64_t *)(task + 1) = (uint64_t)context; in LE_CreateTimer()
93 *timer = (TimerHandle)task; in LE_CreateTimer()
102 TimerTask *task = (TimerTask *)timer; in LE_StartTimer() local
103 task->timeout = timeout; in LE_StartTimer()
104 task->repeat = repeat; in LE_StartTimer()
105 int ret = SetTimer_(GetSocketFd(timer), task->timeout); in LE_StartTimer()
107 ret = loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_StartTimer()