Add RTCPeerConnection RAPPOR metrics.

third_party/WebKit/Source/modules/mediastream/RTCPeerConnection.cpp

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 28 matching lines @@
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ScriptValue.h"
 #include "bindings/core/v8/V8ThrowException.h"
 #include "bindings/modules/v8/RTCIceCandidateInitOrRTCIceCandidate.h"
 #include "bindings/modules/v8/V8RTCCertificate.h"
 #include "core/dom/DOMException.h"
 #include "core/dom/DOMTimeStamp.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
+#include "core/frame/HostsUsingFeatures.h"
 #include "core/frame/LocalFrame.h"
 #include "core/frame/UseCounter.h"
 #include "core/html/VoidCallback.h"
 #include "core/loader/FrameLoader.h"
 #include "core/loader/FrameLoaderClient.h"
 #include "modules/crypto/CryptoResultImpl.h"
 #include "modules/mediastream/MediaConstraintsImpl.h"
 #include "modules/mediastream/MediaStreamEvent.h"
 #include "modules/mediastream/RTCAnswerOptions.h"
 #include "modules/mediastream/RTCDTMFSender.h"
@@ skipping 329 matching lines @@
     return true;
 }
 
 DEFINE_TRACE(RTCPeerConnection::EventWrapper)
 {
     visitor->trace(m_event);
 }
 
 RTCPeerConnection* RTCPeerConnection::create(ExecutionContext* context, const Dictionary& rtcConfiguration, const Dictionary& mediaConstraints, ExceptionState& exceptionState)
 {
+    Document* document = toDocument(context);
+    HostsUsingFeatures::countAnyWorld(*document, HostsUsingFeatures::Feature::RTCPeerConnectionCreated);
+
     if (mediaConstraints.isObject())
         UseCounter::count(context, UseCounter::RTCPeerConnectionConstructorConstraints);
     else
         UseCounter::count(context, UseCounter::RTCPeerConnectionConstructorCompliant);
 
     // Record the RtcpMuxPolicy for histogram "WebRTC.PeerConnection.SelectedRtcpMuxPolicy".
     RtcpMuxPolicy selectedRtcpMuxPolicy = RtcpMuxPolicyDefault;
     RTCConfiguration* configuration = parseConfiguration(rtcConfiguration, exceptionState, &selectedRtcpMuxPolicy);
     if (exceptionState.hadException())
         return 0;
@@ skipping 742 matching lines @@
 
     m_dispatchScheduledEventRunner->stop();
 
     m_peerHandler.reset();
 }
 
 void RTCPeerConnection::changeSignalingState(SignalingState signalingState)
 {
     if (m_signalingState != SignalingStateClosed && m_signalingState != signalingState) {
         m_signalingState = signalingState;
+        if (m_signalingState == SignalingStateStable) {
+            Document* document = toDocument(getExecutionContext());
+            HostsUsingFeatures::countAnyWorld(*document, HostsUsingFeatures::Feature::RTCPeerConnectionStable);
+        }
         scheduleDispatchEvent(Event::create(EventTypeNames::signalingstatechange));
     }
 }
 
 void RTCPeerConnection::changeIceGatheringState(ICEGatheringState iceGatheringState)
 {
     m_iceGatheringState = iceGatheringState;
 }
 
 bool RTCPeerConnection::setIceConnectionState(ICEConnectionState iceConnectionState)
 {
     if (m_iceConnectionState != ICEConnectionStateClosed && m_iceConnectionState != iceConnectionState) {
         m_iceConnectionState = iceConnectionState;
+        if (m_iceConnectionState == ICEConnectionStateConnected) {
+            Document* document = toDocument(getExecutionContext());
+            HostsUsingFeatures::countAnyWorld(*document, HostsUsingFeatures::Feature::RTCPeerConnectionConnected);
+        }
         return true;
     }
     return false;
 }
 
 void RTCPeerConnection::changeIceConnectionState(ICEConnectionState iceConnectionState)
 {
     if (m_iceConnectionState != ICEConnectionStateClosed) {
         scheduleDispatchEvent(Event::create(EventTypeNames::iceconnectionstatechange),
             WTF::bind(&RTCPeerConnection::setIceConnectionState, wrapPersistent(this), iceConnectionState));
@@ skipping 46 matching lines @@
 {
     visitor->trace(m_localStreams);
     visitor->trace(m_remoteStreams);
     visitor->trace(m_dispatchScheduledEventRunner);
     visitor->trace(m_scheduledEvents);
     EventTargetWithInlineData::trace(visitor);
     ActiveDOMObject::trace(visitor);
 }
 
 } // namespace blink