Cast: Limit number of events/packets in EncodingEventSubscriber protos.

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 550 matching lines @@
 
   GetEventsAndReset();
 
   FrameEventMap::iterator it = frame_events_.find(0);
   ASSERT_NE(frame_events_.end(), it);
 
   it = frame_events_.find(30);
   ASSERT_NE(frame_events_.end(), it);
 }
 
+TEST_F(EncodingEventSubscriberTest, MaxEventsPerProto) {
+  Init(VIDEO_EVENT);
+  RtpTimestamp rtp_timestamp = 100;
+  for (int i = 0; i < kMaxEventsPerProto + 1; i++) {
+    cast_environment_->Logging()->InsertFrameEvent(testing_clock_->NowTicks(),
+                                                   kVideoAckReceived,
+                                                   rtp_timestamp,
+                                                   /*frame_id*/ 0);
+    testing_clock_->Advance(base::TimeDelta::FromMilliseconds(30));
+  }
+
+  GetEventsAndReset();
+
+  FrameEventMap::iterator frame_it = frame_events_.find(0);
+  ASSERT_TRUE(frame_it != frame_events_.end());
+
+  linked_ptr<AggregatedFrameEvent> frame_event = frame_it->second;
+
+  EXPECT_EQ(kMaxEventsPerProto, frame_event->event_type_size());
+
+  for (int i = 0; i < kMaxPacketsPerFrame + 1; i++) {
+    for (int j = 0; j < kMaxEventsPerProto + 1; j++) {
+      cast_environment_->Logging()->InsertPacketEvent(
+          testing_clock_->NowTicks(),
+          kVideoPacketRetransmitted,
+          rtp_timestamp,
+          /*frame_id*/ 0,
+          i,
+          kMaxPacketsPerFrame,
+          123);
+      testing_clock_->Advance(base::TimeDelta::FromMilliseconds(30));
+    }
+  }
+
+  GetEventsAndReset();
+
+  PacketEventMap::iterator packet_it = packet_events_.find(0);
+  ASSERT_TRUE(packet_it != packet_events_.end());
+
+  linked_ptr<AggregatedPacketEvent> packet_event = packet_it->second;
+
+  EXPECT_EQ(kMaxPacketsPerFrame, packet_event->base_packet_event_size());
+  for (int i = 0; i < packet_event->base_packet_event_size(); i++) {
+    EXPECT_EQ(kMaxEventsPerProto,
+              packet_event->base_packet_event(i).event_type_size());
+  }
+}
+
 }  // namespace cast
 }  // namespace media