Add chrome to the repository.

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@15 0039d316-1c4b-4281-b951-d872f2087c98

1 files changed, 107 insertions, 0 deletions

diff --git a/chrome/browser/suspend_controller.cc b/chrome/browser/suspend_controller.cc
new file mode 100644
index 0000000..3abcba3
--- /dev/null
+++ b/chrome/browser/suspend_controller.cc
@@ -0,0 +1,107 @@
+// Copyright 2008, Google Inc.
+// All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are
+// met:
+//
+//    * Redistributions of source code must retain the above copyright
+// notice, this list of conditions and the following disclaimer.
+//    * Redistributions in binary form must reproduce the above
+// copyright notice, this list of conditions and the following disclaimer
+// in the documentation and/or other materials provided with the
+// distribution.
+//    * Neither the name of Google Inc. nor the names of its
+// contributors may be used to endorse or promote products derived from
+// this software without specific prior written permission.
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+#include "chrome/browser/suspend_controller.h"
+
+#include "base/logging.h"
+#include "base/message_loop.h"
+#include "base/task.h"
+#include "base/thread.h"
+#include "chrome/browser/browser_process.h"
+#include "chrome/browser/profile.h"
+#include "chrome/browser/resource_dispatcher_host.h"
+#include "chrome/browser/safe_browsing/safe_browsing_service.h"
+#include "net/url_request/url_request_job.h"
+#include "net/url_request/url_request_job_tracker.h"
+
+// Static member.
+bool SuspendController::is_suspended_ = false;
+
+// Static method.
+void SuspendController::OnSuspend(Profile* profile) {
+  if (is_suspended_)
+    return;
+  is_suspended_ = true;
+
+  LOG(INFO) << "Received APM suspend message";
+
+  SuspendController* controller = g_browser_process->suspend_controller();
+
+  MessageLoop* io_loop = g_browser_process->io_thread()->message_loop();
+  io_loop->PostTask(FROM_HERE,
+      NewRunnableMethod(controller,
+                        &SuspendController::StopRequests,
+                        profile));
+
+  ResourceDispatcherHost* rdh = g_browser_process->resource_dispatcher_host();
+  SafeBrowsingService* safe_browsing_service = rdh->safe_browsing_service();
+  io_loop->PostTask(FROM_HERE,
+      NewRunnableMethod(safe_browsing_service,
+                        &SafeBrowsingService::OnSuspend));
+}
+
+// Static method.
+void SuspendController::OnResume(Profile* profile) {
+  if (!is_suspended_)
+    return;
+  is_suspended_ = false;
+
+  LOG(INFO) << "Received APM resume message";
+
+  SuspendController* controller = g_browser_process->suspend_controller();
+
+  MessageLoop* io_loop = g_browser_process->io_thread()->message_loop();
+  io_loop->PostTask(FROM_HERE,
+      NewRunnableMethod(controller,
+                        &SuspendController::AllowNewRequests,
+                        profile));
+
+  ResourceDispatcherHost* rdh = g_browser_process->resource_dispatcher_host();
+  SafeBrowsingService* safe_browsing_service = rdh->safe_browsing_service();
+  io_loop->PostTask(FROM_HERE,
+      NewRunnableMethod(safe_browsing_service,
+                        &SafeBrowsingService::OnResume));
+}
+
+void SuspendController::StopRequests(Profile* profile) {
+  // Cancel all requests and stop creating new ones.
+  URLRequestJobTracker::JobIterator it = g_url_request_job_tracker.begin();
+  for (;it != g_url_request_job_tracker.end(); ++it) {
+    URLRequestJob* job = const_cast<URLRequestJob*>(*it);
+    job->Kill();
+  }
+
+  // Close the network session.
+  profile->GetRequestContext()->http_transaction_factory()->Suspend(true);
+}
+
+void SuspendController::AllowNewRequests(Profile* profile) {
+  // Re-enable the network session.
+  profile->GetRequestContext()->http_transaction_factory()->Suspend(false);
+}