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 |