Index: chrome/renderer/audio_device.cc |
=================================================================== |
--- chrome/renderer/audio_device.cc (revision 78436) |
+++ chrome/renderer/audio_device.cc (working copy) |
@@ -1,188 +0,0 @@ |
-// Copyright (c) 2010 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 "chrome/renderer/audio_device.h" |
- |
-#include "base/singleton.h" |
-#include "chrome/common/render_messages.h" |
-#include "chrome/common/render_messages_params.h" |
-#include "chrome/renderer/render_thread.h" |
-#include "media/audio/audio_util.h" |
- |
-scoped_refptr<AudioMessageFilter> AudioDevice::filter_; |
- |
-namespace { |
- |
-// AudioMessageFilterCreator is intended to be used as a singleton so we can |
-// get access to a shared AudioMessageFilter. |
-// Example usage: |
-// AudioMessageFilter* filter = AudioMessageFilterCreator::SharedFilter(); |
- |
-class AudioMessageFilterCreator { |
- public: |
- AudioMessageFilterCreator() { |
- int routing_id; |
- RenderThread::current()->Send( |
- new ViewHostMsg_GenerateRoutingID(&routing_id)); |
- filter_ = new AudioMessageFilter(routing_id); |
- RenderThread::current()->AddFilter(filter_); |
- } |
- |
- static AudioMessageFilter* SharedFilter() { |
- return GetInstance()->filter_.get(); |
- } |
- |
- static AudioMessageFilterCreator* GetInstance() { |
- return Singleton<AudioMessageFilterCreator>::get(); |
- } |
- |
- private: |
- scoped_refptr<AudioMessageFilter> filter_; |
-}; |
- |
-} |
- |
-AudioDevice::AudioDevice(size_t buffer_size, |
- int channels, |
- double sample_rate, |
- RenderCallback* callback) |
- : buffer_size_(buffer_size), |
- channels_(channels), |
- sample_rate_(sample_rate), |
- callback_(callback), |
- stream_id_(0) { |
- audio_data_.reserve(channels); |
- for (int i = 0; i < channels; ++i) { |
- float* channel_data = new float[buffer_size]; |
- audio_data_.push_back(channel_data); |
- } |
-} |
- |
-AudioDevice::~AudioDevice() { |
- Stop(); |
- for (int i = 0; i < channels_; ++i) |
- delete [] audio_data_[i]; |
-} |
- |
-bool AudioDevice::Start() { |
- // Make sure we don't call Start() more than once. |
- DCHECK_EQ(0, stream_id_); |
- if (stream_id_) |
- return false; |
- |
- // Lazily create the message filter and share across AudioDevice instances. |
- filter_ = AudioMessageFilterCreator::SharedFilter(); |
- |
- stream_id_ = filter_->AddDelegate(this); |
- |
- ViewHostMsg_Audio_CreateStream_Params params; |
- params.params.format = AudioParameters::AUDIO_PCM_LOW_LATENCY; |
- params.params.channels = channels_; |
- params.params.sample_rate = static_cast<int>(sample_rate_); |
- params.params.bits_per_sample = 16; |
- params.params.samples_per_packet = buffer_size_; |
- |
- filter_->Send( |
- new ViewHostMsg_CreateAudioStream(0, stream_id_, params, true)); |
- |
- return true; |
-} |
- |
-bool AudioDevice::Stop() { |
- if (stream_id_) { |
- OnDestroy(); |
- return true; |
- } |
- return false; |
-} |
- |
-void AudioDevice::OnDestroy() { |
- // Make sure we don't call destroy more than once. |
- DCHECK_NE(0, stream_id_); |
- if (!stream_id_) |
- return; |
- |
- filter_->RemoveDelegate(stream_id_); |
- filter_->Send(new ViewHostMsg_CloseAudioStream(0, stream_id_)); |
- stream_id_ = 0; |
- if (audio_thread_.get()) { |
- socket_->Close(); |
- audio_thread_->Join(); |
- } |
-} |
- |
-void AudioDevice::OnRequestPacket(AudioBuffersState buffers_state) { |
- // This method does not apply to the low-latency system. |
- NOTIMPLEMENTED(); |
-} |
- |
-void AudioDevice::OnStateChanged( |
- const ViewMsg_AudioStreamState_Params& state) { |
- // Not needed in this simple implementation. |
- NOTIMPLEMENTED(); |
-} |
- |
-void AudioDevice::OnCreated( |
- base::SharedMemoryHandle handle, uint32 length) { |
- // Not needed in this simple implementation. |
- NOTIMPLEMENTED(); |
-} |
- |
-void AudioDevice::OnLowLatencyCreated( |
- base::SharedMemoryHandle handle, |
- base::SyncSocket::Handle socket_handle, |
- uint32 length) { |
- |
-#if defined(OS_WIN) |
- DCHECK(handle); |
- DCHECK(socket_handle); |
-#else |
- DCHECK_GE(handle.fd, 0); |
- DCHECK_GE(socket_handle, 0); |
-#endif |
- DCHECK(length); |
- DCHECK(!audio_thread_.get()); |
- |
- // TODO(crogers) : check that length is big enough for buffer_size_ |
- |
- shared_memory_.reset(new base::SharedMemory(handle, false)); |
- shared_memory_->Map(length); |
- |
- socket_.reset(new base::SyncSocket(socket_handle)); |
- // Allow the client to pre-populate the buffer. |
- FireRenderCallback(); |
- |
- // TODO(crogers): we could optionally set the thread to high-priority |
- audio_thread_.reset( |
- new base::DelegateSimpleThread(this, "renderer_audio_thread")); |
- audio_thread_->Start(); |
- |
- filter_->Send(new ViewHostMsg_PlayAudioStream(0, stream_id_)); |
-} |
- |
-void AudioDevice::OnVolume(double volume) { |
- // Not needed in this simple implementation. |
- NOTIMPLEMENTED(); |
-} |
- |
-// Our audio thread runs here. |
-void AudioDevice::Run() { |
- int pending_data; |
- while (sizeof(pending_data) == socket_->Receive(&pending_data, |
- sizeof(pending_data)) && |
- pending_data >= 0) { |
- FireRenderCallback(); |
- } |
-} |
- |
-void AudioDevice::FireRenderCallback() { |
- if (callback_) { |
- // Ask client to render audio. |
- callback_->Render(audio_data_, buffer_size_); |
- |
- // Interleave, scale, and clip to int16. |
- int16* output_buffer16 = static_cast<int16*>(shared_memory_data()); |
- media::InterleaveFloatToInt16(audio_data_, output_buffer16, buffer_size_); |
- } |
-} |