rom/task/NextTaskEntry.c

   1 /*
   2     Copyright © 2015, The AROS Development Team. All rights reserved.
   3     $Id$
   4 */
   5
   6 #define DEBUG 0
   7
   8 #include <aros/debug.h>
   9 #include <exec/types.h>
  10 #include <aros/libcall.h>
  11 #include <proto/utility.h>
  12 #include <resources/task.h>
  13
  14 #include <resources/task.h>
  15
  16 #include "taskres_intern.h"
  17
  18 /*****************************************************************************
  19
  20     NAME */
  21 #include <proto/task.h>
  22
  23         AROS_LH2(struct Task *, NextTaskEntry,
  24
  25 /*  SYNOPSIS */
  26         AROS_LHA(struct TaskList *, tlist, D1),
  27         AROS_LHA(ULONG           , flags, D2),
  28
  29 /*  LOCATION */
  30         struct TaskResBase *, TaskResBase, 3, Task)
  31
  32 /*  FUNCTION
  33         Looks for the next task list entry with the right type. The list
  34         must be locked for this.
  35
  36     INPUTS
  37         tlist - the value given by LockTaskList()
  38         flags - the same flags as given to LockTaskList() or a subset
  39                 of them.
  40
  41     RESULT
  42         Pointer to task entry found or NULL if the are no more entries.
  43
  44     NOTES
  45
  46     EXAMPLE
  47
  48     BUGS
  49
  50     SEE ALSO
  51         LockTaskList(), UnLockTaskList().
  52
  53     INTERNALS
  54
  55 *****************************************************************************/
  56 {
  57     AROS_LIBFUNC_INIT
  58
  59     struct TaskListPrivate *taskList = (struct TaskListPrivate *)tlist;
  60     struct Task *retVal = NULL;
  61
  62     D(bug("[TaskRes] NextTaskEntry: tlist @ 0x%p, flags = $%lx\n", tlist, flags));
  63
  64     if (taskList)
  65     {
  66         if ((taskList->tlp_Flags & ~LTF_WRITE) != 0)
  67         {
  68             if (taskList->tlp_Flags & LTF_RUNNING)
  69             {
  70                 while (taskList->tlp_Next &&
  71                            ((!taskList->tlp_Next->tle_Task) ||
  72                             (taskList->tlp_Next->tle_Task->tc_State != TS_RUN)))
  73                 {
  74                      taskList->tlp_Next = (struct TaskListEntry *)GetSucc(taskList->tlp_Next);
  75                 }
  76             }
  77             else if (taskList->tlp_Flags & LTF_READY)
  78             {
  79                 while (taskList->tlp_Next &&
  80                            ((!taskList->tlp_Next->tle_Task) ||
  81                             (taskList->tlp_Next->tle_Task->tc_State != TS_READY)))
  82                 {
  83                      taskList->tlp_Next = (struct TaskListEntry *)GetSucc(taskList->tlp_Next);
  84                 }
  85             }
  86             else if (taskList->tlp_Flags & LTF_WAITING)
  87             {
  88                 while (taskList->tlp_Next &&
  89                           ((!taskList->tlp_Next->tle_Task) ||
  90                           !((taskList->tlp_Next->tle_Task->tc_State == TS_WAIT) ||
  91                             (taskList->tlp_Next->tle_Task->tc_State == TS_SPIN))))
  92                 {
  93                      taskList->tlp_Next = (struct TaskListEntry *)GetSucc(taskList->tlp_Next);
  94                 }
  95             }
  96         }
  97
  98         if (taskList->tlp_Next)
  99         {
 100             retVal = taskList->tlp_Next->tle_Task;
 101             taskList->tlp_Next = (struct TaskListEntry *)GetSucc(taskList->tlp_Next);
 102         }
 103     }
 104
 105     return retVal;
 106
 107     AROS_LIBFUNC_EXIT
 108 } /* NextTaskEntry */