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/browser/renderer_host/media/media_stream_dispatcher_host.h" | 5 #include "content/browser/renderer_host/media/media_stream_dispatcher_host.h" |
6 | 6 |
7 #include "content/browser/browser_main_loop.h" | 7 #include "content/browser/browser_main_loop.h" |
8 #include "content/common/media/media_stream_messages.h" | 8 #include "content/common/media/media_stream_messages.h" |
9 #include "content/common/media/media_stream_options.h" | 9 #include "content/common/media/media_stream_options.h" |
10 #include "googleurl/src/gurl.h" | 10 #include "googleurl/src/gurl.h" |
11 | 11 |
12 using content::BrowserMainLoop; | 12 namespace content { |
13 using content::BrowserMessageFilter; | |
14 using content::BrowserThread; | |
15 | |
16 namespace media_stream { | |
17 | 13 |
18 struct MediaStreamDispatcherHost::StreamRequest { | 14 struct MediaStreamDispatcherHost::StreamRequest { |
19 StreamRequest() : render_view_id(0), page_request_id(0) {} | 15 StreamRequest() : render_view_id(0), page_request_id(0) {} |
20 StreamRequest(int render_view_id, int page_request_id) | 16 StreamRequest(int render_view_id, int page_request_id) |
21 : render_view_id(render_view_id), | 17 : render_view_id(render_view_id), |
22 page_request_id(page_request_id ) { | 18 page_request_id(page_request_id ) { |
23 } | 19 } |
24 int render_view_id; | 20 int render_view_id; |
25 // Id of the request generated by MediaStreamDispatcher. | 21 // Id of the request generated by MediaStreamDispatcher. |
26 int page_request_id; | 22 int page_request_id; |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
125 streams_.clear(); | 121 streams_.clear(); |
126 } | 122 } |
127 | 123 |
128 MediaStreamDispatcherHost::~MediaStreamDispatcherHost() { | 124 MediaStreamDispatcherHost::~MediaStreamDispatcherHost() { |
129 DCHECK(streams_.empty()); | 125 DCHECK(streams_.empty()); |
130 } | 126 } |
131 | 127 |
132 void MediaStreamDispatcherHost::OnGenerateStream( | 128 void MediaStreamDispatcherHost::OnGenerateStream( |
133 int render_view_id, | 129 int render_view_id, |
134 int page_request_id, | 130 int page_request_id, |
135 const media_stream::StreamOptions& components, | 131 const StreamOptions& components, |
136 const GURL& security_origin) { | 132 const GURL& security_origin) { |
137 DVLOG(1) << "MediaStreamDispatcherHost::OnGenerateStream(" | 133 DVLOG(1) << "MediaStreamDispatcherHost::OnGenerateStream(" |
138 << render_view_id << ", " | 134 << render_view_id << ", " |
139 << page_request_id << ", [" | 135 << page_request_id << ", [" |
140 << " audio:" << components.audio_type | 136 << " audio:" << components.audio_type |
141 << " video:" << components.video_type | 137 << " video:" << components.video_type |
142 << " ], " | 138 << " ], " |
143 << security_origin.spec() << ")"; | 139 << security_origin.spec() << ")"; |
144 | 140 |
145 std::string label; | 141 std::string label; |
146 if (components.audio_type == content::MEDIA_TAB_AUDIO_CAPTURE || | 142 if (components.audio_type == MEDIA_TAB_AUDIO_CAPTURE || |
147 components.video_type == content::MEDIA_TAB_VIDEO_CAPTURE) { | 143 components.video_type == MEDIA_TAB_VIDEO_CAPTURE) { |
148 const std::string& device_id = components.video_device_id; | 144 const std::string& device_id = components.video_device_id; |
149 DCHECK(!device_id.empty()); | 145 DCHECK(!device_id.empty()); |
150 // TODO(justinlin): Cleanup/get rid of GenerateStreamForDevice and merge | 146 // TODO(justinlin): Cleanup/get rid of GenerateStreamForDevice and merge |
151 // with the regular GenerateStream. | 147 // with the regular GenerateStream. |
152 GetManager()->GenerateStreamForDevice( | 148 GetManager()->GenerateStreamForDevice( |
153 this, render_process_id_, render_view_id, | 149 this, render_process_id_, render_view_id, |
154 components, device_id, security_origin, &label); | 150 components, device_id, security_origin, &label); |
155 } else { | 151 } else { |
156 GetManager()->GenerateStream(this, render_process_id_, render_view_id, | 152 GetManager()->GenerateStream(this, render_process_id_, render_view_id, |
157 components, security_origin, &label); | 153 components, security_origin, &label); |
(...skipping 22 matching lines...) Expand all Loading... |
180 << ", {label = " << label << "})"; | 176 << ", {label = " << label << "})"; |
181 | 177 |
182 StreamMap::iterator it = streams_.find(label); | 178 StreamMap::iterator it = streams_.find(label); |
183 GetManager()->StopGeneratedStream(label); | 179 GetManager()->StopGeneratedStream(label); |
184 streams_.erase(it); | 180 streams_.erase(it); |
185 } | 181 } |
186 | 182 |
187 void MediaStreamDispatcherHost::OnEnumerateDevices( | 183 void MediaStreamDispatcherHost::OnEnumerateDevices( |
188 int render_view_id, | 184 int render_view_id, |
189 int page_request_id, | 185 int page_request_id, |
190 media_stream::MediaStreamType type, | 186 MediaStreamType type, |
191 const GURL& security_origin) { | 187 const GURL& security_origin) { |
192 DVLOG(1) << "MediaStreamDispatcherHost::OnEnumerateDevices(" | 188 DVLOG(1) << "MediaStreamDispatcherHost::OnEnumerateDevices(" |
193 << render_view_id << ", " | 189 << render_view_id << ", " |
194 << page_request_id << ", " | 190 << page_request_id << ", " |
195 << type << ", " | 191 << type << ", " |
196 << security_origin.spec() << ")"; | 192 << security_origin.spec() << ")"; |
197 | 193 |
198 std::string label; | 194 std::string label; |
199 GetManager()->EnumerateDevices(this, render_process_id_, render_view_id, | 195 GetManager()->EnumerateDevices(this, render_process_id_, render_view_id, |
200 type, security_origin, &label); | 196 type, security_origin, &label); |
201 DCHECK(!label.empty()); | 197 DCHECK(!label.empty()); |
202 streams_[label] = StreamRequest(render_view_id, page_request_id); | 198 streams_[label] = StreamRequest(render_view_id, page_request_id); |
203 } | 199 } |
204 | 200 |
205 void MediaStreamDispatcherHost::OnOpenDevice( | 201 void MediaStreamDispatcherHost::OnOpenDevice( |
206 int render_view_id, | 202 int render_view_id, |
207 int page_request_id, | 203 int page_request_id, |
208 const std::string& device_id, | 204 const std::string& device_id, |
209 media_stream::MediaStreamType type, | 205 MediaStreamType type, |
210 const GURL& security_origin) { | 206 const GURL& security_origin) { |
211 DVLOG(1) << "MediaStreamDispatcherHost::OnOpenDevice(" | 207 DVLOG(1) << "MediaStreamDispatcherHost::OnOpenDevice(" |
212 << render_view_id << ", " | 208 << render_view_id << ", " |
213 << page_request_id << ", device_id: " | 209 << page_request_id << ", device_id: " |
214 << device_id.c_str() << ", type: " | 210 << device_id.c_str() << ", type: " |
215 << type << ", " | 211 << type << ", " |
216 << security_origin.spec() << ")"; | 212 << security_origin.spec() << ")"; |
217 | 213 |
218 std::string label; | 214 std::string label; |
219 GetManager()->OpenDevice(this, render_process_id_, render_view_id, | 215 GetManager()->OpenDevice(this, render_process_id_, render_view_id, |
220 device_id, type, security_origin, &label); | 216 device_id, type, security_origin, &label); |
221 DCHECK(!label.empty()); | 217 DCHECK(!label.empty()); |
222 streams_[label] = StreamRequest(render_view_id, page_request_id); | 218 streams_[label] = StreamRequest(render_view_id, page_request_id); |
223 } | 219 } |
224 | 220 |
225 MediaStreamManager* MediaStreamDispatcherHost::GetManager() { | 221 MediaStreamManager* MediaStreamDispatcherHost::GetManager() { |
226 return BrowserMainLoop::GetMediaStreamManager(); | 222 return BrowserMainLoop::GetMediaStreamManager(); |
227 } | 223 } |
228 | 224 |
229 } // namespace media_stream | 225 } // namespace content |
OLD | NEW |