Cast: Implemented size limiting and event filtering in EncodingEventSubscriber.

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"
 #include "media/cast/logging/logging_defines.h"
 #include "media/cast/test/fake_single_thread_task_runner.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using media::cast::proto::AggregatedFrameEvent;
 using media::cast::proto::AggregatedGenericEvent;
 using media::cast::proto::AggregatedPacketEvent;
 using media::cast::proto::BasePacketEvent;
 
 namespace media {
 namespace cast {
 
+namespace {
+
+EncodingEventSubscriberConfig GetConfig(EventMediaType event_media_type) {
+  EncodingEventSubscriberConfig config;
+  config.event_media_type = event_media_type;
+  config.max_frames = 10;
+  config.max_generic_event_values = 10;
+  return config;
+}
+}
+
 class EncodingEventSubscriberTest : public ::testing::Test {
  protected:
   EncodingEventSubscriberTest()
       : testing_clock_(new base::SimpleTestTickClock()),
         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_, GetLoggingConfigWithRawEventsAndStatsEnabled())) {
-    cast_environment_->Logging()->AddRawEventSubscriber(&event_subscriber_);
+            scoped_ptr<base::TickClock>(testing_clock_).Pass(),
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            task_runner_,
+            GetLoggingConfigWithRawEventsAndStatsEnabled())) {}
+
+  void Init(EncodingEventSubscriberConfig config) {
+    DCHECK(!event_subscriber_);
+    event_subscriber_.reset(new EncodingEventSubscriber(config));
+    cast_environment_->Logging()->AddRawEventSubscriber(
+        event_subscriber_.get());
   }
 
   virtual ~EncodingEventSubscriberTest() {
-    cast_environment_->Logging()->RemoveRawEventSubscriber(&event_subscriber_);
+    if (event_subscriber_) {
+      cast_environment_->Logging()->RemoveRawEventSubscriber(
+          event_subscriber_.get());
+    }
   }
 
   base::SimpleTestTickClock* testing_clock_;  // Owned by CastEnvironment.
   scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_;
   scoped_refptr<CastEnvironment> cast_environment_;
-  EncodingEventSubscriber event_subscriber_;
+  scoped_ptr<EncodingEventSubscriber> event_subscriber_;
 };
 
+TEST_F(EncodingEventSubscriberTest, FrameEventTruncating) {
+  Init(GetConfig(VIDEO_EVENT));
+
+  base::TimeTicks now(testing_clock_->NowTicks());
+
+  // Entry with RTP timestamp 0 should get dropped.
+  for (int i = 0; i < 11; i++) {
+    cast_environment_->Logging()->InsertFrameEvent(now,
+                                                   kVideoFrameCaptured,
+                                                   i * 100,
+                                                   /*frame_id*/ 0);
+    cast_environment_->Logging()->InsertFrameEvent(now,
+                                                   kVideoFrameDecoded,
+                                                   i * 100,
+                                                   /*frame_id*/ 0);
+  }
+
+  FrameEventMap frame_events;
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
+
+  ASSERT_EQ(10u, frame_events.size());
+  EXPECT_EQ(100u, frame_events.begin()->first);
+  EXPECT_EQ(1000u, frame_events.rbegin()->first);
+}
+
+TEST_F(EncodingEventSubscriberTest, PacketEventTruncating) {
+  Init(GetConfig(AUDIO_EVENT));
+
+  base::TimeTicks now(testing_clock_->NowTicks());
+
+  // Entry with RTP timestamp 0 should get dropped.
+  for (int i = 0; i < 11; i++) {
+    cast_environment_->Logging()->InsertPacketEvent(now,
+                                                    kAudioPacketReceived,
+                                                    /*rtp_timestamp*/ i * 100,
+                                                    /*frame_id*/ 0,
+                                                    /*packet_id*/ i,
+                                                    /*max_packet_id*/ 10,
+                                                    /*size*/ 123);
+  }
+
+  PacketEventMap packet_events;
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
+
+  ASSERT_EQ(10u, packet_events.size());
+  EXPECT_EQ(100u, packet_events.begin()->first);
+  EXPECT_EQ(1000u, packet_events.rbegin()->first);
+}
+
+TEST_F(EncodingEventSubscriberTest, GenericEventMaxLimit) {
+  Init(GetConfig(OTHER_EVENT));
+
+  base::TimeTicks now(testing_clock_->NowTicks());
+  for (int i = 0; i < 11; i++)
+    cast_environment_->Logging()->InsertGenericEvent(now, kJitterMs, 10 * i);
+
+  GenericEventMap generic_events;
+  event_subscriber_->GetGenericEventsAndReset(&generic_events);
+
+  GenericEventMap::iterator it = generic_events.find(kJitterMs);
+  ASSERT_NE(generic_events.end(), it);
+  ASSERT_EQ(10, it->second->value_size());
+  // The first value that was logged (0) should be gone.
+  for (int i = 0; i < 10; i++)
+    EXPECT_NE(0, it->second->value(i));
+}
+
+TEST_F(EncodingEventSubscriberTest, EventFiltering) {
+  Init(GetConfig(VIDEO_EVENT));
+
+  base::TimeTicks now(testing_clock_->NowTicks());
+  RtpTimestamp rtp_timestamp = 100;
+  cast_environment_->Logging()->InsertFrameEvent(now,
+                                                 kVideoFrameDecoded,
+                                                 rtp_timestamp,
+                                                 /*frame_id*/ 0);
+
+  // This is an AUDIO_EVENT and shouldn't be processed by the subscriber.
+  cast_environment_->Logging()->InsertFrameEvent(now,
+                                                 kAudioFrameDecoded,
+                                                 rtp_timestamp,
+                                                 /*frame_id*/ 0);
+
+  // This is an OTHER_EVENT and shouldn't be processed by the subscriber.
+  cast_environment_->Logging()->InsertGenericEvent(now, kRttMs, 100);
+
+  FrameEventMap frame_events;
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
+
+  FrameEventMap::iterator frame_it = frame_events.find(rtp_timestamp);
+  ASSERT_TRUE(frame_it != frame_events.end());
+
+  linked_ptr<AggregatedFrameEvent> frame_event = frame_it->second;
+
+  ASSERT_EQ(1, frame_event->event_type_size());
+  EXPECT_EQ(media::cast::proto::VIDEO_FRAME_DECODED,
+            frame_event->event_type(0));
+
+  PacketEventMap packet_events;
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
+  EXPECT_TRUE(packet_events.empty());
+
+  GenericEventMap generic_events;
+  event_subscriber_->GetGenericEventsAndReset(&generic_events);
+
+  EXPECT_TRUE(generic_events.empty());
+}
+
 TEST_F(EncodingEventSubscriberTest, FrameEvent) {
+  Init(GetConfig(VIDEO_EVENT));
   base::TimeTicks now(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp = 100;
   cast_environment_->Logging()->InsertFrameEvent(now, kVideoFrameDecoded,
                                                  rtp_timestamp,
                                                  /*frame_id*/ 0);
 
   FrameEventMap frame_events;
-  event_subscriber_.GetFrameEventsAndReset(&frame_events);
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
 
   ASSERT_EQ(1u, frame_events.size());
 
   FrameEventMap::iterator it = frame_events.find(rtp_timestamp);
   ASSERT_TRUE(it != frame_events.end());
 
   linked_ptr<AggregatedFrameEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp, event->rtp_timestamp());
 
   ASSERT_EQ(1, event->event_type_size());
   EXPECT_EQ(media::cast::proto::VIDEO_FRAME_DECODED, event->event_type(0));
   ASSERT_EQ(1, event->event_timestamp_micros_size());
   EXPECT_EQ(now.ToInternalValue(), event->event_timestamp_micros(0));
 
   EXPECT_EQ(0, event->encoded_frame_size());
   EXPECT_EQ(0, event->delay_millis());
 
-  event_subscriber_.GetFrameEventsAndReset(&frame_events);
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
   EXPECT_TRUE(frame_events.empty());
 }
 
 TEST_F(EncodingEventSubscriberTest, FrameEventDelay) {
+  Init(GetConfig(AUDIO_EVENT));
   base::TimeTicks now(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp = 100;
   int delay_ms = 100;
   cast_environment_->Logging()->InsertFrameEventWithDelay(
       now, kAudioPlayoutDelay, rtp_timestamp,
       /*frame_id*/ 0, base::TimeDelta::FromMilliseconds(delay_ms));
 
   FrameEventMap frame_events;
-  event_subscriber_.GetFrameEventsAndReset(&frame_events);
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
 
   ASSERT_EQ(1u, frame_events.size());
 
   FrameEventMap::iterator it = frame_events.find(rtp_timestamp);
   ASSERT_TRUE(it != frame_events.end());
 
   linked_ptr<AggregatedFrameEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp, event->rtp_timestamp());
 
   ASSERT_EQ(1, event->event_type_size());
   EXPECT_EQ(media::cast::proto::AUDIO_PLAYOUT_DELAY, event->event_type(0));
   ASSERT_EQ(1, event->event_timestamp_micros_size());
   EXPECT_EQ(now.ToInternalValue(), event->event_timestamp_micros(0));
 
   EXPECT_EQ(0, event->encoded_frame_size());
   EXPECT_EQ(100, event->delay_millis());
 }
 
 TEST_F(EncodingEventSubscriberTest, FrameEventSize) {
+  Init(GetConfig(VIDEO_EVENT));
   base::TimeTicks now(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp = 100;
   int size = 123;
   cast_environment_->Logging()->InsertFrameEventWithSize(
       now, kVideoFrameEncoded, rtp_timestamp,
       /*frame_id*/ 0, size);
 
   FrameEventMap frame_events;
-  event_subscriber_.GetFrameEventsAndReset(&frame_events);
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
 
   ASSERT_EQ(1u, frame_events.size());
 
   FrameEventMap::iterator it = frame_events.find(rtp_timestamp);
   ASSERT_TRUE(it != frame_events.end());
 
   linked_ptr<AggregatedFrameEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp, event->rtp_timestamp());
 
   ASSERT_EQ(1, event->event_type_size());
   EXPECT_EQ(media::cast::proto::VIDEO_FRAME_ENCODED, event->event_type(0));
   ASSERT_EQ(1, event->event_timestamp_micros_size());
   EXPECT_EQ(now.ToInternalValue(), event->event_timestamp_micros(0));
 
   EXPECT_EQ(size, event->encoded_frame_size());
   EXPECT_EQ(0, event->delay_millis());
 }
 
 TEST_F(EncodingEventSubscriberTest, MultipleFrameEvents) {
+  Init(GetConfig(AUDIO_EVENT));
   RtpTimestamp rtp_timestamp1 = 100;
   RtpTimestamp rtp_timestamp2 = 200;
   base::TimeTicks now1(testing_clock_->NowTicks());
   cast_environment_->Logging()->InsertFrameEventWithDelay(
       now1, kAudioPlayoutDelay, rtp_timestamp1,
       /*frame_id*/ 0, /*delay*/ base::TimeDelta::FromMilliseconds(100));
 
   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
   base::TimeTicks now2(testing_clock_->NowTicks());
   cast_environment_->Logging()->InsertFrameEventWithSize(
       now2, kAudioFrameEncoded, rtp_timestamp2,
       /*frame_id*/ 0, /*size*/ 123);
 
   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
   base::TimeTicks now3(testing_clock_->NowTicks());
   cast_environment_->Logging()->InsertFrameEvent(
       now3, kAudioFrameDecoded, rtp_timestamp1, /*frame_id*/ 0);
 
   FrameEventMap frame_events;
-  event_subscriber_.GetFrameEventsAndReset(&frame_events);
+  event_subscriber_->GetFrameEventsAndReset(&frame_events);
 
   ASSERT_EQ(2u, frame_events.size());
 
   FrameEventMap::iterator it = frame_events.find(100);
   ASSERT_TRUE(it != frame_events.end());
 
   linked_ptr<AggregatedFrameEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp1, event->rtp_timestamp());
 
@@ skipping 13 matching lines @@
   EXPECT_EQ(rtp_timestamp2, event->rtp_timestamp());
 
   ASSERT_EQ(1, event->event_type_size());
   EXPECT_EQ(media::cast::proto::AUDIO_FRAME_ENCODED, event->event_type(0));
 
   ASSERT_EQ(1, event->event_timestamp_micros_size());
   EXPECT_EQ(now2.ToInternalValue(), event->event_timestamp_micros(0));
 }
 
 TEST_F(EncodingEventSubscriberTest, PacketEvent) {
+  Init(GetConfig(AUDIO_EVENT));
   base::TimeTicks now(testing_clock_->NowTicks());
   RtpTimestamp rtp_timestamp = 100;
   int packet_id = 2;
   int size = 100;
   cast_environment_->Logging()->InsertPacketEvent(
       now, kAudioPacketReceived, rtp_timestamp, /*frame_id*/ 0, packet_id,
       /*max_packet_id*/ 10, size);
 
   PacketEventMap packet_events;
-  event_subscriber_.GetPacketEventsAndReset(&packet_events);
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
 
   ASSERT_EQ(1u, packet_events.size());
 
   PacketEventMap::iterator it = packet_events.find(rtp_timestamp);
   ASSERT_TRUE(it != packet_events.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp, event->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(1, base_event.event_type_size());
   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));
 
-  event_subscriber_.GetPacketEventsAndReset(&packet_events);
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
   EXPECT_TRUE(packet_events.empty());
 }
 
 TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForPacket) {
+  Init(GetConfig(OTHER_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);
 
   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);
 
   PacketEventMap packet_events;
-  event_subscriber_.GetPacketEventsAndReset(&packet_events);
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
 
   ASSERT_EQ(1u, packet_events.size());
 
   PacketEventMap::iterator it = packet_events.find(rtp_timestamp);
   ASSERT_TRUE(it != packet_events.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp, event->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,
             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(GetConfig(OTHER_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);
 
   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);
 
   PacketEventMap packet_events;
-  event_subscriber_.GetPacketEventsAndReset(&packet_events);
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
 
   ASSERT_EQ(1u, packet_events.size());
 
   PacketEventMap::iterator it = packet_events.find(rtp_timestamp);
   ASSERT_TRUE(it != packet_events.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp, event->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));
   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,
             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(GetConfig(OTHER_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);
 
   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);
 
   PacketEventMap packet_events;
-  event_subscriber_.GetPacketEventsAndReset(&packet_events);
+  event_subscriber_->GetPacketEventsAndReset(&packet_events);
 
   ASSERT_EQ(2u, packet_events.size());
 
   PacketEventMap::iterator it = packet_events.find(rtp_timestamp_1);
   ASSERT_TRUE(it != packet_events.end());
 
   linked_ptr<AggregatedPacketEvent> event = it->second;
 
   EXPECT_EQ(rtp_timestamp_1, event->rtp_timestamp());
 
@@ skipping 16 matching lines @@
   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,
             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, GenericEvent) {
+  Init(GetConfig(OTHER_EVENT));
   base::TimeTicks now(testing_clock_->NowTicks());
   int value = 123;
   cast_environment_->Logging()->InsertGenericEvent(now, kJitterMs, value);
 
   GenericEventMap generic_events;
-  event_subscriber_.GetGenericEventsAndReset(&generic_events);
+  event_subscriber_->GetGenericEventsAndReset(&generic_events);
 
   ASSERT_EQ(1u, generic_events.size());
 
   GenericEventMap::iterator it = generic_events.find(kJitterMs);
   ASSERT_TRUE(it != generic_events.end());
 
   linked_ptr<AggregatedGenericEvent> event = it->second;
 
   ASSERT_EQ(media::cast::proto::JITTER_MS, event->event_type());
   ASSERT_EQ(1, event->event_timestamp_micros_size());
   EXPECT_EQ(now.ToInternalValue(), event->event_timestamp_micros(0));
   ASSERT_EQ(1, event->value_size());
   EXPECT_EQ(value, event->value(0));
 
-  event_subscriber_.GetGenericEventsAndReset(&generic_events);
+  event_subscriber_->GetGenericEventsAndReset(&generic_events);
   EXPECT_TRUE(generic_events.empty());
 }
 
 TEST_F(EncodingEventSubscriberTest, MultipleGenericEventsForType) {
+  Init(GetConfig(OTHER_EVENT));
   base::TimeTicks now1(testing_clock_->NowTicks());
   int value1 = 123;
   cast_environment_->Logging()->InsertGenericEvent(now1, kJitterMs, value1);
 
   testing_clock_->Advance(base::TimeDelta::FromMilliseconds(20));
   base::TimeTicks now2(testing_clock_->NowTicks());
   int value2 = 456;
   cast_environment_->Logging()->InsertGenericEvent(now2, kJitterMs, value2);
 
   GenericEventMap generic_events;
-  event_subscriber_.GetGenericEventsAndReset(&generic_events);
+  event_subscriber_->GetGenericEventsAndReset(&generic_events);
 
   ASSERT_EQ(1u, generic_events.size());
 
   GenericEventMap::iterator it = generic_events.find(kJitterMs);
   ASSERT_TRUE(it != generic_events.end());
 
   linked_ptr<AggregatedGenericEvent> event = it->second;
 
   ASSERT_EQ(media::cast::proto::JITTER_MS, event->event_type());
   ASSERT_EQ(2, event->event_timestamp_micros_size());
   EXPECT_EQ(now1.ToInternalValue(), event->event_timestamp_micros(0));
   EXPECT_EQ(now2.ToInternalValue(), event->event_timestamp_micros(1));
   ASSERT_EQ(2, event->value_size());
   EXPECT_EQ(value1, event->value(0));
   EXPECT_EQ(value2, event->value(1));
 }
 
 }  // namespace cast
 }  // namespace media