Changeset 38d8849 in mainline for uspace/app/tester/float/float1.c

Timestamp:

2018-07-16T15:58:51Z (6 years ago)

Author:

Jiří Zárevúcky <jiri.zarevucky@…>

Branches:

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

Children:

db51219f

Parents:

c124c985

git-author:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-07-14 16:53:46)

git-committer:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-07-16 15:58:51)

Message:

Privatize <thread.h>.

File:

• uspace/app/tester/float/float1.c (modified) (5 diffs)

uspace/app/tester/float/float1.c

@@ -33 +33 @@
 #include <stddef.h>
 #include <atomic.h>
-#include <thread.h>
+#include <fibril.h>
+#include <fibril_synch.h>
 #include <inttypes.h>
 #include "../tester.h"
@@ -43 +44 @@
 #define PRECISION  100000000
 
-static atomic_t threads_finished;
+static FIBRIL_SEMAPHORE_INITIALIZE(threads_finished, 0);
 static atomic_t threads_fault;
 
-static void e(void *data)
+static errno_t e(void *data)
 {
         for (unsigned int i = 0; i < ATTEMPTS; i++) {
@@ -64 +65 @@
         }
 
-        atomic_inc(&threads_finished);
+        fibril_semaphore_up(&threads_finished);
+        return EOK;
 }
 
@@ -71 +73 @@
         atomic_count_t total = 0;
 
-        atomic_set(&threads_finished, 0);
         atomic_set(&threads_fault, 0);
+        fibril_test_spawn_runners(THREADS);
 
         TPRINTF("Creating threads");
         for (unsigned int i = 0; i < THREADS; i++) {
-                if (thread_create(e, NULL, "e", NULL) != EOK) {
+                fid_t f = fibril_create(e, NULL);
+                if (!f) {
                         TPRINTF("\nCould not create thread %u\n", i);
                         break;
                 }
+                fibril_detach(f);
+                fibril_add_ready(f);
 
                 TPRINTF(".");
@@ -87 +92 @@
         TPRINTF("\n");
 
-        while (atomic_get(&threads_finished) < total) {
-                TPRINTF("Threads left: %" PRIua "\n",
-                    total - atomic_get(&threads_finished));
-                thread_sleep(1);
+        for (unsigned int i = 0; i < total; i++) {
+                TPRINTF("Threads left: %" PRIua "\n", total - i);
+                fibril_semaphore_down(&threads_finished);
         }