blob: f96b39136f88830d91e3f6a1fa30c592880ce2ab [file] [log] [blame]
// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef MEDIA_AUDIO_ALSA_ALSA_INPUT_H_
#define MEDIA_AUDIO_ALSA_ALSA_INPUT_H_
#include <alsa/asoundlib.h>
#include <stdint.h>
#include <memory>
#include <string>
#include "base/compiler_specific.h"
#include "base/macros.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/thread.h"
#include "base/time/time.h"
#include "media/audio/agc_audio_stream.h"
#include "media/audio/audio_io.h"
#include "media/base/audio_parameters.h"
namespace media {
class AlsaWrapper;
class AudioManagerBase;
// Provides an input stream for audio capture based on the ALSA PCM interface.
// This object is not thread safe and all methods should be invoked in the
// thread that created the object.
class MEDIA_EXPORT AlsaPcmInputStream
: public AgcAudioStream<AudioInputStream> {
public:
// Pass this to the constructor if you want to attempt auto-selection
// of the audio recording device.
static const char kAutoSelectDevice[];
// Create a PCM Output stream for the ALSA device identified by
// |device_name|. If unsure of what to use for |device_name|, use
// |kAutoSelectDevice|.
AlsaPcmInputStream(AudioManagerBase* audio_manager,
const std::string& device_name,
const AudioParameters& params,
AlsaWrapper* wrapper);
AlsaPcmInputStream(const AlsaPcmInputStream&) = delete;
AlsaPcmInputStream& operator=(const AlsaPcmInputStream&) = delete;
~AlsaPcmInputStream() override;
// Implementation of AudioInputStream.
OpenOutcome Open() override;
void Start(AudioInputCallback* callback) override;
void Stop() override;
void Close() override;
double GetMaxVolume() override;
void SetVolume(double volume) override;
double GetVolume() override;
bool IsMuted() override;
void SetOutputDeviceForAec(const std::string& output_device_id) override;
private:
// Logs the error and invokes any registered callbacks.
void HandleError(const char* method, int error);
// Reads one or more buffers of audio from the device, passes on to the
// registered callback and schedules the next read.
void ReadAudio();
// Recovers from any device errors if possible.
bool Recover(int error);
// Set |running_| to false on |capture_thread_|.
void StopRunningOnCaptureThread();
// Non-refcounted pointer back to the audio manager.
// The AudioManager indirectly holds on to stream objects, so we don't
// want circular references. Additionally, stream objects live on the audio
// thread, which is owned by the audio manager and we don't want to addref
// the manager from that thread.
AudioManagerBase* audio_manager_;
std::string device_name_;
AudioParameters params_;
int bytes_per_buffer_;
AlsaWrapper* wrapper_;
base::TimeDelta buffer_duration_; // Length of each recorded buffer.
AudioInputCallback* callback_; // Valid during a recording session.
base::TimeTicks next_read_time_; // Scheduled time for next read callback.
snd_pcm_t* device_handle_; // Handle to the ALSA PCM recording device.
snd_mixer_t* mixer_handle_; // Handle to the ALSA microphone mixer.
snd_mixer_elem_t* mixer_element_handle_; // Handle to the capture element.
// Buffer used for reading audio data.
std::unique_ptr<uint8_t[]> audio_buffer_;
bool read_callback_behind_schedule_;
std::unique_ptr<AudioBus> audio_bus_;
base::Thread capture_thread_;
bool running_;
};
} // namespace media
#endif // MEDIA_AUDIO_ALSA_ALSA_INPUT_H_