| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/quic/quic_connection.h" | 5 #include "net/quic/quic_connection.h" |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
| (...skipping 2550 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2561 ASSERT_EQ(0u, connection_.NumFecGroups()); | 2561 ASSERT_EQ(0u, connection_.NumFecGroups()); |
| 2562 } | 2562 } |
| 2563 | 2563 |
| 2564 TEST_P(QuicConnectionTest, NoQuicCongestionFeedbackFrame) { | 2564 TEST_P(QuicConnectionTest, NoQuicCongestionFeedbackFrame) { |
| 2565 SendAckPacketToPeer(); | 2565 SendAckPacketToPeer(); |
| 2566 EXPECT_TRUE(writer_->feedback_frames().empty()); | 2566 EXPECT_TRUE(writer_->feedback_frames().empty()); |
| 2567 } | 2567 } |
| 2568 | 2568 |
| 2569 TEST_P(QuicConnectionTest, WithQuicCongestionFeedbackFrame) { | 2569 TEST_P(QuicConnectionTest, WithQuicCongestionFeedbackFrame) { |
| 2570 QuicCongestionFeedbackFrame info; | 2570 QuicCongestionFeedbackFrame info; |
| 2571 info.type = kFixRate; | 2571 info.type = kTCP; |
| 2572 info.fix_rate.bitrate = QuicBandwidth::FromBytesPerSecond(123); | 2572 info.tcp.receive_window = 0x4030; |
| 2573 SetFeedback(&info); | 2573 SetFeedback(&info); |
| 2574 | 2574 |
| 2575 SendAckPacketToPeer(); | 2575 SendAckPacketToPeer(); |
| 2576 ASSERT_FALSE(writer_->feedback_frames().empty()); | 2576 ASSERT_FALSE(writer_->feedback_frames().empty()); |
| 2577 ASSERT_EQ(kFixRate, writer_->feedback_frames()[0].type); | 2577 ASSERT_EQ(kTCP, writer_->feedback_frames()[0].type); |
| 2578 ASSERT_EQ(info.fix_rate.bitrate, | |
| 2579 writer_->feedback_frames()[0].fix_rate.bitrate); | |
| 2580 } | 2578 } |
| 2581 | 2579 |
| 2582 TEST_P(QuicConnectionTest, UpdateQuicCongestionFeedbackFrame) { | 2580 TEST_P(QuicConnectionTest, UpdateQuicCongestionFeedbackFrame) { |
| 2583 SendAckPacketToPeer(); | 2581 SendAckPacketToPeer(); |
| 2584 EXPECT_CALL(*receive_algorithm_, RecordIncomingPacket(_, _, _)); | 2582 EXPECT_CALL(*receive_algorithm_, RecordIncomingPacket(_, _, _)); |
| 2585 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2583 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2586 ProcessPacket(1); | 2584 ProcessPacket(1); |
| 2587 } | 2585 } |
| 2588 | 2586 |
| 2589 TEST_P(QuicConnectionTest, DontUpdateQuicCongestionFeedbackFrameForRevived) { | 2587 TEST_P(QuicConnectionTest, DontUpdateQuicCongestionFeedbackFrameForRevived) { |
| (...skipping 1396 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3986 QuicBlockedFrame blocked; | 3984 QuicBlockedFrame blocked; |
| 3987 blocked.stream_id = 3; | 3985 blocked.stream_id = 3; |
| 3988 EXPECT_CALL(visitor_, OnBlockedFrames(_)); | 3986 EXPECT_CALL(visitor_, OnBlockedFrames(_)); |
| 3989 ProcessFramePacket(QuicFrame(&blocked)); | 3987 ProcessFramePacket(QuicFrame(&blocked)); |
| 3990 EXPECT_TRUE(ack_alarm->IsSet()); | 3988 EXPECT_TRUE(ack_alarm->IsSet()); |
| 3991 } | 3989 } |
| 3992 | 3990 |
| 3993 } // namespace | 3991 } // namespace |
| 3994 } // namespace test | 3992 } // namespace test |
| 3995 } // namespace net | 3993 } // namespace net |
| OLD | NEW |