Annotation of libaitsched/example/test_time.c, revision 1.10.8.1
1.2 misho 1: #include <stdio.h>
1.4 misho 2: #include <stdlib.h>
1.2 misho 3: #include <unistd.h>
4: #include <fcntl.h>
1.4 misho 5: #include <signal.h>
1.2 misho 6: #include <sys/types.h>
1.4 misho 7: #include <sys/event.h>
1.2 misho 8: #include <sys/stat.h>
9: #include <sys/signal.h>
10: #include <netinet/in.h>
11: #include <aitsched.h>
12:
13: intptr_t Kill;
1.5 misho 14: sched_root_task_t *root;
1.2 misho 15:
16: void *event(sched_task_t *arg)
17: {
18: printf("Event::\n");
1.9 misho 19: taskExit(arg, NULL);
1.2 misho 20: }
21:
1.6 misho 22: void *regular(sched_task_t *arg)
1.2 misho 23: {
1.7 misho 24: printf("Task(%lu):: %s\n", TASK_VAL(arg), (char*) TASK_ARG(arg));
1.6 misho 25: fflush(stdout);
1.9 misho 26: taskExit(arg, NULL);
1.2 misho 27: }
28:
29: void *timer(sched_task_t *arg)
30: {
1.4 misho 31: printf("Timer %p sec::\n", TASK_ARG(arg));
1.9 misho 32: taskExit(arg, NULL);
1.2 misho 33: }
34:
1.3 misho 35: void *alarmz(sched_task_t *arg)
36: {
1.4 misho 37: printf("Alarm %ld sec::\n", (u_long) TASK_ARG(arg));
1.9 misho 38: taskExit(arg, NULL);
1.3 misho 39: }
40:
1.4 misho 41: void *node(sched_task_t *arg)
42: {
1.10.8.1! misho 43: printf("Node %s data %ld fflags 0x%X\n", (char*) TASK_ARG(arg), (long) TASK_RET(arg), TASK_FLAG(arg));
1.9 misho 44: taskExit(arg, NULL);
1.4 misho 45: }
46:
47: void *proc(sched_task_t *arg)
48: {
1.10.8.1! misho 49: printf("Proc pid=%ld data %ld fflags 0x%X\n", TASK_VAL(arg), (long) TASK_RET(arg), TASK_FLAG(arg));
1.9 misho 50: taskExit(arg, NULL);
1.4 misho 51: }
52:
53: void *sigz(sched_task_t *arg)
54: {
1.10.8.1! misho 55: printf("Signal signal=%ld how many times %ld\n", TASK_VAL(arg), (long) TASK_RET(arg));
1.9 misho 56: taskExit(arg, NULL);
1.4 misho 57: }
58:
59: #ifdef EVFILT_USER
60: void *user(sched_task_t *arg)
61: {
1.8 misho 62: printf("User trigger id %ld fflags %d\n", TASK_VAL(arg), TASK_FLAG(arg) & NOTE_FFLAGSMASK);
1.9 misho 63: taskExit(arg, NULL);
1.4 misho 64: }
65: #endif
66:
1.5 misho 67: void *susp1(sched_task_t *arg)
68: {
69: printf("Suspend 1 =%ld\n", TASK_VAL(arg));
1.9 misho 70: taskExit(arg, NULL);
1.5 misho 71: }
72: void *susp2(sched_task_t *arg)
73: {
74: printf("Suspend 2 =%ld\n", TASK_VAL(arg));
1.9 misho 75: taskExit(arg, NULL);
1.5 misho 76: }
77: void *susp3(sched_task_t *arg)
78: {
79: printf("Suspend 3 =%ld\n", TASK_VAL(arg));
1.9 misho 80: taskExit(arg, NULL);
1.5 misho 81: }
82:
1.2 misho 83: void *once(sched_task_t *arg)
84: {
85: printf("once::\n");
1.9 misho 86: taskExit(arg, NULL);
87: }
88:
89: void *thr(sched_task_t *arg)
90: {
91: printf("tid (%lx):: %s\n", TASK_VAL(arg), __func__);
92: printf("tid (%lu):: %s\n", TASK_VAL(arg), (char*) TASK_ARG(arg));
93: taskExit(arg, 42);
94: }
95:
96: void *thr4kill(sched_task_t *arg)
97: {
98: char blah[BUFSIZ];
99:
100: printf("tid (%lx):: %s\n", TASK_VAL(arg), __func__);
101:
102: read(0, blah, sizeof blah);
103: printf("never see!!! (%lx):: %s (%d == %d)\n", TASK_VAL(arg), (char*) TASK_ARG(arg), TASK_TYPE(arg), taskTHREAD);
104: taskExit(arg, 0);
1.2 misho 105: }
106:
107: void sig(int s)
108: {
109: switch (s) {
1.9 misho 110: case SIGINT:
1.2 misho 111: case SIGTERM:
112: Kill++;
113: break;
1.4 misho 114: case SIGUSR1:
1.5 misho 115: schedResumeby(root, CRITERIA_ID, (void*) 0);
116: schedResumeby(root, CRITERIA_ID, (void*) 7);
1.4 misho 117: break;
1.2 misho 118: }
119: }
120:
121: int
122: main(int argc, char **argv)
123: {
124: struct timespec ts = { 20, 0 };
125: // struct timespec p = { 0, 10000000 };
1.4 misho 126: int f = 0;
127: struct sigaction sa;
1.9 misho 128: sched_task_t *t;
1.4 misho 129: #ifdef EVFILT_USER
1.9 misho 130: sched_task_t *tt[4];
1.4 misho 131: #endif
1.5 misho 132: sched_task_t *task;
1.4 misho 133:
134: sa.sa_handler = sig;
135: sigemptyset(&sa.sa_mask);
136: sigaction(SIGTERM, &sa, NULL);
1.9 misho 137: sigaction(SIGINT, &sa, NULL);
1.4 misho 138: sigaction(SIGUSR1, &sa, NULL);
1.2 misho 139:
140: root = schedBegin();
141: if (!root) {
142: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
143: return 1;
144: }
145:
1.4 misho 146: if (!schedTimer(root, timer, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) {
1.2 misho 147: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
148: return 4;
149: } else
150: ts.tv_sec = 15;
1.4 misho 151: if (!schedTimer(root, timer, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) {
1.2 misho 152: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
153: return 4;
154: } else
155: ts.tv_sec = 10;
156:
157: if (!schedEvent(root, event, "piuk", 1234, NULL, 0)) {
158: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
159: return 2;
160: }
161:
1.7 misho 162: if (!schedTask(root, regular, "piuk", 11, NULL, 0)) {
163: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
164: return 3;
165: }
166: if (!schedTask(root, regular, "piuk", 1, NULL, 0)) {
167: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
168: return 3;
169: }
170: if (!schedTask(root, regular, "piuk", 0, NULL, 0)) {
171: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
172: return 3;
173: }
174: if (!schedTask(root, regular, "piuk", 1000001, NULL, 0)) {
1.2 misho 175: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
176: return 3;
177: }
178:
1.4 misho 179: if (!schedTimer(root, timer, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) {
1.2 misho 180: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
181: return 4;
182: }
183:
1.4 misho 184: if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, NULL, 0)) {
1.3 misho 185: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
186: return 5;
187: } else {
188: ts.tv_sec = 3;
189: ts.tv_nsec = 500000000;
190: }
191:
1.4 misho 192: if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, (void*) 1, 0)) {
1.3 misho 193: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
194: return 5;
195: }
1.4 misho 196: if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, (void*) 2, 0)) {
1.3 misho 197: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
198: return 5;
199: } else {
200: ts.tv_sec = 0;
201: ts.tv_nsec = 700000000;
202: }
1.4 misho 203: if (!schedAlarm(root, alarmz, (void*) (intptr_t) ts.tv_sec, ts, (void*) 3, 0)) {
1.3 misho 204: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
205: return 5;
206: }
207:
1.4 misho 208: #ifdef EVFILT_USER
1.9 misho 209: if (!(tt[0] = schedUser(root, user, NULL, 42, 0, 0))) {
1.4 misho 210: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
211: return 6;
212: }
1.9 misho 213: if (!(tt[1] = schedUser(root, user, NULL, 1, 0, 73))) {
1.4 misho 214: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
215: return 6;
216: }
1.9 misho 217: if (!(tt[2] = schedUser(root, user, NULL, 0xaa, 0, NOTE_FFAND | 0xaa))) {
1.4 misho 218: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
219: return 6;
220: }
1.9 misho 221: if (!(tt[3] = schedUser(root, user, NULL, -1, 0, NOTE_FFCOPY | 1003))) {
1.4 misho 222: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
223: return 6;
224: }
225: #endif
1.5 misho 226: if (!schedSuspend(root, susp1, NULL, 7, NULL, 0)) {
227: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
228: return 6;
229: }
230: if (!(task = schedSuspend(root, susp2, NULL, 1, NULL, 0))) {
231: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
232: return 6;
233: }
234: if (!schedSuspend(root, susp3, NULL, 0, NULL, 0)) {
235: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
236: return 6;
237: }
1.4 misho 238:
1.10 misho 239: if (!(t = schedThread(root, thr4kill, "0aaaa", 0, 0, NULL, 0))) {
1.9 misho 240: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
241: return 7;
242: }
1.10 misho 243: if (!schedThread(root, thr, "mdaaaa this is thread task", 0, 131072, NULL, 0)) {
1.9 misho 244: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
245: return 7;
246: }
1.10 misho 247: if (!schedThread(root, thr, "mdaaaa this is thread task -detached", 42, 0, NULL, 0)) {
1.9 misho 248: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
249: return 7;
250: }
1.10 misho 251: if (!schedThread(root, thr, "mdaaaa this is thread task -j", 0, 131072, NULL, 0)) {
1.9 misho 252: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
253: return 7;
254: }
255: printf("try to cancel tid = %lx\n", TASK_VAL(t));
256: schedCancel(t);
1.10 misho 257: if (!schedThread(root, thr, "mdaaaa this is thread task -j2", 0, 131072 * 2, NULL, 0)) {
1.9 misho 258: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
259: return 7;
260: }
1.10 misho 261: if (!(t = schedThread(root, thr4kill, "0aaaa", 42, /*4096*/0, NULL, 0))) {
1.9 misho 262: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
263: return 7;
264: }
1.10 misho 265: if (!schedThread(root, thr, "mdaaaa this is thread task -j3", 0, 0, NULL, 0)) {
1.9 misho 266: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
267: return 7;
268: }
269: sleep(1);
270: schedCancel(t);
271:
1.4 misho 272: if (argc > 1)
273: if (!schedProc(root, proc, NULL, atoi(argv[1]), 0, 0)) {
274: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
275: return 7;
276: }
277: if (argc > 2) {
278: f = open(argv[2], O_RDWR);
279: if (f == -1) {
280: perror("open()");
281: return 8;
282: }
283: if (!schedNode(root, node, argv[2], f, 0, 0)) {
284: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
285: close(f);
286: return 8;
287: }
288: }
289:
290: #ifdef EVFILT_USER
1.9 misho 291: schedTrigger(tt[3]);
292: schedTrigger(tt[1]);
1.4 misho 293: #endif
1.5 misho 294: schedResumeby(root, CRITERIA_DATA, task);
1.4 misho 295:
296: if (!schedSignal(root, sigz, NULL, SIGUSR1, 0, 0)) {
297: printf("Error:: #%d - %s\n", sched_GetErrno(), sched_GetError());
298: close(f);
299: return 9;
300: }
301:
302: #ifdef EVFILT_USER
1.9 misho 303: schedTrigger(tt[2]);
304: schedTrigger(tt[0]);
1.4 misho 305: #endif
306:
1.2 misho 307: schedCallOnce(root, once, "000000", 42, NULL, 0);
308:
309: printf("read_queue=%d timer_queue=%d\n",
310: ROOT_QUEUE_EMPTY(root, read), ROOT_QUEUE_EMPTY(root, timer));
311:
312: // schedPolling(root, &p, NULL);
313: schedRun(root, &Kill);
314: schedEnd(&root);
1.4 misho 315:
316: if (f > 2)
317: close(f);
1.2 misho 318: return 0;
319: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to test_time.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / libaitsched / example