Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(147)

Side by Side Diff: content/browser/media/webrtc/webrtc_internals.cc

Issue 1855193002: Move the call to enable the WebRTC event log from PeerConnectionFactory to PeerConnection. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Addressed review comments. Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2013 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/media/webrtc/webrtc_internals.h" 5 #include "content/browser/media/webrtc/webrtc_internals.h"
6 6
7 #include <stddef.h> 7 #include <stddef.h>
8 8
9 #include "base/strings/string_number_conversions.h" 9 #include "base/strings/string_number_conversions.h"
10 #include "build/build_config.h" 10 #include "build/build_config.h"
11 #include "content/browser/media/webrtc/webrtc_internals_ui_observer.h" 11 #include "content/browser/media/webrtc/webrtc_internals_ui_observer.h"
12 #include "content/browser/renderer_host/render_process_host_impl.h"
12 #include "content/browser/web_contents/web_contents_view.h" 13 #include "content/browser/web_contents/web_contents_view.h"
13 #include "content/public/browser/browser_thread.h" 14 #include "content/public/browser/browser_thread.h"
14 #include "content/public/browser/content_browser_client.h" 15 #include "content/public/browser/content_browser_client.h"
15 #include "content/public/browser/power_save_blocker.h" 16 #include "content/public/browser/power_save_blocker.h"
16 #include "content/public/browser/render_process_host.h"
17 #include "content/public/browser/web_contents.h" 17 #include "content/public/browser/web_contents.h"
18 #include "ipc/ipc_platform_file.h"
19
20 #if defined(OS_WIN)
21 #define IntToStringType base::IntToString16
22 #else
23 #define IntToStringType base::IntToString
24 #endif
18 25
19 using base::ProcessId; 26 using base::ProcessId;
20 using std::string; 27 using std::string;
21 28
22 namespace content { 29 namespace content {
23 30
24 namespace { 31 namespace {
25 32
26 static base::LazyInstance<WebRTCInternals>::Leaky g_webrtc_internals = 33 static base::LazyInstance<WebRTCInternals>::Leaky g_webrtc_internals =
27 LAZY_INSTANCE_INITIALIZER; 34 LAZY_INSTANCE_INITIALIZER;
(...skipping 217 matching lines...) Expand 10 before | Expand all | Expand 10 after
245 252
246 void WebRTCInternals::AddObserver(WebRTCInternalsUIObserver* observer) { 253 void WebRTCInternals::AddObserver(WebRTCInternalsUIObserver* observer) {
247 DCHECK_CURRENTLY_ON(BrowserThread::UI); 254 DCHECK_CURRENTLY_ON(BrowserThread::UI);
248 observers_.AddObserver(observer); 255 observers_.AddObserver(observer);
249 } 256 }
250 257
251 void WebRTCInternals::RemoveObserver(WebRTCInternalsUIObserver* observer) { 258 void WebRTCInternals::RemoveObserver(WebRTCInternalsUIObserver* observer) {
252 DCHECK_CURRENTLY_ON(BrowserThread::UI); 259 DCHECK_CURRENTLY_ON(BrowserThread::UI);
253 observers_.RemoveObserver(observer); 260 observers_.RemoveObserver(observer);
254 261
255 // Disables audio debug recordings if it is enabled and the last 262 // Disables audio debug recordings and event log if enabled and the last
256 // webrtc-internals page is going away. 263 // webrtc-internals page is going away.
257 if (audio_debug_recordings_ && !observers_.might_have_observers()) 264 if (audio_debug_recordings_ && !observers_.might_have_observers()) {
258 DisableAudioDebugRecordings(); 265 DisableAudioDebugRecordings();
266 SetEventLogRecordings(false, nullptr);
267 }
259 } 268 }
260 269
261 void WebRTCInternals::UpdateObserver(WebRTCInternalsUIObserver* observer) { 270 void WebRTCInternals::UpdateObserver(WebRTCInternalsUIObserver* observer) {
262 DCHECK_CURRENTLY_ON(BrowserThread::UI); 271 DCHECK_CURRENTLY_ON(BrowserThread::UI);
263 if (peer_connection_data_.GetSize() > 0) 272 if (peer_connection_data_.GetSize() > 0)
264 observer->OnUpdate("updateAllPeerConnections", &peer_connection_data_); 273 observer->OnUpdate("updateAllPeerConnections", &peer_connection_data_);
265 274
266 for (base::ListValue::iterator it = get_user_media_requests_.begin(); 275 for (base::ListValue::iterator it = get_user_media_requests_.begin();
267 it != get_user_media_requests_.end(); 276 it != get_user_media_requests_.end();
268 ++it) { 277 ++it) {
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after
335 select_file_dialog_ = ui::SelectFileDialog::Create(this, nullptr); 344 select_file_dialog_ = ui::SelectFileDialog::Create(this, nullptr);
336 select_file_dialog_->SelectFile( 345 select_file_dialog_->SelectFile(
337 ui::SelectFileDialog::SELECT_SAVEAS_FILE, base::string16(), 346 ui::SelectFileDialog::SELECT_SAVEAS_FILE, base::string16(),
338 event_log_recordings_file_path_, nullptr, 0, FILE_PATH_LITERAL(""), 347 event_log_recordings_file_path_, nullptr, 0, FILE_PATH_LITERAL(""),
339 web_contents->GetTopLevelNativeWindow(), nullptr); 348 web_contents->GetTopLevelNativeWindow(), nullptr);
340 #endif 349 #endif
341 } else { 350 } else {
342 event_log_recordings_ = false; 351 event_log_recordings_ = false;
343 // Tear down the dialog since the user has unchecked the audio debug 352 // Tear down the dialog since the user has unchecked the audio debug
344 // recordings box. 353 // recordings box.
354 DCHECK(select_file_dialog_->HasOneRef());
345 select_file_dialog_ = nullptr; 355 select_file_dialog_ = nullptr;
346 DCHECK(select_file_dialog_->HasOneRef());
347 356
348 for (RenderProcessHost::iterator i( 357 for (RenderProcessHost::iterator i(
349 content::RenderProcessHost::AllHostsIterator()); 358 content::RenderProcessHost::AllHostsIterator());
350 !i.IsAtEnd(); i.Advance()) { 359 !i.IsAtEnd(); i.Advance())
351 i.GetCurrentValue()->DisableEventLogRecordings(); 360 i.GetCurrentValue()->StopWebRTCEventLog();
352 }
353 } 361 }
354 #endif 362 #endif
355 } 363 }
356 364
357 bool WebRTCInternals::IsEventLogRecordingsEnabled() const { 365 bool WebRTCInternals::IsEventLogRecordingsEnabled() const {
358 DCHECK_CURRENTLY_ON(BrowserThread::UI); 366 DCHECK_CURRENTLY_ON(BrowserThread::UI);
359 return event_log_recordings_; 367 return event_log_recordings_;
360 } 368 }
361 369
362 const base::FilePath& WebRTCInternals::GetEventLogRecordingsFilePath() const {
363 DCHECK_CURRENTLY_ON(BrowserThread::UI);
364 return event_log_recordings_file_path_;
365 }
366
367 void WebRTCInternals::SendUpdate(const string& command, 370 void WebRTCInternals::SendUpdate(const string& command,
368 std::unique_ptr<base::Value> value) { 371 std::unique_ptr<base::Value> value) {
369 DCHECK_CURRENTLY_ON(BrowserThread::UI); 372 DCHECK_CURRENTLY_ON(BrowserThread::UI);
370 DCHECK(observers_.might_have_observers()); 373 DCHECK(observers_.might_have_observers());
371 374
372 bool queue_was_empty = pending_updates_.empty(); 375 bool queue_was_empty = pending_updates_.empty();
373 pending_updates_.push(PendingUpdate(command, std::move(value))); 376 pending_updates_.push(PendingUpdate(command, std::move(value)));
374 377
375 if (queue_was_empty) { 378 if (queue_was_empty) {
376 BrowserThread::PostDelayedTask(BrowserThread::UI, FROM_HERE, 379 BrowserThread::PostDelayedTask(BrowserThread::UI, FROM_HERE,
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after
478 audio_debug_recordings_file_path_); 481 audio_debug_recordings_file_path_);
479 } 482 }
480 } 483 }
481 484
482 void WebRTCInternals::EnableEventLogRecordingsOnAllRenderProcessHosts() { 485 void WebRTCInternals::EnableEventLogRecordingsOnAllRenderProcessHosts() {
483 DCHECK_CURRENTLY_ON(BrowserThread::UI); 486 DCHECK_CURRENTLY_ON(BrowserThread::UI);
484 487
485 event_log_recordings_ = true; 488 event_log_recordings_ = true;
486 for (RenderProcessHost::iterator i( 489 for (RenderProcessHost::iterator i(
487 content::RenderProcessHost::AllHostsIterator()); 490 content::RenderProcessHost::AllHostsIterator());
488 !i.IsAtEnd(); i.Advance()) { 491 !i.IsAtEnd(); i.Advance())
489 i.GetCurrentValue()->EnableEventLogRecordings( 492 i.GetCurrentValue()->StartWebRTCEventLog(event_log_recordings_file_path_);
490 event_log_recordings_file_path_);
491 }
492 } 493 }
493 #endif 494 #endif
494 495
495 void WebRTCInternals::CreateOrReleasePowerSaveBlocker() { 496 void WebRTCInternals::CreateOrReleasePowerSaveBlocker() {
496 DCHECK_CURRENTLY_ON(BrowserThread::UI); 497 DCHECK_CURRENTLY_ON(BrowserThread::UI);
497 498
498 if (peer_connection_data_.empty() && power_save_blocker_) { 499 if (peer_connection_data_.empty() && power_save_blocker_) {
499 DVLOG(1) << ("Releasing the block on application suspension since no " 500 DVLOG(1) << ("Releasing the block on application suspension since no "
500 "PeerConnections are active anymore."); 501 "PeerConnections are active anymore.");
501 power_save_blocker_.reset(); 502 power_save_blocker_.reset();
(...skipping 11 matching lines...) Expand all
513 while (!pending_updates_.empty()) { 514 while (!pending_updates_.empty()) {
514 const auto& update = pending_updates_.front(); 515 const auto& update = pending_updates_.front();
515 FOR_EACH_OBSERVER(WebRTCInternalsUIObserver, 516 FOR_EACH_OBSERVER(WebRTCInternalsUIObserver,
516 observers_, 517 observers_,
517 OnUpdate(update.command(), update.value())); 518 OnUpdate(update.command(), update.value()));
518 pending_updates_.pop(); 519 pending_updates_.pop();
519 } 520 }
520 } 521 }
521 522
522 } // namespace content 523 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698