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

Timestamp:

2018-11-03T23:32:39Z (7 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/thread.c (modified) (4 diffs)

kernel/generic/src/proc/thread.c

@@ -772 +772 @@
 void thread_print_list(bool additional)
 {
-        odlink_t *odlink;
         thread_t *thread;
 
@@ -796 +795 @@
 #endif
 
-        odlink = odict_first(&threads);
-        while (odlink != NULL) {
-                thread = odict_get_instance(odlink, thread_t, lthreads);
+        thread = thread_first();
+        while (thread != NULL) {
                 thread_print(thread, additional);
-                odlink = odict_next(odlink, &threads);
+                thread = thread_next(thread);
         }
 
@@ -860 +858 @@
 thread_t *thread_find_by_id(thread_id_t thread_id)
 {
-        odlink_t *odlink;
         thread_t *thread;
 
@@ -866 +863 @@
         assert(irq_spinlock_locked(&threads_lock));
 
-        odlink = odict_first(&threads);
-        while (odlink != NULL) {
-                thread = odict_get_instance(odlink, thread_t, lthreads);
+        thread = thread_first();
+        while (thread != NULL) {
                 if (thread->tid == thread_id)
                         return thread;
 
-                odlink = odict_next(odlink, &threads);
+                thread = thread_next(thread);
         }
 
         return NULL;
+}
+
+/** Get count of threads.
+ *
+ * @return Number of threads in the system
+ */
+size_t thread_count(void)
+{
+        assert(interrupts_disabled());
+        assert(irq_spinlock_locked(&threads_lock));
+
+        return odict_count(&threads);
+}
+
+/** Get first thread.
+ *
+ * @return Pointer to first thread or @c NULL if there are none.
+ */
+thread_t *thread_first(void)
+{
+        odlink_t *odlink;
+
+        assert(interrupts_disabled());
+        assert(irq_spinlock_locked(&threads_lock));
+
+        odlink = odict_first(&threads);
+        if (odlink == NULL)
+                return NULL;
+
+        return odict_get_instance(odlink, thread_t, lthreads);
+}
+
+/** Get next thread.
+ *
+ * @param cur Current thread
+ * @return Pointer to next thread or @c NULL if there are no more threads.
+ */
+thread_t *thread_next(thread_t *cur)
+{
+        odlink_t *odlink;
+
+        assert(interrupts_disabled());
+        assert(irq_spinlock_locked(&threads_lock));
+
+        odlink = odict_next(&cur->lthreads, &threads);
+        if (odlink == NULL)
+                return NULL;
+
+        return odict_get_instance(odlink, thread_t, lthreads);
 }