Changeset 9ae22ba in mainline for uspace/lib/libc/generic/fibril_sync.c

Timestamp:

2009-06-12T17:35:40Z (15 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

26360f7

Parents:

92d34f0b

Message:

Condition variables for fibrils.

File:

• uspace/lib/libc/generic/fibril_sync.c (modified) (3 diffs)

uspace/lib/libc/generic/fibril_sync.c

@@ -72 +72 @@
 }
 
-void fibril_mutex_unlock(fibril_mutex_t *fm)
-{
-        futex_down(&async_futex);
+static void _fibril_mutex_unlock_unsafe(fibril_mutex_t *fm)
+{
         assert(fm->counter <= 0);
         if (fm->counter++ < 0) {
@@ -86 +85 @@
                 fibril_add_ready((fid_t) f);
         }
+}
+
+void fibril_mutex_unlock(fibril_mutex_t *fm)
+{
+        futex_down(&async_futex);
+        _fibril_mutex_unlock_unsafe(fm);
         futex_up(&async_futex);
 }
@@ -168 +173 @@
 }
 
+void fibril_condvar_initialize(fibril_condvar_t *fcv)
+{
+        list_initialize(&fcv->waiters);
+}
+
+void fibril_condvar_wait(fibril_condvar_t *fcv, fibril_mutex_t *fm)
+{
+        fibril_t *f = (fibril_t *) fibril_get_id();
+
+        futex_down(&async_futex);
+        list_append(&f->link, &fcv->waiters);
+        _fibril_mutex_unlock_unsafe(fm);
+        fibril_switch(FIBRIL_TO_MANAGER);
+        fibril_mutex_lock(fm);
+}
+
+static void _fibril_condvar_wakeup_common(fibril_condvar_t *fcv, bool once)
+{
+        link_t *tmp;
+        fibril_t *f;
+
+        futex_down(&async_futex);
+        while (!list_empty(&fcv->waiters)) {
+                tmp = fcv->waiters.next;
+                f = list_get_instance(tmp, fibril_t, link);
+                fibril_add_ready((fid_t) f);
+                if (once)
+                        break;
+        }
+        futex_up(&async_futex);
+}
+
+void fibril_condvar_signal(fibril_condvar_t *fcv)
+{
+        _fibril_condvar_wakeup_common(fcv, true);
+}
+
+void fibril_condvar_broadcast(fibril_condvar_t *fcv)
+{
+        _fibril_condvar_wakeup_common(fcv, false);
+}
+
 /** @}
  */