X-Git-Url: http://git.archive.openwrt.org/?p=project%2Flibubox.git;a=blobdiff_plain;f=examples%2Frunqueue-example.c;h=13ab864e8671fdd412a062d60bcb1b5c6a188638;hp=727463ffac99223e67d4173b38ba9f5537ee66fa;hb=HEAD;hpb=cb6c1718e711db77f7b6a06c8bc51fe392509bbc diff --git a/examples/runqueue-example.c b/examples/runqueue-example.c index 727463f..13ab864 100644 --- a/examples/runqueue-example.c +++ b/examples/runqueue-example.c @@ -16,11 +16,11 @@ * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */ -#include #include #include #include +#include "uloop.h" #include "runqueue.h" static struct runqueue q; @@ -66,9 +66,9 @@ static void q_sleep_cancel(struct runqueue *q, struct runqueue_task *t, int type runqueue_process_cancel_cb(q, t, type); } -static void q_sleep_complete(struct runqueue *q, struct runqueue_process *p, int ret) +static void q_sleep_complete(struct runqueue *q, struct runqueue_task *p) { - struct sleeper *s = container_of(p, struct sleeper, proc); + struct sleeper *s = container_of(p, struct sleeper, proc.task); fprintf(stderr, "[%d/%d] finish 'sleep %d'\n", q->running_tasks, q->max_running_tasks, s->val); free(s); @@ -86,7 +86,7 @@ static void add_sleeper(int val) s = calloc(1, sizeof(*s)); s->proc.task.type = &sleeper_type; s->proc.task.run_timeout = 500; - s->proc.complete = q_sleep_complete; + s->proc.task.complete = q_sleep_complete; s->val = val; runqueue_task_add(&q, &s->proc.task, false); }