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" |
(...skipping 28 matching lines...) Expand all Loading... |
39 namespace test { | 39 namespace test { |
40 namespace { | 40 namespace { |
41 | 41 |
42 const char kUploadData[] = "hello world!"; | 42 const char kUploadData[] = "hello world!"; |
43 | 43 |
44 class TestQuicConnection : public QuicConnection { | 44 class TestQuicConnection : public QuicConnection { |
45 public: | 45 public: |
46 TestQuicConnection(QuicGuid guid, | 46 TestQuicConnection(QuicGuid guid, |
47 IPEndPoint address, | 47 IPEndPoint address, |
48 QuicConnectionHelper* helper) | 48 QuicConnectionHelper* helper) |
49 : QuicConnection(guid, address, helper, false) { | 49 : QuicConnection(guid, address, helper, false, QuicVersionMax()) { |
50 } | 50 } |
51 | 51 |
52 void SetSendAlgorithm(SendAlgorithmInterface* send_algorithm) { | 52 void SetSendAlgorithm(SendAlgorithmInterface* send_algorithm) { |
53 QuicConnectionPeer::SetSendAlgorithm(this, send_algorithm); | 53 QuicConnectionPeer::SetSendAlgorithm(this, send_algorithm); |
54 } | 54 } |
55 | 55 |
56 void SetReceiveAlgorithm(ReceiveAlgorithmInterface* receive_algorithm) { | 56 void SetReceiveAlgorithm(ReceiveAlgorithmInterface* receive_algorithm) { |
57 QuicConnectionPeer::SetReceiveAlgorithm(this, receive_algorithm); | 57 QuicConnectionPeer::SetReceiveAlgorithm(this, receive_algorithm); |
58 } | 58 } |
59 }; | 59 }; |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
111 } | 111 } |
112 IoMode mode; | 112 IoMode mode; |
113 QuicEncryptedPacket* packet; | 113 QuicEncryptedPacket* packet; |
114 }; | 114 }; |
115 | 115 |
116 QuicHttpStreamTest() | 116 QuicHttpStreamTest() |
117 : net_log_(BoundNetLog()), | 117 : net_log_(BoundNetLog()), |
118 use_closing_stream_(false), | 118 use_closing_stream_(false), |
119 read_buffer_(new IOBufferWithSize(4096)), | 119 read_buffer_(new IOBufferWithSize(4096)), |
120 guid_(2), | 120 guid_(2), |
121 framer_(kQuicVersion1, QuicTime::Zero(), false), | 121 framer_(QuicVersionMax(), QuicTime::Zero(), false), |
122 creator_(guid_, &framer_, &random_, false) { | 122 creator_(guid_, &framer_, &random_, false) { |
123 IPAddressNumber ip; | 123 IPAddressNumber ip; |
124 CHECK(ParseIPLiteralToNumber("192.0.2.33", &ip)); | 124 CHECK(ParseIPLiteralToNumber("192.0.2.33", &ip)); |
125 peer_addr_ = IPEndPoint(ip, 443); | 125 peer_addr_ = IPEndPoint(ip, 443); |
126 self_addr_ = IPEndPoint(ip, 8435); | 126 self_addr_ = IPEndPoint(ip, 8435); |
127 } | 127 } |
128 | 128 |
129 ~QuicHttpStreamTest() { | 129 ~QuicHttpStreamTest() { |
130 for (size_t i = 0; i < writes_.size(); i++) { | 130 for (size_t i = 0; i < writes_.size(); i++) { |
131 delete writes_[i].packet; | 131 delete writes_[i].packet; |
(...skipping 422 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
554 | 554 |
555 // In the course of processing this packet, the QuicHttpStream close itself. | 555 // In the course of processing this packet, the QuicHttpStream close itself. |
556 ProcessPacket(*resp); | 556 ProcessPacket(*resp); |
557 | 557 |
558 EXPECT_TRUE(AtEof()); | 558 EXPECT_TRUE(AtEof()); |
559 } | 559 } |
560 | 560 |
561 } // namespace test | 561 } // namespace test |
562 | 562 |
563 } // namespace net | 563 } // namespace net |
OLD | NEW |