OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/renderer/media/audio_message_filter.h" | 5 #include "content/renderer/media/audio_message_filter.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
9 #include "base/time.h" | 9 #include "base/time.h" |
10 #include "content/common/child_process.h" | 10 #include "content/common/child_process.h" |
11 #include "content/common/media/audio_messages.h" | 11 #include "content/common/media/audio_messages.h" |
| 12 #include "content/renderer/render_thread_impl.h" |
12 #include "ipc/ipc_logging.h" | 13 #include "ipc/ipc_logging.h" |
13 | 14 |
| 15 AudioMessageFilter* AudioMessageFilter::filter_ = NULL; |
| 16 |
| 17 // static |
| 18 AudioMessageFilter* AudioMessageFilter::Get() { |
| 19 return filter_; |
| 20 } |
| 21 |
14 AudioMessageFilter::AudioMessageFilter() | 22 AudioMessageFilter::AudioMessageFilter() |
15 : channel_(NULL) { | 23 : channel_(NULL) { |
16 VLOG(1) << "AudioMessageFilter::AudioMessageFilter()"; | 24 VLOG(1) << "AudioMessageFilter::AudioMessageFilter()"; |
| 25 DCHECK(!filter_); |
| 26 filter_ = this; |
17 } | 27 } |
18 | 28 |
19 int32 AudioMessageFilter::AddDelegate(Delegate* delegate) { | 29 int32 AudioMessageFilter::AddDelegate(Delegate* delegate) { |
20 return delegates_.Add(delegate); | 30 return delegates_.Add(delegate); |
21 } | 31 } |
22 | 32 |
23 void AudioMessageFilter::RemoveDelegate(int32 id) { | 33 void AudioMessageFilter::RemoveDelegate(int32 id) { |
24 delegates_.Remove(id); | 34 delegates_.Remove(id); |
25 } | 35 } |
26 | 36 |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
62 void AudioMessageFilter::OnFilterRemoved() { | 72 void AudioMessageFilter::OnFilterRemoved() { |
63 channel_ = NULL; | 73 channel_ = NULL; |
64 } | 74 } |
65 | 75 |
66 void AudioMessageFilter::OnChannelClosing() { | 76 void AudioMessageFilter::OnChannelClosing() { |
67 channel_ = NULL; | 77 channel_ = NULL; |
68 } | 78 } |
69 | 79 |
70 AudioMessageFilter::~AudioMessageFilter() { | 80 AudioMessageFilter::~AudioMessageFilter() { |
71 VLOG(1) << "AudioMessageFilter::~AudioMessageFilter()"; | 81 VLOG(1) << "AudioMessageFilter::~AudioMessageFilter()"; |
| 82 DCHECK(filter_); |
| 83 filter_ = NULL; |
72 } | 84 } |
73 | 85 |
74 void AudioMessageFilter::OnStreamCreated( | 86 void AudioMessageFilter::OnStreamCreated( |
75 int stream_id, | 87 int stream_id, |
76 base::SharedMemoryHandle handle, | 88 base::SharedMemoryHandle handle, |
77 #if defined(OS_WIN) | 89 #if defined(OS_WIN) |
78 base::SyncSocket::Handle socket_handle, | 90 base::SyncSocket::Handle socket_handle, |
79 #else | 91 #else |
80 base::FileDescriptor socket_descriptor, | 92 base::FileDescriptor socket_descriptor, |
81 #endif | 93 #endif |
(...skipping 15 matching lines...) Expand all Loading... |
97 void AudioMessageFilter::OnStreamStateChanged( | 109 void AudioMessageFilter::OnStreamStateChanged( |
98 int stream_id, AudioStreamState state) { | 110 int stream_id, AudioStreamState state) { |
99 Delegate* delegate = delegates_.Lookup(stream_id); | 111 Delegate* delegate = delegates_.Lookup(stream_id); |
100 if (!delegate) { | 112 if (!delegate) { |
101 DLOG(WARNING) << "Got audio stream event for a non-existent or removed" | 113 DLOG(WARNING) << "Got audio stream event for a non-existent or removed" |
102 " audio renderer."; | 114 " audio renderer."; |
103 return; | 115 return; |
104 } | 116 } |
105 delegate->OnStateChanged(state); | 117 delegate->OnStateChanged(state); |
106 } | 118 } |
OLD | NEW |