RTCIceCandidateStats.transportId added and collected.

webrtc/api/rtcstatscollector_unittest.cc

 /*
  *  Copyright 2016 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 141 matching lines @@
   }
   EXPECT_EQ(info->ders.size(), info->fingerprints.size());
   return info;
 }
 
 std::unique_ptr<cricket::Candidate> CreateFakeCandidate(
     const std::string& hostname,
     int port,
     const std::string& protocol,
     const std::string& candidate_type,
-    uint32_t priority) {
+    uint32_t priority,
+    int component = 0,
+    const std::string& transport_name = "") {

[Taylor Brandstetter, 2016/12/22 19:28:31]

As mentioned in other comments, I wouldn't use the transport_name on the
candidate.

[hbos, 2016/12/23 14:25:17]

Done.

   std::unique_ptr<cricket::Candidate> candidate(new cricket::Candidate());
   candidate->set_address(rtc::SocketAddress(hostname, port));
   candidate->set_protocol(protocol);
   candidate->set_type(candidate_type);
   candidate->set_priority(priority);
+  candidate->set_component(component);
+  candidate->set_transport_name(transport_name);
   return candidate;
 }
 
 class FakeAudioProcessorForStats
     : public rtc::RefCountedObject<AudioProcessorInterface> {
  public:
   FakeAudioProcessorForStats(
       AudioProcessorInterface::AudioProcessorStats stats)
       : stats_(stats) {
   }
@@ skipping 734 matching lines @@
             report->Get(expected_data_channel3.id())->cast_to<
                 RTCDataChannelStats>());
 }
 
 TEST_F(RTCStatsCollectorTest, CollectRTCIceCandidateStats) {
   // Candidates in the first transport stats.
   std::unique_ptr<cricket::Candidate> a_local_host = CreateFakeCandidate(
       "1.2.3.4", 5,
       "a_local_host's protocol",
       cricket::LOCAL_PORT_TYPE,
-      0);
+      0,
+      cricket::ICE_CANDIDATE_COMPONENT_RTP,
+      "a");
   RTCLocalIceCandidateStats expected_a_local_host(
       "RTCIceCandidate_" + a_local_host->id(), 0);
   expected_a_local_host.ip = "1.2.3.4";
   expected_a_local_host.port = 5;
   expected_a_local_host.protocol = "a_local_host's protocol";
   expected_a_local_host.candidate_type = "host";
   expected_a_local_host.priority = 0;
+  expected_a_local_host.transport_id = "RTCTransport_a_" +
+      rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP);
 
   std::unique_ptr<cricket::Candidate> a_remote_srflx = CreateFakeCandidate(
       "6.7.8.9", 10,
       "remote_srflx's protocol",
       cricket::STUN_PORT_TYPE,
-      1);
+      1,
+      cricket::ICE_CANDIDATE_COMPONENT_RTP,
+      "a");
   RTCRemoteIceCandidateStats expected_a_remote_srflx(
       "RTCIceCandidate_" + a_remote_srflx->id(), 0);
   expected_a_remote_srflx.ip = "6.7.8.9";
   expected_a_remote_srflx.port = 10;
   expected_a_remote_srflx.protocol = "remote_srflx's protocol";
   expected_a_remote_srflx.candidate_type = "srflx";
   expected_a_remote_srflx.priority = 1;
+  expected_a_remote_srflx.transport_id = "RTCTransport_a_" +
+      rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTP);
 
   std::unique_ptr<cricket::Candidate> a_local_prflx = CreateFakeCandidate(
       "11.12.13.14", 15,
       "a_local_prflx's protocol",
       cricket::PRFLX_PORT_TYPE,
-      2);
+      2,
+      cricket::ICE_CANDIDATE_COMPONENT_RTCP,
+      "a");
   RTCLocalIceCandidateStats expected_a_local_prflx(
       "RTCIceCandidate_" + a_local_prflx->id(), 0);
   expected_a_local_prflx.ip = "11.12.13.14";
   expected_a_local_prflx.port = 15;
   expected_a_local_prflx.protocol = "a_local_prflx's protocol";
   expected_a_local_prflx.candidate_type = "prflx";
   expected_a_local_prflx.priority = 2;
+  expected_a_local_prflx.transport_id = "RTCTransport_a_" +
+      rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTCP);
 
   std::unique_ptr<cricket::Candidate> a_remote_relay = CreateFakeCandidate(
       "16.17.18.19", 20,
       "a_remote_relay's protocol",
       cricket::RELAY_PORT_TYPE,
-      3);
+      3,
+      cricket::ICE_CANDIDATE_COMPONENT_RTCP,
+      "a");
   RTCRemoteIceCandidateStats expected_a_remote_relay(
       "RTCIceCandidate_" + a_remote_relay->id(), 0);
   expected_a_remote_relay.ip = "16.17.18.19";
   expected_a_remote_relay.port = 20;
   expected_a_remote_relay.protocol = "a_remote_relay's protocol";
   expected_a_remote_relay.candidate_type = "relay";
   expected_a_remote_relay.priority = 3;
+  expected_a_remote_relay.transport_id = "RTCTransport_a_" +
+      rtc::ToString<>(cricket::ICE_CANDIDATE_COMPONENT_RTCP);
 
   // Candidates in the second transport stats.
   std::unique_ptr<cricket::Candidate> b_local = CreateFakeCandidate(
       "42.42.42.42", 42,
       "b_local's protocol",
       cricket::LOCAL_PORT_TYPE,
       42);
   RTCLocalIceCandidateStats expected_b_local(
       "RTCIceCandidate_" + b_local->id(), 0);
   expected_b_local.ip = "42.42.42.42";
@@ skipping 10 matching lines @@
   RTCRemoteIceCandidateStats expected_b_remote(
       "RTCIceCandidate_" + b_remote->id(), 0);
   expected_b_remote.ip = "42.42.42.42";
   expected_b_remote.port = 42;
   expected_b_remote.protocol = "b_remote's protocol";
   expected_b_remote.candidate_type = "host";
   expected_b_remote.priority = 42;
 
   SessionStats session_stats;
 
-  cricket::TransportChannelStats a_transport_channel_stats;
-  a_transport_channel_stats.connection_infos.push_back(
+  cricket::TransportChannelStats a_transport_channel_stats_rtp;
+  a_transport_channel_stats_rtp.component =
+      cricket::ICE_CANDIDATE_COMPONENT_RTP;
+  a_transport_channel_stats_rtp.connection_infos.push_back(
       cricket::ConnectionInfo());
-  a_transport_channel_stats.connection_infos[0].local_candidate =
+  a_transport_channel_stats_rtp.connection_infos[0].local_candidate =
       *a_local_host.get();
-  a_transport_channel_stats.connection_infos[0].remote_candidate =
+  a_transport_channel_stats_rtp.connection_infos[0].remote_candidate =
       *a_remote_srflx.get();
-  a_transport_channel_stats.connection_infos.push_back(
+  cricket::TransportChannelStats a_transport_channel_stats_rtcp;
+  a_transport_channel_stats_rtcp.component =
+      cricket::ICE_CANDIDATE_COMPONENT_RTCP;
+  a_transport_channel_stats_rtcp.connection_infos.push_back(
       cricket::ConnectionInfo());
-  a_transport_channel_stats.connection_infos[1].local_candidate =
+  a_transport_channel_stats_rtcp.connection_infos[0].local_candidate =
       *a_local_prflx.get();
-  a_transport_channel_stats.connection_infos[1].remote_candidate =
+  a_transport_channel_stats_rtcp.connection_infos[0].remote_candidate =
       *a_remote_relay.get();
   session_stats.transport_stats["a"].transport_name = "a";
   session_stats.transport_stats["a"].channel_stats.push_back(
-      a_transport_channel_stats);
+      a_transport_channel_stats_rtp);
+  session_stats.transport_stats["a"].channel_stats.push_back(
+      a_transport_channel_stats_rtcp);
 
   cricket::TransportChannelStats b_transport_channel_stats;
   b_transport_channel_stats.connection_infos.push_back(
       cricket::ConnectionInfo());
   b_transport_channel_stats.connection_infos[0].local_candidate =
       *b_local.get();
   b_transport_channel_stats.connection_infos[0].remote_candidate =
       *b_remote.get();
   session_stats.transport_stats["b"].transport_name = "b";
   session_stats.transport_stats["b"].channel_stats.push_back(
@@ skipping 24 matching lines @@
             report->Get(expected_a_remote_relay.id())->cast_to<
                 RTCRemoteIceCandidateStats>());
   EXPECT_TRUE(report->Get(expected_b_local.id()));
   EXPECT_EQ(expected_b_local,
             report->Get(expected_b_local.id())->cast_to<
                 RTCLocalIceCandidateStats>());
   EXPECT_TRUE(report->Get(expected_b_remote.id()));
   EXPECT_EQ(expected_b_remote,
             report->Get(expected_b_remote.id())->cast_to<
                 RTCRemoteIceCandidateStats>());
+
+  EXPECT_TRUE(report->Get(*expected_a_local_host.transport_id));
+  EXPECT_TRUE(report->Get(*expected_a_remote_srflx.transport_id));
+  EXPECT_TRUE(report->Get(*expected_a_local_prflx.transport_id));
+  EXPECT_TRUE(report->Get(*expected_a_remote_relay.transport_id));
 }
 
 TEST_F(RTCStatsCollectorTest, CollectRTCIceCandidatePairStats) {
   std::unique_ptr<cricket::Candidate> local_candidate = CreateFakeCandidate(
       "42.42.42.42", 42, "protocol", cricket::LOCAL_PORT_TYPE, 42);
   std::unique_ptr<cricket::Candidate> remote_candidate = CreateFakeCandidate(
       "42.42.42.42", 42, "protocol", cricket::LOCAL_PORT_TYPE, 42);
 
   SessionStats session_stats;
 
@@ skipping 917 matching lines @@
   rtc::scoped_refptr<FakeRTCStatsCollector> collector_;
 };
 
 TEST_F(RTCStatsCollectorTestWithFakeCollector, ThreadUsageAndResultsMerging) {
   collector_->VerifyThreadUsageAndResultsMerging();
 }
 
 }  // namespace
 
 }  // namespace webrtc