version 1.19, 2013/08/15 19:10:48
|
version 1.24, 2013/11/14 21:37:27
|
Line 629 sched_hook_fetch(void *root, void *arg __unused)
|
Line 629 sched_hook_fetch(void *root, void *arg __unused)
|
return NULL; |
return NULL; |
} else if (errno != EINTR) |
} else if (errno != EINTR) |
LOGERR; |
LOGERR; |
return NULL; | goto skip_event; |
} |
} |
|
|
|
/* kevent dispatcher */ |
now.tv_sec = now.tv_nsec = 0; |
now.tv_sec = now.tv_nsec = 0; |
/* Go and catch the cat into pipes ... */ |
/* Go and catch the cat into pipes ... */ |
for (i = 0; i < en; i++) { |
for (i = 0; i < en; i++) { |
Line 1003 sched_hook_fetch(void *root, void *arg __unused)
|
Line 1004 sched_hook_fetch(void *root, void *arg __unused)
|
} else |
} else |
LOGERR; |
LOGERR; |
} |
} |
} | } /* end of kevent dispatcher */ |
|
|
|
skip_event: |
/* timer update & put in ready queue */ |
/* timer update & put in ready queue */ |
clock_gettime(CLOCK_MONOTONIC, &now); |
clock_gettime(CLOCK_MONOTONIC, &now); |
|
|
Line 1146 sched_hook_rtc(void *task, void *arg __unused)
|
Line 1148 sched_hook_rtc(void *task, void *arg __unused)
|
|
|
memset(&evt, 0, sizeof evt); |
memset(&evt, 0, sizeof evt); |
evt.sigev_notify = SIGEV_SIGNAL; |
evt.sigev_notify = SIGEV_SIGNAL; |
evt.sigev_signo = (int) TASK_DATA(t) + SIGRTMIN; | evt.sigev_signo = (intptr_t) TASK_DATA(t) + SIGRTMIN; |
evt.sigev_value.sival_ptr = TASK_DATA(t); |
evt.sigev_value.sival_ptr = TASK_DATA(t); |
|
|
if (timer_create(CLOCK_MONOTONIC, &evt, &tmr) == -1) { |
if (timer_create(CLOCK_MONOTONIC, &evt, &tmr) == -1) { |
Line 1158 sched_hook_rtc(void *task, void *arg __unused)
|
Line 1160 sched_hook_rtc(void *task, void *arg __unused)
|
} else |
} else |
TASK_FLAG(t) = (u_long) tmr; |
TASK_FLAG(t) = (u_long) tmr; |
|
|
if (!(sigt = schedSignal(TASK_ROOT(t), TASK_FUNC(t), TASK_ARG(t), evt.sigev_signo, | if (!(sigt = schedSignal(TASK_ROOT(t), _sched_rtcWrapper, TASK_ARG(t), evt.sigev_signo, |
TASK_DATA(t), (size_t) tmr))) { | t, (size_t) tmr))) { |
if (TASK_ROOT(t)->root_hooks.hook_exec.exception) |
if (TASK_ROOT(t)->root_hooks.hook_exec.exception) |
TASK_ROOT(t)->root_hooks.hook_exec.exception(TASK_ROOT(t), NULL); |
TASK_ROOT(t)->root_hooks.hook_exec.exception(TASK_ROOT(t), NULL); |
else |
else |