1 files changed, 55 insertions, 0 deletions
diff --git a/chromium/net/quic/congestion_control/inter_arrival_receiver_test.cc b/chromium/net/quic/congestion_control/inter_arrival_receiver_test.cc
new file mode 100644
index 00000000000..927fb6d92f7
--- /dev/null
+++ b/chromium/net/quic/congestion_control/inter_arrival_receiver_test.cc
@@ -0,0 +1,55 @@
+// Copyright (c) 2013 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/logging.h"
+#include "net/quic/congestion_control/inter_arrival_receiver.h"
+#include "net/quic/test_tools/mock_clock.h"
+#include "testing/gtest/include/gtest/gtest.h"
+
+namespace net {
+namespace test {
+
+class InterArrivalReceiverTest : public ::testing::Test {
+ protected:
+  InterArrivalReceiver receiver_;
+  MockClock clock_;
+};
+
+TEST_F(InterArrivalReceiverTest, SimpleReceiver) {
+  QuicTime start = clock_.ApproximateNow();
+  QuicTime::Delta received_delta = QuicTime::Delta::FromMilliseconds(10);
+  clock_.AdvanceTime(received_delta);
+  QuicTime receive_timestamp = clock_.ApproximateNow();
+  receiver_.RecordIncomingPacket(1, 1, receive_timestamp, false);
+
+  QuicCongestionFeedbackFrame feedback;
+  ASSERT_FALSE(receiver_.GenerateCongestionFeedback(&feedback));
+
+  clock_.AdvanceTime(received_delta);
+  receive_timestamp = clock_.ApproximateNow();
+  // Packet not received; but rather revived by FEC.
+  receiver_.RecordIncomingPacket(1, 2, receive_timestamp, true);
+  clock_.AdvanceTime(received_delta);
+  receive_timestamp = clock_.ApproximateNow();
+  receiver_.RecordIncomingPacket(1, 3, receive_timestamp, false);
+
+  ASSERT_TRUE(receiver_.GenerateCongestionFeedback(&feedback));
+
+  EXPECT_EQ(kInterArrival, feedback.type);
+  EXPECT_EQ(1, feedback.inter_arrival.accumulated_number_of_lost_packets);
+  EXPECT_EQ(3u, feedback.inter_arrival.received_packet_times.size());
+  TimeMap::iterator it = feedback.inter_arrival.received_packet_times.begin();
+  EXPECT_EQ(1u, it->first);
+  EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), it->second.Subtract(start));
+  it = feedback.inter_arrival.received_packet_times.begin();
+  it++;
+  EXPECT_EQ(2u, it->first);
+  EXPECT_EQ(QuicTime::Delta::FromMilliseconds(20), it->second.Subtract(start));
+  it++;
+  EXPECT_EQ(3u, it->first);
+  EXPECT_EQ(QuicTime::Delta::FromMilliseconds(30), it->second.Subtract(start));
+}
+
+}  // namespace test
+}  // namespace net