Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(131)

Side by Side Diff: content/renderer/audio_message_filter.cc

Issue 7003053: Moves audio files from content\renderer\ to content\renderer\media. (Closed) Base URL: http://src.chromium.org/svn/trunk/src/
Patch Set: Created 9 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
(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 "content/renderer/audio_message_filter.h"
6
7 #include "base/message_loop.h"
8 #include "base/time.h"
9 #include "content/common/audio_messages.h"
10 #include "ipc/ipc_logging.h"
11
12 AudioMessageFilter::AudioMessageFilter(int32 route_id)
13 : channel_(NULL),
14 route_id_(route_id),
15 message_loop_(NULL) {
16 }
17
18 AudioMessageFilter::~AudioMessageFilter() {
19 }
20
21 // Called on the IPC thread.
22 bool AudioMessageFilter::Send(IPC::Message* message) {
23 if (!channel_) {
24 delete message;
25 return false;
26 }
27
28 if (MessageLoop::current() != message_loop_) {
29 // Can only access the IPC::Channel on the IPC thread since it's not thread
30 // safe.
31 message_loop_->PostTask(
32 FROM_HERE, NewRunnableMethod(this, &AudioMessageFilter::Send, message));
33 return true;
34 }
35
36 message->set_routing_id(route_id_);
37 return channel_->Send(message);
38 }
39
40 bool AudioMessageFilter::OnMessageReceived(const IPC::Message& message) {
41 if (message.routing_id() != route_id_)
42 return false;
43
44 bool handled = true;
45 IPC_BEGIN_MESSAGE_MAP(AudioMessageFilter, message)
46 IPC_MESSAGE_HANDLER(AudioMsg_RequestPacket, OnRequestPacket)
47 IPC_MESSAGE_HANDLER(AudioMsg_NotifyStreamCreated, OnStreamCreated)
48 IPC_MESSAGE_HANDLER(AudioMsg_NotifyLowLatencyStreamCreated,
49 OnLowLatencyStreamCreated)
50 IPC_MESSAGE_HANDLER(AudioMsg_NotifyStreamStateChanged, OnStreamStateChanged)
51 IPC_MESSAGE_HANDLER(AudioMsg_NotifyStreamVolume, OnStreamVolume)
52 IPC_MESSAGE_UNHANDLED(handled = false)
53 IPC_END_MESSAGE_MAP()
54 return handled;
55 }
56
57 void AudioMessageFilter::OnFilterAdded(IPC::Channel* channel) {
58 // Captures the message loop for IPC.
59 message_loop_ = MessageLoop::current();
60 channel_ = channel;
61 }
62
63 void AudioMessageFilter::OnFilterRemoved() {
64 channel_ = NULL;
65 }
66
67 void AudioMessageFilter::OnChannelClosing() {
68 channel_ = NULL;
69 }
70
71 void AudioMessageFilter::OnRequestPacket(const IPC::Message& msg,
72 int stream_id,
73 AudioBuffersState buffers_state) {
74 Delegate* delegate = delegates_.Lookup(stream_id);
75 if (!delegate) {
76 DLOG(WARNING) << "Got audio packet request for a non-existent or removed"
77 " audio renderer.";
78 return;
79 }
80
81 delegate->OnRequestPacket(buffers_state);
82 }
83
84 void AudioMessageFilter::OnStreamCreated(int stream_id,
85 base::SharedMemoryHandle handle,
86 uint32 length) {
87 Delegate* delegate = delegates_.Lookup(stream_id);
88 if (!delegate) {
89 DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
90 " audio renderer.";
91 return;
92 }
93 delegate->OnCreated(handle, length);
94 }
95
96 void AudioMessageFilter::OnLowLatencyStreamCreated(
97 int stream_id,
98 base::SharedMemoryHandle handle,
99 #if defined(OS_WIN)
100 base::SyncSocket::Handle socket_handle,
101 #else
102 base::FileDescriptor socket_descriptor,
103 #endif
104 uint32 length) {
105 Delegate* delegate = delegates_.Lookup(stream_id);
106 if (!delegate) {
107 DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
108 " audio renderer.";
109 return;
110 }
111 #if !defined(OS_WIN)
112 base::SyncSocket::Handle socket_handle = socket_descriptor.fd;
113 #endif
114 delegate->OnLowLatencyCreated(handle, socket_handle, length);
115 }
116
117 void AudioMessageFilter::OnStreamStateChanged(
118 int stream_id, AudioStreamState state) {
119 Delegate* delegate = delegates_.Lookup(stream_id);
120 if (!delegate) {
121 DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
122 " audio renderer.";
123 return;
124 }
125 delegate->OnStateChanged(state);
126 }
127
128 void AudioMessageFilter::OnStreamVolume(int stream_id, double volume) {
129 Delegate* delegate = delegates_.Lookup(stream_id);
130 if (!delegate) {
131 DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
132 " audio renderer.";
133 return;
134 }
135 delegate->OnVolume(volume);
136 }
137
138 int32 AudioMessageFilter::AddDelegate(Delegate* delegate) {
139 return delegates_.Add(delegate);
140 }
141
142 void AudioMessageFilter::RemoveDelegate(int32 id) {
143 delegates_.Remove(id);
144 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698