| Index: content/renderer/audio_input_message_filter.cc
|
| ===================================================================
|
| --- content/renderer/audio_input_message_filter.cc (revision 88131)
|
| +++ content/renderer/audio_input_message_filter.cc (working copy)
|
| @@ -1,109 +0,0 @@
|
| -// Copyright (c) 2011 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 "content/renderer/audio_input_message_filter.h"
|
| -
|
| -#include "base/message_loop.h"
|
| -#include "base/time.h"
|
| -#include "content/common/audio_messages.h"
|
| -#include "ipc/ipc_logging.h"
|
| -
|
| -AudioInputMessageFilter::AudioInputMessageFilter(int32 route_id)
|
| - : channel_(NULL),
|
| - route_id_(route_id),
|
| - message_loop_(NULL) {
|
| - VLOG(1) << "AudioInputMessageFilter(route_id=" << route_id << ")";
|
| -}
|
| -
|
| -AudioInputMessageFilter::~AudioInputMessageFilter() {}
|
| -
|
| -// Called on the IPC thread.
|
| -bool AudioInputMessageFilter::Send(IPC::Message* message) {
|
| - if (!channel_) {
|
| - delete message;
|
| - return false;
|
| - }
|
| -
|
| - if (MessageLoop::current() != message_loop_) {
|
| - // Can only access the IPC::Channel on the IPC thread since it's not thread
|
| - // safe.
|
| - message_loop_->PostTask(
|
| - FROM_HERE, NewRunnableMethod(this,
|
| - &AudioInputMessageFilter::Send,
|
| - message));
|
| - return true;
|
| - }
|
| -
|
| - message->set_routing_id(route_id_);
|
| - return channel_->Send(message);
|
| -}
|
| -
|
| -bool AudioInputMessageFilter::OnMessageReceived(const IPC::Message& message) {
|
| - if (message.routing_id() != route_id_)
|
| - return false;
|
| -
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(AudioInputMessageFilter, message)
|
| - IPC_MESSAGE_HANDLER(AudioInputMsg_NotifyLowLatencyStreamCreated,
|
| - OnLowLatencyStreamCreated)
|
| - IPC_MESSAGE_HANDLER(AudioInputMsg_NotifyStreamVolume, OnStreamVolume)
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| - return handled;
|
| -}
|
| -
|
| -void AudioInputMessageFilter::OnFilterAdded(IPC::Channel* channel) {
|
| - VLOG(1) << "AudioInputMessageFilter::OnFilterAdded()";
|
| - // Captures the message loop for IPC.
|
| - message_loop_ = MessageLoop::current();
|
| - channel_ = channel;
|
| -}
|
| -
|
| -void AudioInputMessageFilter::OnFilterRemoved() {
|
| - channel_ = NULL;
|
| -}
|
| -
|
| -void AudioInputMessageFilter::OnChannelClosing() {
|
| - channel_ = NULL;
|
| -}
|
| -
|
| -void AudioInputMessageFilter::OnLowLatencyStreamCreated(
|
| - int stream_id,
|
| - base::SharedMemoryHandle handle,
|
| -#if defined(OS_WIN)
|
| - base::SyncSocket::Handle socket_handle,
|
| -#else
|
| - base::FileDescriptor socket_descriptor,
|
| -#endif
|
| - uint32 length) {
|
| - Delegate* delegate = delegates_.Lookup(stream_id);
|
| - if (!delegate) {
|
| - DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
|
| - " audio capturer.";
|
| - return;
|
| - }
|
| -#if !defined(OS_WIN)
|
| - base::SyncSocket::Handle socket_handle = socket_descriptor.fd;
|
| -#endif
|
| - // Forward message to the stream delegate.
|
| - delegate->OnLowLatencyCreated(handle, socket_handle, length);
|
| -}
|
| -
|
| -void AudioInputMessageFilter::OnStreamVolume(int stream_id, double volume) {
|
| - Delegate* delegate = delegates_.Lookup(stream_id);
|
| - if (!delegate) {
|
| - DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
|
| - " audio capturer.";
|
| - return;
|
| - }
|
| - delegate->OnVolume(volume);
|
| -}
|
| -
|
| -int32 AudioInputMessageFilter::AddDelegate(Delegate* delegate) {
|
| - return delegates_.Add(delegate);
|
| -}
|
| -
|
| -void AudioInputMessageFilter::RemoveDelegate(int32 id) {
|
| - delegates_.Remove(id);
|
| -}
|
|
|