blob: 0bae9db7c4e77937a5c52aafb48064c694baa066 [file] [log] [blame]
// Copyright (c) 2012 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.
#include "base/basictypes.h"
#include "base/environment.h"
#include "base/memory/scoped_ptr.h"
#include "base/message_loop/message_loop.h"
#include "base/run_loop.h"
#include "base/synchronization/waitable_event.h"
#include "base/threading/platform_thread.h"
#include "media/audio/audio_io.h"
#include "media/audio/audio_manager_base.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace media {
// This class allows to find out if the callbacks are occurring as
// expected and if any error has been reported.
class TestInputCallback : public AudioInputStream::AudioInputCallback {
public:
explicit TestInputCallback()
: callback_count_(0),
had_error_(0) {
}
virtual void OnData(AudioInputStream* stream,
const AudioBus* source,
uint32 hardware_delay_bytes,
double volume) OVERRIDE {
++callback_count_;
}
virtual void OnError(AudioInputStream* stream) OVERRIDE {
++had_error_;
}
// Returns how many times OnData() has been called.
int callback_count() const {
return callback_count_;
}
// Returns how many times the OnError callback was called.
int had_error() const {
return had_error_;
}
private:
int callback_count_;
int had_error_;
};
class AudioInputTest : public testing::Test {
public:
AudioInputTest() :
message_loop_(base::MessageLoop::TYPE_UI),
audio_manager_(AudioManager::CreateForTesting()),
audio_input_stream_(NULL) {
// Wait for the AudioManager to finish any initialization on the audio loop.
base::RunLoop().RunUntilIdle();
}
virtual ~AudioInputTest() {
base::RunLoop().RunUntilIdle();
}
protected:
AudioManager* audio_manager() { return audio_manager_.get(); }
bool CanRunAudioTests() {
bool has_input = audio_manager()->HasAudioInputDevices();
LOG_IF(WARNING, !has_input) << "No input devices detected";
return has_input;
}
void MakeAudioInputStreamOnAudioThread() {
RunOnAudioThread(
base::Bind(&AudioInputTest::MakeAudioInputStream,
base::Unretained(this)));
}
void CloseAudioInputStreamOnAudioThread() {
RunOnAudioThread(
base::Bind(&AudioInputStream::Close,
base::Unretained(audio_input_stream_)));
audio_input_stream_ = NULL;
}
void OpenAndCloseAudioInputStreamOnAudioThread() {
RunOnAudioThread(
base::Bind(&AudioInputTest::OpenAndClose,
base::Unretained(this)));
}
void OpenStopAndCloseAudioInputStreamOnAudioThread() {
RunOnAudioThread(
base::Bind(&AudioInputTest::OpenStopAndClose,
base::Unretained(this)));
}
void OpenAndStartAudioInputStreamOnAudioThread(
AudioInputStream::AudioInputCallback* sink) {
RunOnAudioThread(
base::Bind(&AudioInputTest::OpenAndStart,
base::Unretained(this),
sink));
}
void StopAndCloseAudioInputStreamOnAudioThread() {
RunOnAudioThread(
base::Bind(&AudioInputTest::StopAndClose,
base::Unretained(this)));
}
void MakeAudioInputStream() {
DCHECK(audio_manager()->GetTaskRunner()->BelongsToCurrentThread());
AudioParameters params = audio_manager()->GetInputStreamParameters(
AudioManagerBase::kDefaultDeviceId);
audio_input_stream_ = audio_manager()->MakeAudioInputStream(params,
AudioManagerBase::kDefaultDeviceId);
EXPECT_TRUE(audio_input_stream_);
}
void OpenAndClose() {
DCHECK(audio_manager()->GetTaskRunner()->BelongsToCurrentThread());
EXPECT_TRUE(audio_input_stream_->Open());
audio_input_stream_->Close();
audio_input_stream_ = NULL;
}
void OpenAndStart(AudioInputStream::AudioInputCallback* sink) {
DCHECK(audio_manager()->GetTaskRunner()->BelongsToCurrentThread());
EXPECT_TRUE(audio_input_stream_->Open());
audio_input_stream_->Start(sink);
}
void OpenStopAndClose() {
DCHECK(audio_manager()->GetTaskRunner()->BelongsToCurrentThread());
EXPECT_TRUE(audio_input_stream_->Open());
audio_input_stream_->Stop();
audio_input_stream_->Close();
audio_input_stream_ = NULL;
}
void StopAndClose() {
DCHECK(audio_manager()->GetTaskRunner()->BelongsToCurrentThread());
audio_input_stream_->Stop();
audio_input_stream_->Close();
audio_input_stream_ = NULL;
}
// Synchronously runs the provided callback/closure on the audio thread.
void RunOnAudioThread(const base::Closure& closure) {
if (!audio_manager()->GetTaskRunner()->BelongsToCurrentThread()) {
base::WaitableEvent event(false, false);
audio_manager()->GetTaskRunner()->PostTask(
FROM_HERE,
base::Bind(&AudioInputTest::RunOnAudioThreadImpl,
base::Unretained(this),
closure,
&event));
event.Wait();
} else {
closure.Run();
}
}
void RunOnAudioThreadImpl(const base::Closure& closure,
base::WaitableEvent* event) {
DCHECK(audio_manager()->GetTaskRunner()->BelongsToCurrentThread());
closure.Run();
event->Signal();
}
base::MessageLoop message_loop_;
scoped_ptr<AudioManager> audio_manager_;
AudioInputStream* audio_input_stream_;
private:
DISALLOW_COPY_AND_ASSIGN(AudioInputTest);
};
// Test create and close of an AudioInputStream without recording audio.
TEST_F(AudioInputTest, CreateAndClose) {
if (!CanRunAudioTests())
return;
MakeAudioInputStreamOnAudioThread();
CloseAudioInputStreamOnAudioThread();
}
#if defined(OS_LINUX) && !defined(OS_CHROMEOS) && defined(ARCH_CPU_ARM_FAMILY)
// This test is failing on ARM linux: http://crbug.com/238490
#define MAYBE_OpenAndClose DISABLED_OpenAndClose
#else
#define MAYBE_OpenAndClose OpenAndClose
#endif
// Test create, open and close of an AudioInputStream without recording audio.
TEST_F(AudioInputTest, MAYBE_OpenAndClose) {
if (!CanRunAudioTests())
return;
MakeAudioInputStreamOnAudioThread();
OpenAndCloseAudioInputStreamOnAudioThread();
}
#if defined(OS_LINUX) && !defined(OS_CHROMEOS) && defined(ARCH_CPU_ARM_FAMILY)
// This test is failing on ARM linux: http://crbug.com/238490
#define MAYBE_OpenStopAndClose DISABLED_OpenStopAndClose
#else
#define MAYBE_OpenStopAndClose OpenStopAndClose
#endif
// Test create, open, stop and close of an AudioInputStream without recording.
TEST_F(AudioInputTest, MAYBE_OpenStopAndClose) {
if (!CanRunAudioTests())
return;
MakeAudioInputStreamOnAudioThread();
OpenStopAndCloseAudioInputStreamOnAudioThread();
}
#if defined(OS_LINUX) && !defined(OS_CHROMEOS) && defined(ARCH_CPU_ARM_FAMILY)
// This test is failing on ARM linux: http://crbug.com/238490
#define MAYBE_Record DISABLED_Record
#else
#define MAYBE_Record Record
#endif
// Test a normal recording sequence using an AudioInputStream.
// Very simple test which starts capturing during half a second and verifies
// that recording starts.
TEST_F(AudioInputTest, MAYBE_Record) {
if (!CanRunAudioTests())
return;
MakeAudioInputStreamOnAudioThread();
TestInputCallback test_callback;
OpenAndStartAudioInputStreamOnAudioThread(&test_callback);
message_loop_.PostDelayedTask(
FROM_HERE,
base::MessageLoop::QuitClosure(),
base::TimeDelta::FromMilliseconds(500));
message_loop_.Run();
EXPECT_GE(test_callback.callback_count(), 2);
EXPECT_FALSE(test_callback.had_error());
StopAndCloseAudioInputStreamOnAudioThread();
}
} // namespace media