Changes in uspace/lib/c/generic/fibril.c [4d11204:c1b979a] in mainline

File:

• uspace/lib/c/generic/fibril.c (modified) (13 diffs)

uspace/lib/c/generic/fibril.c

@@ -49 +49 @@
 #include <assert.h>
 #include <async.h>
-#include <futex.h>
-
-#ifdef FUTEX_UPGRADABLE
-#include <rcu.h>
-#endif
 
 /**
  * This futex serializes access to ready_list,
- * serialized_list, manager_list and fibril_list.
- */
-static futex_t fibril_futex = FUTEX_INITIALIZER;
+ * serialized_list and manager_list.
+ */
+static atomic_t fibril_futex = FUTEX_INITIALIZER;
 
 static LIST_INITIALIZE(ready_list);
@@ -88 +83 @@
 {
         fibril_t *fibril = __tcb_get()->fibril_data;
-
-#ifdef FUTEX_UPGRADABLE
-        rcu_register_fibril();
-#endif
         
         /* Call the implementing function. */
@@ -126 +117 @@
         
         fibril->waits_for = NULL;
-
-        futex_lock(&fibril_futex);
         list_append(&fibril->all_link, &fibril_list);
-        futex_unlock(&fibril_futex);
         
         return fibril;
 }
 
-void fibril_teardown(fibril_t *fibril, bool locked)
-{       
-        if (!locked)
-                futex_lock(&fibril_futex);
+void fibril_teardown(fibril_t *fibril)
+{
         list_remove(&fibril->all_link);
-        if (!locked)
-                futex_unlock(&fibril_futex);
         tls_free(fibril->tcb);
         free(fibril);
@@ -162 +146 @@
         int retval = 0;
         
-        futex_lock(&fibril_futex);
+        futex_down(&fibril_futex);
         
         if (stype == FIBRIL_PREEMPT && list_empty(&ready_list))
@@ -184 +168 @@
         if ((stype == FIBRIL_TO_MANAGER) || (stype == FIBRIL_FROM_DEAD)) {
                 while (list_empty(&manager_list)) {
-                        futex_unlock(&fibril_futex);
+                        futex_up(&fibril_futex);
                         async_create_manager();
-                        futex_lock(&fibril_futex);
+                        futex_down(&fibril_futex);
                 }
         }
@@ -215 +199 @@
                                         as_area_destroy(stack);
                                 }
-                                fibril_teardown(srcf->clean_after_me, true);
+                                fibril_teardown(srcf->clean_after_me);
                                 srcf->clean_after_me = NULL;
                         }
                         
-                        return 1;       /* futex_unlock already done here */
+                        return 1;       /* futex_up already done here */
                 }
                 
@@ -262 +246 @@
         list_remove(&dstf->link);
         
-        futex_unlock(&fibril_futex);
-        
-#ifdef FUTEX_UPGRADABLE
-        if (stype == FIBRIL_FROM_DEAD) {
-                rcu_deregister_fibril();
-        }
-#endif
-        
+        futex_up(&fibril_futex);
         context_restore(&dstf->ctx);
         /* not reached */
         
 ret_0:
-        futex_unlock(&fibril_futex);
+        futex_up(&fibril_futex);
         return retval;
 }
@@ -301 +278 @@
             AS_AREA_LATE_RESERVE);
         if (fibril->stack == (void *) -1) {
-                fibril_teardown(fibril, false);
+                fibril_teardown(fibril);
                 return 0;
         }
@@ -328 +305 @@
         
         as_area_destroy(fibril->stack);
-        fibril_teardown(fibril, false);
+        fibril_teardown(fibril);
 }
 
@@ -341 +318 @@
         fibril_t *fibril = (fibril_t *) fid;
         
-        futex_lock(&fibril_futex);
+        futex_down(&fibril_futex);
         
         if ((fibril->flags & FIBRIL_SERIALIZED))
@@ -348 +325 @@
                 list_append(&fibril->link, &ready_list);
         
-        futex_unlock(&fibril_futex);
+        futex_up(&fibril_futex);
 }
 
@@ -361 +338 @@
         fibril_t *fibril = (fibril_t *) fid;
         
-        futex_lock(&fibril_futex);
+        futex_down(&fibril_futex);
         list_append(&fibril->link, &manager_list);
-        futex_unlock(&fibril_futex);
+        futex_up(&fibril_futex);
 }
 
@@ -369 +346 @@
 void fibril_remove_manager(void)
 {
-        futex_lock(&fibril_futex);
+        futex_down(&fibril_futex);
         
         if (!list_empty(&manager_list))
                 list_remove(list_first(&manager_list));
         
-        futex_unlock(&fibril_futex);
+        futex_up(&fibril_futex);
 }