| Index: net/quic/quic_stream_factory.cc
|
| diff --git a/net/quic/quic_stream_factory.cc b/net/quic/quic_stream_factory.cc
|
| index a82a840b135cbe85d218330516fd7a0194baaa1e..cb488a9b05781f2950c041232c66987f4d60b6a1 100644
|
| --- a/net/quic/quic_stream_factory.cc
|
| +++ b/net/quic/quic_stream_factory.cc
|
| @@ -8,7 +8,6 @@
|
|
|
| #include "base/cpu.h"
|
| #include "base/message_loop/message_loop.h"
|
| -#include "base/message_loop/message_loop_proxy.h"
|
| #include "base/metrics/field_trial.h"
|
| #include "base/metrics/histogram.h"
|
| #include "base/metrics/sparse_histogram.h"
|
| @@ -644,7 +643,7 @@ int QuicStreamFactory::Create(const HostPortPair& host_port_pair,
|
| // TODO(rtenneti): |task_runner_| is used by the Job. Initialize task_runner_
|
| // in the constructor after WebRequestActionWithThreadsTest.* tests are fixed.
|
| if (!task_runner_)
|
| - task_runner_ = base::MessageLoop::current()->message_loop_proxy().get();
|
| + task_runner_ = base::MessageLoop::current()->task_runner().get();
|
|
|
| QuicServerInfo* quic_server_info = nullptr;
|
| if (quic_server_info_factory_) {
|
| @@ -1044,8 +1043,8 @@ int QuicStreamFactory::CreateSession(const QuicServerId& server_id,
|
|
|
| if (!helper_.get()) {
|
| helper_.reset(new QuicConnectionHelper(
|
| - base::MessageLoop::current()->message_loop_proxy().get(),
|
| - clock_.get(), random_generator_));
|
| + base::MessageLoop::current()->task_runner().get(), clock_.get(),
|
| + random_generator_));
|
| }
|
|
|
| QuicConnection* connection = new QuicConnection(
|
| @@ -1078,8 +1077,7 @@ int QuicStreamFactory::CreateSession(const QuicServerId& server_id,
|
| connection, socket.Pass(), this, transport_security_state_,
|
| server_info.Pass(), config, network_connection_.GetDescription(),
|
| dns_resolution_end_time,
|
| - base::MessageLoop::current()->message_loop_proxy().get(),
|
| - net_log.net_log());
|
| + base::MessageLoop::current()->task_runner().get(), net_log.net_log());
|
|
|
| all_sessions_[*session] = server_id; // owning pointer
|
|
|
|
|