| 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 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 172 WillRepeatedly(testing::Return(QuicTime::Delta::Zero())); | 172 WillRepeatedly(testing::Return(QuicTime::Delta::Zero())); |
| 173 helper_ = new QuicConnectionHelper(runner_.get(), &clock_, | 173 helper_ = new QuicConnectionHelper(runner_.get(), &clock_, |
| 174 &random_generator_, socket); | 174 &random_generator_, socket); |
| 175 connection_ = new TestQuicConnection(guid_, peer_addr_, helper_); | 175 connection_ = new TestQuicConnection(guid_, peer_addr_, helper_); |
| 176 connection_->set_visitor(&visitor_); | 176 connection_->set_visitor(&visitor_); |
| 177 connection_->SetSendAlgorithm(send_algorithm_); | 177 connection_->SetSendAlgorithm(send_algorithm_); |
| 178 connection_->SetReceiveAlgorithm(receive_algorithm_); | 178 connection_->SetReceiveAlgorithm(receive_algorithm_); |
| 179 crypto_config_.SetDefaults(); | 179 crypto_config_.SetDefaults(); |
| 180 session_.reset(new QuicClientSession(connection_, socket, NULL, | 180 session_.reset(new QuicClientSession(connection_, socket, NULL, |
| 181 &crypto_client_stream_factory_, | 181 &crypto_client_stream_factory_, |
| 182 "www.google.com", QuicConfig(), | 182 "www.google.com", DefaultQuicConfig(), |
| 183 &crypto_config_, NULL)); | 183 &crypto_config_, NULL)); |
| 184 session_->config()->SetDefaults(); | |
| 185 session_->GetCryptoStream()->CryptoConnect(); | 184 session_->GetCryptoStream()->CryptoConnect(); |
| 186 EXPECT_TRUE(session_->IsCryptoHandshakeConfirmed()); | 185 EXPECT_TRUE(session_->IsCryptoHandshakeConfirmed()); |
| 187 QuicReliableClientStream* stream = | 186 QuicReliableClientStream* stream = |
| 188 session_->CreateOutgoingReliableStream(); | 187 session_->CreateOutgoingReliableStream(); |
| 189 stream_.reset(use_closing_stream_ ? | 188 stream_.reset(use_closing_stream_ ? |
| 190 new AutoClosingStream(stream) : | 189 new AutoClosingStream(stream) : |
| 191 new QuicHttpStream(stream)); | 190 new QuicHttpStream(stream)); |
| 192 } | 191 } |
| 193 | 192 |
| 194 void SetRequestString(const std::string& method, const std::string& path) { | 193 void SetRequestString(const std::string& method, const std::string& path) { |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 273 std::string response_data_; | 272 std::string response_data_; |
| 274 | 273 |
| 275 private: | 274 private: |
| 276 void InitializeHeader(QuicPacketSequenceNumber sequence_number, | 275 void InitializeHeader(QuicPacketSequenceNumber sequence_number, |
| 277 bool should_include_version) { | 276 bool should_include_version) { |
| 278 header_.public_header.guid = guid_; | 277 header_.public_header.guid = guid_; |
| 279 header_.public_header.reset_flag = false; | 278 header_.public_header.reset_flag = false; |
| 280 header_.public_header.version_flag = should_include_version; | 279 header_.public_header.version_flag = should_include_version; |
| 281 header_.packet_sequence_number = sequence_number; | 280 header_.packet_sequence_number = sequence_number; |
| 282 header_.fec_group = 0; | 281 header_.fec_group = 0; |
| 283 header_.fec_entropy_flag = false; | |
| 284 header_.entropy_flag = false; | 282 header_.entropy_flag = false; |
| 285 header_.fec_flag = false; | 283 header_.fec_flag = false; |
| 286 } | 284 } |
| 287 | 285 |
| 288 QuicEncryptedPacket* ConstructPacket(const QuicPacketHeader& header, | 286 QuicEncryptedPacket* ConstructPacket(const QuicPacketHeader& header, |
| 289 const QuicFrame& frame) { | 287 const QuicFrame& frame) { |
| 290 QuicFrames frames; | 288 QuicFrames frames; |
| 291 frames.push_back(frame); | 289 frames.push_back(frame); |
| 292 scoped_ptr<QuicPacket> packet( | 290 scoped_ptr<QuicPacket> packet( |
| 293 framer_.ConstructFrameDataPacket(header_, frames).packet); | 291 framer_.ConstructFrameDataPacket(header_, frames).packet); |
| (...skipping 263 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 557 | 555 |
| 558 // In the course of processing this packet, the QuicHttpStream close itself. | 556 // In the course of processing this packet, the QuicHttpStream close itself. |
| 559 ProcessPacket(*resp); | 557 ProcessPacket(*resp); |
| 560 | 558 |
| 561 EXPECT_TRUE(AtEof()); | 559 EXPECT_TRUE(AtEof()); |
| 562 } | 560 } |
| 563 | 561 |
| 564 } // namespace test | 562 } // namespace test |
| 565 | 563 |
| 566 } // namespace net | 564 } // namespace net |
| OLD | NEW |