Changeset 6da3baec in mainline for uspace/srv/audio/hound/hound.c

Timestamp:

2013-04-03T21:25:28Z (12 years ago)

Author:

Jan Vesely <jano.vesely@…>

Branches:

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

Children:

be7eccf

Parents:

8f8ec69

Message:

hound: fix ctx removal.

warn if still connected

File:

• uspace/srv/audio/hound/hound.c (modified) (6 diffs)

uspace/srv/audio/hound/hound.c

@@ -79 +79 @@
 static int hound_disconnect_internal(hound_t *hound, const char* source_name, const char* sink_name);
 
+static void hound_remove_sink_internal(hound_t *hound, audio_sink_t *sink)
+{
+        assert(hound);
+        assert(sink);
+        log_verbose("Removing sink '%s'.", sink->name);
+        if (!list_empty(&sink->connections))
+                log_warning("Removing sink '%s' while still connected.", sink->name);
+        while (!list_empty(&sink->connections)) {
+                connection_t *conn =
+                    connection_from_sink_list(list_first(&sink->connections));
+                list_remove(&conn->hound_link);
+                connection_destroy(conn);
+        }
+        list_remove(&sink->link);
+}
+
+static void hound_remove_source_internal(hound_t *hound, audio_source_t *source)
+{
+        assert(hound);
+        assert(source);
+        log_verbose("Removing source '%s'.", source->name);
+        if (!list_empty(&source->connections))
+                log_warning("Removing source '%s' while still connected.", source->name);
+        while (!list_empty(&source->connections)) {
+                connection_t *conn =
+                    connection_from_source_list(list_first(&source->connections));
+                assert(conn);
+                list_remove(&conn->hound_link);
+                connection_destroy(conn);
+        }
+        list_remove(&source->link);
+}
+
 int hound_init(hound_t *hound)
 {
@@ -117 +150 @@
         fibril_mutex_lock(&hound->list_guard);
         list_remove(&ctx->link);
+        if (ctx->source)
+                hound_remove_source_internal(hound, ctx->source);
+        if (ctx->sink)
+                hound_remove_sink_internal(hound, ctx->sink);
         fibril_mutex_unlock(&hound->list_guard);
         return EOK;
@@ -250 +287 @@
         if (!source)
                 return EINVAL;
-        log_verbose("Removing source '%s'.", source->name);
-        fibril_mutex_lock(&hound->list_guard);
-
-        list_remove(&source->link);
-        fibril_mutex_unlock(&hound->list_guard);
-        return EOK;
-}
+        fibril_mutex_lock(&hound->list_guard);
+        hound_remove_source_internal(hound, source);
+        fibril_mutex_unlock(&hound->list_guard);
+        return EOK;
+}
+
 
 int hound_remove_sink(hound_t *hound, audio_sink_t *sink)
@@ -263 +299 @@
         if (!sink)
                 return EINVAL;
-        log_verbose("Removing sink '%s'.", sink->name);
-        fibril_mutex_lock(&hound->list_guard);
-
-        if (!list_empty(&sink->connections)) {
-                // TODO disconnect instead
-                fibril_mutex_unlock(&hound->list_guard);
-                return EBUSY;
-        }
-        list_remove(&sink->link);
+        fibril_mutex_lock(&hound->list_guard);
+        hound_remove_sink_internal(hound, sink);
         fibril_mutex_unlock(&hound->list_guard);
         return EOK;
@@ -383 +412 @@
         list_append(&conn->hound_link, &hound->connections);
         fibril_mutex_unlock(&hound->list_guard);
-        log_debug("CONNECTED: %s -> %s", source_name, sink_name);
         return EOK;
 }
@@ -396 +424 @@
 }
 
-static int hound_disconnect_internal(hound_t *hound, const char* source_name, const char* sink_name)
+static int hound_disconnect_internal(hound_t *hound, const char* source_name,
+    const char* sink_name)
 {
         assert(hound);