--- libaitsched/example/test.c 2012/05/31 21:51:28 1.5.6.2 +++ libaitsched/example/test.c 2012/08/01 15:17:38 1.6.8.1 @@ -1,4 +1,6 @@ #include +#include +#include #include #include #include @@ -30,7 +32,7 @@ void *timer(sched_task_t *arg) void *r(sched_task_t *arg) { - printf("read::\n"); + printf("read:: bytes\n"); Kill++; return NULL; } @@ -47,6 +49,27 @@ void *once(sched_task_t *arg) return NULL; } +void *aiowrite(sched_task_t *arg) +{ + printf("AIO write[%d]:: %d bytes\n", TASK_FD(arg), (int) TASK_DATLEN(arg)); + free(TASK_DATA(arg)); + return NULL; +} + +void *aioread(sched_task_t *arg) +{ + char *ole = malloc(BUFSIZ); + + printf("AIO read[%d]:: %d bytes\n", TASK_FD(arg), (int) TASK_DATLEN(arg)); + + write((int) TASK_ARG(arg), TASK_DATA(arg), TASK_DATLEN(arg)); + free(TASK_DATA(arg)); + + schedAIOWrite(TASK_ROOT(arg), aiowrite, TASK_ARG(arg), TASK_FD(arg), ole, + strlcpy(ole, "BAHURA OR CULTURE .... A CULTURE OR BAHURA :-)\n", BUFSIZ)); + return NULL; +} + void sig(int s) { switch (s) { @@ -60,11 +83,12 @@ int main(int argc, char **argv) { sched_root_task_t *root; - int f; + int f, fd; struct sockaddr_in sin; struct timespec ts = { 20, 0 }; // struct timespec p = { 0, 10000000 }; struct sigaction sa; + char *ole = malloc(BUFSIZ); sa.sa_handler = sig; sigemptyset(&sa.sa_mask); @@ -80,18 +104,22 @@ main(int argc, char **argv) if (bind(f, (struct sockaddr*) &sin, sizeof sin) == -1) return 1; + fd = open("test_aio.dat", O_CREAT | O_RDWR | O_TRUNC, 0644); + if (fd == -1) + return 1; + root = schedBegin(); if (!root) { printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError()); 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 @@ -107,7 +135,7 @@ 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; } @@ -122,12 +150,16 @@ main(int argc, char **argv) return 6; } + if (!schedAIORead(root, aioread, (void*) f, fd, ole, BUFSIZ)) + printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError()); + schedCallOnce(root, once, "000000", 42, NULL, 0); // schedPolling(root, &p, NULL); schedRun(root, &Kill); schedEnd(&root); + close(fd); close(f); return 0; }