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

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

Issue 734063004: Update from https://crrev.com/304418 (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Created 6 years, 1 month 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
« no previous file with comments | « net/quic/quic_framer.cc ('k') | net/quic/quic_packet_creator.h » ('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/chunked_upload_data_stream.h" 9 #include "net/base/chunked_upload_data_stream.h"
10 #include "net/base/elements_upload_data_stream.h" 10 #include "net/base/elements_upload_data_stream.h"
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after
58 public: 58 public:
59 TestQuicConnection(const QuicVersionVector& versions, 59 TestQuicConnection(const QuicVersionVector& versions,
60 QuicConnectionId connection_id, 60 QuicConnectionId connection_id,
61 IPEndPoint address, 61 IPEndPoint address,
62 QuicConnectionHelper* helper, 62 QuicConnectionHelper* helper,
63 const QuicConnection::PacketWriterFactory& writer_factory) 63 const QuicConnection::PacketWriterFactory& writer_factory)
64 : QuicConnection(connection_id, 64 : QuicConnection(connection_id,
65 address, 65 address,
66 helper, 66 helper,
67 writer_factory, 67 writer_factory,
68 true /* owns_writer */, 68 true /* owns_writer */,
69 false /* is_server */, 69 false /* is_server */,
70 false /* is_secure */,
70 versions) { 71 versions) {
71 } 72 }
72 73
73 void SetSendAlgorithm(SendAlgorithmInterface* send_algorithm) { 74 void SetSendAlgorithm(SendAlgorithmInterface* send_algorithm) {
74 QuicConnectionPeer::SetSendAlgorithm(this, send_algorithm); 75 QuicConnectionPeer::SetSendAlgorithm(this, send_algorithm);
75 } 76 }
76 77
77 void SetReceiveAlgorithm(ReceiveAlgorithmInterface* receive_algorithm) { 78 void SetReceiveAlgorithm(ReceiveAlgorithmInterface* receive_algorithm) {
78 QuicConnectionPeer::SetReceiveAlgorithm(this, receive_algorithm); 79 QuicConnectionPeer::SetReceiveAlgorithm(this, receive_algorithm);
79 } 80 }
(...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after
208 EXPECT_CALL(*send_algorithm_, 209 EXPECT_CALL(*send_algorithm_,
209 OnPacketSent(_, _, _, _, _)).WillRepeatedly(Return(true)); 210 OnPacketSent(_, _, _, _, _)).WillRepeatedly(Return(true));
210 EXPECT_CALL(*send_algorithm_, RetransmissionDelay()).WillRepeatedly( 211 EXPECT_CALL(*send_algorithm_, RetransmissionDelay()).WillRepeatedly(
211 Return(QuicTime::Delta::Zero())); 212 Return(QuicTime::Delta::Zero()));
212 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()).WillRepeatedly( 213 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()).WillRepeatedly(
213 Return(kMaxPacketSize)); 214 Return(kMaxPacketSize));
214 EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _, _)). 215 EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _, _)).
215 WillRepeatedly(Return(QuicTime::Delta::Zero())); 216 WillRepeatedly(Return(QuicTime::Delta::Zero()));
216 EXPECT_CALL(*send_algorithm_, BandwidthEstimate()).WillRepeatedly( 217 EXPECT_CALL(*send_algorithm_, BandwidthEstimate()).WillRepeatedly(
217 Return(QuicBandwidth::Zero())); 218 Return(QuicBandwidth::Zero()));
218 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)).Times(AnyNumber()); 219 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _, _)).Times(AnyNumber());
219 helper_.reset(new QuicConnectionHelper(runner_.get(), &clock_, 220 helper_.reset(new QuicConnectionHelper(runner_.get(), &clock_,
220 &random_generator_)); 221 &random_generator_));
221 TestPacketWriterFactory writer_factory(socket); 222 TestPacketWriterFactory writer_factory(socket);
222 connection_ = new TestQuicConnection(SupportedVersions(GetParam()), 223 connection_ = new TestQuicConnection(SupportedVersions(GetParam()),
223 connection_id_, peer_addr_, 224 connection_id_, peer_addr_,
224 helper_.get(), writer_factory); 225 helper_.get(), writer_factory);
225 connection_->set_visitor(&visitor_); 226 connection_->set_visitor(&visitor_);
226 connection_->SetSendAlgorithm(send_algorithm_); 227 connection_->SetSendAlgorithm(send_algorithm_);
227 connection_->SetReceiveAlgorithm(receive_algorithm_); 228 connection_->SetReceiveAlgorithm(receive_algorithm_);
228 session_.reset( 229 session_.reset(
229 new QuicClientSession(connection_, 230 new QuicClientSession(connection_,
230 scoped_ptr<DatagramClientSocket>(socket), 231 scoped_ptr<DatagramClientSocket>(socket),
231 nullptr, 232 nullptr,
232 &transport_security_state_, 233 &transport_security_state_,
233 make_scoped_ptr((QuicServerInfo*)nullptr), 234 make_scoped_ptr((QuicServerInfo*)nullptr),
234 DefaultQuicConfig(), 235 DefaultQuicConfig(),
235 /*is_secure=*/false,
236 base::MessageLoop::current()-> 236 base::MessageLoop::current()->
237 message_loop_proxy().get(), 237 message_loop_proxy().get(),
238 nullptr)); 238 nullptr));
239 session_->InitializeSession(QuicServerId(kServerHostname, kServerPort, 239 session_->InitializeSession(QuicServerId(kServerHostname, kServerPort,
240 /*is_secure=*/false, 240 /*is_secure=*/false,
241 PRIVACY_MODE_DISABLED), 241 PRIVACY_MODE_DISABLED),
242 &crypto_config_, 242 &crypto_config_,
243 &crypto_client_stream_factory_); 243 &crypto_client_stream_factory_);
244 session_->GetCryptoStream()->CryptoConnect(); 244 session_->GetCryptoStream()->CryptoConnect();
245 EXPECT_TRUE(session_->IsCryptoHandshakeConfirmed()); 245 EXPECT_TRUE(session_->IsCryptoHandshakeConfirmed());
(...skipping 528 matching lines...) Expand 10 before | Expand all | Expand 10 after
774 // Set Delegate to nullptr and make sure EffectivePriority returns highest 774 // Set Delegate to nullptr and make sure EffectivePriority returns highest
775 // priority. 775 // priority.
776 reliable_stream->SetDelegate(nullptr); 776 reliable_stream->SetDelegate(nullptr);
777 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, 777 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority,
778 reliable_stream->EffectivePriority()); 778 reliable_stream->EffectivePriority());
779 reliable_stream->SetDelegate(delegate); 779 reliable_stream->SetDelegate(delegate);
780 } 780 }
781 781
782 } // namespace test 782 } // namespace test
783 } // namespace net 783 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/quic_framer.cc ('k') | net/quic/quic_packet_creator.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698