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/message_loop.h" | 9 #include "base/message_loop.h" |
10 #include "base/message_loop/message_loop_proxy.h" | 10 #include "base/message_loop/message_loop_proxy.h" |
(...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
370 const BoundNetLog& net_log) { | 370 const BoundNetLog& net_log) { |
371 QuicGuid guid = random_generator_->RandUint64(); | 371 QuicGuid guid = random_generator_->RandUint64(); |
372 IPEndPoint addr = *address_list.begin(); | 372 IPEndPoint addr = *address_list.begin(); |
373 DatagramClientSocket* socket = | 373 DatagramClientSocket* socket = |
374 client_socket_factory_->CreateDatagramClientSocket( | 374 client_socket_factory_->CreateDatagramClientSocket( |
375 DatagramSocket::DEFAULT_BIND, base::Bind(&base::RandInt), | 375 DatagramSocket::DEFAULT_BIND, base::Bind(&base::RandInt), |
376 net_log.net_log(), net_log.source()); | 376 net_log.net_log(), net_log.source()); |
377 socket->Connect(addr); | 377 socket->Connect(addr); |
378 | 378 |
379 QuicConnectionHelper* helper = new QuicConnectionHelper( | 379 QuicConnectionHelper* helper = new QuicConnectionHelper( |
380 base::MessageLoop::current()->message_loop_proxy(), | 380 base::MessageLoop::current()->message_loop_proxy().get(), |
381 clock_.get(), random_generator_, socket); | 381 clock_.get(), |
| 382 random_generator_, |
| 383 socket); |
382 | 384 |
383 QuicConnection* connection = new QuicConnection(guid, addr, helper, false); | 385 QuicConnection* connection = new QuicConnection(guid, addr, helper, false); |
384 | 386 |
385 QuicCryptoClientConfig* crypto_config = | 387 QuicCryptoClientConfig* crypto_config = |
386 GetOrCreateCryptoConfig(host_port_proxy_pair); | 388 GetOrCreateCryptoConfig(host_port_proxy_pair); |
387 DCHECK(crypto_config); | 389 DCHECK(crypto_config); |
388 | 390 |
389 QuicClientSession* session = | 391 QuicClientSession* session = |
390 new QuicClientSession(connection, socket, this, | 392 new QuicClientSession(connection, socket, this, |
391 quic_crypto_client_stream_factory_, | 393 quic_crypto_client_stream_factory_, |
(...skipping 24 matching lines...) Expand all Loading... |
416 DCHECK(crypto_config); | 418 DCHECK(crypto_config); |
417 } else { | 419 } else { |
418 crypto_config = new QuicCryptoClientConfig(); | 420 crypto_config = new QuicCryptoClientConfig(); |
419 crypto_config->SetDefaults(); | 421 crypto_config->SetDefaults(); |
420 all_crypto_configs_[host_port_proxy_pair] = crypto_config; | 422 all_crypto_configs_[host_port_proxy_pair] = crypto_config; |
421 } | 423 } |
422 return crypto_config; | 424 return crypto_config; |
423 } | 425 } |
424 | 426 |
425 } // namespace net | 427 } // namespace net |
OLD | NEW |