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

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

Issue 103973007: Land Recent QUIC Changes. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix for android compile error Created 7 years 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
« no previous file with comments | « net/quic/quic_framer.cc ('k') | net/quic/quic_network_transaction_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 118 matching lines...) Expand 10 before | Expand all | Expand 10 after
129 IoMode mode; 129 IoMode mode;
130 QuicEncryptedPacket* packet; 130 QuicEncryptedPacket* packet;
131 }; 131 };
132 132
133 QuicHttpStreamTest() 133 QuicHttpStreamTest()
134 : net_log_(BoundNetLog()), 134 : net_log_(BoundNetLog()),
135 use_closing_stream_(false), 135 use_closing_stream_(false),
136 read_buffer_(new IOBufferWithSize(4096)), 136 read_buffer_(new IOBufferWithSize(4096)),
137 guid_(2), 137 guid_(2),
138 framer_(QuicSupportedVersions(), QuicTime::Zero(), false), 138 framer_(QuicSupportedVersions(), QuicTime::Zero(), false),
139 creator_(guid_, &framer_, &random_, false) { 139 random_generator_(0),
140 creator_(guid_, &framer_, &random_generator_, false) {
140 IPAddressNumber ip; 141 IPAddressNumber ip;
141 CHECK(ParseIPLiteralToNumber("192.0.2.33", &ip)); 142 CHECK(ParseIPLiteralToNumber("192.0.2.33", &ip));
142 peer_addr_ = IPEndPoint(ip, 443); 143 peer_addr_ = IPEndPoint(ip, 443);
143 self_addr_ = IPEndPoint(ip, 8435); 144 self_addr_ = IPEndPoint(ip, 8435);
144 } 145 }
145 146
146 ~QuicHttpStreamTest() { 147 ~QuicHttpStreamTest() {
147 session_->CloseSessionOnError(ERR_ABORTED); 148 session_->CloseSessionOnError(ERR_ABORTED);
148 for (size_t i = 0; i < writes_.size(); i++) { 149 for (size_t i = 0; i < writes_.size(); i++) {
149 delete writes_[i].packet; 150 delete writes_[i].packet;
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after
298 return ConstructPacket(header_, QuicFrame(&rst)); 299 return ConstructPacket(header_, QuicFrame(&rst));
299 } 300 }
300 301
301 BoundNetLog net_log_; 302 BoundNetLog net_log_;
302 bool use_closing_stream_; 303 bool use_closing_stream_;
303 MockSendAlgorithm* send_algorithm_; 304 MockSendAlgorithm* send_algorithm_;
304 TestReceiveAlgorithm* receive_algorithm_; 305 TestReceiveAlgorithm* receive_algorithm_;
305 scoped_refptr<TestTaskRunner> runner_; 306 scoped_refptr<TestTaskRunner> runner_;
306 scoped_ptr<MockWrite[]> mock_writes_; 307 scoped_ptr<MockWrite[]> mock_writes_;
307 MockClock clock_; 308 MockClock clock_;
308 MockRandom random_generator_;
309 TestQuicConnection* connection_; 309 TestQuicConnection* connection_;
310 scoped_ptr<QuicConnectionHelper> helper_; 310 scoped_ptr<QuicConnectionHelper> helper_;
311 testing::StrictMock<MockConnectionVisitor> visitor_; 311 testing::StrictMock<MockConnectionVisitor> visitor_;
312 scoped_ptr<QuicHttpStream> stream_; 312 scoped_ptr<QuicHttpStream> stream_;
313 scoped_ptr<QuicDefaultPacketWriter> writer_; 313 scoped_ptr<QuicDefaultPacketWriter> writer_;
314 scoped_ptr<QuicClientSession> session_; 314 scoped_ptr<QuicClientSession> session_;
315 QuicCryptoClientConfig crypto_config_; 315 QuicCryptoClientConfig crypto_config_;
316 TestCompletionCallback callback_; 316 TestCompletionCallback callback_;
317 HttpRequestInfo request_; 317 HttpRequestInfo request_;
318 HttpRequestHeaders headers_; 318 HttpRequestHeaders headers_;
(...skipping 22 matching lines...) Expand all
341 scoped_ptr<QuicPacket> packet( 341 scoped_ptr<QuicPacket> packet(
342 framer_.BuildUnsizedDataPacket(header_, frames).packet); 342 framer_.BuildUnsizedDataPacket(header_, frames).packet);
343 return framer_.EncryptPacket( 343 return framer_.EncryptPacket(
344 ENCRYPTION_NONE, header.packet_sequence_number, *packet); 344 ENCRYPTION_NONE, header.packet_sequence_number, *packet);
345 } 345 }
346 346
347 const QuicGuid guid_; 347 const QuicGuid guid_;
348 QuicFramer framer_; 348 QuicFramer framer_;
349 IPEndPoint self_addr_; 349 IPEndPoint self_addr_;
350 IPEndPoint peer_addr_; 350 IPEndPoint peer_addr_;
351 MockRandom random_; 351 MockRandom random_generator_;
352 MockCryptoClientStreamFactory crypto_client_stream_factory_; 352 MockCryptoClientStreamFactory crypto_client_stream_factory_;
353 QuicPacketCreator creator_; 353 QuicPacketCreator creator_;
354 QuicPacketHeader header_; 354 QuicPacketHeader header_;
355 scoped_ptr<StaticSocketDataProvider> socket_data_; 355 scoped_ptr<StaticSocketDataProvider> socket_data_;
356 std::vector<PacketToWrite> writes_; 356 std::vector<PacketToWrite> writes_;
357 }; 357 };
358 358
359 TEST_F(QuicHttpStreamTest, RenewStreamForAuth) { 359 TEST_F(QuicHttpStreamTest, RenewStreamForAuth) {
360 Initialize(); 360 Initialize();
361 EXPECT_EQ(NULL, stream_->RenewStreamForAuth()); 361 EXPECT_EQ(NULL, stream_->RenewStreamForAuth());
(...skipping 394 matching lines...) Expand 10 before | Expand all | Expand 10 after
756 756
757 // Data should flush out now. 757 // Data should flush out now.
758 connection_->OnCanWrite(); 758 connection_->OnCanWrite();
759 EXPECT_FALSE(reliable_stream->HasBufferedData()); 759 EXPECT_FALSE(reliable_stream->HasBufferedData());
760 EXPECT_TRUE(AtEof()); 760 EXPECT_TRUE(AtEof());
761 } 761 }
762 762
763 } // namespace test 763 } // namespace test
764 764
765 } // namespace net 765 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/quic_framer.cc ('k') | net/quic/quic_network_transaction_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698