Get service process running standalone on the mac by hooking it into launchd.

BUG=NONE
TEST=BUILD

Review URL: http://codereview.chromium.org/6482016

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

1 files changed, 63 insertions, 74 deletions

diff --git a/chrome/browser/service/service_process_control.cc b/chrome/browser/service/service_process_control.cc
index 09bc1ad..eb7a983 100644
--- a/chrome/browser/service/service_process_control.cc
+++ b/chrome/browser/service/service_process_control.cc
@@ -21,79 +21,6 @@
 #include "chrome/common/service_process_util.h"
 #include "ui/base/ui_base_switches.h"
 
-// ServiceProcessControl::Launcher implementation.
-// This class is responsible for launching the service process on the
-// PROCESS_LAUNCHER thread.
-class ServiceProcessControl::Launcher
-    : public base::RefCountedThreadSafe<ServiceProcessControl::Launcher> {
- public:
-  Launcher(ServiceProcessControl* process, CommandLine* cmd_line)
-      : process_(process),
-        cmd_line_(cmd_line),
-        launched_(false),
-        retry_count_(0) {
-  }
-
-  // Execute the command line to start the process asynchronously.
-  // After the comamnd is executed |task| is called with the process handle on
-  // the UI thread.
-  void Run(Task* task) {
-    DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-    notify_task_.reset(task);
-    BrowserThread::PostTask(BrowserThread::PROCESS_LAUNCHER, FROM_HERE,
-                           NewRunnableMethod(this, &Launcher::DoRun));
-  }
-
-  bool launched() const { return launched_; }
-
- private:
-  void DoRun() {
-    DCHECK(notify_task_.get());
-    base::LaunchApp(*cmd_line_.get(), false, true, NULL);
-    BrowserThread::PostTask(
-        BrowserThread::IO, FROM_HERE,
-        NewRunnableMethod(this, &Launcher::DoDetectLaunched));
-  }
-
-  void DoDetectLaunched() {
-    DCHECK(notify_task_.get());
-    const uint32 kMaxLaunchDetectRetries = 10;
-
-    {
-      // We should not be doing blocking disk IO from this thread!
-      // Temporarily allowed until we fix
-      //   http://code.google.com/p/chromium/issues/detail?id=60207
-      base::ThreadRestrictions::ScopedAllowIO allow_io;
-      launched_ = CheckServiceProcessReady();
-    }
-
-    if (launched_ || (retry_count_ >= kMaxLaunchDetectRetries)) {
-      BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-          NewRunnableMethod(this, &Launcher::Notify));
-      return;
-    }
-    retry_count_++;
-    // If the service process is not launched yet then check again in 2 seconds.
-    const int kDetectLaunchRetry = 2000;
-    MessageLoop::current()->PostDelayedTask(
-        FROM_HERE,
-        NewRunnableMethod(this, &Launcher::DoDetectLaunched),
-        kDetectLaunchRetry);
-  }
-
-  void Notify() {
-    DCHECK(notify_task_.get());
-    notify_task_->Run();
-    notify_task_.reset();
-  }
-
-  ServiceProcessControl* process_;
-  scoped_ptr<CommandLine> cmd_line_;
-  scoped_ptr<Task> notify_task_;
-  bool launched_;
-  uint32 retry_count_;
-};
 
 // ServiceProcessControl implementation.
 ServiceProcessControl::ServiceProcessControl(Profile* profile)
@@ -120,7 +47,7 @@ void ServiceProcessControl::ConnectInternal() {
   base::Thread* io_thread = g_browser_process->io_thread();
 
   // TODO(hclam): Handle error connecting to channel.
-  const std::string channel_id = GetServiceProcessChannelName();
+  const IPC::ChannelHandle channel_id = GetServiceProcessChannel();
   channel_.reset(
       new IPC::SyncChannel(channel_id, IPC::Channel::MODE_NAMED_CLIENT, this,
                            io_thread->message_loop(), true,
@@ -201,10 +128,19 @@ void ServiceProcessControl::Launch(Task* success_task, Task* failure_task) {
   if (!logging_level.empty())
     cmd_line->AppendSwitchASCII(switches::kLoggingLevel, logging_level);
 
+  std::string v_level = browser_command_line.GetSwitchValueASCII(
+      switches::kV);
+  if (!v_level.empty())
+    cmd_line->AppendSwitchASCII(switches::kV, v_level);
+
   if (browser_command_line.HasSwitch(switches::kWaitForDebuggerChildren)) {
     cmd_line->AppendSwitch(switches::kWaitForDebugger);
   }
 
+  if (browser_command_line.HasSwitch(switches::kEnableLogging)) {
+    cmd_line->AppendSwitch(switches::kEnableLogging);
+  }
+
   std::string locale = g_browser_process->GetApplicationLocale();
   cmd_line->AppendSwitchASCII(switches::kLang, locale);
 
@@ -341,3 +277,56 @@ void ServiceProcessControl::RemoveMessageHandler(
 }
 
 DISABLE_RUNNABLE_METHOD_REFCOUNT(ServiceProcessControl);
+
+ServiceProcessControl::Launcher::Launcher(ServiceProcessControl* process,
+                                          CommandLine* cmd_line)
+    : process_(process),
+      cmd_line_(cmd_line),
+      launched_(false),
+      retry_count_(0) {
+}
+
+// Execute the command line to start the process asynchronously.
+// After the command is executed, |task| is called with the process handle on
+// the UI thread.
+void ServiceProcessControl::Launcher::Run(Task* task) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  notify_task_.reset(task);
+  BrowserThread::PostTask(BrowserThread::PROCESS_LAUNCHER, FROM_HERE,
+                         NewRunnableMethod(this, &Launcher::DoRun));
+}
+
+void ServiceProcessControl::Launcher::Notify() {
+  DCHECK(notify_task_.get());
+  notify_task_->Run();
+  notify_task_.reset();
+}
+
+#if !defined(OS_MACOSX)
+void ServiceProcessControl::Launcher::DoDetectLaunched() {
+  DCHECK(notify_task_.get());
+  const uint32 kMaxLaunchDetectRetries = 10;
+  launched_ = CheckServiceProcessReady();
+  if (launched_ || (retry_count_ >= kMaxLaunchDetectRetries)) {
+    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
+        NewRunnableMethod(this, &Launcher::Notify));
+    return;
+  }
+  retry_count_++;
+
+  // If the service process is not launched yet then check again in 2 seconds.
+  const int kDetectLaunchRetry = 2000;
+  MessageLoop::current()->PostDelayedTask(
+      FROM_HERE,
+      NewRunnableMethod(this, &Launcher::DoDetectLaunched),
+      kDetectLaunchRetry);
+}
+
+void ServiceProcessControl::Launcher::DoRun() {
+  DCHECK(notify_task_.get());
+  base::LaunchApp(*cmd_line_.get(), false, true, NULL);
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      NewRunnableMethod(this, &Launcher::DoDetectLaunched));
+}
+#endif  // !OS_MACOSX