--- libaitsched/example/test.c 2012/08/21 12:54:39 1.9 +++ libaitsched/example/test.c 2012/08/22 10:33:45 1.9.2.3 @@ -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 @@ -121,6 +121,13 @@ void *thr(sched_task_t *arg) taskExit(arg, 42); } +void *thr4kill(sched_task_t *arg) +{ + sleep(3); + printf("never see!!! (%lu):: %s\n", TASK_VAL(arg), (char*) TASK_ARG(arg)); + taskExit(arg, 0); +} + void sig(int s) { switch (s) { @@ -139,6 +146,7 @@ main(int argc, char **argv) struct timespec ts = { 20, 0 }; // struct timespec p = { 0, 10000000 }; struct sigaction sa; + sched_task_t *t; #ifdef AIO_SUPPORT char *ole = malloc(BUFSIZ); register int i; @@ -209,6 +217,10 @@ main(int argc, char **argv) printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 7; } + if (!(t = schedThread(root, thr4kill, "0aaaa", 0, NULL, 0))) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 7; + } if (!schedThread(root, thr, "mdaaaa this is thread task -detached", 42, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 7; @@ -217,6 +229,7 @@ main(int argc, char **argv) printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 7; } + schedCancel(t); #ifdef AIO_SUPPORT memset(ole, 0, BUFSIZ);