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

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

Issue 525313002: SyncSocket Transit Descriptor - refactoring (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Add DCHECK on posix for descriptor pointer Created 6 years, 3 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
OLDNEW
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/message_loop_proxy.h" 8 #include "base/message_loop/message_loop_proxy.h"
9 #include "base/strings/stringprintf.h" 9 #include "base/strings/stringprintf.h"
10 #include "content/common/media/audio_messages.h" 10 #include "content/common/media/audio_messages.h"
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after
159 159
160 IDMap<media::AudioOutputIPCDelegate>::iterator it(&delegates_); 160 IDMap<media::AudioOutputIPCDelegate>::iterator it(&delegates_);
161 while (!it.IsAtEnd()) { 161 while (!it.IsAtEnd()) {
162 it.GetCurrentValue()->OnIPCClosed(); 162 it.GetCurrentValue()->OnIPCClosed();
163 delegates_.Remove(it.GetCurrentKey()); 163 delegates_.Remove(it.GetCurrentKey());
164 it.Advance(); 164 it.Advance();
165 } 165 }
166 } 166 }
167 167
168 void AudioMessageFilter::OnStreamCreated( 168 void AudioMessageFilter::OnStreamCreated(
169 int stream_id, 169 int stream_id, base::SharedMemoryHandle handle,
170 base::SharedMemoryHandle handle, 170 base::SyncSocket::TransitDescriptor socket_descriptor, uint32 length) {
nasko 2014/09/05 17:31:52 style: all parameters must be on their own line
burnik 2014/09/06 18:17:10 Done.
171 #if defined(OS_WIN)
172 base::SyncSocket::Handle socket_handle,
173 #else
174 base::FileDescriptor socket_descriptor,
175 #endif
176 uint32 length) {
177 DCHECK(io_message_loop_->BelongsToCurrentThread()); 171 DCHECK(io_message_loop_->BelongsToCurrentThread());
178 172
179 WebRtcLogMessage(base::StringPrintf( 173 WebRtcLogMessage(base::StringPrintf(
180 "AMF::OnStreamCreated. stream_id=%d", 174 "AMF::OnStreamCreated. stream_id=%d",
181 stream_id)); 175 stream_id));
182 176
183 #if !defined(OS_WIN) 177 base::SyncSocket::Handle socket_handle =
184 base::SyncSocket::Handle socket_handle = socket_descriptor.fd; 178 base::SyncSocket::UnwrapHandle(socket_descriptor);
185 #endif
186 179
187 media::AudioOutputIPCDelegate* delegate = delegates_.Lookup(stream_id); 180 media::AudioOutputIPCDelegate* delegate = delegates_.Lookup(stream_id);
188 if (!delegate) { 181 if (!delegate) {
189 DLOG(WARNING) << "Got OnStreamCreated() event for a non-existent or removed" 182 DLOG(WARNING) << "Got OnStreamCreated() event for a non-existent or removed"
190 << " audio renderer. (stream_id=" << stream_id << ")."; 183 << " audio renderer. (stream_id=" << stream_id << ").";
191 base::SharedMemory::CloseHandle(handle); 184 base::SharedMemory::CloseHandle(handle);
192 base::SyncSocket socket(socket_handle); 185 base::SyncSocket socket(socket_handle);
193 return; 186 return;
194 } 187 }
195 delegate->OnStreamCreated(handle, socket_handle, length); 188 delegate->OnStreamCreated(handle, socket_handle, length);
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after
241 audio_hardware_config_->UpdateOutputConfig(output_params); 234 audio_hardware_config_->UpdateOutputConfig(output_params);
242 } 235 }
243 236
244 void AudioMessageFilter::SetAudioHardwareConfig( 237 void AudioMessageFilter::SetAudioHardwareConfig(
245 media::AudioHardwareConfig* config) { 238 media::AudioHardwareConfig* config) {
246 base::AutoLock auto_lock(lock_); 239 base::AutoLock auto_lock(lock_);
247 audio_hardware_config_ = config; 240 audio_hardware_config_ = config;
248 } 241 }
249 242
250 } // namespace content 243 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698