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 "chrome/browser/media/media_stream_capture_indicator.h" | 5 #include "chrome/browser/media/media_stream_capture_indicator.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/i18n/rtl.h" | 8 #include "base/i18n/rtl.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/memory/scoped_ptr.h" |
10 #include "base/utf_string_conversions.h" | 11 #include "base/utf_string_conversions.h" |
11 #include "chrome/app/chrome_command_ids.h" | 12 #include "chrome/app/chrome_command_ids.h" |
12 #include "chrome/browser/browser_process.h" | 13 #include "chrome/browser/browser_process.h" |
13 #include "chrome/browser/extensions/extension_service.h" | 14 #include "chrome/browser/extensions/extension_service.h" |
14 #include "chrome/browser/extensions/image_loader.h" | 15 #include "chrome/browser/extensions/image_loader.h" |
15 #include "chrome/browser/profiles/profile.h" | 16 #include "chrome/browser/profiles/profile.h" |
16 #include "chrome/browser/status_icons/status_icon.h" | 17 #include "chrome/browser/status_icons/status_icon.h" |
17 #include "chrome/browser/status_icons/status_tray.h" | 18 #include "chrome/browser/status_icons/status_tray.h" |
18 #include "chrome/browser/tab_contents/tab_util.h" | 19 #include "chrome/browser/tab_contents/tab_util.h" |
19 #include "content/public/browser/browser_thread.h" | 20 #include "content/public/browser/browser_thread.h" |
20 #include "content/public/browser/content_browser_client.h" | 21 #include "content/public/browser/content_browser_client.h" |
21 #include "content/public/browser/invalidate_type.h" | 22 #include "content/public/browser/invalidate_type.h" |
22 #include "content/public/browser/render_view_host.h" | |
23 #include "content/public/browser/web_contents.h" | 23 #include "content/public/browser/web_contents.h" |
24 #include "content/public/browser/web_contents_delegate.h" | 24 #include "content/public/browser/web_contents_delegate.h" |
25 #include "content/public/common/media_stream_request.h" | 25 #include "content/public/browser/web_contents_observer.h" |
26 #include "grit/chromium_strings.h" | 26 #include "grit/chromium_strings.h" |
27 #include "grit/generated_resources.h" | 27 #include "grit/generated_resources.h" |
28 #include "grit/theme_resources.h" | 28 #include "grit/theme_resources.h" |
29 #include "net/base/net_util.h" | 29 #include "net/base/net_util.h" |
30 #include "ui/base/l10n/l10n_util.h" | 30 #include "ui/base/l10n/l10n_util.h" |
31 #include "ui/base/resource/resource_bundle.h" | 31 #include "ui/base/resource/resource_bundle.h" |
| 32 #include "ui/gfx/image/image_skia.h" |
32 | 33 |
33 using content::BrowserThread; | 34 using content::BrowserThread; |
34 using content::WebContents; | 35 using content::WebContents; |
35 | 36 |
36 namespace { | 37 namespace { |
37 | 38 |
38 const extensions::Extension* GetExtension(int render_process_id, | 39 const extensions::Extension* GetExtension(WebContents* web_contents) { |
39 int render_view_id) { | |
40 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 40 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
41 | 41 |
42 WebContents* web_contents = tab_util::GetWebContentsByID( | |
43 render_process_id, render_view_id); | |
44 if (!web_contents) | 42 if (!web_contents) |
45 return NULL; | 43 return NULL; |
46 | 44 |
47 Profile* profile = | 45 Profile* profile = |
48 Profile::FromBrowserContext(web_contents->GetBrowserContext()); | 46 Profile::FromBrowserContext(web_contents->GetBrowserContext()); |
49 if (!profile) | 47 if (!profile) |
50 return NULL; | 48 return NULL; |
51 | 49 |
52 ExtensionService* extension_service = profile->GetExtensionService(); | 50 ExtensionService* extension_service = profile->GetExtensionService(); |
53 if (!extension_service) | 51 if (!extension_service) |
54 return NULL; | 52 return NULL; |
55 | 53 |
56 return extension_service->extensions()->GetExtensionOrAppByURL( | 54 return extension_service->extensions()->GetExtensionOrAppByURL( |
57 ExtensionURLInfo(web_contents->GetURL())); | 55 ExtensionURLInfo(web_contents->GetURL())); |
58 } | 56 } |
59 | 57 |
60 // Gets the security originator of the tab. It returns a string with no '/' | 58 // Gets the security originator of the tab. It returns a string with no '/' |
61 // at the end to display in the UI. | 59 // at the end to display in the UI. |
62 string16 GetSecurityOrigin(int render_process_id, int render_view_id) { | 60 string16 GetSecurityOrigin(WebContents* web_contents) { |
63 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 61 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
64 WebContents* tab_content = tab_util::GetWebContentsByID( | 62 |
65 render_process_id, render_view_id); | 63 if (!web_contents) |
66 if (!tab_content) | |
67 return string16(); | 64 return string16(); |
68 | 65 |
69 std::string security_origin = tab_content->GetURL().GetOrigin().spec(); | 66 std::string security_origin = web_contents->GetURL().GetOrigin().spec(); |
70 | 67 |
71 // Remove the last character if it is a '/'. | 68 // Remove the last character if it is a '/'. |
72 if (!security_origin.empty()) { | 69 if (!security_origin.empty()) { |
73 std::string::iterator it = security_origin.end() - 1; | 70 std::string::iterator it = security_origin.end() - 1; |
74 if (*it == '/') | 71 if (*it == '/') |
75 security_origin.erase(it); | 72 security_origin.erase(it); |
76 } | 73 } |
77 | 74 |
78 return UTF8ToUTF16(security_origin); | 75 return UTF8ToUTF16(security_origin); |
79 } | 76 } |
80 | 77 |
81 string16 GetTitle(int render_process_id, int render_view_id) { | 78 string16 GetTitle(WebContents* web_contents) { |
82 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 79 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
83 | 80 |
84 const extensions::Extension* extension = | 81 if (!web_contents) |
85 GetExtension(render_process_id, render_view_id); | 82 return string16(); |
| 83 |
| 84 const extensions::Extension* const extension = GetExtension(web_contents); |
86 if (extension) | 85 if (extension) |
87 return UTF8ToUTF16(extension->name()); | 86 return UTF8ToUTF16(extension->name()); |
88 | 87 |
89 WebContents* tab_content = tab_util::GetWebContentsByID( | 88 string16 tab_title = web_contents->GetTitle(); |
90 render_process_id, render_view_id); | |
91 if (!tab_content) | |
92 return string16(); | |
93 | |
94 string16 tab_title = tab_content->GetTitle(); | |
95 | 89 |
96 if (tab_title.empty()) { | 90 if (tab_title.empty()) { |
97 // If the page's title is empty use its security originator. | 91 // If the page's title is empty use its security originator. |
98 tab_title = GetSecurityOrigin(render_process_id, render_view_id); | 92 tab_title = GetSecurityOrigin(web_contents); |
99 } else { | 93 } else { |
100 // If the page's title matches its URL, use its security originator. | 94 // If the page's title matches its URL, use its security originator. |
101 std::string languages = | 95 std::string languages = |
102 content::GetContentClient()->browser()->GetAcceptLangs( | 96 content::GetContentClient()->browser()->GetAcceptLangs( |
103 tab_content->GetBrowserContext()); | 97 web_contents->GetBrowserContext()); |
104 if (tab_title == net::FormatUrl(tab_content->GetURL(), languages)) | 98 if (tab_title == net::FormatUrl(web_contents->GetURL(), languages)) |
105 tab_title = GetSecurityOrigin(render_process_id, render_view_id); | 99 tab_title = GetSecurityOrigin(web_contents); |
106 } | 100 } |
107 | 101 |
108 return tab_title; | 102 return tab_title; |
109 } | 103 } |
110 | 104 |
111 } // namespace | 105 } // namespace |
112 | 106 |
113 MediaStreamCaptureIndicator::TabEquals::TabEquals(WebContents* web_contents, | 107 // Stores usage counts for all the capture devices associated with a single |
114 int render_process_id, | 108 // WebContents instance, and observes for the destruction of the WebContents |
115 int render_view_id) | 109 // instance. |
116 : web_contents_(web_contents), | 110 class MediaStreamCaptureIndicator::WebContentsDeviceUsage |
117 render_process_id_(render_process_id), | 111 : protected content::WebContentsObserver { |
118 render_view_id_(render_view_id) {} | 112 public: |
| 113 explicit WebContentsDeviceUsage(WebContents* web_contents); |
119 | 114 |
120 bool MediaStreamCaptureIndicator::TabEquals::operator() ( | 115 bool IsWebContentsDestroyed() const { return web_contents() == NULL; } |
121 const MediaStreamCaptureIndicator::CaptureDeviceTab& tab) { | 116 |
122 return (web_contents_ == tab.web_contents || | 117 bool IsCapturingAudio() const { return audio_ref_count_ > 0; } |
123 (render_process_id_ == tab.render_process_id && | 118 bool IsCapturingVideo() const { return video_ref_count_ > 0; } |
124 render_view_id_ == tab.render_view_id)); | 119 bool IsMirroring() const { return mirroring_ref_count_ > 0; } |
| 120 |
| 121 // Updates ref-counts up (|direction| is true) or down by one, based on the |
| 122 // type of each device provided. In the increment-upward case, the return |
| 123 // value is the message ID for the balloon body to show, or zero if the |
| 124 // balloon should not be shown. |
| 125 int TallyUsage(const content::MediaStreamDevices& devices, bool direction); |
| 126 |
| 127 private: |
| 128 int audio_ref_count_; |
| 129 int video_ref_count_; |
| 130 int mirroring_ref_count_; |
| 131 |
| 132 DISALLOW_COPY_AND_ASSIGN(WebContentsDeviceUsage); |
| 133 }; |
| 134 |
| 135 MediaStreamCaptureIndicator::WebContentsDeviceUsage::WebContentsDeviceUsage( |
| 136 WebContents* web_contents) |
| 137 : content::WebContentsObserver(web_contents), |
| 138 audio_ref_count_(0), video_ref_count_(0), mirroring_ref_count_(0) { |
| 139 } |
| 140 |
| 141 int MediaStreamCaptureIndicator::WebContentsDeviceUsage::TallyUsage( |
| 142 const content::MediaStreamDevices& devices, bool direction) { |
| 143 const int inc_amount = direction ? +1 : -1; |
| 144 bool incremented_audio_count = false; |
| 145 bool incremented_video_count = false; |
| 146 for (content::MediaStreamDevices::const_iterator it = devices.begin(); |
| 147 it != devices.end(); ++it) { |
| 148 if (it->type == content::MEDIA_TAB_AUDIO_CAPTURE || |
| 149 it->type == content::MEDIA_TAB_VIDEO_CAPTURE) { |
| 150 mirroring_ref_count_ += inc_amount; |
| 151 } else if (content::IsAudioMediaType(it->type)) { |
| 152 audio_ref_count_ += inc_amount; |
| 153 incremented_audio_count = (inc_amount > 0); |
| 154 } else if (content::IsVideoMediaType(it->type)) { |
| 155 video_ref_count_ += inc_amount; |
| 156 incremented_video_count = (inc_amount > 0); |
| 157 } else { |
| 158 NOTIMPLEMENTED(); |
| 159 } |
| 160 } |
| 161 |
| 162 DCHECK_LE(0, audio_ref_count_); |
| 163 DCHECK_LE(0, video_ref_count_); |
| 164 DCHECK_LE(0, mirroring_ref_count_); |
| 165 |
| 166 if (incremented_audio_count && incremented_video_count) |
| 167 return IDS_MEDIA_STREAM_STATUS_TRAY_BALLOON_BODY_AUDIO_AND_VIDEO; |
| 168 else if (incremented_audio_count) |
| 169 return IDS_MEDIA_STREAM_STATUS_TRAY_BALLOON_BODY_AUDIO_ONLY; |
| 170 else if (incremented_video_count) |
| 171 return IDS_MEDIA_STREAM_STATUS_TRAY_BALLOON_BODY_VIDEO_ONLY; |
| 172 else |
| 173 return 0; |
125 } | 174 } |
126 | 175 |
127 MediaStreamCaptureIndicator::MediaStreamCaptureIndicator() | 176 MediaStreamCaptureIndicator::MediaStreamCaptureIndicator() |
128 : status_icon_(NULL), | 177 : status_icon_(NULL), |
129 mic_image_(NULL), | 178 mic_image_(NULL), |
130 camera_image_(NULL), | 179 camera_image_(NULL), |
131 balloon_image_(NULL), | 180 balloon_image_(NULL), |
132 should_show_balloon_(false) { | 181 should_show_balloon_(false) { |
133 } | 182 } |
134 | 183 |
135 MediaStreamCaptureIndicator::~MediaStreamCaptureIndicator() { | 184 MediaStreamCaptureIndicator::~MediaStreamCaptureIndicator() { |
136 // The user is responsible for cleaning up by closing all the opened devices. | 185 // The user is responsible for cleaning up by reporting the closure of any |
137 DCHECK(tabs_.empty()); | 186 // opened devices. However, there exists a race condition at shutdown: The UI |
| 187 // thread may be stopped before CaptureDevicesClosed() posts the task to |
| 188 // invoke DoDevicesClosedOnUIThread(). In this case, usage_map_ won't be |
| 189 // empty like it should. |
| 190 DCHECK(usage_map_.empty() || |
| 191 !BrowserThread::IsMessageLoopValid(BrowserThread::UI)); |
| 192 |
| 193 // Free any WebContentsDeviceUsage objects left over. |
| 194 for (UsageMap::const_iterator it = usage_map_.begin(); it != usage_map_.end(); |
| 195 ++it) { |
| 196 delete it->second; |
| 197 } |
138 } | 198 } |
139 | 199 |
140 bool MediaStreamCaptureIndicator::IsCommandIdChecked( | 200 bool MediaStreamCaptureIndicator::IsCommandIdChecked( |
141 int command_id) const { | 201 int command_id) const { |
142 NOTIMPLEMENTED() << "There are no checked items in the MediaStream menu."; | 202 NOTIMPLEMENTED() << "There are no checked items in the MediaStream menu."; |
143 return false; | 203 return false; |
144 } | 204 } |
145 | 205 |
146 bool MediaStreamCaptureIndicator::IsCommandIdEnabled( | 206 bool MediaStreamCaptureIndicator::IsCommandIdEnabled( |
147 int command_id) const { | 207 int command_id) const { |
148 return command_id != IDC_MinimumLabelValue; | 208 return command_id != IDC_MinimumLabelValue; |
149 } | 209 } |
150 | 210 |
151 bool MediaStreamCaptureIndicator::GetAcceleratorForCommandId( | 211 bool MediaStreamCaptureIndicator::GetAcceleratorForCommandId( |
152 int command_id, ui::Accelerator* accelerator) { | 212 int command_id, ui::Accelerator* accelerator) { |
153 // No accelerators for status icon context menu. | 213 // No accelerators for status icon context menu. |
154 return false; | 214 return false; |
155 } | 215 } |
156 | 216 |
157 void MediaStreamCaptureIndicator::ExecuteCommand(int command_id) { | 217 void MediaStreamCaptureIndicator::ExecuteCommand(int command_id) { |
158 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 218 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
159 DCHECK(command_id >= IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_FIRST && | 219 |
160 command_id <= IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_LAST); | 220 const int index = |
161 int index = command_id - IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_FIRST; | 221 command_id - IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_FIRST; |
162 WebContents* web_content = tab_util::GetWebContentsByID( | 222 DCHECK_LE(0, index); |
163 tabs_[index].render_process_id, tabs_[index].render_view_id); | 223 DCHECK_GT(static_cast<int>(command_targets_.size()), index); |
164 DCHECK(web_content); | 224 WebContents* const web_contents = command_targets_[index]; |
165 if (!web_content) { | 225 UsageMap::const_iterator it = usage_map_.find(web_contents); |
166 NOTREACHED(); | 226 if (it == usage_map_.end() || it->second->IsWebContentsDestroyed()) |
167 return; | 227 return; |
168 } | 228 web_contents->GetDelegate()->ActivateContents(web_contents); |
169 | |
170 web_content->GetDelegate()->ActivateContents(web_content); | |
171 } | 229 } |
172 | 230 |
173 void MediaStreamCaptureIndicator::CaptureDevicesOpened( | 231 void MediaStreamCaptureIndicator::CaptureDevicesOpened( |
174 int render_process_id, | 232 int render_process_id, |
175 int render_view_id, | 233 int render_view_id, |
176 const content::MediaStreamDevices& devices) { | 234 const content::MediaStreamDevices& devices) { |
177 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 235 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
178 DCHECK(!devices.empty()); | 236 DCHECK(!devices.empty()); |
179 | 237 |
180 BrowserThread::PostTask( | 238 BrowserThread::PostTask( |
(...skipping 14 matching lines...) Expand all Loading... |
195 base::Bind(&MediaStreamCaptureIndicator::DoDevicesClosedOnUIThread, | 253 base::Bind(&MediaStreamCaptureIndicator::DoDevicesClosedOnUIThread, |
196 this, render_process_id, render_view_id, devices)); | 254 this, render_process_id, render_view_id, devices)); |
197 } | 255 } |
198 | 256 |
199 void MediaStreamCaptureIndicator::DoDevicesOpenedOnUIThread( | 257 void MediaStreamCaptureIndicator::DoDevicesOpenedOnUIThread( |
200 int render_process_id, | 258 int render_process_id, |
201 int render_view_id, | 259 int render_view_id, |
202 const content::MediaStreamDevices& devices) { | 260 const content::MediaStreamDevices& devices) { |
203 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 261 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
204 | 262 |
205 CreateStatusTray(); | 263 AddCaptureDevices(render_process_id, render_view_id, devices); |
206 | |
207 AddCaptureDeviceTab(render_process_id, render_view_id, devices); | |
208 } | 264 } |
209 | 265 |
210 void MediaStreamCaptureIndicator::DoDevicesClosedOnUIThread( | 266 void MediaStreamCaptureIndicator::DoDevicesClosedOnUIThread( |
211 int render_process_id, | 267 int render_process_id, |
212 int render_view_id, | 268 int render_view_id, |
213 const content::MediaStreamDevices& devices) { | 269 const content::MediaStreamDevices& devices) { |
214 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 270 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
215 | 271 |
216 RemoveCaptureDeviceTab(render_process_id, render_view_id, devices); | 272 RemoveCaptureDevices(render_process_id, render_view_id, devices); |
217 } | 273 } |
218 | 274 |
219 void MediaStreamCaptureIndicator::CreateStatusTray() { | 275 void MediaStreamCaptureIndicator::MaybeCreateStatusTrayIcon() { |
220 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 276 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
221 if (status_icon_) | 277 if (status_icon_) |
222 return; | 278 return; |
223 | 279 |
224 // If there is no browser process, we should not create the status tray. | 280 // If there is no browser process, we should not create the status tray. |
225 if (!g_browser_process) | 281 if (!g_browser_process) |
226 return; | 282 return; |
227 | 283 |
228 StatusTray* status_tray = g_browser_process->status_tray(); | 284 StatusTray* status_tray = g_browser_process->status_tray(); |
229 if (!status_tray) | 285 if (!status_tray) |
(...skipping 17 matching lines...) Expand all Loading... |
247 if (!balloon_image_) { | 303 if (!balloon_image_) { |
248 balloon_image_ = ResourceBundle::GetSharedInstance().GetImageSkiaNamed( | 304 balloon_image_ = ResourceBundle::GetSharedInstance().GetImageSkiaNamed( |
249 IDR_PRODUCT_LOGO_32); | 305 IDR_PRODUCT_LOGO_32); |
250 } | 306 } |
251 DCHECK(mic_image_); | 307 DCHECK(mic_image_); |
252 DCHECK(camera_image_); | 308 DCHECK(camera_image_); |
253 DCHECK(balloon_image_); | 309 DCHECK(balloon_image_); |
254 } | 310 } |
255 | 311 |
256 void MediaStreamCaptureIndicator::ShowBalloon( | 312 void MediaStreamCaptureIndicator::ShowBalloon( |
257 int render_process_id, | 313 WebContents* web_contents, int balloon_body_message_id) { |
258 int render_view_id, | |
259 bool audio, | |
260 bool video) { | |
261 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 314 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
262 DCHECK(audio || video); | 315 DCHECK_NE(0, balloon_body_message_id); |
263 | |
264 int message_id = IDS_MEDIA_STREAM_STATUS_TRAY_BALLOON_BODY_AUDIO_AND_VIDEO; | |
265 if (audio && !video) | |
266 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_BALLOON_BODY_AUDIO_ONLY; | |
267 else if (!audio && video) | |
268 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_BALLOON_BODY_VIDEO_ONLY; | |
269 | 316 |
270 // Only show the balloon for extensions. | 317 // Only show the balloon for extensions. |
271 const extensions::Extension* extension = | 318 const extensions::Extension* const extension = GetExtension(web_contents); |
272 GetExtension(render_process_id, render_view_id); | |
273 if (!extension) { | 319 if (!extension) { |
274 DVLOG(1) << "Balloon is shown only for extensions"; | 320 DVLOG(1) << "Balloon is shown only for extensions"; |
275 return; | 321 return; |
276 } | 322 } |
277 | 323 |
278 string16 message = | 324 string16 message = |
279 l10n_util::GetStringFUTF16(message_id, | 325 l10n_util::GetStringFUTF16(balloon_body_message_id, |
280 UTF8ToUTF16(extension->name())); | 326 UTF8ToUTF16(extension->name())); |
281 | |
282 WebContents* web_contents = tab_util::GetWebContentsByID( | |
283 render_process_id, render_view_id); | |
284 | |
285 Profile* profile = | 327 Profile* profile = |
286 Profile::FromBrowserContext(web_contents->GetBrowserContext()); | 328 Profile::FromBrowserContext(web_contents->GetBrowserContext()); |
287 | 329 |
288 should_show_balloon_ = true; | 330 should_show_balloon_ = true; |
289 extensions::ImageLoader::Get(profile)->LoadImageAsync( | 331 extensions::ImageLoader::Get(profile)->LoadImageAsync( |
290 extension, | 332 extension, |
291 extension->GetIconResource(32, ExtensionIconSet::MATCH_BIGGER), | 333 extension->GetIconResource(32, ExtensionIconSet::MATCH_BIGGER), |
292 gfx::Size(32, 32), | 334 gfx::Size(32, 32), |
293 base::Bind(&MediaStreamCaptureIndicator::OnImageLoaded, | 335 base::Bind(&MediaStreamCaptureIndicator::OnImageLoaded, |
294 this, message)); | 336 this, message)); |
295 } | 337 } |
296 | 338 |
297 void MediaStreamCaptureIndicator::OnImageLoaded( | 339 void MediaStreamCaptureIndicator::OnImageLoaded( |
298 const string16& message, | 340 const string16& message, |
299 const gfx::Image& image) { | 341 const gfx::Image& image) { |
300 if (!should_show_balloon_) | 342 if (!should_show_balloon_ || !status_icon_) |
301 return; | 343 return; |
302 | 344 |
303 const gfx::ImageSkia* image_skia = !image.IsEmpty() ? image.ToImageSkia() : | 345 const gfx::ImageSkia* image_skia = !image.IsEmpty() ? image.ToImageSkia() : |
304 ui::ResourceBundle::GetSharedInstance().GetImageSkiaNamed( | 346 ui::ResourceBundle::GetSharedInstance().GetImageSkiaNamed( |
305 IDR_APP_DEFAULT_ICON); | 347 IDR_APP_DEFAULT_ICON); |
306 status_icon_->DisplayBalloon(*image_skia, string16(), message); | 348 status_icon_->DisplayBalloon(*image_skia, string16(), message); |
307 } | 349 } |
308 | 350 |
309 void MediaStreamCaptureIndicator::Hide() { | 351 void MediaStreamCaptureIndicator::MaybeDestroyStatusTrayIcon() { |
310 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 352 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
311 | 353 |
312 // Make sure images that finish loading don't cause a balloon to be shown. | 354 // Make sure images that finish loading don't cause a balloon to be shown. |
313 should_show_balloon_ = false; | 355 should_show_balloon_ = false; |
314 | 356 |
315 if (!status_icon_) | 357 if (!status_icon_) |
316 return; | 358 return; |
317 | 359 |
318 // If there is no browser process, we should not do anything. | 360 // If there is no browser process, we should not do anything. |
319 if (!g_browser_process) | 361 if (!g_browser_process) |
320 return; | 362 return; |
321 | 363 |
322 StatusTray* status_tray = g_browser_process->status_tray(); | 364 StatusTray* status_tray = g_browser_process->status_tray(); |
323 if (status_tray != NULL) { | 365 if (status_tray != NULL) { |
324 status_tray->RemoveStatusIcon(status_icon_); | 366 status_tray->RemoveStatusIcon(status_icon_); |
325 status_icon_ = NULL; | 367 status_icon_ = NULL; |
326 } | 368 } |
327 } | 369 } |
328 | 370 |
329 void MediaStreamCaptureIndicator::UpdateStatusTrayIconContextMenu() { | 371 void MediaStreamCaptureIndicator::UpdateStatusTrayIconContextMenu() { |
330 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 372 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
331 scoped_ptr<ui::SimpleMenuModel> menu(new ui::SimpleMenuModel(this)); | 373 scoped_ptr<ui::SimpleMenuModel> menu(new ui::SimpleMenuModel(this)); |
332 | 374 |
333 bool audio = false; | 375 bool audio = false; |
334 bool video = false; | 376 bool video = false; |
335 int command_id = IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_FIRST; | 377 int command_id = IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_FIRST; |
336 for (CaptureDeviceTabs::iterator iter = tabs_.begin(); | 378 command_targets_.clear(); |
337 iter != tabs_.end();) { | 379 for (UsageMap::const_iterator iter = usage_map_.begin(); |
338 string16 tab_title = GetTitle(iter->render_process_id, | 380 iter != usage_map_.end(); ++iter) { |
339 iter->render_view_id); | 381 // Check if any audio and video devices have been used. |
340 if (tab_title.empty()) { | 382 const WebContentsDeviceUsage& usage = *iter->second; |
341 // Delete the entry since the tab has gone away. | 383 if (usage.IsWebContentsDestroyed() || |
342 iter = tabs_.erase(iter); | 384 (!usage.IsCapturingAudio() && !usage.IsCapturingVideo())) { |
343 continue; | 385 continue; |
344 } | 386 } |
| 387 audio = audio || usage.IsCapturingAudio(); |
| 388 video = video || usage.IsCapturingVideo(); |
345 | 389 |
346 // Check if any audio and video devices have been used. | 390 WebContents* const web_contents = iter->first; |
347 audio = audio || iter->audio_ref_count > 0; | 391 command_targets_.push_back(web_contents); |
348 video = video || iter->video_ref_count > 0; | 392 menu->AddItem(command_id, GetTitle(web_contents)); |
349 | |
350 menu->AddItem(command_id, tab_title); | |
351 | 393 |
352 // If reaching the maximum number, no more item will be added to the menu. | 394 // If reaching the maximum number, no more item will be added to the menu. |
353 if (command_id == IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_LAST) | 395 if (command_id == IDC_MEDIA_CONTEXT_MEDIA_STREAM_CAPTURE_LIST_LAST) |
354 break; | 396 break; |
355 | |
356 ++command_id; | 397 ++command_id; |
357 ++iter; | |
358 } | 398 } |
359 | 399 |
360 if (!audio && !video) { | 400 if (command_targets_.empty()) { |
361 Hide(); | 401 MaybeDestroyStatusTrayIcon(); |
362 return; | 402 return; |
363 } | 403 } |
364 | 404 |
365 // The icon will take the ownership of the passed context menu. | 405 // The icon will take the ownership of the passed context menu. |
366 status_icon_->SetContextMenu(menu.release()); | 406 MaybeCreateStatusTrayIcon(); |
367 UpdateStatusTrayIconDisplay(audio, video); | 407 if (status_icon_) { |
| 408 status_icon_->SetContextMenu(menu.release()); |
| 409 UpdateStatusTrayIconDisplay(audio, video); |
| 410 } |
368 } | 411 } |
369 | 412 |
370 void MediaStreamCaptureIndicator::UpdateStatusTrayIconDisplay( | 413 void MediaStreamCaptureIndicator::UpdateStatusTrayIconDisplay( |
371 bool audio, bool video) { | 414 bool audio, bool video) { |
372 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 415 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
373 DCHECK(audio || video); | 416 DCHECK(audio || video); |
| 417 DCHECK(status_icon_); |
374 int message_id = 0; | 418 int message_id = 0; |
375 if (audio && video) { | 419 if (audio && video) { |
376 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_TEXT_AUDIO_AND_VIDEO; | 420 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_TEXT_AUDIO_AND_VIDEO; |
377 status_icon_->SetImage(*camera_image_); | 421 status_icon_->SetImage(*camera_image_); |
378 } else if (audio && !video) { | 422 } else if (audio && !video) { |
379 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_TEXT_AUDIO_ONLY; | 423 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_TEXT_AUDIO_ONLY; |
380 status_icon_->SetImage(*mic_image_); | 424 status_icon_->SetImage(*mic_image_); |
381 } else if (!audio && video) { | 425 } else if (!audio && video) { |
382 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_TEXT_VIDEO_ONLY; | 426 message_id = IDS_MEDIA_STREAM_STATUS_TRAY_TEXT_VIDEO_ONLY; |
383 status_icon_->SetImage(*camera_image_); | 427 status_icon_->SetImage(*camera_image_); |
384 } | 428 } |
385 | 429 |
386 status_icon_->SetToolTip(l10n_util::GetStringFUTF16( | 430 status_icon_->SetToolTip(l10n_util::GetStringFUTF16( |
387 message_id, l10n_util::GetStringUTF16(IDS_PRODUCT_NAME))); | 431 message_id, l10n_util::GetStringUTF16(IDS_PRODUCT_NAME))); |
388 } | 432 } |
389 | 433 |
390 void MediaStreamCaptureIndicator::AddCaptureDeviceTab( | 434 WebContents* MediaStreamCaptureIndicator::LookUpByKnownAlias( |
| 435 int render_process_id, int render_view_id) const { |
| 436 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| 437 |
| 438 WebContents* result = |
| 439 tab_util::GetWebContentsByID(render_process_id, render_view_id); |
| 440 if (!result) { |
| 441 const RenderViewIDs key(render_process_id, render_view_id); |
| 442 AliasMap::const_iterator it = aliases_.find(key); |
| 443 if (it != aliases_.end()) |
| 444 result = it->second; |
| 445 } |
| 446 return result; |
| 447 } |
| 448 |
| 449 void MediaStreamCaptureIndicator::AddCaptureDevices( |
391 int render_process_id, | 450 int render_process_id, |
392 int render_view_id, | 451 int render_view_id, |
393 const content::MediaStreamDevices& devices) { | 452 const content::MediaStreamDevices& devices) { |
394 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 453 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
395 | 454 |
396 WebContents* web_contents = tab_util::GetWebContentsByID(render_process_id, | 455 WebContents* const web_contents = |
397 render_view_id); | 456 LookUpByKnownAlias(render_process_id, render_view_id); |
398 if (!web_contents) | 457 if (!web_contents) |
399 return; | 458 return; |
400 | 459 |
401 CaptureDeviceTabs::iterator iter = std::find_if( | 460 // Increase the usage ref-counts. |
402 tabs_.begin(), tabs_.end(), TabEquals(web_contents, | 461 WebContentsDeviceUsage*& usage = usage_map_[web_contents]; |
403 render_process_id, | 462 if (!usage) |
404 render_view_id)); | 463 usage = new WebContentsDeviceUsage(web_contents); |
405 if (iter == tabs_.end()) { | 464 const int balloon_body_message_id = usage->TallyUsage(devices, true); |
406 tabs_.push_back(CaptureDeviceTab(web_contents, | |
407 render_process_id, | |
408 render_view_id)); | |
409 iter = tabs_.end() - 1; | |
410 } | |
411 | 465 |
412 bool audio = false; | 466 // Keep track of the IDs as a known alias to the WebContents instance. |
413 bool video = false; | 467 const AliasMap::iterator insert_it = aliases_.insert( |
414 bool tab_capture = false; | 468 make_pair(RenderViewIDs(render_process_id, render_view_id), |
415 content::MediaStreamDevices::const_iterator dev = devices.begin(); | 469 web_contents)).first; |
416 for (; dev != devices.end(); ++dev) { | 470 DCHECK_EQ(web_contents, insert_it->second) |
417 if (dev->type == content::MEDIA_TAB_AUDIO_CAPTURE || | 471 << "BUG: IDs refer to two different WebContents instances."; |
418 dev->type == content::MEDIA_TAB_VIDEO_CAPTURE) { | |
419 ++iter->tab_capture_ref_count; | |
420 tab_capture = true; | |
421 } else if (content::IsAudioMediaType(dev->type)) { | |
422 ++iter->audio_ref_count; | |
423 audio = true; | |
424 } else if (content::IsVideoMediaType(dev->type)) { | |
425 ++iter->video_ref_count; | |
426 video = true; | |
427 } else { | |
428 NOTIMPLEMENTED(); | |
429 } | |
430 } | |
431 | 472 |
432 DCHECK(web_contents); | |
433 web_contents->NotifyNavigationStateChanged(content::INVALIDATE_TYPE_TAB); | 473 web_contents->NotifyNavigationStateChanged(content::INVALIDATE_TYPE_TAB); |
434 | 474 |
435 // Don't use desktop notifications for tab capture. We use a favicon | |
436 // glow notification instead. | |
437 if (!status_icon_ || tab_capture) | |
438 return; | |
439 | |
440 UpdateStatusTrayIconContextMenu(); | 475 UpdateStatusTrayIconContextMenu(); |
441 ShowBalloon(render_process_id, render_view_id, audio, video); | 476 if (balloon_body_message_id) |
| 477 ShowBalloon(web_contents, balloon_body_message_id); |
442 } | 478 } |
443 | 479 |
444 void MediaStreamCaptureIndicator::RemoveCaptureDeviceTab( | 480 void MediaStreamCaptureIndicator::RemoveCaptureDevices( |
445 int render_process_id, | 481 int render_process_id, |
446 int render_view_id, | 482 int render_view_id, |
447 const content::MediaStreamDevices& devices) { | 483 const content::MediaStreamDevices& devices) { |
448 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 484 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
449 WebContents* web_contents = tab_util::GetWebContentsByID(render_process_id, | |
450 render_view_id); | |
451 CaptureDeviceTabs::iterator iter = std::find_if( | |
452 tabs_.begin(), tabs_.end(), TabEquals(web_contents, | |
453 render_process_id, | |
454 render_view_id)); | |
455 | 485 |
456 if (iter != tabs_.end()) { | 486 WebContents* const web_contents = |
457 content::MediaStreamDevices::const_iterator dev = devices.begin(); | 487 LookUpByKnownAlias(render_process_id, render_view_id); |
458 for (; dev != devices.end(); ++dev) { | 488 if (!web_contents) |
459 if (dev->type == content::MEDIA_TAB_AUDIO_CAPTURE || | 489 return; |
460 dev->type == content::MEDIA_TAB_VIDEO_CAPTURE) { | |
461 --iter->tab_capture_ref_count; | |
462 } else if (content::IsAudioMediaType(dev->type)) { | |
463 --iter->audio_ref_count; | |
464 } else if (content::IsVideoMediaType(dev->type)) { | |
465 --iter->video_ref_count; | |
466 } else { | |
467 NOTIMPLEMENTED(); | |
468 } | |
469 | 490 |
470 DCHECK_GE(iter->audio_ref_count, 0); | 491 // Decrease the usage ref-counts. |
471 DCHECK_GE(iter->video_ref_count, 0); | 492 WebContentsDeviceUsage* const usage = usage_map_[web_contents]; |
472 } | 493 DCHECK(usage); |
| 494 usage->TallyUsage(devices, false); |
473 | 495 |
474 // Remove the tab if all the devices have been closed. | 496 if (!usage->IsWebContentsDestroyed()) |
475 if (iter->audio_ref_count == 0 && iter->video_ref_count == 0 && | |
476 iter->tab_capture_ref_count == 0) | |
477 tabs_.erase(iter); | |
478 } | |
479 | |
480 if (web_contents) | |
481 web_contents->NotifyNavigationStateChanged(content::INVALIDATE_TYPE_TAB); | 497 web_contents->NotifyNavigationStateChanged(content::INVALIDATE_TYPE_TAB); |
482 | 498 |
483 if (!status_icon_) | 499 // Remove the usage and alias mappings if all the devices have been closed. |
484 return; | 500 if (!usage->IsCapturingAudio() && !usage->IsCapturingVideo() && |
| 501 !usage->IsMirroring()) { |
| 502 for (AliasMap::iterator alias_it = aliases_.begin(); |
| 503 alias_it != aliases_.end(); ) { |
| 504 if (alias_it->second == web_contents) |
| 505 aliases_.erase(alias_it++); |
| 506 else |
| 507 ++alias_it; |
| 508 } |
| 509 delete usage; |
| 510 usage_map_.erase(web_contents); |
| 511 } |
485 | 512 |
486 UpdateStatusTrayIconContextMenu(); | 513 UpdateStatusTrayIconContextMenu(); |
487 } | 514 } |
488 | 515 |
489 bool MediaStreamCaptureIndicator::IsProcessCapturing(int render_process_id, | 516 bool MediaStreamCaptureIndicator::IsCapturingUserMedia( |
490 int render_view_id) const { | 517 int render_process_id, int render_view_id) const { |
491 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 518 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
492 WebContents* web_contents = tab_util::GetWebContentsByID(render_process_id, | 519 |
493 render_view_id); | 520 WebContents* const web_contents = |
| 521 LookUpByKnownAlias(render_process_id, render_view_id); |
494 if (!web_contents) | 522 if (!web_contents) |
495 return false; | 523 return false; |
496 | 524 |
497 CaptureDeviceTabs::const_iterator iter = std::find_if( | 525 UsageMap::const_iterator it = usage_map_.find(web_contents); |
498 tabs_.begin(), tabs_.end(), TabEquals(web_contents, | 526 return (it != usage_map_.end() && |
499 render_process_id, | 527 (it->second->IsCapturingAudio() || it->second->IsCapturingVideo())); |
500 render_view_id)); | |
501 if (iter == tabs_.end()) | |
502 return false; | |
503 return (iter->audio_ref_count > 0 || iter->video_ref_count > 0); | |
504 } | 528 } |
505 | 529 |
506 bool MediaStreamCaptureIndicator::IsProcessCapturingTab( | 530 bool MediaStreamCaptureIndicator::IsBeingMirrored( |
507 int render_process_id, int render_view_id) const { | 531 int render_process_id, int render_view_id) const { |
508 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 532 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
509 WebContents* web_contents = tab_util::GetWebContentsByID(render_process_id, | 533 |
510 render_view_id); | 534 WebContents* const web_contents = |
| 535 LookUpByKnownAlias(render_process_id, render_view_id); |
511 if (!web_contents) | 536 if (!web_contents) |
512 return false; | 537 return false; |
513 | 538 |
514 CaptureDeviceTabs::const_iterator iter = std::find_if( | 539 UsageMap::const_iterator it = usage_map_.find(web_contents); |
515 tabs_.begin(), tabs_.end(), TabEquals(web_contents, | 540 return it != usage_map_.end() && it->second->IsMirroring(); |
516 render_process_id, | |
517 render_view_id)); | |
518 if (iter == tabs_.end()) | |
519 return false; | |
520 return (iter->tab_capture_ref_count > 0); | |
521 } | 541 } |
OLD | NEW |