media/audio/pulse/pulse_unified.h

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef MEDIA_AUDIO_PULSE_PULSE_UNIFIED_H_
   6 #define MEDIA_AUDIO_PULSE_PULSE_UNIFIED_H_
   7
   8 #include <pulse/pulseaudio.h>
   9 #include <string>
  10
  11 #include "base/memory/scoped_ptr.h"
  12 #include "media/audio/audio_io.h"
  13 #include "media/audio/audio_parameters.h"
  14 #include "media/base/audio_fifo.h"
  15
  16 namespace media {
  17
  18 class AudioManagerBase;
  19 class SeekableBuffer;
  20
  21 class PulseAudioUnifiedStream : public AudioOutputStream {
  22  public:
  23   PulseAudioUnifiedStream(const AudioParameters& params,
  24                           const std::string& input_device_id,
  25                           AudioManagerBase* manager);
  26
  27   virtual ~PulseAudioUnifiedStream();
  28
  29   // Implementation of PulseAudioUnifiedStream.
  30   virtual bool Open() OVERRIDE;
  31   virtual void Close() OVERRIDE;
  32   virtual void Start(AudioSourceCallback* callback) OVERRIDE;
  33   virtual void Stop() OVERRIDE;
  34   virtual void SetVolume(double volume) OVERRIDE;
  35   virtual void GetVolume(double* volume) OVERRIDE;
  36
  37  private:
  38   // Called by PulseAudio when |pa_stream_| change state.  If an unexpected
  39   // failure state change happens and |source_callback_| is set
  40   // this method will forward the error via OnError().
  41   static void StreamNotifyCallback(pa_stream* s, void* user_data);
  42
  43   // Called by PulseAudio recording stream when it has data.
  44   static void ReadCallback(pa_stream* s, size_t length, void* user_data);
  45
  46   // Helpers for ReadCallback() to read and write data.
  47   void WriteData(size_t requested_bytes);
  48   void ReadData();
  49
  50   // Close() helper function to free internal structs.
  51   void Reset();
  52
  53   // AudioParameters from the constructor.
  54   const AudioParameters params_;
  55
  56   // Device unique ID of the input device.
  57   const std::string input_device_id_;
  58
  59   // Audio manager that created us.  Used to report that we've closed.
  60   AudioManagerBase* manager_;
  61
  62   // PulseAudio API structs.
  63   pa_context* pa_context_;
  64   pa_threaded_mainloop* pa_mainloop_;
  65   pa_stream* input_stream_;
  66   pa_stream* output_stream_;
  67
  68   // Float representation of volume from 0.0 to 1.0.
  69   float volume_;
  70
  71   // Callback to audio data source.  Must only be modified while holding a lock
  72   // on |pa_mainloop_| via pa_threaded_mainloop_lock().
  73   AudioSourceCallback* source_callback_;
  74
  75   scoped_ptr<AudioBus> input_bus_;
  76   scoped_ptr<AudioBus> output_bus_;
  77
  78   // Used for input to output buffering.
  79   scoped_ptr<media::SeekableBuffer> fifo_;
  80
  81   // Temporary storage for recorded data. It gets a packet of data from
  82   // |fifo_| and deliver the data to OnMoreIOData() callback.
  83   scoped_ptr<uint8[]> input_data_buffer_;
  84
  85   DISALLOW_COPY_AND_ASSIGN(PulseAudioUnifiedStream);
  86 };
  87
  88 }  // namespace media
  89
  90 #endif  // MEDIA_AUDIO_PULSE_PULSE_UNIFIED_H_