Changes in kernel/test/mm/falloc2.c [0f4f1b2:aafed15] in mainline

File:

• kernel/test/mm/falloc2.c (modified) (5 diffs)

kernel/test/mm/falloc2.c

@@ -35 +35 @@
 #include <atomic.h>
 #include <proc/thread.h>
-#include <memw.h>
+#include <mem.h>
 #include <arch.h>
 
@@ -43 +43 @@
 #define THREADS      8
 
-static atomic_size_t thread_fail;
+static atomic_t thread_cnt;
+static atomic_t thread_fail;
 
 static void falloc(void *arg)
@@ -55 +56 @@
                     "Unable to allocate frames\n", THREAD->tid, CPU->id);
                 atomic_inc(&thread_fail);
+                atomic_dec(&thread_cnt);
                 return;
         }
+
+        thread_detach(THREAD);
 
         for (unsigned int run = 0; run < THREAD_RUNS; run++) {
@@ -106 +110 @@
         TPRINTF("Thread #%" PRIu64 " (cpu%u): Exiting\n",
             THREAD->tid, CPU->id);
+        atomic_dec(&thread_cnt);
 }
 
 const char *test_falloc2(void)
 {
+        atomic_store(&thread_cnt, THREADS);
         atomic_store(&thread_fail, 0);
-
-        thread_t *threads[THREADS] = { };
 
         for (unsigned int i = 0; i < THREADS; i++) {
@@ -121 +125 @@
                         break;
                 }
-                thread_start(thrd);
-                threads[i] = thrd;
+                thread_ready(thrd);
         }
 
-        for (unsigned int i = 0; i < THREADS; i++) {
-                if (threads[i] != NULL)
-                        thread_join(threads[i]);
-
-                TPRINTF("Threads left: %u\n", THREADS - i - 1);
+        while (atomic_load(&thread_cnt) > 0) {
+                TPRINTF("Threads left: %zu\n",
+                    atomic_load(&thread_cnt));
+                thread_sleep(1);
         }