| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2010 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 #include "chrome/renderer/audio_message_filter.h" | |
| 6 | |
| 7 #include "base/message_loop.h" | |
| 8 #include "base/time.h" | |
| 9 #include "chrome/common/render_messages.h" | |
| 10 #include "chrome/common/render_messages_params.h" | |
| 11 #include "ipc/ipc_logging.h" | |
| 12 | |
| 13 AudioMessageFilter::AudioMessageFilter(int32 route_id) | |
| 14 : channel_(NULL), | |
| 15 route_id_(route_id), | |
| 16 message_loop_(NULL) { | |
| 17 } | |
| 18 | |
| 19 AudioMessageFilter::~AudioMessageFilter() { | |
| 20 } | |
| 21 | |
| 22 // Called on the IPC thread. | |
| 23 bool AudioMessageFilter::Send(IPC::Message* message) { | |
| 24 if (!channel_) { | |
| 25 delete message; | |
| 26 return false; | |
| 27 } | |
| 28 | |
| 29 if (MessageLoop::current() != message_loop_) { | |
| 30 // Can only access the IPC::Channel on the IPC thread since it's not thread | |
| 31 // safe. | |
| 32 message_loop_->PostTask( | |
| 33 FROM_HERE, NewRunnableMethod(this, &AudioMessageFilter::Send, message)); | |
| 34 return true; | |
| 35 } | |
| 36 | |
| 37 message->set_routing_id(route_id_); | |
| 38 return channel_->Send(message); | |
| 39 } | |
| 40 | |
| 41 bool AudioMessageFilter::OnMessageReceived(const IPC::Message& message) { | |
| 42 if (message.routing_id() != route_id_) | |
| 43 return false; | |
| 44 | |
| 45 bool handled = true; | |
| 46 IPC_BEGIN_MESSAGE_MAP(AudioMessageFilter, message) | |
| 47 IPC_MESSAGE_HANDLER(ViewMsg_RequestAudioPacket, OnRequestPacket) | |
| 48 IPC_MESSAGE_HANDLER(ViewMsg_NotifyAudioStreamCreated, OnStreamCreated) | |
| 49 IPC_MESSAGE_HANDLER(ViewMsg_NotifyLowLatencyAudioStreamCreated, | |
| 50 OnLowLatencyStreamCreated) | |
| 51 IPC_MESSAGE_HANDLER(ViewMsg_NotifyAudioStreamStateChanged, | |
| 52 OnStreamStateChanged) | |
| 53 IPC_MESSAGE_HANDLER(ViewMsg_NotifyAudioStreamVolume, OnStreamVolume) | |
| 54 IPC_MESSAGE_UNHANDLED(handled = false) | |
| 55 IPC_END_MESSAGE_MAP() | |
| 56 return handled; | |
| 57 } | |
| 58 | |
| 59 void AudioMessageFilter::OnFilterAdded(IPC::Channel* channel) { | |
| 60 // Captures the message loop for IPC. | |
| 61 message_loop_ = MessageLoop::current(); | |
| 62 channel_ = channel; | |
| 63 } | |
| 64 | |
| 65 void AudioMessageFilter::OnFilterRemoved() { | |
| 66 channel_ = NULL; | |
| 67 } | |
| 68 | |
| 69 void AudioMessageFilter::OnChannelClosing() { | |
| 70 channel_ = NULL; | |
| 71 } | |
| 72 | |
| 73 void AudioMessageFilter::OnRequestPacket(const IPC::Message& msg, | |
| 74 int stream_id, | |
| 75 AudioBuffersState buffers_state) { | |
| 76 Delegate* delegate = delegates_.Lookup(stream_id); | |
| 77 if (!delegate) { | |
| 78 DLOG(WARNING) << "Got audio packet request for a non-existent or removed" | |
| 79 " audio renderer."; | |
| 80 return; | |
| 81 } | |
| 82 | |
| 83 delegate->OnRequestPacket(buffers_state); | |
| 84 } | |
| 85 | |
| 86 void AudioMessageFilter::OnStreamCreated(int stream_id, | |
| 87 base::SharedMemoryHandle handle, | |
| 88 uint32 length) { | |
| 89 Delegate* delegate = delegates_.Lookup(stream_id); | |
| 90 if (!delegate) { | |
| 91 DLOG(WARNING) << "Got audio stream event for a non-existent or removed" | |
| 92 " audio renderer."; | |
| 93 return; | |
| 94 } | |
| 95 delegate->OnCreated(handle, length); | |
| 96 } | |
| 97 | |
| 98 void AudioMessageFilter::OnLowLatencyStreamCreated( | |
| 99 int stream_id, | |
| 100 base::SharedMemoryHandle handle, | |
| 101 #if defined(OS_WIN) | |
| 102 base::SyncSocket::Handle socket_handle, | |
| 103 #else | |
| 104 base::FileDescriptor socket_descriptor, | |
| 105 #endif | |
| 106 uint32 length) { | |
| 107 Delegate* delegate = delegates_.Lookup(stream_id); | |
| 108 if (!delegate) { | |
| 109 DLOG(WARNING) << "Got audio stream event for a non-existent or removed" | |
| 110 " audio renderer."; | |
| 111 return; | |
| 112 } | |
| 113 #if !defined(OS_WIN) | |
| 114 base::SyncSocket::Handle socket_handle = socket_descriptor.fd; | |
| 115 #endif | |
| 116 delegate->OnLowLatencyCreated(handle, socket_handle, length); | |
| 117 } | |
| 118 | |
| 119 void AudioMessageFilter::OnStreamStateChanged( | |
| 120 int stream_id, | |
| 121 const ViewMsg_AudioStreamState_Params& state) { | |
| 122 Delegate* delegate = delegates_.Lookup(stream_id); | |
| 123 if (!delegate) { | |
| 124 DLOG(WARNING) << "Got audio stream event for a non-existent or removed" | |
| 125 " audio renderer."; | |
| 126 return; | |
| 127 } | |
| 128 delegate->OnStateChanged(state); | |
| 129 } | |
| 130 | |
| 131 void AudioMessageFilter::OnStreamVolume(int stream_id, double volume) { | |
| 132 Delegate* delegate = delegates_.Lookup(stream_id); | |
| 133 if (!delegate) { | |
| 134 DLOG(WARNING) << "Got audio stream event for a non-existent or removed" | |
| 135 " audio renderer."; | |
| 136 return; | |
| 137 } | |
| 138 delegate->OnVolume(volume); | |
| 139 } | |
| 140 | |
| 141 int32 AudioMessageFilter::AddDelegate(Delegate* delegate) { | |
| 142 return delegates_.Add(delegate); | |
| 143 } | |
| 144 | |
| 145 void AudioMessageFilter::RemoveDelegate(int32 id) { | |
| 146 delegates_.Remove(id); | |
| 147 } | |
| OLD | NEW |