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/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 207 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
218 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)).Times(AnyNumber()); | 218 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)).Times(AnyNumber()); |
219 helper_.reset(new QuicConnectionHelper(runner_.get(), &clock_, | 219 helper_.reset(new QuicConnectionHelper(runner_.get(), &clock_, |
220 &random_generator_)); | 220 &random_generator_)); |
221 TestPacketWriterFactory writer_factory(socket); | 221 TestPacketWriterFactory writer_factory(socket); |
222 connection_ = new TestQuicConnection(SupportedVersions(GetParam()), | 222 connection_ = new TestQuicConnection(SupportedVersions(GetParam()), |
223 connection_id_, peer_addr_, | 223 connection_id_, peer_addr_, |
224 helper_.get(), writer_factory); | 224 helper_.get(), writer_factory); |
225 connection_->set_visitor(&visitor_); | 225 connection_->set_visitor(&visitor_); |
226 connection_->SetSendAlgorithm(send_algorithm_); | 226 connection_->SetSendAlgorithm(send_algorithm_); |
227 connection_->SetReceiveAlgorithm(receive_algorithm_); | 227 connection_->SetReceiveAlgorithm(receive_algorithm_); |
228 crypto_config_.SetDefaults(); | |
229 session_.reset( | 228 session_.reset( |
230 new QuicClientSession(connection_, | 229 new QuicClientSession(connection_, |
231 scoped_ptr<DatagramClientSocket>(socket), | 230 scoped_ptr<DatagramClientSocket>(socket), |
232 nullptr, | 231 nullptr, |
233 &transport_security_state_, | 232 &transport_security_state_, |
234 make_scoped_ptr((QuicServerInfo*)nullptr), | 233 make_scoped_ptr((QuicServerInfo*)nullptr), |
235 DefaultQuicConfig(), | 234 DefaultQuicConfig(), |
236 base::MessageLoop::current()-> | 235 base::MessageLoop::current()-> |
237 message_loop_proxy().get(), | 236 message_loop_proxy().get(), |
238 nullptr)); | 237 nullptr)); |
(...skipping 534 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
773 // Set Delegate to nullptr and make sure EffectivePriority returns highest | 772 // Set Delegate to nullptr and make sure EffectivePriority returns highest |
774 // priority. | 773 // priority. |
775 reliable_stream->SetDelegate(nullptr); | 774 reliable_stream->SetDelegate(nullptr); |
776 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, | 775 DCHECK_EQ(QuicWriteBlockedList::kHighestPriority, |
777 reliable_stream->EffectivePriority()); | 776 reliable_stream->EffectivePriority()); |
778 reliable_stream->SetDelegate(delegate); | 777 reliable_stream->SetDelegate(delegate); |
779 } | 778 } |
780 | 779 |
781 } // namespace test | 780 } // namespace test |
782 } // namespace net | 781 } // namespace net |
OLD | NEW |