--- libaitsched/example/test_time.c 2012/05/31 14:45:10 1.3.2.1 +++ libaitsched/example/test_time.c 2012/07/24 14:06:10 1.5 @@ -2,13 +2,16 @@ #include #include #include +#include #include +#include #include #include #include #include intptr_t Kill; +sched_root_task_t *root; void *event(sched_task_t *arg) { @@ -24,7 +27,7 @@ void *eventlo(sched_task_t *arg) void *timer(sched_task_t *arg) { - printf("Timer %d sec::\n", (int) TASK_ARG(arg)); + printf("Timer %p sec::\n", TASK_ARG(arg)); return NULL; } @@ -36,13 +39,14 @@ void *alarmz(sched_task_t *arg) void *node(sched_task_t *arg) { - printf("Node %s\n", (char*) TASK_ARG(arg)); + printf("Node %s fflags 0x%X\n", (char*) TASK_ARG(arg), (u_int) TASK_DATLEN(arg)); return NULL; } void *proc(sched_task_t *arg) { - printf("Proc pid=%ld\n", TASK_VAL(arg)); + printf("Proc pid=%ld fflags 0x%X data %p\n", TASK_VAL(arg), (u_int) TASK_DATLEN(arg), + TASK_DATA(arg)); return NULL; } @@ -52,12 +56,30 @@ void *sigz(sched_task_t *arg) return NULL; } +#ifdef EVFILT_USER void *user(sched_task_t *arg) { - printf("User trigger id %ld\n", TASK_VAL(arg)); + printf("User trigger id %ld fflags %d\n", TASK_VAL(arg), TASK_DATLEN(arg) & NOTE_FFLAGSMASK); return NULL; } +#endif +void *susp1(sched_task_t *arg) +{ + printf("Suspend 1 =%ld\n", TASK_VAL(arg)); + return NULL; +} +void *susp2(sched_task_t *arg) +{ + printf("Suspend 2 =%ld\n", TASK_VAL(arg)); + return NULL; +} +void *susp3(sched_task_t *arg) +{ + printf("Suspend 3 =%ld\n", TASK_VAL(arg)); + return NULL; +} + void *once(sched_task_t *arg) { printf("once::\n"); @@ -70,18 +92,29 @@ void sig(int s) case SIGTERM: Kill++; break; + case SIGUSR1: + schedResumeby(root, CRITERIA_ID, (void*) 0); + schedResumeby(root, CRITERIA_ID, (void*) 7); + break; } } int main(int argc, char **argv) { - sched_root_task_t *root; struct timespec ts = { 20, 0 }; // struct timespec p = { 0, 10000000 }; int f = 0; + struct sigaction sa; +#ifdef EVFILT_USER + sched_task_t *t[4]; +#endif + sched_task_t *task; - signal(SIGTERM, sig); + sa.sa_handler = sig; + sigemptyset(&sa.sa_mask); + sigaction(SIGTERM, &sa, NULL); + sigaction(SIGUSR1, &sa, NULL); root = schedBegin(); if (!root) { @@ -89,12 +122,12 @@ main(int argc, char **argv) return 1; } - if (!schedTimer(root, timer, (void*) ts.tv_sec, ts, NULL, 0)) { + if (!schedTimer(root, timer, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 4; } else ts.tv_sec = 15; - if (!schedTimer(root, timer, (void*) ts.tv_sec, ts, NULL, 0)) { + if (!schedTimer(root, timer, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 4; } else @@ -110,12 +143,12 @@ main(int argc, char **argv) return 3; } - if (!schedTimer(root, timer, (void*) ts.tv_sec, ts, NULL, 0)) { + if (!schedTimer(root, timer, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 4; } - if (!schedAlarm(root, alarmz, (void*) ts.tv_sec, ts, NULL, 0)) { + if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 5; } else { @@ -123,26 +156,52 @@ main(int argc, char **argv) ts.tv_nsec = 500000000; } - if (!schedAlarm(root, alarmz, (void*) ts.tv_sec, ts, (void*) 1, 0)) { + if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, (void*) 1, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 5; } - if (!schedAlarm(root, alarmz, (void*) ts.tv_sec, ts, (void*) 2, 0)) { + if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, (void*) 2, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 5; } else { ts.tv_sec = 0; ts.tv_nsec = 700000000; } - if (!schedAlarm(root, alarmz, (void*) ts.tv_sec, ts, (void*) 3, 0)) { + if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, (void*) 3, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 5; } - if (!schedUser(root, user, NULL, 42, 0, 0)) { +#ifdef EVFILT_USER + if (!(t[0] = schedUser(root, user, NULL, 42, 0, 0))) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); return 6; } + if (!(t[1] = schedUser(root, user, NULL, 1, 0, 73))) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 6; + } + if (!(t[2] = schedUser(root, user, NULL, 0xaa, 0, NOTE_FFAND | 0xaa))) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 6; + } + if (!(t[3] = schedUser(root, user, NULL, -1, 0, NOTE_FFCOPY | 1003))) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 6; + } +#endif + if (!schedSuspend(root, susp1, NULL, 7, NULL, 0)) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 6; + } + if (!(task = schedSuspend(root, susp2, NULL, 1, NULL, 0))) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 6; + } + if (!schedSuspend(root, susp3, NULL, 0, NULL, 0)) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 6; + } if (argc > 1) if (!schedProc(root, proc, NULL, atoi(argv[1]), 0, 0)) { @@ -161,6 +220,23 @@ main(int argc, char **argv) return 8; } } + +#ifdef EVFILT_USER + schedTrigger(t[3]); + schedTrigger(t[1]); +#endif + schedResumeby(root, CRITERIA_DATA, task); + + if (!schedSignal(root, sigz, NULL, SIGUSR1, 0, 0)) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + close(f); + return 9; + } + +#ifdef EVFILT_USER + schedTrigger(t[2]); + schedTrigger(t[0]); +#endif schedCallOnce(root, once, "000000", 42, NULL, 0);