src/media/cast/logging/encoding_event_subscriber_unittest.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "base/memory/ref_counted.h"
   6 #include "base/memory/scoped_ptr.h"
   7 #include "base/test/simple_test_tick_clock.h"
   8 #include "base/time/tick_clock.h"
   9 #include "media/cast/cast_environment.h"
  10 #include "media/cast/logging/encoding_event_subscriber.h"
  11 #include "media/cast/logging/logging_defines.h"
  12 #include "media/cast/test/fake_single_thread_task_runner.h"
  13 #include "testing/gtest/include/gtest/gtest.h"
  14
  15 using media::cast::proto::AggregatedFrameEvent;
  16 using media::cast::proto::AggregatedPacketEvent;
  17 using media::cast::proto::BasePacketEvent;
  18 using media::cast::proto::LogMetadata;
  19
  20 namespace {
  21
  22 int64 InMilliseconds(base::TimeTicks event_time) {
  23   return (event_time - base::TimeTicks()).InMilliseconds();
  24 }
  25
  26 }
  27
  28 namespace media {
  29 namespace cast {
  30
  31 class EncodingEventSubscriberTest : public ::testing::Test {
  32  protected:
  33   EncodingEventSubscriberTest()
  34       : testing_clock_(new base::SimpleTestTickClock()),
  35         task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)),
  36         cast_environment_(new CastEnvironment(
  37             scoped_ptr<base::TickClock>(testing_clock_).Pass(),
  38             task_runner_,
  39             task_runner_,
  40             task_runner_)),
  41         first_rtp_timestamp_(0) {}
  42
  43   void Init(EventMediaType event_media_type) {
  44     DCHECK(!event_subscriber_);
  45     event_subscriber_.reset(new EncodingEventSubscriber(event_media_type, 10));
  46     cast_environment_->Logging()->AddRawEventSubscriber(
  47         event_subscriber_.get());
  48   }
  49
  50   virtual ~EncodingEventSubscriberTest() {
  51     if (event_subscriber_) {
  52       cast_environment_->Logging()->RemoveRawEventSubscriber(
  53           event_subscriber_.get());
  54     }
  55   }
  56
  57   void GetEventsAndReset() {
  58     event_subscriber_->GetEventsAndReset(
  59         &metadata_, &frame_events_, &packet_events_);
  60     first_rtp_timestamp_ = metadata_.first_rtp_timestamp();
  61   }
  62
  63   base::SimpleTestTickClock* testing_clock_;  // Owned by CastEnvironment.
  64   scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_;
  65   scoped_refptr<CastEnvironment> cast_environment_;
  66   scoped_ptr<EncodingEventSubscriber> event_subscriber_;
  67   FrameEventList frame_events_;
  68   PacketEventList packet_events_;
  69   LogMetadata metadata_;
  70   RtpTimestamp first_rtp_timestamp_;
  71 };
  72
  73 TEST_F(EncodingEventSubscriberTest, FrameEventTruncating) {
  74   Init(VIDEO_EVENT);
  75
  76   base::TimeTicks now(testing_clock_->NowTicks());
  77
  78   // Entry with RTP timestamp 0 should get dropped.
  79   for (int i = 0; i < 11; i++) {
  80     cast_environment_->Logging()->InsertFrameEvent(now,
  81                                                    FRAME_CAPTURE_BEGIN,
  82                                                    VIDEO_EVENT,
  83                                                    i * 100,
  84                                                    /*frame_id*/ 0);
  85     cast_environment_->Logging()->InsertFrameEvent(now,
  86                                                    FRAME_DECODED,
  87                                                    VIDEO_EVENT,
  88                                                    i * 100,
  89                                                    /*frame_id*/ 0);
  90   }
  91
  92   GetEventsAndReset();
  93
  94   ASSERT_EQ(10u, frame_events_.size());
  95   EXPECT_EQ(100u, frame_events_.front()->relative_rtp_timestamp());
  96   EXPECT_EQ(1000u, frame_events_.back()->relative_rtp_timestamp());
  97 }
  98
  99 TEST_F(EncodingEventSubscriberTest, PacketEventTruncating) {
 100   Init(AUDIO_EVENT);
 101
 102   base::TimeTicks now(testing_clock_->NowTicks());
 103
 104   // Entry with RTP timestamp 0 should get dropped.
 105   for (int i = 0; i < 11; i++) {
 106     cast_environment_->Logging()->InsertPacketEvent(now,
 107                                                     PACKET_RECEIVED,
 108                                                     AUDIO_EVENT,
 109                                                     /*rtp_timestamp*/ i * 100,
 110                                                     /*frame_id*/ 0,
 111                                                     /*packet_id*/ i,
 112                                                     /*max_packet_id*/ 10,
 113                                                     /*size*/ 123);
 114   }
 115
 116   GetEventsAndReset();
 117
 118   ASSERT_EQ(10u, packet_events_.size());
 119   EXPECT_EQ(100u, packet_events_.front()->relative_rtp_timestamp());
 120   EXPECT_EQ(1000u, packet_events_.back()->relative_rtp_timestamp());
 121 }
 122
 123 TEST_F(EncodingEventSubscriberTest, EventFiltering) {
 124   Init(VIDEO_EVENT);
 125
 126   base::TimeTicks now(testing_clock_->NowTicks());
 127   RtpTimestamp rtp_timestamp = 100;
 128   cast_environment_->Logging()->InsertFrameEvent(now,
 129                                                  FRAME_DECODED,
 130                                                  VIDEO_EVENT,
 131                                                  rtp_timestamp,
 132                                                  /*frame_id*/ 0);
 133
 134   // This is an AUDIO_EVENT and shouldn't be processed by the subscriber.
 135   cast_environment_->Logging()->InsertFrameEvent(now,
 136                                                  FRAME_DECODED,
 137                                                  AUDIO_EVENT,
 138                                                  rtp_timestamp,
 139                                                  /*frame_id*/ 0);
 140
 141   GetEventsAndReset();
 142
 143   ASSERT_EQ(1u, frame_events_.size());
 144   FrameEventList::iterator it = frame_events_.begin();
 145
 146   linked_ptr<AggregatedFrameEvent> frame_event = *it;
 147
 148   ASSERT_EQ(1, frame_event->event_type_size());
 149   EXPECT_EQ(media::cast::proto::FRAME_DECODED,
 150             frame_event->event_type(0));
 151
 152   GetEventsAndReset();
 153
 154   EXPECT_TRUE(packet_events_.empty());
 155 }
 156
 157 TEST_F(EncodingEventSubscriberTest, FrameEvent) {
 158   Init(VIDEO_EVENT);
 159   base::TimeTicks now(testing_clock_->NowTicks());
 160   RtpTimestamp rtp_timestamp = 100;
 161   cast_environment_->Logging()->InsertFrameEvent(now, FRAME_DECODED,
 162                                                  VIDEO_EVENT,
 163                                                  rtp_timestamp,
 164                                                  /*frame_id*/ 0);
 165
 166   GetEventsAndReset();
 167
 168   ASSERT_EQ(1u, frame_events_.size());
 169
 170   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
 171   FrameEventList::iterator it = frame_events_.begin();
 172
 173   linked_ptr<AggregatedFrameEvent> event = *it;
 174
 175   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 176
 177   ASSERT_EQ(1, event->event_type_size());
 178   EXPECT_EQ(media::cast::proto::FRAME_DECODED, event->event_type(0));
 179   ASSERT_EQ(1, event->event_timestamp_ms_size());
 180   EXPECT_EQ(InMilliseconds(now), event->event_timestamp_ms(0));
 181
 182   EXPECT_EQ(0, event->encoded_frame_size());
 183   EXPECT_EQ(0, event->delay_millis());
 184
 185   GetEventsAndReset();
 186   EXPECT_TRUE(frame_events_.empty());
 187 }
 188
 189 TEST_F(EncodingEventSubscriberTest, FrameEventDelay) {
 190   Init(AUDIO_EVENT);
 191   base::TimeTicks now(testing_clock_->NowTicks());
 192   RtpTimestamp rtp_timestamp = 100;
 193   int delay_ms = 100;
 194   cast_environment_->Logging()->InsertFrameEventWithDelay(
 195       now, FRAME_PLAYOUT, AUDIO_EVENT, rtp_timestamp,
 196       /*frame_id*/ 0, base::TimeDelta::FromMilliseconds(delay_ms));
 197
 198   GetEventsAndReset();
 199
 200   ASSERT_EQ(1u, frame_events_.size());
 201
 202   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
 203   FrameEventList::iterator it = frame_events_.begin();
 204
 205   linked_ptr<AggregatedFrameEvent> event = *it;
 206
 207   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 208
 209   ASSERT_EQ(1, event->event_type_size());
 210   EXPECT_EQ(media::cast::proto::FRAME_PLAYOUT, event->event_type(0));
 211   ASSERT_EQ(1, event->event_timestamp_ms_size());
 212   EXPECT_EQ(InMilliseconds(now), event->event_timestamp_ms(0));
 213
 214   EXPECT_EQ(0, event->encoded_frame_size());
 215   EXPECT_EQ(100, event->delay_millis());
 216   EXPECT_FALSE(event->has_key_frame());
 217 }
 218
 219 TEST_F(EncodingEventSubscriberTest, FrameEventSize) {
 220   Init(VIDEO_EVENT);
 221   base::TimeTicks now(testing_clock_->NowTicks());
 222   RtpTimestamp rtp_timestamp = 100;
 223   int size = 123;
 224   bool key_frame = true;
 225   int target_bitrate = 1024;
 226   cast_environment_->Logging()->InsertEncodedFrameEvent(
 227       now, FRAME_ENCODED, VIDEO_EVENT, rtp_timestamp,
 228       /*frame_id*/ 0, size, key_frame, target_bitrate);
 229
 230   GetEventsAndReset();
 231
 232   ASSERT_EQ(1u, frame_events_.size());
 233
 234   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
 235   FrameEventList::iterator it = frame_events_.begin();
 236
 237   linked_ptr<AggregatedFrameEvent> event = *it;
 238
 239   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 240
 241   ASSERT_EQ(1, event->event_type_size());
 242   EXPECT_EQ(media::cast::proto::FRAME_ENCODED, event->event_type(0));
 243   ASSERT_EQ(1, event->event_timestamp_ms_size());
 244   EXPECT_EQ(InMilliseconds(now), event->event_timestamp_ms(0));
 245
 246   EXPECT_EQ(size, event->encoded_frame_size());
 247   EXPECT_EQ(0, event->delay_millis());
 248   EXPECT_TRUE(event->has_key_frame());
 249   EXPECT_EQ(key_frame, event->key_frame());
 250   EXPECT_EQ(target_bitrate, event->target_bitrate());
 251 }
 252
 253 TEST_F(EncodingEventSubscriberTest, MultipleFrameEvents) {
 254   Init(AUDIO_EVENT);
 255   RtpTimestamp rtp_timestamp1 = 100;
 256   RtpTimestamp rtp_timestamp2 = 200;
 257   base::TimeTicks now1(testing_clock_->NowTicks());
 258   cast_environment_->Logging()->InsertFrameEventWithDelay(
 259       now1, FRAME_PLAYOUT, AUDIO_EVENT, rtp_timestamp1,
 260       /*frame_id*/ 0, /*delay*/ base::TimeDelta::FromMilliseconds(100));
 261
 262   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
 263   base::TimeTicks now2(testing_clock_->NowTicks());
 264   cast_environment_->Logging()->InsertEncodedFrameEvent(
 265       now2, FRAME_ENCODED, AUDIO_EVENT, rtp_timestamp2,
 266       /*frame_id*/ 0, /*size*/ 123, /* key_frame - unused */ false,
 267       /*target_bitrate - unused*/ 0);
 268
 269   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
 270   base::TimeTicks now3(testing_clock_->NowTicks());
 271   cast_environment_->Logging()->InsertFrameEvent(
 272       now3, FRAME_DECODED, AUDIO_EVENT, rtp_timestamp1, /*frame_id*/ 0);
 273
 274   GetEventsAndReset();
 275
 276   ASSERT_EQ(2u, frame_events_.size());
 277
 278   RtpTimestamp relative_rtp_timestamp = rtp_timestamp1 - first_rtp_timestamp_;
 279   FrameEventList::iterator it = frame_events_.begin();
 280
 281   linked_ptr<AggregatedFrameEvent> event = *it;
 282
 283   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 284
 285   ASSERT_EQ(2, event->event_type_size());
 286   EXPECT_EQ(media::cast::proto::FRAME_PLAYOUT, event->event_type(0));
 287   EXPECT_EQ(media::cast::proto::FRAME_DECODED, event->event_type(1));
 288
 289   ASSERT_EQ(2, event->event_timestamp_ms_size());
 290   EXPECT_EQ(InMilliseconds(now1), event->event_timestamp_ms(0));
 291   EXPECT_EQ(InMilliseconds(now3), event->event_timestamp_ms(1));
 292
 293   EXPECT_FALSE(event->has_key_frame());
 294
 295   relative_rtp_timestamp = rtp_timestamp2 - first_rtp_timestamp_;
 296   ++it;
 297
 298   event = *it;
 299
 300   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 301
 302   ASSERT_EQ(1, event->event_type_size());
 303   EXPECT_EQ(media::cast::proto::FRAME_ENCODED, event->event_type(0));
 304
 305   ASSERT_EQ(1, event->event_timestamp_ms_size());
 306   EXPECT_EQ(InMilliseconds(now2), event->event_timestamp_ms(0));
 307
 308   EXPECT_FALSE(event->has_key_frame());
 309 }
 310
 311 TEST_F(EncodingEventSubscriberTest, PacketEvent) {
 312   Init(AUDIO_EVENT);
 313   base::TimeTicks now(testing_clock_->NowTicks());
 314   RtpTimestamp rtp_timestamp = 100;
 315   int packet_id = 2;
 316   int size = 100;
 317   cast_environment_->Logging()->InsertPacketEvent(
 318       now, PACKET_RECEIVED, AUDIO_EVENT,
 319       rtp_timestamp, /*frame_id*/ 0, packet_id,
 320       /*max_packet_id*/ 10, size);
 321
 322   GetEventsAndReset();
 323
 324   ASSERT_EQ(1u, packet_events_.size());
 325
 326   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
 327   PacketEventList::iterator it = packet_events_.begin();
 328
 329   linked_ptr<AggregatedPacketEvent> event = *it;
 330
 331   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 332
 333   ASSERT_EQ(1, event->base_packet_event_size());
 334   const BasePacketEvent& base_event = event->base_packet_event(0);
 335   EXPECT_EQ(packet_id, base_event.packet_id());
 336   ASSERT_EQ(1, base_event.event_type_size());
 337   EXPECT_EQ(media::cast::proto::PACKET_RECEIVED,
 338             base_event.event_type(0));
 339   ASSERT_EQ(1, base_event.event_timestamp_ms_size());
 340   EXPECT_EQ(InMilliseconds(now), base_event.event_timestamp_ms(0));
 341   EXPECT_EQ(size, base_event.size());
 342
 343   GetEventsAndReset();
 344   EXPECT_TRUE(packet_events_.empty());
 345 }
 346
 347 TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForPacket) {
 348   Init(VIDEO_EVENT);
 349   base::TimeTicks now1(testing_clock_->NowTicks());
 350   RtpTimestamp rtp_timestamp = 100;
 351   int packet_id = 2;
 352   int size = 100;
 353   cast_environment_->Logging()->InsertPacketEvent(now1,
 354                                                   PACKET_SENT_TO_NETWORK,
 355                                                   VIDEO_EVENT,
 356                                                   rtp_timestamp,
 357                                                   /*frame_id*/ 0,
 358                                                   packet_id,
 359                                                   /*max_packet_id*/ 10,
 360                                                   size);
 361
 362   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
 363   base::TimeTicks now2(testing_clock_->NowTicks());
 364   cast_environment_->Logging()->InsertPacketEvent(now2,
 365                                                   PACKET_RETRANSMITTED,
 366                                                   VIDEO_EVENT,
 367                                                   rtp_timestamp,
 368                                                   /*frame_id*/ 0,
 369                                                   packet_id,
 370                                                   /*max_packet_id*/ 10,
 371                                                   size);
 372
 373   GetEventsAndReset();
 374
 375   ASSERT_EQ(1u, packet_events_.size());
 376
 377   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
 378   PacketEventList::iterator it = packet_events_.begin();
 379
 380   linked_ptr<AggregatedPacketEvent> event = *it;
 381
 382   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 383
 384   ASSERT_EQ(1, event->base_packet_event_size());
 385   const BasePacketEvent& base_event = event->base_packet_event(0);
 386   EXPECT_EQ(packet_id, base_event.packet_id());
 387   ASSERT_EQ(2, base_event.event_type_size());
 388   EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_NETWORK,
 389             base_event.event_type(0));
 390   EXPECT_EQ(media::cast::proto::PACKET_RETRANSMITTED,
 391             base_event.event_type(1));
 392   ASSERT_EQ(2, base_event.event_timestamp_ms_size());
 393   EXPECT_EQ(InMilliseconds(now1), base_event.event_timestamp_ms(0));
 394   EXPECT_EQ(InMilliseconds(now2), base_event.event_timestamp_ms(1));
 395 }
 396
 397 TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForFrame) {
 398   Init(VIDEO_EVENT);
 399   base::TimeTicks now1(testing_clock_->NowTicks());
 400   RtpTimestamp rtp_timestamp = 100;
 401   int packet_id_1 = 2;
 402   int packet_id_2 = 3;
 403   int size = 100;
 404   cast_environment_->Logging()->InsertPacketEvent(now1,
 405                                                   PACKET_SENT_TO_NETWORK,
 406                                                   VIDEO_EVENT,
 407                                                   rtp_timestamp,
 408                                                   /*frame_id*/ 0,
 409                                                   packet_id_1,
 410                                                   /*max_packet_id*/ 10,
 411                                                   size);
 412
 413   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
 414   base::TimeTicks now2(testing_clock_->NowTicks());
 415   cast_environment_->Logging()->InsertPacketEvent(now2,
 416                                                   PACKET_RETRANSMITTED,
 417                                                   VIDEO_EVENT,
 418                                                   rtp_timestamp,
 419                                                   /*frame_id*/ 0,
 420                                                   packet_id_2,
 421                                                   /*max_packet_id*/ 10,
 422                                                   size);
 423
 424   GetEventsAndReset();
 425
 426   ASSERT_EQ(1u, packet_events_.size());
 427
 428   RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_;
 429   PacketEventList::iterator it = packet_events_.begin();
 430
 431   linked_ptr<AggregatedPacketEvent> event = *it;
 432
 433   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 434
 435   ASSERT_EQ(2, event->base_packet_event_size());
 436   const BasePacketEvent& base_event = event->base_packet_event(0);
 437   EXPECT_EQ(packet_id_1, base_event.packet_id());
 438   ASSERT_EQ(1, base_event.event_type_size());
 439   EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_NETWORK,
 440             base_event.event_type(0));
 441   ASSERT_EQ(1, base_event.event_timestamp_ms_size());
 442   EXPECT_EQ(InMilliseconds(now1), base_event.event_timestamp_ms(0));
 443
 444   const BasePacketEvent& base_event_2 = event->base_packet_event(1);
 445   EXPECT_EQ(packet_id_2, base_event_2.packet_id());
 446   ASSERT_EQ(1, base_event_2.event_type_size());
 447   EXPECT_EQ(media::cast::proto::PACKET_RETRANSMITTED,
 448             base_event_2.event_type(0));
 449   ASSERT_EQ(1, base_event_2.event_timestamp_ms_size());
 450   EXPECT_EQ(InMilliseconds(now2), base_event_2.event_timestamp_ms(0));
 451 }
 452
 453 TEST_F(EncodingEventSubscriberTest, MultiplePacketEvents) {
 454   Init(VIDEO_EVENT);
 455   base::TimeTicks now1(testing_clock_->NowTicks());
 456   RtpTimestamp rtp_timestamp_1 = 100;
 457   RtpTimestamp rtp_timestamp_2 = 200;
 458   int packet_id_1 = 2;
 459   int packet_id_2 = 3;
 460   int size = 100;
 461   cast_environment_->Logging()->InsertPacketEvent(now1,
 462                                                   PACKET_SENT_TO_NETWORK,
 463                                                   VIDEO_EVENT,
 464                                                   rtp_timestamp_1,
 465                                                   /*frame_id*/ 0,
 466                                                   packet_id_1,
 467                                                   /*max_packet_id*/ 10,
 468                                                   size);
 469
 470   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
 471   base::TimeTicks now2(testing_clock_->NowTicks());
 472   cast_environment_->Logging()->InsertPacketEvent(now2,
 473                                                   PACKET_RETRANSMITTED,
 474                                                   VIDEO_EVENT,
 475                                                   rtp_timestamp_2,
 476                                                   /*frame_id*/ 0,
 477                                                   packet_id_2,
 478                                                   /*max_packet_id*/ 10,
 479                                                   size);
 480
 481   GetEventsAndReset();
 482
 483   ASSERT_EQ(2u, packet_events_.size());
 484
 485   RtpTimestamp relative_rtp_timestamp = rtp_timestamp_1 - first_rtp_timestamp_;
 486   PacketEventList::iterator it = packet_events_.begin();
 487
 488   linked_ptr<AggregatedPacketEvent> event = *it;
 489
 490   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 491
 492   ASSERT_EQ(1, event->base_packet_event_size());
 493   const BasePacketEvent& base_event = event->base_packet_event(0);
 494   EXPECT_EQ(packet_id_1, base_event.packet_id());
 495   ASSERT_EQ(1, base_event.event_type_size());
 496   EXPECT_EQ(media::cast::proto::PACKET_SENT_TO_NETWORK,
 497             base_event.event_type(0));
 498   ASSERT_EQ(1, base_event.event_timestamp_ms_size());
 499   EXPECT_EQ(InMilliseconds(now1), base_event.event_timestamp_ms(0));
 500
 501   relative_rtp_timestamp = rtp_timestamp_2 - first_rtp_timestamp_;
 502   ++it;
 503   ASSERT_TRUE(it != packet_events_.end());
 504
 505   event = *it;
 506   EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp());
 507
 508   ASSERT_EQ(1, event->base_packet_event_size());
 509   const BasePacketEvent& base_event_2 = event->base_packet_event(0);
 510   EXPECT_EQ(packet_id_2, base_event_2.packet_id());
 511   ASSERT_EQ(1, base_event_2.event_type_size());
 512   EXPECT_EQ(media::cast::proto::PACKET_RETRANSMITTED,
 513             base_event_2.event_type(0));
 514   ASSERT_EQ(1, base_event_2.event_timestamp_ms_size());
 515   EXPECT_EQ(InMilliseconds(now2), base_event_2.event_timestamp_ms(0));
 516 }
 517
 518 TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) {
 519   Init(VIDEO_EVENT);
 520   RtpTimestamp rtp_timestamp = 12345;
 521   base::TimeTicks now(testing_clock_->NowTicks());
 522
 523   cast_environment_->Logging()->InsertFrameEvent(now,
 524                                                  FRAME_CAPTURE_BEGIN,
 525                                                  VIDEO_EVENT,
 526                                                  rtp_timestamp,
 527                                                  /*frame_id*/ 0);
 528
 529   cast_environment_->Logging()->InsertFrameEvent(now,
 530                                                  FRAME_CAPTURE_END,
 531                                                  VIDEO_EVENT,
 532                                                  rtp_timestamp + 30,
 533                                                  /*frame_id*/ 1);
 534
 535   GetEventsAndReset();
 536
 537   EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_);
 538   FrameEventList::iterator it = frame_events_.begin();
 539   ASSERT_NE(frame_events_.end(), it);
 540   EXPECT_EQ(0u, (*it)->relative_rtp_timestamp());
 541
 542   ++it;
 543   ASSERT_NE(frame_events_.end(), it);
 544   EXPECT_EQ(30u, (*it)->relative_rtp_timestamp());
 545
 546   rtp_timestamp = 67890;
 547
 548   cast_environment_->Logging()->InsertFrameEvent(now,
 549                                                  FRAME_CAPTURE_BEGIN,
 550                                                  VIDEO_EVENT,
 551                                                  rtp_timestamp,
 552                                                  /*frame_id*/ 0);
 553   GetEventsAndReset();
 554
 555   EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_);
 556 }
 557
 558 TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) {
 559   Init(VIDEO_EVENT);
 560   RtpTimestamp rtp_timestamp = 0xffffffff - 20;
 561   base::TimeTicks now(testing_clock_->NowTicks());
 562
 563   cast_environment_->Logging()->InsertFrameEvent(now,
 564                                                  FRAME_CAPTURE_BEGIN,
 565                                                  VIDEO_EVENT,
 566                                                  rtp_timestamp,
 567                                                  /*frame_id*/ 0);
 568
 569   // RtpTimestamp has now wrapped around.
 570   cast_environment_->Logging()->InsertFrameEvent(now,
 571                                                  FRAME_CAPTURE_END,
 572                                                  VIDEO_EVENT,
 573                                                  rtp_timestamp + 30,
 574                                                  /*frame_id*/ 1);
 575
 576   GetEventsAndReset();
 577
 578   FrameEventList::iterator it = frame_events_.begin();
 579   ASSERT_NE(frame_events_.end(), it);
 580   EXPECT_EQ(0u, (*it)->relative_rtp_timestamp());
 581
 582   ++it;
 583   ASSERT_NE(frame_events_.end(), it);
 584   EXPECT_EQ(30u, (*it)->relative_rtp_timestamp());
 585 }
 586
 587 TEST_F(EncodingEventSubscriberTest, MaxEventsPerProto) {
 588   Init(VIDEO_EVENT);
 589   RtpTimestamp rtp_timestamp = 100;
 590   for (int i = 0; i < kMaxEventsPerProto + 1; i++) {
 591     cast_environment_->Logging()->InsertFrameEvent(testing_clock_->NowTicks(),
 592                                                    FRAME_ACK_RECEIVED,
 593                                                    VIDEO_EVENT,
 594                                                    rtp_timestamp,
 595                                                    /*frame_id*/ 0);
 596     testing_clock_->Advance(base::TimeDelta::FromMilliseconds(30));
 597   }
 598
 599   GetEventsAndReset();
 600
 601   ASSERT_EQ(2u, frame_events_.size());
 602   FrameEventList::iterator frame_it = frame_events_.begin();
 603   ASSERT_TRUE(frame_it != frame_events_.end());
 604
 605   linked_ptr<AggregatedFrameEvent> frame_event = *frame_it;
 606
 607   EXPECT_EQ(kMaxEventsPerProto, frame_event->event_type_size());
 608
 609   for (int i = 0; i < kMaxPacketsPerFrame + 1; i++) {
 610     cast_environment_->Logging()->InsertPacketEvent(
 611         testing_clock_->NowTicks(),
 612         PACKET_SENT_TO_NETWORK,
 613         VIDEO_EVENT,
 614         rtp_timestamp,
 615         /*frame_id*/ 0,
 616         i,
 617         kMaxPacketsPerFrame,
 618         123);
 619     testing_clock_->Advance(base::TimeDelta::FromMilliseconds(30));
 620   }
 621
 622   GetEventsAndReset();
 623
 624   EXPECT_EQ(2u, packet_events_.size());
 625
 626   PacketEventList::iterator packet_it = packet_events_.begin();
 627   ASSERT_TRUE(packet_it != packet_events_.end());
 628
 629   linked_ptr<AggregatedPacketEvent> packet_event = *packet_it;
 630
 631   EXPECT_EQ(kMaxPacketsPerFrame,
 632       packet_event->base_packet_event_size());
 633
 634   ++packet_it;
 635   packet_event = *packet_it;
 636   EXPECT_EQ(1, packet_event->base_packet_event_size());
 637
 638   for (int j = 0; j < kMaxEventsPerProto + 1; j++) {
 639     cast_environment_->Logging()->InsertPacketEvent(
 640         testing_clock_->NowTicks(),
 641         PACKET_SENT_TO_NETWORK,
 642         VIDEO_EVENT,
 643         rtp_timestamp,
 644         /*frame_id*/ 0,
 645         0,
 646         0,
 647         123);
 648     testing_clock_->Advance(base::TimeDelta::FromMilliseconds(30));
 649   }
 650
 651   GetEventsAndReset();
 652
 653   EXPECT_EQ(2u, packet_events_.size());
 654   packet_it = packet_events_.begin();
 655   ASSERT_TRUE(packet_it != packet_events_.end());
 656
 657   packet_event = *packet_it;
 658
 659   EXPECT_EQ(kMaxEventsPerProto,
 660       packet_event->base_packet_event(0).event_type_size());
 661
 662   ++packet_it;
 663   packet_event = *packet_it;
 664   EXPECT_EQ(1, packet_event->base_packet_event(0).event_type_size());
 665 }
 666
 667 }  // namespace cast
 668 }  // namespace media