Changeset 5029c788 in mainline for uspace/srv/audio/hound/connection.c

Timestamp:

2013-04-04T16:21:41Z (11 years ago)

Author:

Jan Vesely <jano.vesely@…>

Branches:

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

Children:

9e40d443

Parents:

5a6f362

Message:

hound: add connection fifo, implement stream mixing

File:

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

uspace/srv/audio/hound/connection.c

@@ -46 +46 @@
         connection_t *conn = malloc(sizeof(connection_t));
         if (conn) {
+                list_initialize(&conn->fifo);
                 link_initialize(&conn->source_link);
                 link_initialize(&conn->sink_link);
@@ -73 +74 @@
         if (connection->source && connection->source->connection_change)
                 connection->source->connection_change(connection->source, false);
+        while (!list_empty(&connection->fifo)) {
+                link_t *l = list_first(&connection->fifo);
+                audio_data_link_t *data = audio_data_link_list_instance(l);
+                list_remove(&data->link);
+                audio_data_link_destroy(data);
+        }
         log_debug("DISCONNECTED: %s -> %s",
             connection->source->name, connection->sink->name);
@@ -87 +94 @@
 }
 
-int connection_new_data(connection_t *connection, const void *data, size_t size)
+int connection_push_data(connection_t *connection, audio_data_t *adata)
 {
         assert(connection);
-        return ENOTSUP;
+        assert(adata);
+        audio_data_link_t *alink = audio_data_link_create(adata);
+        if (!alink) {
+                log_warning("Failed to buffer %zu bytes of data.", adata->size);
+                return ENOMEM;
+        }
+        log_fatal("Pushed new data to connection fifo");
+        list_append(&alink->link, &connection->fifo);
+        return EOK;
 }