| 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/reliable_quic_stream.h" | 5 #include "net/quic/reliable_quic_stream.h" |
| 6 | 6 |
| 7 #include "net/quic/quic_ack_notifier.h" | 7 #include "net/quic/quic_ack_notifier.h" |
| 8 #include "net/quic/quic_connection.h" | 8 #include "net/quic/quic_connection.h" |
| 9 #include "net/quic/quic_spdy_compressor.h" | 9 #include "net/quic/quic_spdy_compressor.h" |
| 10 #include "net/quic/quic_spdy_decompressor.h" | 10 #include "net/quic/quic_spdy_decompressor.h" |
| 11 #include "net/quic/quic_utils.h" | 11 #include "net/quic/quic_utils.h" |
| 12 #include "net/quic/quic_write_blocked_list.h" |
| 12 #include "net/quic/spdy_utils.h" | 13 #include "net/quic/spdy_utils.h" |
| 13 #include "net/quic/test_tools/quic_session_peer.h" | 14 #include "net/quic/test_tools/quic_session_peer.h" |
| 14 #include "net/quic/test_tools/quic_test_utils.h" | 15 #include "net/quic/test_tools/quic_test_utils.h" |
| 15 #include "testing/gmock/include/gmock/gmock.h" | 16 #include "testing/gmock/include/gmock/gmock.h" |
| 16 | 17 |
| 17 using base::StringPiece; | 18 using base::StringPiece; |
| 18 using std::min; | 19 using std::min; |
| 19 using testing::_; | 20 using testing::_; |
| 20 using testing::InSequence; | 21 using testing::InSequence; |
| 21 using testing::Return; | 22 using testing::Return; |
| (...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 110 } | 111 } |
| 111 | 112 |
| 112 protected: | 113 protected: |
| 113 MockConnection* connection_; | 114 MockConnection* connection_; |
| 114 scoped_ptr<MockSession> session_; | 115 scoped_ptr<MockSession> session_; |
| 115 scoped_ptr<TestStream> stream_; | 116 scoped_ptr<TestStream> stream_; |
| 116 scoped_ptr<TestStream> stream2_; | 117 scoped_ptr<TestStream> stream2_; |
| 117 scoped_ptr<QuicSpdyCompressor> compressor_; | 118 scoped_ptr<QuicSpdyCompressor> compressor_; |
| 118 scoped_ptr<QuicSpdyDecompressor> decompressor_; | 119 scoped_ptr<QuicSpdyDecompressor> decompressor_; |
| 119 SpdyHeaderBlock headers_; | 120 SpdyHeaderBlock headers_; |
| 120 WriteBlockedList<QuicStreamId>* write_blocked_list_; | 121 QuicWriteBlockedList* write_blocked_list_; |
| 121 }; | 122 }; |
| 122 | 123 |
| 123 TEST_F(ReliableQuicStreamTest, WriteAllData) { | 124 TEST_F(ReliableQuicStreamTest, WriteAllData) { |
| 124 Initialize(kShouldProcessData); | 125 Initialize(kShouldProcessData); |
| 125 | 126 |
| 126 connection_->options()->max_packet_length = | 127 connection_->options()->max_packet_length = |
| 127 1 + QuicPacketCreator::StreamFramePacketOverhead( | 128 1 + QuicPacketCreator::StreamFramePacketOverhead( |
| 128 connection_->version(), PACKET_8BYTE_GUID, !kIncludeVersion, | 129 connection_->version(), PACKET_8BYTE_GUID, !kIncludeVersion, |
| 129 PACKET_6BYTE_SEQUENCE_NUMBER, NOT_IN_FEC_GROUP); | 130 PACKET_6BYTE_SEQUENCE_NUMBER, NOT_IN_FEC_GROUP); |
| 130 EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce( | 131 EXPECT_CALL(*session_, WritevData(kStreamId, _, 1, _, _, _)).WillOnce( |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 223 EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); | 224 EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); |
| 224 EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error()); | 225 EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error()); |
| 225 stream_->OnConnectionClosed(QUIC_INTERNAL_ERROR, false); | 226 stream_->OnConnectionClosed(QUIC_INTERNAL_ERROR, false); |
| 226 EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); | 227 EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); |
| 227 EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error()); | 228 EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error()); |
| 228 } | 229 } |
| 229 | 230 |
| 230 } // namespace | 231 } // namespace |
| 231 } // namespace test | 232 } // namespace test |
| 232 } // namespace net | 233 } // namespace net |
| OLD | NEW |