--- libaitsched/example/test.c 2012/08/21 12:54:39 1.9 +++ libaitsched/example/test.c 2012/08/21 13:01:58 1.9.2.1 @@ -19,38 +19,38 @@ struct iovec iv[3], wiv[3], riv[3]; void *event(sched_task_t *arg) { printf("Event::\n"); - return NULL; + taskExit(arg, NULL); } void *regular(sched_task_t *arg) { printf("Task::\n"); - return NULL; + taskExit(arg, NULL); } void *timer(sched_task_t *arg) { printf("Timer %p sec::\n", TASK_ARG(arg)); - return NULL; + taskExit(arg, NULL); } void *r(sched_task_t *arg) { printf("read:: %d bytes wait\n", TASK_RET(arg)); Kill++; - return NULL; + taskExit(arg, NULL); } void *w(sched_task_t *arg) { printf("write:: %d bytes wait\n", TASK_RET(arg)); - return NULL; + taskExit(arg, NULL); } void *once(sched_task_t *arg) { printf("once::\n"); - return NULL; + taskExit(arg, NULL); } #ifdef AIO_SUPPORT @@ -65,7 +65,7 @@ void *aiowrite(sched_task_t *arg) memset(ole, 0, BUFSIZ); schedAIORead(TASK_ROOT(arg), aioread, NULL, TASK_FD(arg), ole, BUFSIZ - 1, -1); - return NULL; + taskExit(arg, NULL); } void *aioread(sched_task_t *arg) @@ -83,7 +83,7 @@ void *aioread(sched_task_t *arg) } free(TASK_DATA(arg)); - return NULL; + taskExit(arg, NULL); } void *aiobulkread(sched_task_t *arg) @@ -97,7 +97,7 @@ void *aiobulkread(sched_task_t *arg) free(iv[i].iov_base); } - return NULL; + taskExit(arg, NULL); } void *aiobulkwrite(sched_task_t *arg) @@ -111,7 +111,7 @@ void *aiobulkwrite(sched_task_t *arg) free(iv[i].iov_base); } - return NULL; + taskExit(arg, NULL); } #endif