Move more files from chrome/common to chrome/browser

to further reduce bad dependencies on chrome/browser.

BUG=none
TEST=none
Review URL: http://codereview.chromium.org/652051

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

1 files changed, 309 insertions, 0 deletions

diff --git a/chrome/browser/child_process_host.cc b/chrome/browser/child_process_host.cc
new file mode 100644
index 0000000..3aea690
--- /dev/null
+++ b/chrome/browser/child_process_host.cc
@@ -0,0 +1,309 @@
+// Copyright (c) 2009 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/child_process_host.h"
+
+#include "base/command_line.h"
+#include "base/compiler_specific.h"
+#include "base/file_path.h"
+#include "base/histogram.h"
+#include "base/logging.h"
+#include "base/path_service.h"
+#include "base/process_util.h"
+#include "base/singleton.h"
+#include "base/string_util.h"
+#include "base/waitable_event.h"
+#include "chrome/browser/chrome_thread.h"
+#include "chrome/common/chrome_constants.h"
+#include "chrome/common/chrome_paths_internal.h"
+#include "chrome/common/chrome_switches.h"
+#include "chrome/common/notification_service.h"
+#include "chrome/common/notification_type.h"
+#include "chrome/common/plugin_messages.h"
+#include "chrome/common/process_watcher.h"
+#include "chrome/common/result_codes.h"
+#include "chrome/installer/util/google_update_settings.h"
+
+#if defined(OS_LINUX)
+#include "base/linux_util.h"
+#endif  // OS_LINUX
+
+#if defined(OS_POSIX)
+// This is defined in chrome/browser/google_update_settings_posix.cc.  It's the
+// static string containing the user's unique GUID.  We send this in the crash
+// report.
+namespace google_update {
+extern std::string posix_guid;
+}  // namespace google_update
+#endif  // OS_POSIX
+
+
+namespace {
+
+typedef std::list<ChildProcessHost*> ChildProcessList;
+
+// The NotificationTask is used to notify about plugin process connection/
+// disconnection. It is needed because the notifications in the
+// NotificationService must happen in the main thread.
+class ChildNotificationTask : public Task {
+ public:
+  ChildNotificationTask(
+      NotificationType notification_type, ChildProcessInfo* info)
+      : notification_type_(notification_type), info_(*info) { }
+
+  virtual void Run() {
+    NotificationService::current()->
+        Notify(notification_type_, NotificationService::AllSources(),
+               Details<ChildProcessInfo>(&info_));
+  }
+
+ private:
+  NotificationType notification_type_;
+  ChildProcessInfo info_;
+};
+
+}  // namespace
+
+
+ChildProcessHost::ChildProcessHost(
+    ProcessType type, ResourceDispatcherHost* resource_dispatcher_host)
+    : Receiver(type, -1),
+      ALLOW_THIS_IN_INITIALIZER_LIST(listener_(this)),
+      resource_dispatcher_host_(resource_dispatcher_host),
+      opening_channel_(false) {
+  Singleton<ChildProcessList>::get()->push_back(this);
+}
+
+
+ChildProcessHost::~ChildProcessHost() {
+  Singleton<ChildProcessList>::get()->remove(this);
+
+  resource_dispatcher_host_->CancelRequestsForProcess(id());
+}
+
+// static
+FilePath ChildProcessHost::GetChildPath(bool allow_self) {
+  FilePath child_path;
+
+  child_path = CommandLine::ForCurrentProcess()->GetSwitchValuePath(
+      switches::kBrowserSubprocessPath);
+  if (!child_path.empty())
+    return child_path;
+
+#if defined(OS_MACOSX)
+  // On the Mac, the child executable lives at a predefined location within
+  // the app bundle's versioned directory.
+  return chrome::GetVersionedDirectory().
+      Append(chrome::kHelperProcessExecutablePath);
+#endif
+
+#if defined(OS_LINUX)
+  // Use /proc/self/exe rather than our known binary path so updates
+  // can't swap out the binary from underneath us.
+  if (allow_self)
+    return FilePath("/proc/self/exe");
+#endif
+
+  // On most platforms, the child executable is the same as the current
+  // executable.
+  PathService::Get(base::FILE_EXE, &child_path);
+  return child_path;
+}
+
+// static
+void ChildProcessHost::SetCrashReporterCommandLine(CommandLine* command_line) {
+#if defined(USE_LINUX_BREAKPAD)
+  const bool unattended = (getenv("CHROME_HEADLESS") != NULL);
+  if (unattended || GoogleUpdateSettings::GetCollectStatsConsent()) {
+    command_line->AppendSwitchWithValue(switches::kEnableCrashReporter,
+                                        ASCIIToWide(google_update::posix_guid +
+                                                    "," +
+                                                    base::GetLinuxDistro()));
+  }
+#elif defined(OS_MACOSX)
+  if (GoogleUpdateSettings::GetCollectStatsConsent())
+    command_line->AppendSwitchWithValue(switches::kEnableCrashReporter,
+                                        ASCIIToWide(google_update::posix_guid));
+#endif  // OS_MACOSX
+}
+
+void ChildProcessHost::Launch(
+#if defined(OS_WIN)
+    const FilePath& exposed_dir,
+#elif defined(OS_POSIX)
+    bool use_zygote,
+    const base::environment_vector& environ,
+#endif
+    CommandLine* cmd_line) {
+  child_process_.reset(new ChildProcessLauncher(
+#if defined(OS_WIN)
+      exposed_dir,
+#elif defined(OS_POSIX)
+      use_zygote,
+      environ,
+      channel_->GetClientFileDescriptor(),
+#endif
+      cmd_line,
+      &listener_));
+}
+
+bool ChildProcessHost::CreateChannel() {
+  channel_id_ = GenerateRandomChannelID(this);
+  channel_.reset(new IPC::Channel(
+      channel_id_, IPC::Channel::MODE_SERVER, &listener_));
+  if (!channel_->Connect())
+    return false;
+
+  opening_channel_ = true;
+
+  return true;
+}
+
+void ChildProcessHost::InstanceCreated() {
+  Notify(NotificationType::CHILD_INSTANCE_CREATED);
+}
+
+bool ChildProcessHost::Send(IPC::Message* msg) {
+  if (!channel_.get()) {
+    delete msg;
+    return false;
+  }
+  return channel_->Send(msg);
+}
+
+void ChildProcessHost::Notify(NotificationType type) {
+  ChromeThread::PostTask(
+      ChromeThread::UI, FROM_HERE, new ChildNotificationTask(type, this));
+}
+
+bool ChildProcessHost::DidChildCrash() {
+  return child_process_->DidProcessCrash();
+}
+
+void ChildProcessHost::OnChildDied() {
+  if (handle() != base::kNullProcessHandle) {
+    bool did_crash = DidChildCrash();
+    if (did_crash) {
+      OnProcessCrashed();
+      // Report that this child process crashed.
+      Notify(NotificationType::CHILD_PROCESS_CRASHED);
+      UMA_HISTOGRAM_COUNTS("ChildProcess.Crashes", this->type());
+    }
+    // Notify in the main loop of the disconnection.
+    Notify(NotificationType::CHILD_PROCESS_HOST_DISCONNECTED);
+  }
+
+  delete this;
+}
+
+ChildProcessHost::ListenerHook::ListenerHook(ChildProcessHost* host)
+    : host_(host) {
+}
+
+void ChildProcessHost::ListenerHook::OnMessageReceived(
+    const IPC::Message& msg) {
+#ifdef IPC_MESSAGE_LOG_ENABLED
+  IPC::Logging* logger = IPC::Logging::current();
+  if (msg.type() == IPC_LOGGING_ID) {
+    logger->OnReceivedLoggingMessage(msg);
+    return;
+  }
+
+  if (logger->Enabled())
+    logger->OnPreDispatchMessage(msg);
+#endif
+
+  bool msg_is_ok = true;
+  bool handled = host_->resource_dispatcher_host_->OnMessageReceived(
+      msg, host_, &msg_is_ok);
+
+  if (!handled) {
+    if (msg.type() == PluginProcessHostMsg_ShutdownRequest::ID) {
+      // Must remove the process from the list now, in case it gets used for a
+      // new instance before our watcher tells us that the process terminated.
+      Singleton<ChildProcessList>::get()->remove(host_);
+      if (host_->CanShutdown())
+        host_->Send(new PluginProcessMsg_Shutdown());
+    } else {
+      host_->OnMessageReceived(msg);
+    }
+  }
+
+  if (!msg_is_ok)
+    base::KillProcess(host_->handle(), ResultCodes::KILLED_BAD_MESSAGE, false);
+
+#ifdef IPC_MESSAGE_LOG_ENABLED
+  if (logger->Enabled())
+    logger->OnPostDispatchMessage(msg, host_->channel_id_);
+#endif
+}
+
+void ChildProcessHost::ListenerHook::OnChannelConnected(int32 peer_pid) {
+  host_->opening_channel_ = false;
+  host_->OnChannelConnected(peer_pid);
+
+#if defined(IPC_MESSAGE_LOG_ENABLED)
+  bool enabled = IPC::Logging::current()->Enabled();
+  host_->Send(new PluginProcessMsg_SetIPCLoggingEnabled(enabled));
+#endif
+
+  host_->Send(new PluginProcessMsg_AskBeforeShutdown());
+
+  // Notify in the main loop of the connection.
+  host_->Notify(NotificationType::CHILD_PROCESS_HOST_CONNECTED);
+}
+
+void ChildProcessHost::ListenerHook::OnChannelError() {
+  host_->opening_channel_ = false;
+  host_->OnChannelError();
+
+  // This will delete host_, which will also destroy this!
+  host_->OnChildDied();
+}
+
+void ChildProcessHost::ListenerHook::OnProcessLaunched() {
+  if (!host_->child_process_->GetHandle()) {
+    delete this;
+    return;
+  }
+
+  host_->set_handle(host_->child_process_->GetHandle());
+  host_->OnProcessLaunched();
+}
+
+
+ChildProcessHost::Iterator::Iterator()
+    : all_(true), type_(UNKNOWN_PROCESS) {
+  DCHECK(ChromeThread::CurrentlyOn(ChromeThread::IO)) <<
+          "ChildProcessInfo::Iterator must be used on the IO thread.";
+  iterator_ = Singleton<ChildProcessList>::get()->begin();
+}
+
+ChildProcessHost::Iterator::Iterator(ProcessType type)
+    : all_(false), type_(type) {
+  DCHECK(ChromeThread::CurrentlyOn(ChromeThread::IO)) <<
+          "ChildProcessInfo::Iterator must be used on the IO thread.";
+  iterator_ = Singleton<ChildProcessList>::get()->begin();
+  if (!Done() && (*iterator_)->type() != type_)
+    ++(*this);
+}
+
+ChildProcessHost* ChildProcessHost::Iterator::operator++() {
+  do {
+    ++iterator_;
+    if (Done())
+      break;
+
+    if (!all_ && (*iterator_)->type() != type_)
+      continue;
+
+    return *iterator_;
+  } while (true);
+
+  return NULL;
+}
+
+bool ChildProcessHost::Iterator::Done() {
+  return iterator_ == Singleton<ChildProcessList>::get()->end();
+}