if (!t->queued)
return;
- runqueue_task_complete(t);
if (running && t->type->kill)
t->type->kill(q, t);
- runqueue_start_next(q);
+ runqueue_task_complete(t);
}
void runqueue_stop(struct runqueue *q)
if (t->running)
t->q->running_tasks--;
+ uloop_timeout_cancel(&t->timeout);
+
safe_list_del(&t->list);
t->queued = false;
t->running = false;
t->cancelled = false;
if (t->complete)
t->complete(q, t);
- runqueue_start_next(t->q);
+ runqueue_start_next(q);
}
static void