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 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
47 namespace { | 47 namespace { |
48 | 48 |
49 const char kUploadData[] = "hello world!"; | 49 const char kUploadData[] = "hello world!"; |
50 | 50 |
51 class TestQuicConnection : public QuicConnection { | 51 class TestQuicConnection : public QuicConnection { |
52 public: | 52 public: |
53 TestQuicConnection(QuicGuid guid, | 53 TestQuicConnection(QuicGuid guid, |
54 IPEndPoint address, | 54 IPEndPoint address, |
55 QuicConnectionHelper* helper, | 55 QuicConnectionHelper* helper, |
56 QuicPacketWriter* writer) | 56 QuicPacketWriter* writer) |
57 : QuicConnection(guid, address, helper, writer, false, QuicVersionMax()) { | 57 : QuicConnection(guid, address, helper, writer, false, |
| 58 QuicSupportedVersions()) { |
58 } | 59 } |
59 | 60 |
60 void SetSendAlgorithm(SendAlgorithmInterface* send_algorithm) { | 61 void SetSendAlgorithm(SendAlgorithmInterface* send_algorithm) { |
61 QuicConnectionPeer::SetSendAlgorithm(this, send_algorithm); | 62 QuicConnectionPeer::SetSendAlgorithm(this, send_algorithm); |
62 } | 63 } |
63 | 64 |
64 void SetReceiveAlgorithm(ReceiveAlgorithmInterface* receive_algorithm) { | 65 void SetReceiveAlgorithm(ReceiveAlgorithmInterface* receive_algorithm) { |
65 QuicConnectionPeer::SetReceiveAlgorithm(this, receive_algorithm); | 66 QuicConnectionPeer::SetReceiveAlgorithm(this, receive_algorithm); |
66 } | 67 } |
67 }; | 68 }; |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
127 } | 128 } |
128 IoMode mode; | 129 IoMode mode; |
129 QuicEncryptedPacket* packet; | 130 QuicEncryptedPacket* packet; |
130 }; | 131 }; |
131 | 132 |
132 QuicHttpStreamTest() | 133 QuicHttpStreamTest() |
133 : net_log_(BoundNetLog()), | 134 : net_log_(BoundNetLog()), |
134 use_closing_stream_(false), | 135 use_closing_stream_(false), |
135 read_buffer_(new IOBufferWithSize(4096)), | 136 read_buffer_(new IOBufferWithSize(4096)), |
136 guid_(2), | 137 guid_(2), |
137 framer_(QuicVersionMax(), QuicTime::Zero(), false), | 138 framer_(QuicSupportedVersions(), QuicTime::Zero(), false), |
138 creator_(guid_, &framer_, &random_, false) { | 139 creator_(guid_, &framer_, &random_, false) { |
139 IPAddressNumber ip; | 140 IPAddressNumber ip; |
140 CHECK(ParseIPLiteralToNumber("192.0.2.33", &ip)); | 141 CHECK(ParseIPLiteralToNumber("192.0.2.33", &ip)); |
141 peer_addr_ = IPEndPoint(ip, 443); | 142 peer_addr_ = IPEndPoint(ip, 443); |
142 self_addr_ = IPEndPoint(ip, 8435); | 143 self_addr_ = IPEndPoint(ip, 8435); |
143 } | 144 } |
144 | 145 |
145 ~QuicHttpStreamTest() { | 146 ~QuicHttpStreamTest() { |
146 session_->CloseSessionOnError(ERR_ABORTED); | 147 session_->CloseSessionOnError(ERR_ABORTED); |
147 for (size_t i = 0; i < writes_.size(); i++) { | 148 for (size_t i = 0; i < writes_.size(); i++) { |
(...skipping 575 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
723 // priority. | 724 // priority. |
724 reliable_stream->SetDelegate(NULL); | 725 reliable_stream->SetDelegate(NULL); |
725 DCHECK_EQ(static_cast<QuicPriority>(kHighestPriority), | 726 DCHECK_EQ(static_cast<QuicPriority>(kHighestPriority), |
726 reliable_stream->EffectivePriority()); | 727 reliable_stream->EffectivePriority()); |
727 reliable_stream->SetDelegate(delegate); | 728 reliable_stream->SetDelegate(delegate); |
728 } | 729 } |
729 | 730 |
730 } // namespace test | 731 } // namespace test |
731 | 732 |
732 } // namespace net | 733 } // namespace net |
OLD | NEW |