Simple shell that loads a dll and calls an entrypoint function passing in a handle to a pipe create…

mojo/shell/app_container.cc

+// Copyright (c) 2013 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 "base/bind.h"
+#include "base/callback_forward.h"
+#include "base/files/file_path.h"
+#include "base/native_library.h"
+#include "base/thread_task_runner_handle.h"
+#include "base/threading/thread.h"
+#include "mojo/public/system/core.h"
+#include "mojo/shell/app_container.h"
+
+typedef MojoResult (*MojoMainFunction)(mojo::Handle pipe);
+
+namespace mojo {
+namespace shell {
+
+void LaunchAppOnThread(
+    const base::FilePath& app_path,
+    mojo::Handle app_handle) {
+  base::NativeLibrary app_library = base::LoadNativeLibrary(app_path, NULL);
+  if (!app_library) {
+    LOG(ERROR) << "Failed to load library: " << app_path.value().c_str();
+    goto completed;
+  }
+
+  MojoMainFunction main_function =
+      reinterpret_cast<MojoMainFunction>(
+          base::GetFunctionPointerFromNativeLibrary(app_library, "MojoMain"));
+  if (!main_function) {
+    LOG(ERROR) << "Entrypoint MojoMain not found.";
+    goto completed;
+  }
+
+  MojoResult result = main_function(app_handle);
+  if (result < MOJO_RESULT_OK) {
+    LOG(ERROR) << "MojoMain returned an error: " << result;
+    // TODO(*): error handling?
+    goto completed;
+  }
+
+completed:
+  base::UnloadNativeLibrary(app_library);
+  mojo::Close(app_handle);

[darin (slow to review), 2013/10/08 21:30:06]

nit: you could leave off the mojo:: if you wanted since you are already inside
the mojo namespace. ditto for the remainder of this file.

+}
+
+AppContainer::AppContainer()
+    : weak_factory_(this) {
+}
+
+AppContainer::~AppContainer() {
+}
+
+void AppContainer::LaunchApp(const base::FilePath& app_path) {
+  mojo::Handle app_handle;
+  MojoResult result = mojo::CreateMessagePipe(&shell_handle_, &app_handle);
+  if (result < MOJO_RESULT_OK) {
+    // Failure..
+  }
+
+  // Launch the app on its own thread.
+  // TODO(beng): Create a unique thread name.
+  thread_.reset(new base::Thread("app_thread"));
+  thread_->Start();
+  thread_->message_loop_proxy()->PostTaskAndReply(
+      FROM_HERE,
+      base::Bind(&LaunchAppOnThread, app_path, app_handle),
+      base::Bind(&AppContainer::AppCompleted, weak_factory_.GetWeakPtr()));
+
+  const char* hello_msg = "Hello";
+  result = mojo::WriteMessage(shell_handle_, hello_msg, strlen(hello_msg)+1,
+                              NULL, 0, MOJO_WRITE_MESSAGE_FLAG_NONE);
+  if (result < MOJO_RESULT_OK) {
+    // Failure..
+  }
+}
+
+
+void AppContainer::AppCompleted() {
+  thread_.reset();
+  mojo::Close(shell_handle_);
+
+  // Probably want to do something more sophisticated here, like notify someone
+  // else to do this.
+  base::MessageLoop::current()->Quit();
+}
+
+}  // namespace shell
+}  // namespace mojo