Changeset 2e39656 in mainline for uspace/srv/logger/namespace.c

Timestamp:

2012-07-14T17:41:01Z (12 years ago)

Author:

Vojtech Horky <vojtechhorky@…>

Branches:

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

Children:

ceafd1b

Parents:

ef5be68

Message:

Check for log readers in separate fibril

Do not even try to send when no reader was announced.

File:

• uspace/srv/logger/namespace.c (modified) (4 diffs)

uspace/srv/logger/namespace.c

@@ -43 +43 @@
         fibril_mutex_t guard;
         size_t writers_count;
+        fibril_condvar_t reader_appeared_cv;
         bool has_reader;
         const char *name;
@@ -167 +168 @@
                 fibril_mutex_lock(&namespace->guard);
                 namespace->has_reader = true;
+                fibril_condvar_broadcast(&namespace->reader_appeared_cv);
                 fibril_mutex_unlock(&namespace->guard);
         }
@@ -200 +202 @@
         fibril_mutex_lock(&namespace->guard);
         namespace->has_reader = false;
+        fibril_condvar_broadcast(&namespace->reader_appeared_cv);
         fibril_mutex_unlock(&namespace->guard);
 
@@ -221 +224 @@
         fibril_mutex_unlock(&namespace->guard);
         return has_reader;
+}
+
+void namespace_wait_for_reader_change(logging_namespace_t *namespace, bool *has_reader_now)
+{
+        fibril_mutex_lock(&namespace->guard);
+        bool had_reader = namespace->has_reader;
+        while (had_reader == namespace->has_reader) {
+                fibril_condvar_wait(&namespace->reader_appeared_cv, &namespace->guard);
+        }
+        *has_reader_now = namespace->has_reader;
+        fibril_mutex_unlock(&namespace->guard);
 }