OLD | NEW |
(Empty) | |
| 1 // Copyright 2016 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/browser/renderer_host/media/render_frame_audio_output_service.
h" |
| 6 |
| 7 #include <utility> |
| 8 |
| 9 #include "base/metrics/histogram_macros.h" |
| 10 #include "base/threading/thread_checker.h" |
| 11 #include "content/browser/bad_message.h" |
| 12 #include "content/browser/media/capture/audio_mirroring_manager.h" |
| 13 #include "content/browser/renderer_host/media/audio_output_impl.h" |
| 14 #include "content/browser/renderer_host/media/audio_output_service_context.h" |
| 15 #include "content/browser/renderer_host/media/media_stream_manager.h" |
| 16 #include "content/common/media/audio_output.mojom.h" |
| 17 #include "media/audio/audio_manager.h" |
| 18 #include "media/base/audio_parameters.h" |
| 19 #include "mojo/public/cpp/bindings/binding.h" |
| 20 |
| 21 namespace content { |
| 22 |
| 23 namespace { |
| 24 |
| 25 void UMALogDeviceAuthorizationTime(base::TimeTicks auth_start_time) { |
| 26 UMA_HISTOGRAM_CUSTOM_TIMES("Media.Audio.OutputDeviceAuthorizationTime", |
| 27 base::TimeTicks::Now() - auth_start_time, |
| 28 base::TimeDelta::FromMilliseconds(1), |
| 29 base::TimeDelta::FromMilliseconds(5000), 50); |
| 30 } |
| 31 |
| 32 } // namespace |
| 33 |
| 34 RenderFrameAudioOutputService::RenderFrameAudioOutputService( |
| 35 AudioOutputServiceContext* context, |
| 36 int render_frame_id, |
| 37 mojom::RendererAudioOutputServiceRequest request) |
| 38 : binding_(this, std::move(request)), |
| 39 context_(context), |
| 40 render_frame_id_(render_frame_id) { |
| 41 DCHECK(thread_checker_.CalledOnValidThread()); |
| 42 CHECK(context_); |
| 43 binding_.set_connection_error_handler( |
| 44 base::Bind(&AudioOutputServiceContext::OnServiceFinished, |
| 45 base::Unretained(context), base::Unretained(this))); |
| 46 } |
| 47 |
| 48 RenderFrameAudioOutputService::~RenderFrameAudioOutputService() { |
| 49 DCHECK(thread_checker_.CalledOnValidThread()); |
| 50 } |
| 51 |
| 52 void RenderFrameAudioOutputService::RequestDeviceAuthorization( |
| 53 mojom::AudioOutputRequest audio_output_request, |
| 54 int64_t session_id, |
| 55 const std::string& device_id, |
| 56 const url::Origin& origin, |
| 57 const RequestDeviceAuthorizationCallback& callback) { |
| 58 DCHECK(thread_checker_.CalledOnValidThread()); |
| 59 const base::TimeTicks auth_start_time = base::TimeTicks::Now(); |
| 60 |
| 61 if (!base::IsValueInRangeForNumericType<int>(session_id)) { |
| 62 UMALogDeviceAuthorizationTime(auth_start_time); |
| 63 binding_.Close(); |
| 64 bad_message::ReceivedBadMessage(context_->GetRenderProcessId(), |
| 65 bad_message::RFAOS_OUT_OF_RANGE_INTEGER); |
| 66 context_->OnServiceFinished(this); |
| 67 return; |
| 68 } |
| 69 |
| 70 context_->RequestDeviceAuthorization( |
| 71 render_frame_id_, static_cast<int>(session_id), device_id, origin, |
| 72 base::Bind(&RenderFrameAudioOutputService::AuthorizationCompleted, |
| 73 base::Unretained(this), origin, auth_start_time, |
| 74 base::Passed(std::move(audio_output_request)), callback)); |
| 75 } |
| 76 |
| 77 void RenderFrameAudioOutputService::AuthorizationCompleted( |
| 78 const url::Origin& origin, |
| 79 base::TimeTicks auth_start_time, |
| 80 mojom::AudioOutputRequest request, |
| 81 const RequestDeviceAuthorizationCallback& callback, |
| 82 media::OutputDeviceStatus status, |
| 83 bool should_send_id, |
| 84 const media::AudioParameters& params, |
| 85 const std::string& raw_device_id) { |
| 86 DCHECK(thread_checker_.CalledOnValidThread()); |
| 87 UMALogDeviceAuthorizationTime(auth_start_time); |
| 88 |
| 89 if (status != media::OUTPUT_DEVICE_STATUS_OK) { |
| 90 callback.Run(media::OutputDeviceStatus(status), |
| 91 media::AudioParameters::UnavailableDeviceParams(), |
| 92 std::string()); |
| 93 return; |
| 94 } |
| 95 |
| 96 if (request.is_pending()) { |
| 97 audio_outputs_.push_back( |
| 98 base::WrapUnique<mojom::AudioOutput>(new AudioOutputImpl( |
| 99 std::move(request), |
| 100 base::BindOnce(&AudioOutputServiceContext::CreateDelegate, |
| 101 base::Unretained(context_), raw_device_id, |
| 102 render_frame_id_), |
| 103 base::BindOnce(&RenderFrameAudioOutputService::RemoveOutput, |
| 104 base::Unretained(this))))); |
| 105 } |
| 106 |
| 107 callback.Run(media::OutputDeviceStatus(status), params, |
| 108 should_send_id ? MediaStreamManager::GetHMACForMediaDeviceID( |
| 109 context_->GetSalt(), origin, raw_device_id) |
| 110 : std::string()); |
| 111 } |
| 112 |
| 113 void RenderFrameAudioOutputService::RemoveOutput( |
| 114 mojom::AudioOutput* audio_output) { |
| 115 auto it = std::find_if( |
| 116 audio_outputs_.begin(), audio_outputs_.end(), |
| 117 [audio_output](const std::unique_ptr<mojom::AudioOutput>& other) { |
| 118 return other.get() == audio_output; |
| 119 }); |
| 120 |
| 121 // It is possible that the output is already gone, in case destruction |
| 122 // triggered a connection error. |
| 123 if (it != audio_outputs_.end()) { |
| 124 std::swap(*it, audio_outputs_.back()); |
| 125 audio_outputs_.pop_back(); |
| 126 } |
| 127 } |
| 128 |
| 129 } // namespace content |
OLD | NEW |