Cast: Log sender side packet events.

media/cast/logging/encoding_event_subscriber_unittest.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/test/simple_test_tick_clock.h"
 #include "base/time/tick_clock.h"
 #include "media/cast/cast_environment.h"
 #include "media/cast/logging/encoding_event_subscriber.h"
@@ skipping 310 matching lines @@
   EXPECT_EQ(media::cast::proto::AUDIO_PACKET_RECEIVED,
             base_event.event_type(0));
   ASSERT_EQ(1, base_event.event_timestamp_micros_size());
   EXPECT_EQ(now.ToInternalValue(), base_event.event_timestamp_micros(0));
 
   GetEventsAndReset();
   EXPECT_TRUE(packet_events_.empty());
 }
 
 TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForPacket) {
-  Init(OTHER_EVENT);
+  Init(VIDEO_EVENT);
   base::TimeTicks now1(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp = 100;
   int packet_id = 2;
   int size = 100;
-  cast_environment_->Logging()->InsertPacketEvent(
-      now1, kPacketSentToPacer, rtp_timestamp, /*frame_id*/ 0, packet_id,
-      /*max_packet_id*/ 10, size);
+  cast_environment_->Logging()->InsertPacketEvent(now1,
+                                                  kVideoPacketSentToPacer,
+                                                  rtp_timestamp,
+                                                  /*frame_id*/ 0,
+                                                  packet_id,
+                                                  /*max_packet_id*/ 10,
+                                                  size);
 
   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
   base::TimeTicks now2(testing_clock_->NowTicks());
-  cast_environment_->Logging()->InsertPacketEvent(
-      now2, kPacketSentToNetwork, rtp_timestamp, /*frame_id*/ 0, packet_id,
-      /*max_packet_id*/ 10, size);
+  cast_environment_->Logging()->InsertPacketEvent(now2,
+                                                  kVideoPacketSentToNetwork,
+                                                  rtp_timestamp,
+                                                  /*frame_id*/ 0,
+                                                  packet_id,
+                                                  /*max_packet_id*/ 10,
+                                                  size);
 
   GetEventsAndReset();
 
   ASSERT_EQ(1u, packet_events_.size());
 
   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
   PacketEventMap::iterator it = packet_events_.find(relative_rtp_timestamp);
   ASSERT_TRUE(it != packet_events_.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 
   ASSERT_EQ(1, event->base_packet_event_size());
   const BasePacketEvent& base_event = event->base_packet_event(0);
   EXPECT_EQ(packet_id, base_event.packet_id());
   ASSERT_EQ(2, base_event.event_type_size());
-  EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_PACER, base_event.event_type(0));
-  EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_NETWORK,
+  EXPECT_EQ(media::cast::proto::VIDEO_PACKET_SENT_TO_PACER,
+            base_event.event_type(0));
+  EXPECT_EQ(media::cast::proto::VIDEO_PACKET_SENT_TO_NETWORK,
             base_event.event_type(1));
   ASSERT_EQ(2, base_event.event_timestamp_micros_size());
   EXPECT_EQ(now1.ToInternalValue(), base_event.event_timestamp_micros(0));
   EXPECT_EQ(now2.ToInternalValue(), base_event.event_timestamp_micros(1));
 }
 
 TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForFrame) {
-  Init(OTHER_EVENT);
+  Init(VIDEO_EVENT);
   base::TimeTicks now1(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp = 100;
   int packet_id_1 = 2;
   int packet_id_2 = 3;
   int size = 100;
-  cast_environment_->Logging()->InsertPacketEvent(
-      now1, kPacketSentToPacer, rtp_timestamp, /*frame_id*/ 0, packet_id_1,
-      /*max_packet_id*/ 10, size);
+  cast_environment_->Logging()->InsertPacketEvent(now1,
+                                                  kVideoPacketSentToPacer,
+                                                  rtp_timestamp,
+                                                  /*frame_id*/ 0,
+                                                  packet_id_1,
+                                                  /*max_packet_id*/ 10,
+                                                  size);
 
   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
   base::TimeTicks now2(testing_clock_->NowTicks());
-  cast_environment_->Logging()->InsertPacketEvent(
-      now2, kPacketRetransmitted, rtp_timestamp, /*frame_id*/ 0, packet_id_2,
-      /*max_packet_id*/ 10, size);
+  cast_environment_->Logging()->InsertPacketEvent(now2,
+                                                  kVideoPacketRetransmitted,
+                                                  rtp_timestamp,
+                                                  /*frame_id*/ 0,
+                                                  packet_id_2,
+                                                  /*max_packet_id*/ 10,
+                                                  size);
 
   GetEventsAndReset();
 
   ASSERT_EQ(1u, packet_events_.size());
 
   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
   PacketEventMap::iterator it = packet_events_.find(relative_rtp_timestamp);
   ASSERT_TRUE(it != packet_events_.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 
   ASSERT_EQ(2, event->base_packet_event_size());
   const BasePacketEvent& base_event = event->base_packet_event(0);
   EXPECT_EQ(packet_id_1, base_event.packet_id());
   ASSERT_EQ(1, base_event.event_type_size());
-  EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_PACER, base_event.event_type(0));
+  EXPECT_EQ(media::cast::proto::VIDEO_PACKET_SENT_TO_PACER,
+            base_event.event_type(0));
   ASSERT_EQ(1, base_event.event_timestamp_micros_size());
   EXPECT_EQ(now1.ToInternalValue(), base_event.event_timestamp_micros(0));
 
   const BasePacketEvent& base_event_2 = event->base_packet_event(1);
   EXPECT_EQ(packet_id_2, base_event_2.packet_id());
   ASSERT_EQ(1, base_event_2.event_type_size());
-  EXPECT_EQ(media::cast::proto::PACKET_RETRANSMITTED,
+  EXPECT_EQ(media::cast::proto::VIDEO_PACKET_RETRANSMITTED,
             base_event_2.event_type(0));
   ASSERT_EQ(1, base_event_2.event_timestamp_micros_size());
   EXPECT_EQ(now2.ToInternalValue(), base_event_2.event_timestamp_micros(0));
 }
 
 TEST_F(EncodingEventSubscriberTest, MultiplePacketEvents) {
-  Init(OTHER_EVENT);
+  Init(VIDEO_EVENT);
   base::TimeTicks now1(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp_1 = 100;
   RtpTimestamp rtp_timestamp_2 = 200;
   int packet_id_1 = 2;
   int packet_id_2 = 3;
   int size = 100;
-  cast_environment_->Logging()->InsertPacketEvent(
-      now1, kPacketSentToPacer, rtp_timestamp_1, /*frame_id*/ 0, packet_id_1,
-      /*max_packet_id*/ 10, size);
+  cast_environment_->Logging()->InsertPacketEvent(now1,
+                                                  kVideoPacketSentToPacer,
+                                                  rtp_timestamp_1,
+                                                  /*frame_id*/ 0,
+                                                  packet_id_1,
+                                                  /*max_packet_id*/ 10,
+                                                  size);
 
   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
   base::TimeTicks now2(testing_clock_->NowTicks());
-  cast_environment_->Logging()->InsertPacketEvent(
-      now2, kPacketRetransmitted, rtp_timestamp_2, /*frame_id*/ 0, packet_id_2,
-      /*max_packet_id*/ 10, size);
+  cast_environment_->Logging()->InsertPacketEvent(now2,
+                                                  kVideoPacketRetransmitted,
+                                                  rtp_timestamp_2,
+                                                  /*frame_id*/ 0,
+                                                  packet_id_2,
+                                                  /*max_packet_id*/ 10,
+                                                  size);
 
   GetEventsAndReset();
 
   ASSERT_EQ(2u, packet_events_.size());
 
   RtpTimestamp relative_rtp_timestamp = rtp_timestamp_1 - first_rtp_timestamp_;
   PacketEventMap::iterator it = packet_events_.find(relative_rtp_timestamp);
   ASSERT_TRUE(it != packet_events_.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 
   ASSERT_EQ(1, event->base_packet_event_size());
   const BasePacketEvent& base_event = event->base_packet_event(0);
   EXPECT_EQ(packet_id_1, base_event.packet_id());
   ASSERT_EQ(1, base_event.event_type_size());
-  EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_PACER, base_event.event_type(0));
+  EXPECT_EQ(media::cast::proto::VIDEO_PACKET_SENT_TO_PACER,
+            base_event.event_type(0));
   ASSERT_EQ(1, base_event.event_timestamp_micros_size());
   EXPECT_EQ(now1.ToInternalValue(), base_event.event_timestamp_micros(0));
 
   relative_rtp_timestamp = rtp_timestamp_2 - first_rtp_timestamp_;
   it = packet_events_.find(relative_rtp_timestamp);
   ASSERT_TRUE(it != packet_events_.end());
 
   event = it->second;
 
   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 
   ASSERT_EQ(1, event->base_packet_event_size());
   const BasePacketEvent& base_event_2 = event->base_packet_event(0);
   EXPECT_EQ(packet_id_2, base_event_2.packet_id());
   ASSERT_EQ(1, base_event_2.event_type_size());
-  EXPECT_EQ(media::cast::proto::PACKET_RETRANSMITTED,
+  EXPECT_EQ(media::cast::proto::VIDEO_PACKET_RETRANSMITTED,
             base_event_2.event_type(0));
   ASSERT_EQ(1, base_event_2.event_timestamp_micros_size());
   EXPECT_EQ(now2.ToInternalValue(), base_event_2.event_timestamp_micros(0));
 }
 
 TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) {
   Init(VIDEO_EVENT);
   RtpTimestamp rtp_timestamp = 12345;
   base::TimeTicks now(testing_clock_->NowTicks());
 
@@ skipping 47 matching lines @@
 
   FrameEventMap::iterator it = frame_events_.find(0);
   ASSERT_NE(frame_events_.end(), it);
 
   it = frame_events_.find(30);
   ASSERT_NE(frame_events_.end(), it);
 }
 
 }  // namespace cast
 }  // namespace media