version 1.24.4.8, 2014/01/28 13:01:58
|
version 1.25.2.1, 2014/01/28 16:43:41
|
Line 638 sched_hook_fetch(void *root, void *arg __unused)
|
Line 638 sched_hook_fetch(void *root, void *arg __unused)
|
struct timespec now, m, mtmp; |
struct timespec now, m, mtmp; |
#ifndef KQ_DISABLE |
#ifndef KQ_DISABLE |
struct kevent evt[1], res[KQ_EVENTS]; |
struct kevent evt[1], res[KQ_EVENTS]; |
struct timespec *timeout, m, mtmp; | struct timespec *timeout; |
#else |
#else |
struct timeval *timeout, tv; |
struct timeval *timeout, tv; |
fd_set rfd, wfd, xfd; |
fd_set rfd, wfd, xfd; |
Line 1149 sched_hook_fetch(void *root, void *arg __unused)
|
Line 1149 sched_hook_fetch(void *root, void *arg __unused)
|
continue; |
continue; |
else { |
else { |
flg++; |
flg++; |
TASK_RET(task) ^= TASK_RET(task); | TASK_FLAG(task) = ioctl(TASK_FD(task), |
TASK_FLAG(task) ^= TASK_FLAG(task); | FIONREAD, &TASK_RET(task)); |
} |
} |
/* remove read handle */ |
/* remove read handle */ |
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
Line 1203 sched_hook_fetch(void *root, void *arg __unused)
|
Line 1203 sched_hook_fetch(void *root, void *arg __unused)
|
continue; |
continue; |
else { |
else { |
flg++; |
flg++; |
TASK_RET(task) ^= TASK_RET(task); | TASK_FLAG(task) = ioctl(TASK_FD(task), |
TASK_FLAG(task) ^= TASK_FLAG(task); | FIONWRITE, &TASK_RET(task)); |
} |
} |
/* remove write handle */ |
/* remove write handle */ |
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |