[BACK]Return to hooks.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitsched / src

Diff for /libaitsched/src/hooks.c between versions 1.1.1.1.2.6 and 1.1.1.1.2.8

version 1.1.1.1.2.6, 2011/08/12 12:12:01 version 1.1.1.1.2.8, 2011/09/30 08:13:41
Line 129  sched_hook_cancel(void *task, void *arg __unused) Line 129  sched_hook_cancel(void *task, void *arg __unused)
         switch (t->task_type) {          switch (t->task_type) {
                 case taskREAD:                  case taskREAD:
 #ifdef __NetBSD__  #ifdef __NetBSD__
                        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_DELETE, 0, 0, (intptr_t) &TASK_FD(t));                        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_DELETE, 0, 0, (intptr_t) TASK_FD(t));
 #else  #else
                        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_DELETE, 0, 0, &TASK_FD(t));                        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_DELETE, 0, 0, (void*) TASK_FD(t));
 #endif  #endif
                         kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout);                          kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout);
                         FD_CLR(TASK_FD(t), &io->rfd);                          FD_CLR(TASK_FD(t), &io->rfd);
                         break;                          break;
                 case taskWRITE:                  case taskWRITE:
 #ifdef __NetBSD__  #ifdef __NetBSD__
                        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_DELETE, 0, 0, (intptr_t) &TASK_FD(t));                        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_DELETE, 0, 0, (intptr_t) TASK_FD(t));
 #else  #else
                        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_DELETE, 0, 0, &TASK_FD(t));                        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_DELETE, 0, 0, (void*) TASK_FD(t));
 #endif  #endif
                         kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout);                          kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout);
                         FD_CLR(TASK_FD(t), &io->wfd);                          FD_CLR(TASK_FD(t), &io->wfd);
Line 177  sched_hook_read(void *task, void *arg __unused) Line 177  sched_hook_read(void *task, void *arg __unused)
                 FD_SET(TASK_FD(t), &io->rfd);                  FD_SET(TASK_FD(t), &io->rfd);
   
 #ifdef __NetBSD__  #ifdef __NetBSD__
        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_ADD, 0, 0, (intptr_t) &TASK_FD(t));        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_ADD, 0, 0, (intptr_t) TASK_FD(t));
 #else  #else
        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_ADD, 0, 0, &TASK_FD(t));        EV_SET(&chg[0], TASK_FD(t), EVFILT_READ, EV_ADD, 0, 0, (void*) TASK_FD(t));
 #endif  #endif
         if (kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout) == -1) {          if (kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout) == -1) {
                 LOGERR;                  LOGERR;
Line 214  sched_hook_write(void *task, void *arg __unused) Line 214  sched_hook_write(void *task, void *arg __unused)
                 FD_SET(TASK_FD(t), &io->wfd);                  FD_SET(TASK_FD(t), &io->wfd);
   
 #ifdef __NetBSD__  #ifdef __NetBSD__
        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_ADD, 0, 0, (intptr_t) &TASK_FD(t));        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_ADD, 0, 0, (intptr_t) TASK_FD(t));
 #else  #else
        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_ADD, 0, 0, &TASK_FD(t));        EV_SET(&chg[0], TASK_FD(t), EVFILT_WRITE, EV_ADD, 0, 0, (void*) TASK_FD(t));
 #endif  #endif
         if (kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout) == -1) {          if (kevent(t->task_root->root_kq, chg, 1, NULL, 0, &timeout) == -1) {
                 LOGERR;                  LOGERR;
Line 309  retry: Line 309  retry:
                 timeout = NULL;                  timeout = NULL;
         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) {
                 LOGERR;                  LOGERR;
   #ifdef NDEBUG
                   /* kevent no exit by error, if non-debug version */
                 goto retry;                  goto retry;
   #else
                   /* diagnostic exit from scheduler if kevent error occur */
                   return NULL;
   #endif
         }          }
   
         nw.tv_sec = nw.tv_nsec = 0;          nw.tv_sec = nw.tv_nsec = 0;
Line 321  retry: Line 327  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) != ((int) res[i].udata))
                                                 continue;                                                  continue;
                                         /* remove read handle */                                          /* remove read handle */
                                         io = ROOT_DATA(task->task_root);                                          io = ROOT_DATA(task->task_root);
                                         FD_CLR(TASK_FD(task), &io->rfd);                                          FD_CLR(TASK_FD(task), &io->rfd);
   
                                         TAILQ_REMOVE(&r->root_read, task, task_node);                                          TAILQ_REMOVE(&r->root_read, task, task_node);
                                        task->task_type = taskREADY;/*                                      if (res[i].flags & EV_EOF) {
                                        TAILQ_INSERT_TAIL(&r->root_ready, task, task_node);                                                task->task_type = taskUNUSE;
                                                 TAILQ_INSERT_TAIL(&r->root_unuse, task, task_node);
                                         } else { */
                                                 task->task_type = taskREADY;
                                                 TAILQ_INSERT_TAIL(&r->root_ready, task, task_node);
 /*                                      } */
                                         break;                                          break;
                                 }                                  }
                                 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) != ((int) res[i].udata))
                                                 continue;                                                  continue;
                                         /* remove write handle */                                          /* remove write handle */
                                         io = ROOT_DATA(task->task_root);                                          io = ROOT_DATA(task->task_root);
                                         FD_CLR(TASK_FD(task), &io->wfd);                                          FD_CLR(TASK_FD(task), &io->wfd);
   
                                         TAILQ_REMOVE(&r->root_write, task, task_node);                                          TAILQ_REMOVE(&r->root_write, task, task_node);
                                        task->task_type = taskREADY;/*                                      if (res[i].flags & EV_EOF) {
                                        TAILQ_INSERT_TAIL(&r->root_ready, task, task_node);                                                task->task_type = taskUNUSE;
                                                 TAILQ_INSERT_TAIL(&r->root_unuse, task, task_node);
                                         } else { */
                                                 task->task_type = taskREADY;
                                                 TAILQ_INSERT_TAIL(&r->root_ready, task, task_node);
 /*                                      } */
                                         break;                                          break;
                                 }                                  }
                                 break;                                  break;
Removed from v.1.1.1.1.2.6  
changed lines
  Added in v.1.1.1.1.2.8

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