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