Upstreaming RegisterProcessUtils()

chrome/browser/android/process_utils.cc

 // Copyright (c) 2012 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/android/process_utils.h"
 
 #include <vector>
 
 #include "base/lazy_instance.h"
 #include "base/logging.h"
+#include "chrome/browser/browser_process.h"
+#include "chrome/browser/profiles/profile.h"
+#include "chrome/browser/profiles/profile_manager.h"
 #include "chrome/common/render_messages.h"
+#include "content/public/browser/browser_thread.h"
 #include "content/public/browser/render_process_host.h"
 #include "jni/ProcessUtils_jni.h"
+#include "net/http/http_network_session.h"
+#include "net/http/http_transaction_factory.h"
+#include "net/url_request/url_request_context.h"
+#include "net/url_request/url_request_context_getter.h"
 
 namespace {
 
+void CloseIdleConnectionsForProfile(

[Yaron, 2012/07/24 17:15:47]

Not familiar with this. Adding Satish

+    scoped_refptr<net::URLRequestContextGetter> context_getter) {
+  DCHECK(context_getter.get());
+  if (!content::BrowserThread::CurrentlyOn(content::BrowserThread::IO)) {
+    content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE,
+                           base::Bind(&CloseIdleConnectionsForProfile,
+                                      context_getter));
+    return;
+  }
+
+  net::URLRequestContext* context = context_getter->GetURLRequestContext();
+  DCHECK(context->http_transaction_factory());
+  // TODO(satish): Remove this early return after verifying the above doesn't
+  // fail.
+  if (!context->http_transaction_factory())
+    return;
+  net::HttpNetworkSession* session =
+      context->http_transaction_factory()->GetSession();
+  DCHECK(session);
+  // TODO(satish): Remove this check after verifying the above doesn't fail.
+  if (session)
+    session->CloseIdleConnections();
+}
+
 // Only accessed from the JNI thread by ToggleWebKitSharedTimers() which is
 // implemented below.
 base::LazyInstance<std::vector<int /* process id */> > g_suspended_processes =
     LAZY_INSTANCE_INITIALIZER;
 
 // Suspends timers in all current render processes.
 void SuspendWebKitSharedTimers(std::vector<int>* suspended_processes) {
   for (content::RenderProcessHost::iterator i(
           content::RenderProcessHost::AllHostsIterator());
        !i.IsAtEnd(); i.Advance()) {
@@ skipping 20 matching lines @@
   std::vector<int>* suspended_processes = &g_suspended_processes.Get();
   if (suspend) {
     DCHECK(suspended_processes->empty());
     SuspendWebKitSharedTimers(suspended_processes);
   } else {
     ResumeWebkitSharedTimers(*suspended_processes);
     suspended_processes->clear();
   }
 }
 
 // TODO(pliard): http://crbug.com/137674

[Yaron, 2012/07/24 17:15:47]

Remove TODO

[aurimas (slooooooooow), 2012/07/24 18:12:14]

Done.

 bool RegisterProcessUtils(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }