--- libaitsched/example/test_time.c 2012/05/30 08:34:43 1.2.4.1 +++ libaitsched/example/test_time.c 2012/08/08 08:24:51 1.5.4.1 @@ -1,13 +1,17 @@ #include +#include #include #include +#include #include +#include #include #include #include #include intptr_t Kill; +sched_root_task_t *root; void *event(sched_task_t *arg) { @@ -15,24 +19,68 @@ void *event(sched_task_t *arg) return NULL; } -void *eventlo(sched_task_t *arg) +void *regular(sched_task_t *arg) { - printf("EventLOW::\n"); + printf("Task::\n"); + fflush(stdout); return NULL; } void *timer(sched_task_t *arg) { - printf("Timer %ld sec::\n", (intptr_t) TASK_ARG(arg)); + printf("Timer %p sec::\n", TASK_ARG(arg)); return NULL; } void *alarmz(sched_task_t *arg) { - printf("Alarm %ld sec::\n", (intptr_t) TASK_ARG(arg)); + printf("Alarm %ld sec::\n", (u_long) TASK_ARG(arg)); return NULL; } +void *node(sched_task_t *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 fflags 0x%X data %p\n", TASK_VAL(arg), (u_int) TASK_DATLEN(arg), + TASK_DATA(arg)); + return NULL; +} + +void *sigz(sched_task_t *arg) +{ + printf("Signal signal=%ld\n", TASK_VAL(arg)); + return NULL; +} + +#ifdef EVFILT_USER +void *user(sched_task_t *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"); @@ -45,17 +93,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) { @@ -63,12 +123,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 @@ -79,22 +139,106 @@ main(int argc, char **argv) return 2; } - if (!schedEventLo(root, eventlo, "piuk", 1111, NULL, 0)) { + if (!schedTask(root, regular, "piuk", 1111, NULL, 0)) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); 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; } - ts.tv_sec = 11; - 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 { + ts.tv_sec = 3; + ts.tv_nsec = 500000000; } + 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*) (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*) (intptr_t) ts.tv_sec, ts, (void*) 3, 0)) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 5; + } + +#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)) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + return 7; + } + if (argc > 2) { + f = open(argv[2], O_RDWR); + if (f == -1) { + perror("open()"); + return 8; + } + if (!schedNode(root, node, argv[2], f, 0, 0)) { + printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + close(f); + 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); printf("read_queue=%d timer_queue=%d\n", @@ -103,5 +247,8 @@ main(int argc, char **argv) // schedPolling(root, &p, NULL); schedRun(root, &Kill); schedEnd(&root); + + if (f > 2) + close(f); return 0; }