Changes in kernel/test/synch/semaphore1.c [bab75df6:0f4f1b2] in mainline

File:

• kernel/test/synch/semaphore1.c (modified) (4 diffs)

kernel/test/synch/semaphore1.c

@@ -41 +41 @@
 
 static waitq_t can_start;
-static atomic_t items_produced;
-static atomic_t items_consumed;
+static atomic_size_t items_produced;
+static atomic_size_t items_consumed;
 
 static void producer(void *arg)
 {
-        thread_detach(THREAD);
-
         waitq_sleep(&can_start);
 
@@ -58 +56 @@
 static void consumer(void *arg)
 {
-        thread_detach(THREAD);
-
         waitq_sleep(&can_start);
 
@@ -93 +89 @@
                                 thrd = thread_create(consumer, NULL, TASK,
                                     THREAD_FLAG_NONE, "consumer");
-                                if (thrd)
-                                        thread_ready(thrd);
-                                else
+                                if (thrd) {
+                                        thread_start(thrd);
+                                        thread_detach(thrd);
+                                } else {
                                         TPRINTF("could not create consumer %d\n", i);
+                                }
                         }
                         for (k = 0; k < (4 - i); k++) {
                                 thrd = thread_create(producer, NULL, TASK,
                                     THREAD_FLAG_NONE, "producer");
-                                if (thrd)
-                                        thread_ready(thrd);
-                                else
+                                if (thrd) {
+                                        thread_start(thrd);
+                                        thread_detach(thrd);
+                                } else {
                                         TPRINTF("could not create producer %d\n", i);
+                                }
                         }
                 }
@@ -111 +111 @@
 
                 thread_sleep(1);
-                waitq_wakeup(&can_start, WAKEUP_ALL);
+                waitq_wake_all(&can_start);
 
                 while ((items_consumed != consumers) || (items_produced != producers)) {