Upstream version 5.34.104.0

[platform/framework/web/crosswalk.git] / src / media / cast / rtcp / rtcp_unittest.cc

diff --git a/src/media/cast/rtcp/rtcp_unittest.cc b/src/media/cast/rtcp/rtcp_unittest.cc
index a89ae6e..cf74ef5 100644 (file)
--- a/src/media/cast/rtcp/rtcp_unittest.cc
+++ b/src/media/cast/rtcp/rtcp_unittest.cc
@@ -9,7 +9,7 @@
 #include "media/cast/rtcp/mock_rtcp_sender_feedback.h"
 #include "media/cast/rtcp/rtcp.h"
 #include "media/cast/rtcp/test_rtcp_packet_builder.h"
-#include "media/cast/test/fake_task_runner.h"
+#include "media/cast/test/fake_single_thread_task_runner.h"
 #include "media/cast/transport/cast_transport_config.h"
 #include "media/cast/transport/cast_transport_sender_impl.h"
 #include "media/cast/transport/pacing/paced_sender.h"
@@ -26,7 +26,7 @@ static const std::string kCName("test@10.1.1.1");
 static const uint32 kRtcpIntervalMs = 500;
 static const int64 kStartMillisecond = GG_INT64_C(12345678900000);
 static const int64 kAddedDelay = 123;
-static const int64 kAddedShortDelay= 100;
+static const int64 kAddedShortDelay = 100;
 
 class RtcpTestPacketSender : public transport::PacketSender {
  public:
@@ -88,15 +88,14 @@ class LocalRtcpTransport : public transport::PacedPacketSender {
     } else {
       testing_clock_->Advance(base::TimeDelta::FromMilliseconds(kAddedDelay));
     }
-    if (drop_packets_) return true;
+    if (drop_packets_)
+      return true;
 
     rtcp_->IncomingRtcpPacket(&(packet[0]), packet.size());
     return true;
   }
 
-  virtual bool SendPackets(const PacketList& packets) OVERRIDE {
-    return false;
-  }
+  virtual bool SendPackets(const PacketList& packets) OVERRIDE { return false; }
 
   virtual bool ResendPackets(const PacketList& packets) OVERRIDE {
     return false;
@@ -108,6 +107,8 @@ class LocalRtcpTransport : public transport::PacedPacketSender {
   Rtcp* rtcp_;
   base::SimpleTestTickClock* testing_clock_;
   scoped_refptr<CastEnvironment> cast_environment_;
+
+  DISALLOW_COPY_AND_ASSIGN(LocalRtcpTransport);
 };
 
 class RtcpPeer : public Rtcp {
@@ -133,8 +134,7 @@ class RtcpPeer : public Rtcp {
              rtcp_interval,
              local_ssrc,
              remote_ssrc,
-             c_name) {
-  }
+             c_name) {}
 
   using Rtcp::CheckForWrapAround;
   using Rtcp::OnReceivedLipSyncInfo;
@@ -144,11 +144,16 @@ class RtcpTest : public ::testing::Test {
  protected:
   RtcpTest()
       : testing_clock_(new base::SimpleTestTickClock()),
-        task_runner_(new test::FakeTaskRunner(testing_clock_)),
+        task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)),
         cast_environment_(new CastEnvironment(
             scoped_ptr<base::TickClock>(testing_clock_).Pass(),
-            task_runner_, task_runner_, task_runner_, task_runner_,
-            task_runner_, task_runner_, GetDefaultCastSenderLoggingConfig())),
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            GetDefaultCastSenderLoggingConfig())),
         sender_to_receiver_(testing_clock_),
         receiver_to_sender_(cast_environment_, testing_clock_) {
     testing_clock_->Advance(
@@ -157,8 +162,9 @@ class RtcpTest : public ::testing::Test {
     transport_sender_.reset(new transport::CastTransportSenderImpl(
         testing_clock_,
         transport_config,
-        base::Bind(&UpdateCastTransportStatus), task_runner_));
-    transport_sender_->InsertFakeTransportForTesting(&sender_to_receiver_);
+        base::Bind(&UpdateCastTransportStatus),
+        task_runner_,
+        &sender_to_receiver_));
     EXPECT_CALL(mock_sender_feedback_, OnReceivedCastFeedback(_)).Times(0);
   }
 
@@ -177,12 +183,14 @@ class RtcpTest : public ::testing::Test {
   }
 
   base::SimpleTestTickClock* testing_clock_;  // Owned by CastEnvironment.
-  scoped_refptr<test::FakeTaskRunner> task_runner_;
+  scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_;
   scoped_refptr<CastEnvironment> cast_environment_;
   RtcpTestPacketSender sender_to_receiver_;
   scoped_ptr<transport::CastTransportSenderImpl> transport_sender_;
   LocalRtcpTransport receiver_to_sender_;
   MockRtcpSenderFeedback mock_sender_feedback_;
+
+  DISALLOW_COPY_AND_ASSIGN(RtcpTest);
 };
 
 TEST_F(RtcpTest, TimeToSend) {
@@ -201,9 +209,9 @@ TEST_F(RtcpTest, TimeToSend) {
             kCName);
   receiver_to_sender_.set_rtcp_receiver(&rtcp);
   EXPECT_LE(start_time, rtcp.TimeToSendNextRtcpReport());
-  EXPECT_GE(start_time + base::TimeDelta::FromMilliseconds(
-                kRtcpIntervalMs * 3 / 2),
-            rtcp.TimeToSendNextRtcpReport());
+  EXPECT_GE(
+      start_time + base::TimeDelta::FromMilliseconds(kRtcpIntervalMs * 3 / 2),
+      rtcp.TimeToSendNextRtcpReport());
   base::TimeDelta delta = rtcp.TimeToSendNextRtcpReport() - start_time;
   testing_clock_->Advance(delta);
   EXPECT_EQ(testing_clock_->NowTicks(), rtcp.TimeToSendNextRtcpReport());
@@ -261,8 +269,7 @@ TEST_F(RtcpTest, BasicCast) {
   RtcpCastMessage cast_message(kSenderSsrc);
   cast_message.ack_frame_id_ = kAckFrameId;
   PacketIdSet missing_packets;
-  cast_message.missing_frames_and_packets_[
-      kLostFrameId] = missing_packets;
+  cast_message.missing_frames_and_packets_[kLostFrameId] = missing_packets;
 
   missing_packets.insert(kLostPacketId1);
   missing_packets.insert(kLostPacketId2);
@@ -306,22 +313,22 @@ TEST_F(RtcpTest, RttReducedSizeRtcp) {
   base::TimeDelta avg_rtt;
   base::TimeDelta min_rtt;
   base::TimeDelta max_rtt;
-  EXPECT_FALSE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
-  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_FALSE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
+  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
 
   transport::RtcpSenderLogMessage empty_sender_log;
   rtcp_sender.SendRtcpFromRtpSender(empty_sender_log);
   RunTasks(33);
   rtcp_receiver.SendRtcpFromRtpReceiver(NULL, NULL);
-  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
-  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
+  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(2 * kAddedDelay, rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, avg_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, min_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, max_rtt.InMilliseconds(), 2);
   rtcp_sender.SendRtcpFromRtpSender(empty_sender_log);
   RunTasks(33);
-  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
 
   EXPECT_NEAR(2 * kAddedDelay, rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, avg_rtt.InMilliseconds(), 2);
@@ -363,18 +370,18 @@ TEST_F(RtcpTest, Rtt) {
   base::TimeDelta avg_rtt;
   base::TimeDelta min_rtt;
   base::TimeDelta max_rtt;
-  EXPECT_FALSE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
-  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_FALSE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
+  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
 
   transport::RtcpSenderLogMessage empty_sender_log;
   rtcp_sender.SendRtcpFromRtpSender(empty_sender_log);
   RunTasks(33);
   rtcp_receiver.SendRtcpFromRtpReceiver(NULL, NULL);
 
-  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   RunTasks(33);
 
-  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_FALSE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   RunTasks(33);
 
   EXPECT_NEAR(2 * kAddedDelay, rtt.InMilliseconds(), 2);
@@ -384,7 +391,7 @@ TEST_F(RtcpTest, Rtt) {
 
   rtcp_sender.SendRtcpFromRtpSender(empty_sender_log);
   RunTasks(33);
-  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(2 * kAddedDelay, rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, avg_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, min_rtt.InMilliseconds(), 2);
@@ -393,32 +400,31 @@ TEST_F(RtcpTest, Rtt) {
   receiver_to_sender_.set_short_delay();
   sender_to_receiver_.set_short_delay();
   rtcp_receiver.SendRtcpFromRtpReceiver(NULL, NULL);
-  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(kAddedDelay + kAddedShortDelay, rtt.InMilliseconds(), 2);
-  EXPECT_NEAR((kAddedShortDelay + 3 * kAddedDelay) / 2,
-               avg_rtt.InMilliseconds(),
-               2);
+  EXPECT_NEAR(
+      (kAddedShortDelay + 3 * kAddedDelay) / 2, avg_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(kAddedDelay + kAddedShortDelay, min_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, max_rtt.InMilliseconds(), 2);
 
   rtcp_sender.SendRtcpFromRtpSender(empty_sender_log);
   RunTasks(33);
-  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(2 * kAddedShortDelay, rtt.InMilliseconds(), 1);
   EXPECT_NEAR((2 * kAddedShortDelay + 2 * kAddedDelay) / 2,
-               avg_rtt.InMilliseconds(),
-               1);
+              avg_rtt.InMilliseconds(),
+              1);
   EXPECT_NEAR(2 * kAddedShortDelay, min_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, max_rtt.InMilliseconds(), 2);
 
   rtcp_receiver.SendRtcpFromRtpReceiver(NULL, NULL);
-  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(2 * kAddedShortDelay, rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedShortDelay, min_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, max_rtt.InMilliseconds(), 2);
 
   rtcp_receiver.SendRtcpFromRtpReceiver(NULL, NULL);
-  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(2 * kAddedShortDelay, rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedShortDelay, min_rtt.InMilliseconds(), 2);
   EXPECT_NEAR(2 * kAddedDelay, max_rtt.InMilliseconds(), 2);
@@ -442,7 +448,7 @@ TEST_F(RtcpTest, RttWithPacketLoss) {
   Rtcp rtcp_sender(cast_environment_,
                    &mock_sender_feedback_,
                    transport_sender_.get(),
-                   NULL, //&transport_,
+                   NULL,
                    NULL,
                    NULL,
                    kRtcpReducedSize,
@@ -463,8 +469,8 @@ TEST_F(RtcpTest, RttWithPacketLoss) {
   base::TimeDelta avg_rtt;
   base::TimeDelta min_rtt;
   base::TimeDelta max_rtt;
-  EXPECT_FALSE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
-  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_FALSE(rtcp_sender.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
+  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(2 * kAddedDelay, rtt.InMilliseconds(), 1);
   EXPECT_NEAR(2 * kAddedDelay, avg_rtt.InMilliseconds(), 1);
   EXPECT_NEAR(2 * kAddedDelay, min_rtt.InMilliseconds(), 1);
@@ -478,7 +484,7 @@ TEST_F(RtcpTest, RttWithPacketLoss) {
   rtcp_sender.SendRtcpFromRtpSender(empty_sender_log);
   RunTasks(33);
 
-  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt,  &max_rtt));
+  EXPECT_TRUE(rtcp_receiver.Rtt(&rtt, &avg_rtt, &min_rtt, &max_rtt));
   EXPECT_NEAR(kAddedDelay + kAddedShortDelay, rtt.InMilliseconds(), 2);
 }
 
@@ -574,8 +580,8 @@ TEST_F(RtcpTest, RtpTimestampInSenderTime) {
   base::TimeTicks rtp_timestamp_in_ticks;
 
   // Test fail before we get a OnReceivedLipSyncInfo.
-  EXPECT_FALSE(rtcp_peer.RtpTimestampInSenderTime(frequency, rtp_timestamp,
-                                                   &rtp_timestamp_in_ticks));
+  EXPECT_FALSE(rtcp_peer.RtpTimestampInSenderTime(
+      frequency, rtp_timestamp, &rtp_timestamp_in_ticks));
 
   uint32 ntp_seconds = 0;
   uint32 ntp_fractions = 0;
@@ -586,28 +592,28 @@ TEST_F(RtcpTest, RtpTimestampInSenderTime) {
   // Test exact match.
   ConvertTimeTicksToNtp(input_time, &ntp_seconds, &ntp_fractions);
   rtcp_peer.OnReceivedLipSyncInfo(rtp_timestamp, ntp_seconds, ntp_fractions);
-  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(frequency, rtp_timestamp,
-                                                 &rtp_timestamp_in_ticks));
+  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(
+      frequency, rtp_timestamp, &rtp_timestamp_in_ticks));
   EXPECT_EQ(input_time, rtp_timestamp_in_ticks);
 
   // Test older rtp_timestamp.
   rtp_timestamp = 32000;
-  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(frequency, rtp_timestamp,
-                                                 &rtp_timestamp_in_ticks));
+  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(
+      frequency, rtp_timestamp, &rtp_timestamp_in_ticks));
   EXPECT_EQ(input_time - base::TimeDelta::FromMilliseconds(1000),
             rtp_timestamp_in_ticks);
 
   // Test older rtp_timestamp with wrap.
   rtp_timestamp = 4294903296u;
-  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(frequency, rtp_timestamp,
-                                                 &rtp_timestamp_in_ticks));
+  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(
+      frequency, rtp_timestamp, &rtp_timestamp_in_ticks));
   EXPECT_EQ(input_time - base::TimeDelta::FromMilliseconds(4000),
             rtp_timestamp_in_ticks);
 
   // Test newer rtp_timestamp.
   rtp_timestamp = 128000;
-  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(frequency, rtp_timestamp,
-                                                 &rtp_timestamp_in_ticks));
+  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(
+      frequency, rtp_timestamp, &rtp_timestamp_in_ticks));
   EXPECT_EQ(input_time + base::TimeDelta::FromMilliseconds(2000),
             rtp_timestamp_in_ticks);
 
@@ -615,8 +621,8 @@ TEST_F(RtcpTest, RtpTimestampInSenderTime) {
   rtp_timestamp = 4294903296u;
   rtcp_peer.OnReceivedLipSyncInfo(rtp_timestamp, ntp_seconds, ntp_fractions);
   rtp_timestamp = 64000;
-  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(frequency, rtp_timestamp,
-                                                 &rtp_timestamp_in_ticks));
+  EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime(
+      frequency, rtp_timestamp, &rtp_timestamp_in_ticks));
   EXPECT_EQ(input_time + base::TimeDelta::FromMilliseconds(4000),
             rtp_timestamp_in_ticks);
 }