| 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 <errno.h> | 7 #include <errno.h> |
| 8 #include <memory> | 8 #include <memory> |
| 9 #include <ostream> | 9 #include <ostream> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 1039 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1050 SimpleBufferAllocator buffer_allocator_; | 1050 SimpleBufferAllocator buffer_allocator_; |
| 1051 std::unique_ptr<TestConnectionHelper> helper_; | 1051 std::unique_ptr<TestConnectionHelper> helper_; |
| 1052 std::unique_ptr<TestAlarmFactory> alarm_factory_; | 1052 std::unique_ptr<TestAlarmFactory> alarm_factory_; |
| 1053 QuicFramer peer_framer_; | 1053 QuicFramer peer_framer_; |
| 1054 QuicPacketCreator peer_creator_; | 1054 QuicPacketCreator peer_creator_; |
| 1055 std::unique_ptr<TestPacketWriter> writer_; | 1055 std::unique_ptr<TestPacketWriter> writer_; |
| 1056 TestConnection connection_; | 1056 TestConnection connection_; |
| 1057 QuicPacketCreator* creator_; | 1057 QuicPacketCreator* creator_; |
| 1058 QuicPacketGenerator* generator_; | 1058 QuicPacketGenerator* generator_; |
| 1059 QuicSentPacketManager* manager_; | 1059 QuicSentPacketManager* manager_; |
| 1060 StrictMock<MockConnectionVisitor> visitor_; | 1060 StrictMock<MockQuicConnectionVisitor> visitor_; |
| 1061 | 1061 |
| 1062 QuicStreamFrame frame1_; | 1062 QuicStreamFrame frame1_; |
| 1063 QuicStreamFrame frame2_; | 1063 QuicStreamFrame frame2_; |
| 1064 QuicAckFrame ack_; | 1064 QuicAckFrame ack_; |
| 1065 QuicStopWaitingFrame stop_waiting_; | 1065 QuicStopWaitingFrame stop_waiting_; |
| 1066 QuicPacketNumberLength packet_number_length_; | 1066 QuicPacketNumberLength packet_number_length_; |
| 1067 QuicConnectionIdLength connection_id_length_; | 1067 QuicConnectionIdLength connection_id_length_; |
| 1068 | 1068 |
| 1069 private: | 1069 private: |
| 1070 DISALLOW_COPY_AND_ASSIGN(QuicConnectionTest); | 1070 DISALLOW_COPY_AND_ASSIGN(QuicConnectionTest); |
| (...skipping 832 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1903 | 1903 |
| 1904 EXPECT_EQ(0u, connection_.NumQueuedPackets()); | 1904 EXPECT_EQ(0u, connection_.NumQueuedPackets()); |
| 1905 EXPECT_FALSE(connection_.HasQueuedData()); | 1905 EXPECT_FALSE(connection_.HasQueuedData()); |
| 1906 | 1906 |
| 1907 // Parse the last packet and ensure multiple iovector blocks have | 1907 // Parse the last packet and ensure multiple iovector blocks have |
| 1908 // been packed into a single stream frame from one stream. | 1908 // been packed into a single stream frame from one stream. |
| 1909 EXPECT_EQ(1u, writer_->frame_count()); | 1909 EXPECT_EQ(1u, writer_->frame_count()); |
| 1910 EXPECT_EQ(1u, writer_->stream_frames().size()); | 1910 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 1911 QuicStreamFrame* frame = writer_->stream_frames()[0]; | 1911 QuicStreamFrame* frame = writer_->stream_frames()[0]; |
| 1912 EXPECT_EQ(1u, frame->stream_id); | 1912 EXPECT_EQ(1u, frame->stream_id); |
| 1913 EXPECT_EQ("ABCD", StringPiece(frame->frame_buffer, frame->frame_length)); | 1913 EXPECT_EQ("ABCD", StringPiece(frame->data_buffer, frame->data_length)); |
| 1914 } | 1914 } |
| 1915 | 1915 |
| 1916 TEST_P(QuicConnectionTest, FramePackingSendvQueued) { | 1916 TEST_P(QuicConnectionTest, FramePackingSendvQueued) { |
| 1917 // Try to send two stream frames in 1 packet by using writev. | 1917 // Try to send two stream frames in 1 packet by using writev. |
| 1918 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); | 1918 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); |
| 1919 | 1919 |
| 1920 BlockOnNextWrite(); | 1920 BlockOnNextWrite(); |
| 1921 char data[] = "ABCD"; | 1921 char data[] = "ABCD"; |
| 1922 struct iovec iov[2]; | 1922 struct iovec iov[2]; |
| 1923 iov[0].iov_base = data; | 1923 iov[0].iov_base = data; |
| (...skipping 3035 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4959 EXPECT_CALL(visitor_, OnConnectionClosed(_, _, _)).Times(1); | 4959 EXPECT_CALL(visitor_, OnConnectionClosed(_, _, _)).Times(1); |
| 4960 connection_.CloseConnection(QUIC_NO_ERROR, "no reason", | 4960 connection_.CloseConnection(QUIC_NO_ERROR, "no reason", |
| 4961 ConnectionCloseBehavior::SILENT_CLOSE); | 4961 ConnectionCloseBehavior::SILENT_CLOSE); |
| 4962 connection_.CloseConnection(QUIC_NO_ERROR, "no reason", | 4962 connection_.CloseConnection(QUIC_NO_ERROR, "no reason", |
| 4963 ConnectionCloseBehavior::SILENT_CLOSE); | 4963 ConnectionCloseBehavior::SILENT_CLOSE); |
| 4964 } | 4964 } |
| 4965 | 4965 |
| 4966 } // namespace | 4966 } // namespace |
| 4967 } // namespace test | 4967 } // namespace test |
| 4968 } // namespace net | 4968 } // namespace net |
| OLD | NEW |