--- libaitsched/example/test.c 2013/08/26 18:48:23 1.13 +++ libaitsched/example/test.c 2014/06/05 22:37:29 1.14 @@ -11,7 +11,7 @@ #include "../inc/config.h" #include -intptr_t Kill; +intptr_t Kill[1]; #ifdef AIO_SUPPORT struct iovec iv[3], wiv[3], riv[3]; #endif @@ -37,7 +37,7 @@ void *timer(sched_task_t *arg) void *r(sched_task_t *arg) { printf("read:: %ld bytes wait\n", (long) TASK_RET(arg)); - Kill++; + Kill[0]++; taskExit(arg, NULL); } @@ -125,7 +125,7 @@ void *thr4kill(sched_task_t *arg) { char blah[BUFSIZ]; - printf("tid (%lx):: %s\n", TASK_VAL(arg), __func__); + printf("THREAD!!! tid (%lx):: %s\n", TASK_VAL(arg), __func__); read(0, blah, sizeof blah); printf("never see!!! (%lx):: %s (%d == %d)\n", TASK_VAL(arg), (char*) TASK_ARG(arg), TASK_TYPE(arg), taskTHREAD); @@ -136,7 +136,7 @@ void sig(int s) { switch (s) { case SIGTERM: - Kill++; + Kill[0]++; break; } } @@ -163,7 +163,9 @@ main(int argc, char **argv) f = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); if (f == -1) return 1; +#ifndef __linux__ sin.sin_len = sizeof sin; +#endif sin.sin_family = AF_INET; sin.sin_port = htons(2345); sin.sin_addr.s_addr = INADDR_ANY; @@ -207,10 +209,15 @@ main(int argc, char **argv) return 4; } + if (!(t = schedRead(root, r, "rrr_test", f, NULL, 0))) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 5; + } if (!schedRead(root, r, "rrr", f, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 5; } + schedCancel(t); if (!schedWrite(root, w, "www", f, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); @@ -223,7 +230,7 @@ main(int argc, char **argv) } if (!schedThread(root, thr, "mdaaaa this is thread task", 8192, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); - return 7; + printf("stack is too small\n"); } if (!schedThread(root, thr, "mdaaaa this is thread task -detached", 131072, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); @@ -233,7 +240,7 @@ main(int argc, char **argv) printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 7; } - printf("try to cancel tid = %lx\n", TASK_VAL(t)); + printf("~~~try to cancel tid = %lx\n", TASK_VAL(t)); schedCancel(t); if (!schedThread(root, thr, "mdaaaa this is thread task -j2", 0, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); @@ -245,7 +252,7 @@ main(int argc, char **argv) } if (!schedThread(root, thr, "mdaaaa this is thread task -j3", 4096, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); - return 7; + printf("stack is too small\n"); } sleep(1); schedCancel(t); @@ -289,8 +296,9 @@ main(int argc, char **argv) schedCallOnce(root, once, "000000", 42, NULL, 0); // schedPolling(root, &p, NULL); - schedRun(root, &Kill); + schedRun(root, Kill); schedEnd(&root); + sleep(1); #ifdef AIO_SUPPORT for (i = 0; i < 3; i++)