Changeset 4eff63c in mainline for uspace/srv/audio/hound/audio_device.c

Timestamp:

2013-04-11T21:55:43Z (12 years ago)

Author:

Jan Vesely <jano.vesely@…>

Branches:

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

Children:

6eeaf1d

Parents:

bee5349

Message:

hound: implement device source events

File:

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

uspace/srv/audio/hound/audio_device.c

@@ -55 +55 @@
 static int get_buffer(audio_device_t *dev);
 static int release_buffer(audio_device_t *dev);
-static void fill_buffer(audio_device_t *dev, size_t size);
+static void advance_buffer(audio_device_t *dev, size_t size);
 static inline bool is_running(audio_device_t *dev)
 {
@@ -167 +167 @@
                 pcm_format_silence(dev->buffer.base, dev->buffer.size,
                     &dev->sink.format);
-                fill_buffer(dev, dev->buffer.fragment_size * 2);
+                //TODO add underrun detection.
+                const size_t size = dev->buffer.fragment_size * 2;
+                /* We never cross the end of the buffer here */
+                audio_sink_mix_inputs(&dev->sink, dev->buffer.position, size);
+                advance_buffer(dev, size);
 
                 const unsigned frames = dev->buffer.fragment_size /
@@ -280 +284 @@
                         struct timeval time1;
                         getuptime(&time1);
-                        fill_buffer(dev, dev->buffer.fragment_size);
+                        //TODO add underrun detection.
+                        /* We never cross the end of the buffer here */
+                        audio_sink_mix_inputs(&dev->sink, dev->buffer.position,
+                            dev->buffer.fragment_size);
+                        advance_buffer(dev, dev->buffer.fragment_size);
                         struct timeval time2;
                         getuptime(&time2);
@@ -290 +298 @@
                         log_verbose("Playback terminated!");
                         return;
-                case PCM_EVENT_FRAMES_CAPTURED:
-                        //TODO implement
+                case PCM_EVENT_FRAMES_CAPTURED: {
+                        const int ret = audio_source_push_data(&dev->source,
+                            dev->buffer.position, dev->buffer.fragment_size);
+                        advance_buffer(dev, dev->buffer.fragment_size);
+                        if (ret != EOK)
+                                log_warning("Failed to push recorded data");
                         break;
+                }
                 case PCM_EVENT_CAPTURE_TERMINATED:
                         log_verbose("Recording terminated!");
@@ -372 +385 @@
 
 /**
- * Mix data from all connections and add it to the device buffer.
+ * Move buffer position pointer.
  * @param dev Audio device.
- * @param size portion of the device buffer to fill.
- */
-static void fill_buffer(audio_device_t *dev, size_t size)
+ * @param size number of bytes to move forward
+ */
+static void advance_buffer(audio_device_t *dev, size_t size)
 {
         assert(dev);
         assert(dev->buffer.position >= dev->buffer.base);
         assert(dev->buffer.position < (dev->buffer.base + dev->buffer.size));
-
-        //TODO add underrun detection.
-        audio_sink_mix_inputs(&dev->sink, dev->buffer.position, size);
         dev->buffer.position += size;
         if (dev->buffer.position == (dev->buffer.base + dev->buffer.size))