| 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 |