Diff for /libaitsched/src/aitsched.c between versions 1.11.2.1 and 1.13

version 1.11.2.1, 2012/07/30 00:20:27 version 1.13, 2012/08/08 08:25:39
Line 140  schedInit(void ** __restrict data, size_t datlen) Line 140  schedInit(void ** __restrict data, size_t datlen)
         } else {          } else {
                 memset(root, 0, sizeof(sched_root_task_t));                  memset(root, 0, sizeof(sched_root_task_t));
   
                   /* set default maximum regular task hit misses */
                   root->root_miss = MAX_TASK_MISS;
   
                 /* INFINIT polling period by default */                  /* INFINIT polling period by default */
                 sched_timespecinf(&root->root_poll);                  sched_timespecinf(&root->root_poll);
   
Line 163  schedInit(void ** __restrict data, size_t datlen) Line 166  schedInit(void ** __restrict data, size_t datlen)
                 TAILQ_INIT(&root->root_alarm);                  TAILQ_INIT(&root->root_alarm);
                 TAILQ_INIT(&root->root_node);                  TAILQ_INIT(&root->root_node);
                 TAILQ_INIT(&root->root_proc);                  TAILQ_INIT(&root->root_proc);
                 TAILQ_INIT(&root->root_user);  
                 TAILQ_INIT(&root->root_signal);                  TAILQ_INIT(&root->root_signal);
                   TAILQ_INIT(&root->root_aio);
                   TAILQ_INIT(&root->root_lio);
                   TAILQ_INIT(&root->root_user);
                 TAILQ_INIT(&root->root_event);                  TAILQ_INIT(&root->root_event);
                TAILQ_INIT(&root->root_eventlo);                TAILQ_INIT(&root->root_task);
                 TAILQ_INIT(&root->root_suspend);                  TAILQ_INIT(&root->root_suspend);
                 TAILQ_INIT(&root->root_ready);                  TAILQ_INIT(&root->root_ready);
                 TAILQ_INIT(&root->root_unuse);                  TAILQ_INIT(&root->root_unuse);
Line 223  schedEnd(sched_root_task_t ** __restrict root) Line 228  schedEnd(sched_root_task_t ** __restrict root)
                 schedCancel(task);                  schedCancel(task);
         TAILQ_FOREACH_SAFE(task, &(*root)->root_proc, task_node, tmp)          TAILQ_FOREACH_SAFE(task, &(*root)->root_proc, task_node, tmp)
                 schedCancel(task);                  schedCancel(task);
         TAILQ_FOREACH_SAFE(task, &(*root)->root_user, task_node, tmp)  
                 schedCancel(task);  
         TAILQ_FOREACH_SAFE(task, &(*root)->root_signal, task_node, tmp)          TAILQ_FOREACH_SAFE(task, &(*root)->root_signal, task_node, tmp)
                 schedCancel(task);                  schedCancel(task);
           TAILQ_FOREACH_SAFE(task, &(*root)->root_aio, task_node, tmp)
                   schedCancel(task);
           TAILQ_FOREACH_SAFE(task, &(*root)->root_lio, task_node, tmp)
                   schedCancel(task);
           TAILQ_FOREACH_SAFE(task, &(*root)->root_user, task_node, tmp)
                   schedCancel(task);
         TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp)          TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp)
                 schedCancel(task);                  schedCancel(task);
        TAILQ_FOREACH_SAFE(task, &(*root)->root_eventlo, task_node, tmp)        TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp)
                 schedCancel(task);                  schedCancel(task);
         TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp)          TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp)
                 schedCancel(task);                  schedCancel(task);
Line 375  schedCancel(sched_task_t * __restrict task) Line 384  schedCancel(sched_task_t * __restrict task)
                 case taskPROC:                  case taskPROC:
                         queue = &TASK_ROOT(task)->root_proc;                          queue = &TASK_ROOT(task)->root_proc;
                         break;                          break;
                 case taskUSER:  
                         queue = &TASK_ROOT(task)->root_user;  
                         break;  
                 case taskSIGNAL:                  case taskSIGNAL:
                         queue = &TASK_ROOT(task)->root_signal;                          queue = &TASK_ROOT(task)->root_signal;
                         break;                          break;
                   case taskAIO:
                           queue = &TASK_ROOT(task)->root_aio;
                           break;
                   case taskLIO:
                           queue = &TASK_ROOT(task)->root_lio;
                           break;
                   case taskUSER:
                           queue = &TASK_ROOT(task)->root_user;
                           break;
                 case taskEVENT:                  case taskEVENT:
                         queue = &TASK_ROOT(task)->root_event;                          queue = &TASK_ROOT(task)->root_event;
                         break;                          break;
                case taskEVENTLO:                case taskTASK:
                        queue = &TASK_ROOT(task)->root_eventlo;                        queue = &TASK_ROOT(task)->root_task;
                         break;                          break;
                 case taskSUSPEND:                  case taskSUSPEND:
                         queue = &TASK_ROOT(task)->root_suspend;                          queue = &TASK_ROOT(task)->root_suspend;
Line 446  schedCancelby(sched_root_task_t * __restrict root, sch Line 461  schedCancelby(sched_root_task_t * __restrict root, sch
                         return -2;                          return -2;
                 if (schedCancelby(root, taskPROC, criteria, param, hook))                  if (schedCancelby(root, taskPROC, criteria, param, hook))
                         return -2;                          return -2;
                 if (schedCancelby(root, taskUSER, criteria, param, hook))  
                         return -2;  
                 if (schedCancelby(root, taskSIGNAL, criteria, param, hook))                  if (schedCancelby(root, taskSIGNAL, criteria, param, hook))
                         return -2;                          return -2;
                   if (schedCancelby(root, taskAIO, criteria, param, hook))
                           return -2;
                   if (schedCancelby(root, taskLIO, criteria, param, hook))
                           return -2;
                   if (schedCancelby(root, taskUSER, criteria, param, hook))
                           return -2;
                 if (schedCancelby(root, taskEVENT, criteria, param, hook))                  if (schedCancelby(root, taskEVENT, criteria, param, hook))
                         return -2;                          return -2;
                if (schedCancelby(root, taskEVENTLO, criteria, param, hook))                if (schedCancelby(root, taskTASK, criteria, param, hook))
                         return -2;                          return -2;
                 if (schedCancelby(root, taskSUSPEND, criteria, param, hook))                  if (schedCancelby(root, taskSUSPEND, criteria, param, hook))
                         return -2;                          return -2;
Line 480  schedCancelby(sched_root_task_t * __restrict root, sch Line 499  schedCancelby(sched_root_task_t * __restrict root, sch
                 case taskPROC:                  case taskPROC:
                         queue = &root->root_proc;                          queue = &root->root_proc;
                         break;                          break;
                 case taskUSER:  
                         queue = &root->root_user;  
                         break;  
                 case taskSIGNAL:                  case taskSIGNAL:
                         queue = &root->root_signal;                          queue = &root->root_signal;
                         break;                          break;
                   case taskAIO:
                           queue = &root->root_aio;
                           break;
                   case taskLIO:
                           queue = &root->root_lio;
                           break;
                   case taskUSER:
                           queue = &root->root_user;
                           break;
                 case taskEVENT:                  case taskEVENT:
                         queue = &root->root_event;                          queue = &root->root_event;
                         break;                          break;
                case taskEVENTLO:                case taskTASK:
                        queue = &root->root_eventlo;                        queue = &root->root_task;
                         break;                          break;
                 case taskSUSPEND:                  case taskSUSPEND:
                         queue = &root->root_suspend;                          queue = &root->root_suspend;
Line 643  schedPolling(sched_root_task_t * __restrict root, stru Line 668  schedPolling(sched_root_task_t * __restrict root, stru
  *   *
  * @root = root task   * @root = root task
  * @condValue = condition value, kill schedRun() if condValue == killState   * @condValue = condition value, kill schedRun() if condValue == killState
 * return: -1 error ok 0 ok * return: -1 error or 0 ok
  */   */
 inline int  inline int
 schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue)  schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue)
Line 653  schedTermCondition(sched_root_task_t * __restrict root Line 678  schedTermCondition(sched_root_task_t * __restrict root
   
         root->root_cond = condValue;          root->root_cond = condValue;
         root->root_hooks.hook_exec.condition = sched_hook_condition;          root->root_hooks.hook_exec.condition = sched_hook_condition;
           return 0;
   }
   
   /*
    * schedMissEvents() - Set new miss events rate for regular tasks
    *
    * @root = root task
    * @missEvents = maximum number of missed events before firing tasks
    * return: -1 error or 0 ok
    */
   inline int
   schedMissEvents(sched_root_task_t * __restrict root, u_int missEvents)
   {
           if (!root)
                   return -1;
   
           root->root_miss = missEvents;
         return 0;          return 0;
 }  }
   

Removed from v.1.11.2.1  
changed lines
  Added in v.1.13


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