| 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/media_stream_dependency_factory.h" | 5 #include "content/renderer/media/media_stream_dependency_factory.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
| 10 #include "base/strings/utf_string_conversions.h" | 10 #include "base/strings/utf_string_conversions.h" |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 89 &already_set_value, NULL)) { | 89 &already_set_value, NULL)) { |
| 90 constraints->AddMandatory(kDefaultAudioConstraints[i].key, | 90 constraints->AddMandatory(kDefaultAudioConstraints[i].key, |
| 91 kDefaultAudioConstraints[i].value, false); | 91 kDefaultAudioConstraints[i].value, false); |
| 92 } else { | 92 } else { |
| 93 DVLOG(1) << "Constraint " << kDefaultAudioConstraints[i].key | 93 DVLOG(1) << "Constraint " << kDefaultAudioConstraints[i].key |
| 94 << " already set to " << already_set_value; | 94 << " already set to " << already_set_value; |
| 95 } | 95 } |
| 96 } | 96 } |
| 97 } | 97 } |
| 98 | 98 |
| 99 void TransferConstraintToPlatformEffect(RTCMediaConstraints* constraints, |
| 100 const char* key, |
| 101 bool* platform_effect) { |
| 102 bool value; |
| 103 if (!webrtc::FindConstraint(constraints, key, &value, NULL) || |
| 104 value == false) { |
| 105 // If the constraint does not exist, or is set to false, disable the |
| 106 // corresponding platform effect. |
| 107 *platform_effect = false; |
| 108 DVLOG(1) << "Disabling platform effect: " << key; |
| 109 } else { |
| 110 if (*platform_effect) { |
| 111 // If the constraint is set to true, and the corresponding platform effect |
| 112 // is available, disable the constraint. |
| 113 constraints->AddMandatory(key, |
| 114 webrtc::MediaConstraintsInterface::kValueFalse, true); |
| 115 DVLOG(1) << "Disabling constraint: " << key; |
| 116 } |
| 117 } |
| 118 } |
| 119 |
| 120 // Any true constraint with an available corresponding platform effect will be |
| 121 // set to false. Any false constraint will cause the corresponding platform |
| 122 // effect to be disabled. |
| 123 // |
| 124 // This currently only deals with AEC, but is prepared for expansion to other |
| 125 // platform effects. |
| 126 void TransferConstraintsToPlatformEffects(RTCMediaConstraints* constraints, |
| 127 MediaStreamDevice::AudioDeviceParameters* params) { |
| 128 TransferConstraintToPlatformEffect(constraints, |
| 129 webrtc::MediaConstraintsInterface::kEchoCancellation, |
| 130 ¶ms->use_platform_aec); |
| 131 } |
| 132 |
| 99 class P2PPortAllocatorFactory : public webrtc::PortAllocatorFactoryInterface { | 133 class P2PPortAllocatorFactory : public webrtc::PortAllocatorFactoryInterface { |
| 100 public: | 134 public: |
| 101 P2PPortAllocatorFactory( | 135 P2PPortAllocatorFactory( |
| 102 P2PSocketDispatcher* socket_dispatcher, | 136 P2PSocketDispatcher* socket_dispatcher, |
| 103 talk_base::NetworkManager* network_manager, | 137 talk_base::NetworkManager* network_manager, |
| 104 talk_base::PacketSocketFactory* socket_factory, | 138 talk_base::PacketSocketFactory* socket_factory, |
| 105 blink::WebFrame* web_frame) | 139 blink::WebFrame* web_frame) |
| 106 : socket_dispatcher_(socket_dispatcher), | 140 : socket_dispatcher_(socket_dispatcher), |
| 107 network_manager_(network_manager), | 141 network_manager_(network_manager), |
| 108 socket_factory_(socket_factory), | 142 socket_factory_(socket_factory), |
| (...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 316 static_cast<MediaStreamSourceExtraData*>(source.extraData()); | 350 static_cast<MediaStreamSourceExtraData*>(source.extraData()); |
| 317 | 351 |
| 318 // Check if the source has already been created. This happens when the same | 352 // Check if the source has already been created. This happens when the same |
| 319 // source is used in multiple MediaStreams as a result of calling | 353 // source is used in multiple MediaStreams as a result of calling |
| 320 // getUserMedia. | 354 // getUserMedia. |
| 321 if (source_data->local_audio_source()) | 355 if (source_data->local_audio_source()) |
| 322 continue; | 356 continue; |
| 323 | 357 |
| 324 // TODO(xians): Create a new capturer for difference microphones when we | 358 // TODO(xians): Create a new capturer for difference microphones when we |
| 325 // support multiple microphones. See issue crbug/262117 . | 359 // support multiple microphones. See issue crbug/262117 . |
| 326 const StreamDeviceInfo device_info = source_data->device_info(); | 360 StreamDeviceInfo device_info = source_data->device_info(); |
| 361 |
| 362 RTCMediaConstraints platform_constraints = native_audio_constraints; |
| 363 // This causes constraint settings to be transferred to their corresponding |
| 364 // platform effects. For example, if a platform AEC is available, and the |
| 365 // AEC constraint is set to true, we should leave the platform AEC |
| 366 // enabled, and disable the software AEC by setting the constraint to false. |
| 367 // Contrariwise, if the AEC constraint is set to false, we should disable |
| 368 // the platform AEC even if available. |
| 369 TransferConstraintsToPlatformEffects(&platform_constraints, |
| 370 &device_info.device.input); |
| 327 scoped_refptr<WebRtcAudioCapturer> capturer( | 371 scoped_refptr<WebRtcAudioCapturer> capturer( |
| 328 MaybeCreateAudioCapturer(render_view_id, device_info)); | 372 MaybeCreateAudioCapturer(render_view_id, device_info)); |
| 329 if (!capturer.get()) { | 373 if (!capturer.get()) { |
| 330 DLOG(WARNING) << "Failed to create the capturer for device " | 374 DLOG(WARNING) << "Failed to create the capturer for device " |
| 331 << device_info.device.id; | 375 << device_info.device.id; |
| 332 sources_created.Run(web_stream, false); | 376 sources_created.Run(web_stream, false); |
| 333 // TODO(xians): Don't we need to check if source_observer is observing | 377 // TODO(xians): Don't we need to check if source_observer is observing |
| 334 // something? If not, then it looks like we have a leak here. | 378 // something? If not, then it looks like we have a leak here. |
| 335 // OTOH, if it _is_ observing something, then the callback might | 379 // OTOH, if it _is_ observing something, then the callback might |
| 336 // be called multiple times which is likely also a bug. | 380 // be called multiple times which is likely also a bug. |
| 337 return; | 381 return; |
| 338 } | 382 } |
| 339 source_data->SetAudioCapturer(capturer); | 383 source_data->SetAudioCapturer(capturer); |
| 340 | 384 |
| 341 // Creates a LocalAudioSource object which holds audio options. | 385 // Creates a LocalAudioSource object which holds audio options. |
| 342 // TODO(xians): The option should apply to the track instead of the source. | 386 // TODO(xians): The option should apply to the track instead of the source. |
| 343 source_data->SetLocalAudioSource( | 387 source_data->SetLocalAudioSource( |
| 344 CreateLocalAudioSource(&native_audio_constraints).get()); | 388 CreateLocalAudioSource(&platform_constraints).get()); |
| 345 source_observer->AddSource(source_data->local_audio_source()); | 389 source_observer->AddSource(source_data->local_audio_source()); |
| 346 } | 390 } |
| 347 | 391 |
| 348 source_observer->StartObservering(); | 392 source_observer->StartObservering(); |
| 349 } | 393 } |
| 350 | 394 |
| 351 void MediaStreamDependencyFactory::CreateNativeLocalMediaStream( | 395 void MediaStreamDependencyFactory::CreateNativeLocalMediaStream( |
| 352 blink::WebMediaStream* web_stream) { | 396 blink::WebMediaStream* web_stream) { |
| 353 DVLOG(1) << "MediaStreamDependencyFactory::CreateNativeLocalMediaStream()"; | 397 DVLOG(1) << "MediaStreamDependencyFactory::CreateNativeLocalMediaStream()"; |
| 354 if (!EnsurePeerConnectionFactory()) { | 398 if (!EnsurePeerConnectionFactory()) { |
| (...skipping 548 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 903 | 947 |
| 904 if (!capturer->Initialize( | 948 if (!capturer->Initialize( |
| 905 render_view_id, | 949 render_view_id, |
| 906 static_cast<media::ChannelLayout>( | 950 static_cast<media::ChannelLayout>( |
| 907 device_info.device.input.channel_layout), | 951 device_info.device.input.channel_layout), |
| 908 device_info.device.input.sample_rate, | 952 device_info.device.input.sample_rate, |
| 909 device_info.device.input.frames_per_buffer, | 953 device_info.device.input.frames_per_buffer, |
| 910 device_info.session_id, | 954 device_info.session_id, |
| 911 device_info.device.id, | 955 device_info.device.id, |
| 912 device_info.device.matched_output.sample_rate, | 956 device_info.device.matched_output.sample_rate, |
| 913 device_info.device.matched_output.frames_per_buffer)) { | 957 device_info.device.matched_output.frames_per_buffer, |
| 958 device_info.device.input.use_platform_aec)) { |
| 914 return NULL; | 959 return NULL; |
| 915 } | 960 } |
| 916 | 961 |
| 917 // Add the capturer to the WebRtcAudioDeviceImpl if it is a new capturer. | 962 // Add the capturer to the WebRtcAudioDeviceImpl if it is a new capturer. |
| 918 if (is_new_capturer) | 963 if (is_new_capturer) |
| 919 GetWebRtcAudioDevice()->AddAudioCapturer(capturer); | 964 GetWebRtcAudioDevice()->AddAudioCapturer(capturer); |
| 920 | 965 |
| 921 return capturer; | 966 return capturer; |
| 922 } | 967 } |
| 923 | 968 |
| (...skipping 28 matching lines...) Expand all Loading... |
| 952 MediaStreamDependencyFactory::GetNativeMediaStreamTrack( | 997 MediaStreamDependencyFactory::GetNativeMediaStreamTrack( |
| 953 const blink::WebMediaStreamTrack& track) { | 998 const blink::WebMediaStreamTrack& track) { |
| 954 if (track.isNull()) | 999 if (track.isNull()) |
| 955 return NULL; | 1000 return NULL; |
| 956 MediaStreamTrackExtraData* extra_data = | 1001 MediaStreamTrackExtraData* extra_data = |
| 957 static_cast<MediaStreamTrackExtraData*>(track.extraData()); | 1002 static_cast<MediaStreamTrackExtraData*>(track.extraData()); |
| 958 return extra_data ? extra_data->track().get() : NULL; | 1003 return extra_data ? extra_data->track().get() : NULL; |
| 959 } | 1004 } |
| 960 | 1005 |
| 961 } // namespace content | 1006 } // namespace content |
| OLD | NEW |