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_stream_factory.h" | 5 #include "net/quic/quic_stream_factory.h" |
6 | 6 |
7 #include <set> | 7 #include <set> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
(...skipping 422 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
433 // requiring the application to refill this OS buffer (ensuring that we don't | 433 // requiring the application to refill this OS buffer (ensuring that we don't |
434 // blast a pile of packets at the kernel's max egress rate). | 434 // blast a pile of packets at the kernel's max egress rate). |
435 // socket->SetSendBufferSize(????); | 435 // socket->SetSendBufferSize(????); |
436 | 436 |
437 QuicConnectionHelper* helper = new QuicConnectionHelper( | 437 QuicConnectionHelper* helper = new QuicConnectionHelper( |
438 base::MessageLoop::current()->message_loop_proxy().get(), | 438 base::MessageLoop::current()->message_loop_proxy().get(), |
439 clock_.get(), | 439 clock_.get(), |
440 random_generator_, | 440 random_generator_, |
441 socket); | 441 socket); |
442 | 442 |
443 QuicConnection* connection = new QuicConnection(guid, addr, helper, false); | 443 QuicConnection* connection = new QuicConnection(guid, addr, helper, false, |
| 444 QuicVersionMax()); |
444 | 445 |
445 QuicCryptoClientConfig* crypto_config = | 446 QuicCryptoClientConfig* crypto_config = |
446 GetOrCreateCryptoConfig(host_port_proxy_pair); | 447 GetOrCreateCryptoConfig(host_port_proxy_pair); |
447 DCHECK(crypto_config); | 448 DCHECK(crypto_config); |
448 | 449 |
449 QuicClientSession* session = | 450 QuicClientSession* session = |
450 new QuicClientSession(connection, socket, this, | 451 new QuicClientSession(connection, socket, this, |
451 quic_crypto_client_stream_factory_, | 452 quic_crypto_client_stream_factory_, |
452 host_port_proxy_pair.first.host(), config_, | 453 host_port_proxy_pair.first.host(), config_, |
453 crypto_config, net_log.net_log()); | 454 crypto_config, net_log.net_log()); |
(...skipping 26 matching lines...) Expand all Loading... |
480 DCHECK(crypto_config); | 481 DCHECK(crypto_config); |
481 } else { | 482 } else { |
482 crypto_config = new QuicCryptoClientConfig(); | 483 crypto_config = new QuicCryptoClientConfig(); |
483 crypto_config->SetDefaults(); | 484 crypto_config->SetDefaults(); |
484 all_crypto_configs_[host_port_proxy_pair] = crypto_config; | 485 all_crypto_configs_[host_port_proxy_pair] = crypto_config; |
485 } | 486 } |
486 return crypto_config; | 487 return crypto_config; |
487 } | 488 } |
488 | 489 |
489 } // namespace net | 490 } // namespace net |
OLD | NEW |