| 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_http_stream.h" | 5 #include "net/quic/quic_http_stream.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "net/base/net_errors.h" | 9 #include "net/base/net_errors.h" |
| 10 #include "net/base/test_completion_callback.h" | 10 #include "net/base/test_completion_callback.h" |
| 11 #include "net/base/upload_bytes_element_reader.h" | 11 #include "net/base/upload_bytes_element_reader.h" |
| 12 #include "net/base/upload_data_stream.h" | 12 #include "net/base/upload_data_stream.h" |
| 13 #include "net/http/http_response_headers.h" | 13 #include "net/http/http_response_headers.h" |
| 14 #include "net/quic/congestion_control/receive_algorithm_interface.h" | 14 #include "net/quic/congestion_control/receive_algorithm_interface.h" |
| 15 #include "net/quic/congestion_control/send_algorithm_interface.h" | 15 #include "net/quic/congestion_control/send_algorithm_interface.h" |
| 16 #include "net/quic/crypto/crypto_protocol.h" | 16 #include "net/quic/crypto/crypto_protocol.h" |
| 17 #include "net/quic/crypto/quic_decrypter.h" | 17 #include "net/quic/crypto/quic_decrypter.h" |
| 18 #include "net/quic/crypto/quic_encrypter.h" | 18 #include "net/quic/crypto/quic_encrypter.h" |
| 19 #include "net/quic/quic_client_session.h" | 19 #include "net/quic/quic_client_session.h" |
| 20 #include "net/quic/quic_connection.h" | 20 #include "net/quic/quic_connection.h" |
| 21 #include "net/quic/quic_connection_helper.h" | 21 #include "net/quic/quic_connection_helper.h" |
| 22 #include "net/quic/quic_default_packet_writer.h" | 22 #include "net/quic/quic_default_packet_writer.h" |
| 23 #include "net/quic/quic_http_utils.h" | 23 #include "net/quic/quic_http_utils.h" |
| 24 #include "net/quic/quic_reliable_client_stream.h" | 24 #include "net/quic/quic_reliable_client_stream.h" |
| 25 #include "net/quic/quic_write_blocked_list.h" |
| 25 #include "net/quic/spdy_utils.h" | 26 #include "net/quic/spdy_utils.h" |
| 26 #include "net/quic/test_tools/mock_clock.h" | 27 #include "net/quic/test_tools/mock_clock.h" |
| 27 #include "net/quic/test_tools/mock_crypto_client_stream_factory.h" | 28 #include "net/quic/test_tools/mock_crypto_client_stream_factory.h" |
| 28 #include "net/quic/test_tools/mock_random.h" | 29 #include "net/quic/test_tools/mock_random.h" |
| 29 #include "net/quic/test_tools/quic_connection_peer.h" | 30 #include "net/quic/test_tools/quic_connection_peer.h" |
| 30 #include "net/quic/test_tools/quic_test_packet_maker.h" | 31 #include "net/quic/test_tools/quic_test_packet_maker.h" |
| 31 #include "net/quic/test_tools/quic_test_utils.h" | 32 #include "net/quic/test_tools/quic_test_utils.h" |
| 32 #include "net/quic/test_tools/test_task_runner.h" | 33 #include "net/quic/test_tools/test_task_runner.h" |
| 33 #include "net/socket/socket_test_util.h" | 34 #include "net/socket/socket_test_util.h" |
| 34 #include "net/spdy/spdy_frame_builder.h" | 35 #include "net/spdy/spdy_frame_builder.h" |
| 35 #include "net/spdy/spdy_framer.h" | 36 #include "net/spdy/spdy_framer.h" |
| 36 #include "net/spdy/spdy_http_utils.h" | 37 #include "net/spdy/spdy_http_utils.h" |
| 37 #include "net/spdy/spdy_protocol.h" | 38 #include "net/spdy/spdy_protocol.h" |
| 38 #include "net/spdy/write_blocked_list.h" | |
| 39 #include "testing/gmock/include/gmock/gmock.h" | 39 #include "testing/gmock/include/gmock/gmock.h" |
| 40 #include "testing/gtest/include/gtest/gtest.h" | 40 #include "testing/gtest/include/gtest/gtest.h" |
| 41 | 41 |
| 42 using testing::_; | 42 using testing::_; |
| 43 using testing::AnyNumber; | 43 using testing::AnyNumber; |
| 44 using testing::Return; | 44 using testing::Return; |
| 45 | 45 |
| 46 namespace net { | 46 namespace net { |
| 47 namespace test { | 47 namespace test { |
| 48 namespace { | 48 namespace { |
| (...skipping 606 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 655 request_.method = "GET"; | 655 request_.method = "GET"; |
| 656 request_.url = GURL("http://www.google.com/"); | 656 request_.url = GURL("http://www.google.com/"); |
| 657 | 657 |
| 658 EXPECT_EQ(OK, stream_->InitializeStream(&request_, MEDIUM, | 658 EXPECT_EQ(OK, stream_->InitializeStream(&request_, MEDIUM, |
| 659 net_log_, callback_.callback())); | 659 net_log_, callback_.callback())); |
| 660 | 660 |
| 661 // Check that priority is highest. | 661 // Check that priority is highest. |
| 662 QuicReliableClientStream* reliable_stream = | 662 QuicReliableClientStream* reliable_stream = |
| 663 QuicHttpStreamPeer::GetQuicReliableClientStream(stream_.get()); | 663 QuicHttpStreamPeer::GetQuicReliableClientStream(stream_.get()); |
| 664 DCHECK(reliable_stream); | 664 DCHECK(reliable_stream); |
| 665 DCHECK_EQ(static_cast<QuicPriority>(kHighestPriority), | 665 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, |
| 666 reliable_stream->EffectivePriority()); | 666 reliable_stream->EffectivePriority()); |
| 667 | 667 |
| 668 EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, | 668 EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, |
| 669 callback_.callback())); | 669 callback_.callback())); |
| 670 EXPECT_EQ(&response_, stream_->GetResponseInfo()); | 670 EXPECT_EQ(&response_, stream_->GetResponseInfo()); |
| 671 | 671 |
| 672 // Check that priority has now dropped back to MEDIUM. | 672 // Check that priority has now dropped back to MEDIUM. |
| 673 DCHECK_EQ(MEDIUM, ConvertQuicPriorityToRequestPriority( | 673 DCHECK_EQ(MEDIUM, ConvertQuicPriorityToRequestPriority( |
| 674 reliable_stream->EffectivePriority())); | 674 reliable_stream->EffectivePriority())); |
| 675 | 675 |
| (...skipping 26 matching lines...) Expand all Loading... |
| 702 | 702 |
| 703 EXPECT_EQ(OK, stream_->InitializeStream(&request_, MEDIUM, | 703 EXPECT_EQ(OK, stream_->InitializeStream(&request_, MEDIUM, |
| 704 net_log_, callback_.callback())); | 704 net_log_, callback_.callback())); |
| 705 | 705 |
| 706 // Check that priority is highest. | 706 // Check that priority is highest. |
| 707 QuicReliableClientStream* reliable_stream = | 707 QuicReliableClientStream* reliable_stream = |
| 708 QuicHttpStreamPeer::GetQuicReliableClientStream(stream_.get()); | 708 QuicHttpStreamPeer::GetQuicReliableClientStream(stream_.get()); |
| 709 DCHECK(reliable_stream); | 709 DCHECK(reliable_stream); |
| 710 QuicReliableClientStream::Delegate* delegate = reliable_stream->GetDelegate(); | 710 QuicReliableClientStream::Delegate* delegate = reliable_stream->GetDelegate(); |
| 711 DCHECK(delegate); | 711 DCHECK(delegate); |
| 712 DCHECK_EQ(static_cast<QuicPriority>(kHighestPriority), | 712 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, |
| 713 reliable_stream->EffectivePriority()); | 713 reliable_stream->EffectivePriority()); |
| 714 | 714 |
| 715 // Set Delegate to NULL and make sure EffectivePriority returns highest | 715 // Set Delegate to NULL and make sure EffectivePriority returns highest |
| 716 // priority. | 716 // priority. |
| 717 reliable_stream->SetDelegate(NULL); | 717 reliable_stream->SetDelegate(NULL); |
| 718 DCHECK_EQ(static_cast<QuicPriority>(kHighestPriority), | 718 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, |
| 719 reliable_stream->EffectivePriority()); | 719 reliable_stream->EffectivePriority()); |
| 720 reliable_stream->SetDelegate(delegate); | 720 reliable_stream->SetDelegate(delegate); |
| 721 } | 721 } |
| 722 | 722 |
| 723 TEST_P(QuicHttpStreamTest, DontCompressHeadersWhenNotWritable) { | 723 TEST_P(QuicHttpStreamTest, DontCompressHeadersWhenNotWritable) { |
| 724 SetRequest("GET", "/", MEDIUM); | 724 SetRequest("GET", "/", MEDIUM); |
| 725 AddWrite(ConstructDataPacket(1, kIncludeVersion, kFin, 0, request_data_)); | 725 AddWrite(ConstructDataPacket(1, kIncludeVersion, kFin, 0, request_data_)); |
| 726 Initialize(); | 726 Initialize(); |
| 727 | 727 |
| 728 if (GetParam() > QUIC_VERSION_12) { | 728 if (GetParam() > QUIC_VERSION_12) { |
| (...skipping 21 matching lines...) Expand all Loading... |
| 750 WillRepeatedly(Return(QuicTime::Delta::Zero())); | 750 WillRepeatedly(Return(QuicTime::Delta::Zero())); |
| 751 | 751 |
| 752 // Data should flush out now. | 752 // Data should flush out now. |
| 753 connection_->OnCanWrite(); | 753 connection_->OnCanWrite(); |
| 754 EXPECT_FALSE(reliable_stream->HasBufferedData()); | 754 EXPECT_FALSE(reliable_stream->HasBufferedData()); |
| 755 EXPECT_TRUE(AtEof()); | 755 EXPECT_TRUE(AtEof()); |
| 756 } | 756 } |
| 757 | 757 |
| 758 } // namespace test | 758 } // namespace test |
| 759 } // namespace net | 759 } // namespace net |
| OLD | NEW |