Changeset aab5e46 in mainline for kernel/generic/src/proc/task.c

Timestamp:

2018-11-03T23:32:39Z (5 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

790f3a3

Parents:

ef1eab7

Message:

Thread and task iterator functions.

File:

• kernel/generic/src/proc/task.c (modified) (5 diffs)

kernel/generic/src/proc/task.c

@@ -107 +107 @@
 {
         size_t tasks_left;
-        odlink_t *odlink;
         task_t *task;
 
@@ -128 +127 @@
                 tasks_left = 0;
 
-                odlink = odict_first(&tasks);
-                while (odlink != NULL) {
-                        task = odict_get_instance(odlink, task_t, ltasks);
-
+                task = task_first();
+                while (task != NULL) {
                         if (task != TASK) {
                                 tasks_left++;
@@ -140 +137 @@
                         }
 
-                        odlink = odict_next(odlink, &tasks);
+                        task = task_next(task);
                 }
 
@@ -452 +449 @@
 }
 
+/** Get count of tasks.
+ *
+ * @return Number of tasks in the system
+ */
+size_t task_count(void)
+{
+        assert(interrupts_disabled());
+        assert(irq_spinlock_locked(&tasks_lock));
+
+        return odict_count(&tasks);
+}
+
+/** Get first task (task with lowest ID).
+ *
+ * @return Pointer to first task or @c NULL if there are none.
+ */
+task_t *task_first(void)
+{
+        odlink_t *odlink;
+
+        assert(interrupts_disabled());
+        assert(irq_spinlock_locked(&tasks_lock));
+
+        odlink = odict_first(&tasks);
+        if (odlink == NULL)
+                return NULL;
+
+        return odict_get_instance(odlink, task_t, ltasks);
+}
+
+/** Get next task (with higher task ID).
+ *
+ * @param cur Current task
+ * @return Pointer to next task or @c NULL if there are no more tasks.
+ */
+task_t *task_next(task_t *cur)
+{
+        odlink_t *odlink;
+
+        assert(interrupts_disabled());
+        assert(irq_spinlock_locked(&tasks_lock));
+
+        odlink = odict_next(&cur->ltasks, &tasks);
+        if (odlink == NULL)
+                return NULL;
+
+        return odict_get_instance(odlink, task_t, ltasks);
+}
+
 /** Get accounting data of given task.
  *
@@ -658 +704 @@
 #endif
 
-        odlink_t *odlink;
         task_t *task;
 
-        odlink = odict_first(&tasks);
-        while (odlink != NULL) {
-                task = odict_get_instance(odlink, task_t, ltasks);
+        task = task_first();
+        while (task != NULL) {
                 task_print(task, additional);
-                odlink = odict_next(odlink, &tasks);
+                task = task_next(task);
         }