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

Side by Side Diff: trunk/src/content/renderer/media/rtc_peer_connection_handler.cc

Issue 296213007: Revert 272504 "Destroy all rtc peer connection handlers before s..." (Closed) Base URL: svn://svn.chromium.org/chrome/
Patch Set: Created 6 years, 7 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 | Annotate | Revision Log
OLDNEW
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/rtc_peer_connection_handler.h" 5 #include "content/renderer/media/rtc_peer_connection_handler.h"
6 6
7 #include <string> 7 #include <string>
8 #include <utility> 8 #include <utility>
9 #include <vector> 9 #include <vector>
10 10
11 #include "base/command_line.h" 11 #include "base/command_line.h"
12 #include "base/debug/trace_event.h" 12 #include "base/debug/trace_event.h"
13 #include "base/lazy_instance.h"
14 #include "base/logging.h" 13 #include "base/logging.h"
15 #include "base/memory/scoped_ptr.h" 14 #include "base/memory/scoped_ptr.h"
16 #include "base/metrics/histogram.h" 15 #include "base/metrics/histogram.h"
17 #include "base/stl_util.h" 16 #include "base/stl_util.h"
18 #include "base/strings/utf_string_conversions.h" 17 #include "base/strings/utf_string_conversions.h"
19 #include "content/public/common/content_switches.h" 18 #include "content/public/common/content_switches.h"
20 #include "content/renderer/media/media_stream_track.h" 19 #include "content/renderer/media/media_stream_track.h"
21 #include "content/renderer/media/peer_connection_tracker.h" 20 #include "content/renderer/media/peer_connection_tracker.h"
22 #include "content/renderer/media/remote_media_stream_impl.h" 21 #include "content/renderer/media/remote_media_stream_impl.h"
23 #include "content/renderer/media/rtc_data_channel_handler.h" 22 #include "content/renderer/media/rtc_data_channel_handler.h"
(...skipping 287 matching lines...) Expand 10 before | Expand all | Expand 10 after
311 double timestamp) { 310 double timestamp) {
312 return impl_.addReport(type, id, timestamp); 311 return impl_.addReport(type, id, timestamp);
313 } 312 }
314 313
315 void LocalRTCStatsResponse::addStatistic(size_t report, 314 void LocalRTCStatsResponse::addStatistic(size_t report,
316 blink::WebString name, 315 blink::WebString name,
317 blink::WebString value) { 316 blink::WebString value) {
318 impl_.addStatistic(report, name, value); 317 impl_.addStatistic(report, name, value);
319 } 318 }
320 319
321 namespace {
322
323 class PeerConnectionUMAObserver : public webrtc::UMAObserver { 320 class PeerConnectionUMAObserver : public webrtc::UMAObserver {
324 public: 321 public:
325 PeerConnectionUMAObserver() {} 322 PeerConnectionUMAObserver() {}
326 virtual ~PeerConnectionUMAObserver() {} 323 virtual ~PeerConnectionUMAObserver() {}
327 324
328 virtual void IncrementCounter( 325 virtual void IncrementCounter(
329 webrtc::PeerConnectionUMAMetricsCounter counter) OVERRIDE { 326 webrtc::PeerConnectionUMAMetricsCounter counter) OVERRIDE {
330 UMA_HISTOGRAM_ENUMERATION("WebRTC.PeerConnection.IPMetrics", 327 UMA_HISTOGRAM_ENUMERATION("WebRTC.PeerConnection.IPMetrics",
331 counter, 328 counter,
332 webrtc::kBoundary); 329 webrtc::kBoundary);
(...skipping 14 matching lines...) Expand all
347 case webrtc::kNetworkInterfaces_IPv6: 344 case webrtc::kNetworkInterfaces_IPv6:
348 UMA_HISTOGRAM_COUNTS_100("WebRTC.PeerConnection.IPv6Interfaces", 345 UMA_HISTOGRAM_COUNTS_100("WebRTC.PeerConnection.IPv6Interfaces",
349 value); 346 value);
350 break; 347 break;
351 default: 348 default:
352 NOTREACHED(); 349 NOTREACHED();
353 } 350 }
354 } 351 }
355 }; 352 };
356 353
357 base::LazyInstance<std::set<RTCPeerConnectionHandler*> >::Leaky
358 g_peer_connection_handlers = LAZY_INSTANCE_INITIALIZER;
359
360 } // namespace
361
362 RTCPeerConnectionHandler::RTCPeerConnectionHandler( 354 RTCPeerConnectionHandler::RTCPeerConnectionHandler(
363 blink::WebRTCPeerConnectionHandlerClient* client, 355 blink::WebRTCPeerConnectionHandlerClient* client,
364 PeerConnectionDependencyFactory* dependency_factory) 356 PeerConnectionDependencyFactory* dependency_factory)
365 : client_(client), 357 : client_(client),
366 dependency_factory_(dependency_factory), 358 dependency_factory_(dependency_factory),
367 frame_(NULL), 359 frame_(NULL),
368 peer_connection_tracker_(NULL), 360 peer_connection_tracker_(NULL),
369 num_data_channels_created_(0) { 361 num_data_channels_created_(0) {
370 g_peer_connection_handlers.Get().insert(this);
371 } 362 }
372 363
373 RTCPeerConnectionHandler::~RTCPeerConnectionHandler() { 364 RTCPeerConnectionHandler::~RTCPeerConnectionHandler() {
374 g_peer_connection_handlers.Get().erase(this);
375 if (peer_connection_tracker_) 365 if (peer_connection_tracker_)
376 peer_connection_tracker_->UnregisterPeerConnection(this); 366 peer_connection_tracker_->UnregisterPeerConnection(this);
377 STLDeleteValues(&remote_streams_); 367 STLDeleteValues(&remote_streams_);
378 368
379 UMA_HISTOGRAM_COUNTS_10000( 369 UMA_HISTOGRAM_COUNTS_10000(
380 "WebRTC.NumDataChannelsPerPeerConnection", num_data_channels_created_); 370 "WebRTC.NumDataChannelsPerPeerConnection", num_data_channels_created_);
381 } 371 }
382 372
383 // static
384 void RTCPeerConnectionHandler::DestructAllHandlers() {
385 std::set<RTCPeerConnectionHandler*> handlers(
386 g_peer_connection_handlers.Get().begin(),
387 g_peer_connection_handlers.Get().end());
388 for (std::set<RTCPeerConnectionHandler*>::iterator handler = handlers.begin();
389 handler != handlers.end();
390 ++handler) {
391 (*handler)->client_->releasePeerConnectionHandler();
392 }
393 }
394
395 void RTCPeerConnectionHandler::associateWithFrame(blink::WebFrame* frame) { 373 void RTCPeerConnectionHandler::associateWithFrame(blink::WebFrame* frame) {
396 DCHECK(frame); 374 DCHECK(frame);
397 frame_ = frame; 375 frame_ = frame;
398 } 376 }
399 377
400 bool RTCPeerConnectionHandler::initialize( 378 bool RTCPeerConnectionHandler::initialize(
401 const blink::WebRTCConfiguration& server_configuration, 379 const blink::WebRTCConfiguration& server_configuration,
402 const blink::WebMediaConstraints& options) { 380 const blink::WebMediaConstraints& options) {
403 DCHECK(frame_); 381 DCHECK(frame_);
404 382
(...skipping 515 matching lines...) Expand 10 before | Expand all | Expand 10 after
920 webrtc::SessionDescriptionInterface* native_desc = 898 webrtc::SessionDescriptionInterface* native_desc =
921 dependency_factory_->CreateSessionDescription(type, sdp, error); 899 dependency_factory_->CreateSessionDescription(type, sdp, error);
922 900
923 LOG_IF(ERROR, !native_desc) << "Failed to create native session description." 901 LOG_IF(ERROR, !native_desc) << "Failed to create native session description."
924 << " Type: " << type << " SDP: " << sdp; 902 << " Type: " << type << " SDP: " << sdp;
925 903
926 return native_desc; 904 return native_desc;
927 } 905 }
928 906
929 } // namespace content 907 } // namespace content
OLDNEW
« no previous file with comments | « trunk/src/content/renderer/media/rtc_peer_connection_handler.h ('k') | trunk/src/content/renderer/render_thread_impl.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698