| 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 592 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 603 EXPECT_CALL(*receive_algorithm_, | 603 EXPECT_CALL(*receive_algorithm_, |
| 604 RecordIncomingPacket(_, _, _)).Times(AnyNumber()); | 604 RecordIncomingPacket(_, _, _)).Times(AnyNumber()); |
| 605 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 605 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 606 .Times(AnyNumber()); | 606 .Times(AnyNumber()); |
| 607 EXPECT_CALL(*send_algorithm_, RetransmissionDelay()).WillRepeatedly( | 607 EXPECT_CALL(*send_algorithm_, RetransmissionDelay()).WillRepeatedly( |
| 608 Return(QuicTime::Delta::Zero())); | 608 Return(QuicTime::Delta::Zero())); |
| 609 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()).WillRepeatedly( | 609 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()).WillRepeatedly( |
| 610 Return(kMaxPacketSize)); | 610 Return(kMaxPacketSize)); |
| 611 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 611 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 612 .WillByDefault(Return(true)); | 612 .WillByDefault(Return(true)); |
| 613 EXPECT_CALL(visitor_, HasPendingWrites()).Times(AnyNumber()); | 613 EXPECT_CALL(visitor_, WillingAndAbleToWrite()).Times(AnyNumber()); |
| 614 EXPECT_CALL(visitor_, HasPendingHandshake()).Times(AnyNumber()); | 614 EXPECT_CALL(visitor_, HasPendingHandshake()).Times(AnyNumber()); |
| 615 EXPECT_CALL(visitor_, OnCanWrite()).Times(AnyNumber()); | 615 EXPECT_CALL(visitor_, OnCanWrite()).Times(AnyNumber()); |
| 616 EXPECT_CALL(visitor_, HasOpenDataStreams()).WillRepeatedly(Return(false)); | 616 EXPECT_CALL(visitor_, HasOpenDataStreams()).WillRepeatedly(Return(false)); |
| 617 | 617 |
| 618 EXPECT_CALL(*loss_algorithm_, GetLossTimeout()) | 618 EXPECT_CALL(*loss_algorithm_, GetLossTimeout()) |
| 619 .WillRepeatedly(Return(QuicTime::Zero())); | 619 .WillRepeatedly(Return(QuicTime::Zero())); |
| 620 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 620 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 621 .WillRepeatedly(Return(SequenceNumberSet())); | 621 .WillRepeatedly(Return(SequenceNumberSet())); |
| 622 } | 622 } |
| 623 | 623 |
| (...skipping 1144 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1768 EXPECT_TRUE(writer_->stream_frames()[0].fin); | 1768 EXPECT_TRUE(writer_->stream_frames()[0].fin); |
| 1769 } | 1769 } |
| 1770 | 1770 |
| 1771 TEST_P(QuicConnectionTest, OnCanWrite) { | 1771 TEST_P(QuicConnectionTest, OnCanWrite) { |
| 1772 // Visitor's OnCanWrite will send data, but will have more pending writes. | 1772 // Visitor's OnCanWrite will send data, but will have more pending writes. |
| 1773 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce(DoAll( | 1773 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce(DoAll( |
| 1774 IgnoreResult(InvokeWithoutArgs(&connection_, | 1774 IgnoreResult(InvokeWithoutArgs(&connection_, |
| 1775 &TestConnection::SendStreamData3)), | 1775 &TestConnection::SendStreamData3)), |
| 1776 IgnoreResult(InvokeWithoutArgs(&connection_, | 1776 IgnoreResult(InvokeWithoutArgs(&connection_, |
| 1777 &TestConnection::SendStreamData5)))); | 1777 &TestConnection::SendStreamData5)))); |
| 1778 EXPECT_CALL(visitor_, HasPendingWrites()).WillOnce(Return(true)); | 1778 EXPECT_CALL(visitor_, WillingAndAbleToWrite()).WillOnce(Return(true)); |
| 1779 EXPECT_CALL(*send_algorithm_, | 1779 EXPECT_CALL(*send_algorithm_, |
| 1780 TimeUntilSend(_, _, _)).WillRepeatedly( | 1780 TimeUntilSend(_, _, _)).WillRepeatedly( |
| 1781 testing::Return(QuicTime::Delta::Zero())); | 1781 testing::Return(QuicTime::Delta::Zero())); |
| 1782 | 1782 |
| 1783 connection_.OnCanWrite(); | 1783 connection_.OnCanWrite(); |
| 1784 | 1784 |
| 1785 // Parse the last packet and ensure it's the two stream frames from | 1785 // Parse the last packet and ensure it's the two stream frames from |
| 1786 // two different streams. | 1786 // two different streams. |
| 1787 EXPECT_EQ(2u, writer_->frame_count()); | 1787 EXPECT_EQ(2u, writer_->frame_count()); |
| 1788 EXPECT_EQ(2u, writer_->stream_frames().size()); | 1788 EXPECT_EQ(2u, writer_->stream_frames().size()); |
| (...skipping 2182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3971 QuicBlockedFrame blocked; | 3971 QuicBlockedFrame blocked; |
| 3972 blocked.stream_id = 3; | 3972 blocked.stream_id = 3; |
| 3973 EXPECT_CALL(visitor_, OnBlockedFrames(_)); | 3973 EXPECT_CALL(visitor_, OnBlockedFrames(_)); |
| 3974 ProcessFramePacket(QuicFrame(&blocked)); | 3974 ProcessFramePacket(QuicFrame(&blocked)); |
| 3975 EXPECT_TRUE(ack_alarm->IsSet()); | 3975 EXPECT_TRUE(ack_alarm->IsSet()); |
| 3976 } | 3976 } |
| 3977 | 3977 |
| 3978 } // namespace | 3978 } // namespace |
| 3979 } // namespace test | 3979 } // namespace test |
| 3980 } // namespace net | 3980 } // namespace net |
| OLD | NEW |