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 <memory> | 5 #include <memory> |
6 #include <ostream> | 6 #include <ostream> |
7 #include <string> | 7 #include <string> |
8 #include <utility> | 8 #include <utility> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 2780 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2791 | 2791 |
2792 QuicStreamOffset offset = 0; | 2792 QuicStreamOffset offset = 0; |
2793 mock_quic_data.AddWrite( | 2793 mock_quic_data.AddWrite( |
2794 ConstructSettingsPacket(1, SETTINGS_MAX_HEADER_LIST_SIZE, | 2794 ConstructSettingsPacket(1, SETTINGS_MAX_HEADER_LIST_SIZE, |
2795 kDefaultMaxUncompressedHeaderSize, &offset)); | 2795 kDefaultMaxUncompressedHeaderSize, &offset)); |
2796 mock_quic_data.AddWrite(ConstructClientRequestHeadersPacket( | 2796 mock_quic_data.AddWrite(ConstructClientRequestHeadersPacket( |
2797 2, kClientDataStreamId1, true, false, | 2797 2, kClientDataStreamId1, true, false, |
2798 GetRequestHeaders("POST", "https", "/"), &offset)); | 2798 GetRequestHeaders("POST", "https", "/"), &offset)); |
2799 | 2799 |
2800 std::unique_ptr<QuicEncryptedPacket> packet; | 2800 std::unique_ptr<QuicEncryptedPacket> packet; |
2801 if (version_ > QUIC_VERSION_35) { | 2801 if (version_ == QUIC_VERSION_36) { |
2802 packet = ConstructClientForceHolDataPacket(3, kClientDataStreamId1, true, | 2802 packet = ConstructClientForceHolDataPacket(3, kClientDataStreamId1, true, |
2803 true, &offset, "1"); | 2803 true, &offset, "1"); |
2804 } else { | 2804 } else { |
2805 packet = | 2805 packet = |
2806 ConstructClientDataPacket(3, kClientDataStreamId1, true, true, 0, "1"); | 2806 ConstructClientDataPacket(3, kClientDataStreamId1, true, true, 0, "1"); |
2807 } | 2807 } |
2808 mock_quic_data.AddWrite(std::move(packet)); | 2808 mock_quic_data.AddWrite(std::move(packet)); |
2809 | 2809 |
2810 mock_quic_data.AddRead(ConstructServerResponseHeadersPacket( | 2810 mock_quic_data.AddRead(ConstructServerResponseHeadersPacket( |
2811 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 2811 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
(...skipping 624 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3436 AddHangingSocketData(); | 3436 AddHangingSocketData(); |
3437 | 3437 |
3438 SendRequestAndExpectQuicResponse(origin1_); | 3438 SendRequestAndExpectQuicResponse(origin1_); |
3439 SendRequestAndExpectQuicResponse(origin2_); | 3439 SendRequestAndExpectQuicResponse(origin2_); |
3440 | 3440 |
3441 EXPECT_TRUE(AllDataConsumed()); | 3441 EXPECT_TRUE(AllDataConsumed()); |
3442 } | 3442 } |
3443 | 3443 |
3444 } // namespace test | 3444 } // namespace test |
3445 } // namespace net | 3445 } // namespace net |
OLD | NEW |