Mac: Proof-of-concept task manager

chrome/common/child_process.cc

 // Copyright (c) 2006-2008 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/common/child_process.h"
 
 #include "app/l10n_util.h"
 #include "base/message_loop.h"
 #include "base/process_util.h"
 #include "base/string_util.h"
 #include "chrome/common/child_thread.h"
 #include "grit/chromium_strings.h"
 
 #if defined(OS_POSIX)
 #include <signal.h>
 
 static void SigUSR1Handler(int signal) { }
 #endif
 
+#if defined(OS_MACOSX)
+#include "ipc/ipc_switches.h"
+#include "base/thread.h"
+#include "chrome/common/mach_ipc_mac.h"
+
+class MachSendTask : public Task {
+ public:
+  MachSendTask(const std::string& channel_name) : channel_name_(channel_name) {}
+
+  virtual void Run() {
+    // TODO(thakis): Put these somewhere central.
+    const int kMachPortMessageID = 57;

[Mark Mentovai, 2010/01/11 20:22:46]

This line and the next are “duplicatious.”  I know English isn’t your first
language, but don’t bother looking that up, I invented it myself.

Heed the good advice of your TODO from line 30.

+    const std::string kMachChannelPrefix = "com.Google.Chrome";

[Mark Mentovai, 2010/01/11 20:22:46]

Same thing here applies about the dots.

+
+    const int kMachPortMessageSendWaitMs = 5000;
+    std::string channel_name = kMachChannelPrefix + channel_name_;
+printf("Creating send port %s\n", channel_name.c_str());

[Mark Mentovai, 2010/01/11 20:22:46]

t’let

+    MachPortSender sender(channel_name.c_str());
+    MachSendMessage message(kMachPortMessageID);
+
+    // add some ports to be translated for us

[Mark Mentovai, 2010/01/11 20:22:46]

Comments ought to be complete sentences with capital letters and periods and
occasionally humor.

+//    message.AddDescriptor(MachMsgPortDescriptor(mach_task_self()));

[Mark Mentovai, 2010/01/11 20:22:46]

Huh?

+    message.AddDescriptor(MachMsgPortDescriptor(mach_task_self(), MACH_MSG_TYPE_COPY_SEND));

[Mark Mentovai, 2010/01/11 20:22:46]

80

+
+    kern_return_t result = sender.SendMessage(message,
+        kMachPortMessageSendWaitMs);
+
+    // TODO(thakis): Log error somewhere? (don't printf in any case :-P)
+    // (error codes are listed in mach/message.h)
+    fprintf(stderr, "send result: 0x%lx\n", (unsigned long)result);

[Mark Mentovai, 2010/01/11 20:22:46]

Observe the TODO from 47, and don't printf in any case.  :)

+    if (result != KERN_SUCCESS)
+      fprintf(stderr, "(Failed :-( )\n");
+  }
+ private:
+  std::string channel_name_;
+};
+
+class MachSendThread : public base::Thread {
+ public:
+  MachSendThread() : base::Thread("MachSendThread") {}
+
+  void DoIt() {
+    DCHECK(message_loop());
+    std::string name = CommandLine::ForCurrentProcess()->GetSwitchValueASCII(
+        switches::kProcessChannelID);
+printf("main thread: %s\n", name.c_str());
+    message_loop()->PostTask(
+        FROM_HERE,
+        new MachSendTask(name));
+  }
+};
+#endif
+
 ChildProcess* ChildProcess::child_process_;
 
 ChildProcess::ChildProcess()
     : ref_count_(0),
       shutdown_event_(true, false),
       io_thread_("Chrome_ChildIOThread") {
   DCHECK(!child_process_);
   child_process_ = this;
 
   io_thread_.StartWithOptions(base::Thread::Options(MessageLoop::TYPE_IO, 0));
+
+#if defined(OS_MACOSX)
+  {
+    MachSendThread mach_thread;
+    CHECK(mach_thread.Start());
+    mach_thread.DoIt();
+  }
+#endif
 }
 
 ChildProcess::~ChildProcess() {
   DCHECK(child_process_ == this);
 
   // Signal this event before destroying the child process.  That way all
   // background threads can cleanup.
   // For example, in the renderer the RenderThread instances will be able to
   // notice shutdown before the render process begins waiting for them to exit.
   shutdown_event_.Signal();
@@ skipping 48 matching lines @@
                  << ") paused waiting for debugger to attach @ pid";
     // Install a signal handler so that pause can be woken.
     struct sigaction sa;
     memset(&sa, 0, sizeof(sa));
     sa.sa_handler = SigUSR1Handler;
     sigaction(SIGUSR1, &sa, NULL);
 
     pause();
 #endif  // defined(OS_POSIX)
 }