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_impl.h" | 5 #include "content/renderer/media/media_stream_impl.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/string_number_conversions.h" | 10 #include "base/string_number_conversions.h" |
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
81 | 81 |
82 void MediaStreamImpl::requestUserMedia( | 82 void MediaStreamImpl::requestUserMedia( |
83 const WebKit::WebUserMediaRequest& user_media_request, | 83 const WebKit::WebUserMediaRequest& user_media_request, |
84 const WebKit::WebVector<WebKit::WebMediaStreamSource>& audio_sources, | 84 const WebKit::WebVector<WebKit::WebMediaStreamSource>& audio_sources, |
85 const WebKit::WebVector<WebKit::WebMediaStreamSource>& video_sources) { | 85 const WebKit::WebVector<WebKit::WebMediaStreamSource>& video_sources) { |
86 // Save histogram data so we can see how much GetUserMedia is used. | 86 // Save histogram data so we can see how much GetUserMedia is used. |
87 // The histogram counts the number of calls to the JS API | 87 // The histogram counts the number of calls to the JS API |
88 // webGetUserMedia. | 88 // webGetUserMedia. |
89 UpdateWebRTCMethodCount(WEBKIT_GET_USER_MEDIA); | 89 UpdateWebRTCMethodCount(WEBKIT_GET_USER_MEDIA); |
90 DCHECK(CalledOnValidThread()); | 90 DCHECK(CalledOnValidThread()); |
91 int request_id = g_next_request_id++; | |
92 bool audio = false; | 91 bool audio = false; |
93 bool video = false; | 92 bool video = false; |
94 WebKit::WebFrame* frame = NULL; | |
95 GURL security_origin; | |
96 | |
97 // |user_media_request| can't be mocked. So in order to test at all we check | 93 // |user_media_request| can't be mocked. So in order to test at all we check |
98 // if it isNull. | 94 // if it isNull. |
99 if (user_media_request.isNull()) { | 95 if (user_media_request.isNull()) { |
100 // We are in a test. | 96 // We are in a test. |
101 audio = audio_sources.size() > 0; | 97 audio = audio_sources.size() > 0; |
102 video = video_sources.size() > 0; | 98 video = video_sources.size() > 0; |
103 } else { | 99 } else { |
104 audio = user_media_request.audio(); | 100 audio = user_media_request.audio(); |
105 video = user_media_request.video(); | 101 video = user_media_request.video(); |
| 102 } |
| 103 |
| 104 content::MediaStreamDeviceType audio_type = |
| 105 audio ? content::MEDIA_DEVICE_AUDIO_CAPTURE : content::MEDIA_NO_SERVICE; |
| 106 content::MediaStreamDeviceType video_type = |
| 107 video ? content::MEDIA_DEVICE_VIDEO_CAPTURE : content::MEDIA_NO_SERVICE; |
| 108 GenerateStreamForMedia(user_media_request, audio_type, video_type, NULL); |
| 109 } |
| 110 |
| 111 void MediaStreamImpl::requestDeviceMedia( |
| 112 const WebKit::WebDeviceMediaRequest& media_request) { |
| 113 const std::string& device_id = UTF16ToUTF8(media_request.deviceId()); |
| 114 |
| 115 content::MediaStreamDeviceType audio_type = media_request.audio() ? |
| 116 content::MEDIA_TAB_AUDIO_CAPTURE : content::MEDIA_NO_SERVICE; |
| 117 content::MediaStreamDeviceType video_type = media_request.video() ? |
| 118 content::MEDIA_TAB_VIDEO_CAPTURE : content::MEDIA_NO_SERVICE; |
| 119 |
| 120 GenerateStreamForMedia(media_request, audio_type, video_type, &device_id); |
| 121 } |
| 122 |
| 123 void MediaStreamImpl::GenerateStreamForMedia( |
| 124 const WebKit::WebUserMediaRequest& user_media_request, |
| 125 const content::MediaStreamDeviceType audio, |
| 126 const content::MediaStreamDeviceType video, |
| 127 const std::string* device_id) { |
| 128 DCHECK(CalledOnValidThread()); |
| 129 int request_id = g_next_request_id++; |
| 130 WebKit::WebFrame* frame = NULL; |
| 131 GURL security_origin; |
| 132 |
| 133 if (!user_media_request.isNull()) { |
106 security_origin = GURL(user_media_request.securityOrigin().toString()); | 134 security_origin = GURL(user_media_request.securityOrigin().toString()); |
107 // Get the WebFrame that requested a MediaStream. | 135 // Get the WebFrame that requested a MediaStream. |
108 // The frame is needed to tell the MediaStreamDispatcher when a stream goes | 136 // The frame is needed to tell the MediaStreamDispatcher when a stream goes |
109 // out of scope. | 137 // out of scope. |
110 frame = user_media_request.ownerDocument().frame(); | 138 frame = user_media_request.ownerDocument().frame(); |
111 DCHECK(frame); | 139 DCHECK(frame); |
112 } | 140 } |
113 | 141 |
114 DVLOG(1) << "MediaStreamImpl::generateStream(" << request_id << ", [ " | 142 DVLOG(1) << "MediaStreamImpl::generateStream(" << request_id << ", [ " |
115 << (audio ? "audio" : "") | 143 << (audio ? "audio" : "") |
116 << (user_media_request.video() ? " video" : "") << "], " | 144 << (user_media_request.video() ? " video" : "") << "], " |
117 << security_origin.spec() << ")"; | 145 << security_origin.spec() << ")"; |
118 | 146 |
119 user_media_requests_[request_id] = | 147 user_media_requests_[request_id] = |
120 UserMediaRequestInfo(frame, user_media_request); | 148 UserMediaRequestInfo(frame, user_media_request); |
121 | 149 |
122 media_stream_dispatcher_->GenerateStream( | 150 if (device_id == NULL) { |
123 request_id, | 151 // WebUserMediaRequest. |
124 AsWeakPtr(), | 152 media_stream_dispatcher_->GenerateStream( |
125 media_stream::StreamOptions(audio, video), | 153 request_id, |
126 security_origin); | 154 AsWeakPtr(), |
| 155 media_stream::StreamOptions(audio, video), |
| 156 security_origin); |
| 157 } else { |
| 158 // WebDeviceMediaRequest. |
| 159 media_stream_dispatcher_->GenerateStreamForDevice( |
| 160 request_id, |
| 161 AsWeakPtr(), |
| 162 media_stream::StreamOptions(audio, video), |
| 163 *device_id, |
| 164 security_origin); |
| 165 |
| 166 } |
127 } | 167 } |
128 | 168 |
129 void MediaStreamImpl::cancelUserMediaRequest( | 169 void MediaStreamImpl::cancelUserMediaRequest( |
130 const WebKit::WebUserMediaRequest& user_media_request) { | 170 const WebKit::WebUserMediaRequest& user_media_request) { |
131 DCHECK(CalledOnValidThread()); | 171 DCHECK(CalledOnValidThread()); |
132 MediaRequestMap::iterator it = user_media_requests_.begin(); | 172 MediaRequestMap::iterator it = user_media_requests_.begin(); |
133 for (; it != user_media_requests_.end(); ++it) { | 173 for (; it != user_media_requests_.end(); ++it) { |
134 if (it->second.request_ == user_media_request) | 174 if (it->second.request_ == user_media_request) |
135 break; | 175 break; |
136 } | 176 } |
(...skipping 319 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
456 | 496 |
457 void MediaStreamExtraData::SetLocalStreamStopCallback( | 497 void MediaStreamExtraData::SetLocalStreamStopCallback( |
458 const StreamStopCallback& stop_callback) { | 498 const StreamStopCallback& stop_callback) { |
459 stream_stop_callback_ = stop_callback; | 499 stream_stop_callback_ = stop_callback; |
460 } | 500 } |
461 | 501 |
462 void MediaStreamExtraData::OnLocalStreamStop() { | 502 void MediaStreamExtraData::OnLocalStreamStop() { |
463 if (!stream_stop_callback_.is_null()) | 503 if (!stream_stop_callback_.is_null()) |
464 stream_stop_callback_.Run(local_stream_->label()); | 504 stream_stop_callback_.Run(local_stream_->label()); |
465 } | 505 } |
OLD | NEW |