Diff for /libaitsched/src/hooks.c between versions 1.2.2.2 and 1.2.2.4

version 1.2.2.2, 2011/10/04 13:50:05 version 1.2.2.4, 2011/10/04 23:03:32
Line 316  retry: Line 316  retry:
         if ((en = kevent(r->root_kq, NULL, 0, res, KQ_EVENTS, timeout)) == -1) {          if ((en = kevent(r->root_kq, NULL, 0, res, KQ_EVENTS, timeout)) == -1) {
                 if (r->root_hooks.hook_exec.exception) {                  if (r->root_hooks.hook_exec.exception) {
                         if (r->root_hooks.hook_exec.exception(r, NULL))                          if (r->root_hooks.hook_exec.exception(r, NULL))
                                return NULL;    /* exit from scheduler */                                return NULL;
                 } else                  } else
                         LOGERR;                          LOGERR;
 #ifdef NDEBUG  #ifdef NDEBUG
Line 337  retry: Line 337  retry:
                 switch (res[i].filter) {                  switch (res[i].filter) {
                         case EVFILT_READ:                          case EVFILT_READ:
                                 TAILQ_FOREACH(task, &r->root_read, task_node) {                                  TAILQ_FOREACH(task, &r->root_read, task_node) {
                                        if (TASK_FD(task) != ((int) res[i].udata))                                        if (TASK_FD(task) != ((intptr_t) res[i].udata))
                                                 continue;                                                  continue;
                                         /* remove read handle */                                          /* remove read handle */
                                         io = ROOT_DATA(task->task_root);                                          io = ROOT_DATA(task->task_root);
Line 361  retry: Line 361  retry:
                                 break;                                  break;
                         case EVFILT_WRITE:                          case EVFILT_WRITE:
                                 TAILQ_FOREACH(task, &r->root_write, task_node) {                                  TAILQ_FOREACH(task, &r->root_write, task_node) {
                                        if (TASK_FD(task) != ((int) res[i].udata))                                        if (TASK_FD(task) != ((intptr_t) res[i].udata))
                                                 continue;                                                  continue;
                                         /* remove write handle */                                          /* remove write handle */
                                         io = ROOT_DATA(task->task_root);                                          io = ROOT_DATA(task->task_root);
Line 387  retry: Line 387  retry:
                 if (kevent(r->root_kq, evt, 1, NULL, 0, &nw) == -1) {                  if (kevent(r->root_kq, evt, 1, NULL, 0, &nw) == -1) {
                         if (r->root_hooks.hook_exec.exception) {                          if (r->root_hooks.hook_exec.exception) {
                                 if (r->root_hooks.hook_exec.exception(r, NULL))                                  if (r->root_hooks.hook_exec.exception(r, NULL))
                                        return NULL;    /* exit from scheduler */                                        return NULL;
                         } else                          } else
                                 LOGERR;                                  LOGERR;
                 }                  }
Line 451  sched_hook_exception(void *root, void *arg) Line 451  sched_hook_exception(void *root, void *arg)
   
         /* if error hook exists */          /* if error hook exists */
         if (r->root_hooks.hook_root.error)          if (r->root_hooks.hook_root.error)
                return (r->root_hooks.hook_root.error(root, (void*) errno));                return (r->root_hooks.hook_root.error(root, (void*) ((intptr_t) errno)));
   
         /* default case! */          /* default case! */
         LOGERR;          LOGERR;

Removed from v.1.2.2.2  
changed lines
  Added in v.1.2.2.4


FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>