Changes in kernel/test/synch/semaphore1.c [0f4f1b2:bab75df6] 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_size_t items_produced;
-static atomic_size_t items_consumed;
+static atomic_t items_produced;
+static atomic_t items_consumed;
 
 static void producer(void *arg)
 {
+        thread_detach(THREAD);
+
         waitq_sleep(&can_start);
 
@@ -56 +58 @@
 static void consumer(void *arg)
 {
+        thread_detach(THREAD);
+
         waitq_sleep(&can_start);
 
@@ -89 +93 @@
                                 thrd = thread_create(consumer, NULL, TASK,
                                     THREAD_FLAG_NONE, "consumer");
-                                if (thrd) {
-                                        thread_start(thrd);
-                                        thread_detach(thrd);
-                                } else {
+                                if (thrd)
+                                        thread_ready(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_start(thrd);
-                                        thread_detach(thrd);
-                                } else {
+                                if (thrd)
+                                        thread_ready(thrd);
+                                else
                                         TPRINTF("could not create producer %d\n", i);
-                                }
                         }
                 }
@@ -111 +111 @@
 
                 thread_sleep(1);
-                waitq_wake_all(&can_start);
+                waitq_wakeup(&can_start, WAKEUP_ALL);
 
                 while ((items_consumed != consumers) || (items_produced != producers)) {