Revert of [mojo-bindings] Use Watch API instead of MessagePumpMojo

mojo/shell/public/cpp/lib/application_runner.cc

 // Copyright 2014 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 "mojo/shell/public/cpp/application_runner.h"
 
 #include "base/at_exit.h"
 #include "base/command_line.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/process/launch.h"
+#include "mojo/message_pump/message_pump_mojo.h"
 #include "mojo/shell/public/cpp/shell_client.h"
 #include "mojo/shell/public/cpp/shell_connection.h"
 
 namespace mojo {
 
 int g_application_runner_argc;
 const char* const* g_application_runner_argv;
 
 ApplicationRunner::ApplicationRunner(ShellClient* client)
     : client_(scoped_ptr<ShellClient>(client)),
-      message_loop_type_(base::MessageLoop::TYPE_DEFAULT),
+      message_loop_type_(base::MessageLoop::TYPE_CUSTOM),
       has_run_(false) {}
 
 ApplicationRunner::~ApplicationRunner() {}
 
 void ApplicationRunner::InitBaseCommandLine() {
   base::CommandLine::Init(g_application_runner_argc, g_application_runner_argv);
 }
 
 void ApplicationRunner::set_message_loop_type(base::MessageLoop::Type type) {
   DCHECK_NE(base::MessageLoop::TYPE_CUSTOM, type);
   DCHECK(!has_run_);
 
   message_loop_type_ = type;
 }
 
 MojoResult ApplicationRunner::Run(MojoHandle shell_client_request_handle,
                                   bool init_base) {
   DCHECK(!has_run_);
   has_run_ = true;
 
   scoped_ptr<base::AtExitManager> at_exit;
   if (init_base) {
     InitBaseCommandLine();
     at_exit.reset(new base::AtExitManager);
   }
 
   {
     scoped_ptr<base::MessageLoop> loop;
-    loop.reset(new base::MessageLoop(message_loop_type_));
+    if (message_loop_type_ == base::MessageLoop::TYPE_CUSTOM)
+      loop.reset(new base::MessageLoop(common::MessagePumpMojo::Create()));
+    else
+      loop.reset(new base::MessageLoop(message_loop_type_));
 
     connection_.reset(new ShellConnection(
         client_.get(),
         MakeRequest<shell::mojom::ShellClient>(MakeScopedHandle(
             MessagePipeHandle(shell_client_request_handle)))));
     loop->Run();
     // It's very common for the client to cache the app and terminate on errors.
     // If we don't delete the client before the app we run the risk of the
     // client having a stale reference to the app and trying to use it.
     // Note that we destruct the message loop first because that might trigger
@@ skipping 13 matching lines @@
         !base::CommandLine::ForCurrentProcess()->HasSwitch("single-process");
   }
   return Run(shell_client_request_handle, init_base);
 }
 
 void ApplicationRunner::DestroyShellConnection() {
   connection_.reset();
 }
 
 }  // namespace mojo