Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(18)

Side by Side Diff: net/quic/quic_http_stream_test.cc

Issue 15937012: Land Recent QUIC changes. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Small bug fixes Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698