Use shared shared URLRequestContextGetter for all gcd_private sessions

chrome/browser/extensions/api/gcd_private/gcd_private_api.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/extensions/api/gcd_private/gcd_private_api.h"
 
 #include "base/command_line.h"
 #include "base/lazy_instance.h"
 #include "base/memory/linked_ptr.h"
 #include "base/thread_task_runner_handle.h"
+#include "chrome/browser/extensions/api/gcd_private/privet_v3_context_getter.h"
 #include "chrome/browser/extensions/api/gcd_private/privet_v3_session.h"
 #include "chrome/browser/local_discovery/endpoint_resolver.h"
 #include "chrome/browser/local_discovery/service_discovery_shared_client.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/common/chrome_switches.h"
 #include "content/public/browser/browser_context.h"
 #include "net/url_request/url_request_context_getter.h"
 
 namespace extensions {
 
@@ skipping 73 matching lines @@
   struct SessionInfo {
     linked_ptr<PrivetV3Session> session;
     linked_ptr<local_discovery::EndpointResolver> resolver;
   };
 
   std::map<int, SessionInfo> sessions_;
   int last_session_id_ = 0;
 
   content::BrowserContext* const browser_context_;
 
+  scoped_refptr<PrivetV3ContextGetter> context_getter_;
+
   base::WeakPtrFactory<GcdPrivateAPIImpl> weak_ptr_factory_{this};
 
   DISALLOW_COPY_AND_ASSIGN(GcdPrivateAPIImpl);
 };
 
-
 GcdPrivateAPIImpl::GcdPrivateAPIImpl(content::BrowserContext* context)
     : browser_context_(context) {
   DCHECK(browser_context_);
 }
 
 GcdPrivateAPIImpl::~GcdPrivateAPIImpl() {
 }
 
 // static
 GcdPrivateAPIImpl* GcdPrivateAPIImpl::Get(content::BrowserContext* context) {
@@ skipping 18 matching lines @@
 }
 
 void GcdPrivateAPIImpl::OnServiceResolved(int session_id,
                                           const CreateSessionCallback& callback,
                                           const net::IPEndPoint& endpoint) {
   if (endpoint.address().empty()) {
     return callback.Run(session_id, gcd_private::STATUS_SERVICERESOLUTIONERROR,
                         base::DictionaryValue());
   }
   auto& session_data = sessions_[session_id];
-  session_data.session.reset(
-      new PrivetV3Session(browser_context_->GetRequestContext(),
-                          net::HostPortPair::FromIPEndPoint(endpoint)));
+
+  if (!context_getter_) {
+    context_getter_ = new PrivetV3ContextGetter(
+        browser_context_->GetRequestContext()->GetNetworkTaskRunner());
+  }
+
+  session_data.session.reset(new PrivetV3Session(
+      context_getter_, net::HostPortPair::FromIPEndPoint(endpoint)));
   session_data.session->Init(base::Bind(callback, session_id));
 }
 
 void GcdPrivateAPIImpl::StartPairing(int session_id,
                                      api::gcd_private::PairingType pairing_type,
                                      const SessionCallback& callback) {
   auto found = sessions_.find(session_id);
 
   if (found == sessions_.end())
     return callback.Run(gcd_private::STATUS_UNKNOWNSESSIONERROR);
@@ skipping 273 matching lines @@
 
   GcdPrivateAPIImpl* gcd_api = GcdPrivateAPIImpl::Get(GetProfile());
 
   gcd_api->RemoveSession(params->session_id);
 
   SendResponse(true);
   return true;
 }
 
 }  // namespace extensions