text: // 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 "shell/in_process_native_runner.h"
  
  #include "base/bind.h"
  #include "base/callback_helpers.h"
  #include "base/location.h"
  #include "base/thread_task_runner_handle.h"
  #include "base/threading/platform_thread.h"
  #include "shell/native_application_support.h"
  
  namespace shell {
  
  InProcessNativeRunner::InProcessNativeRunner(Context* context)
      : app_library_(nullptr) {
  }
  
  InProcessNativeRunner::~InProcessNativeRunner() {
    // It is important to let the thread exit before unloading the DSO (when
    // app_library_ is destructed), because the library may have registered
    // thread-local data and destructors to run on thread termination.
    if (thread_) {
      DCHECK(thread_->HasBeenStarted());
      DCHECK(!thread_->HasBeenJoined());
      thread_->Join();
    }
  }
  
  void InProcessNativeRunner::Start(
      const base::FilePath& app_path,
      mojo::InterfaceRequest<mojo::Application> application_request,
      const base::Closure& app_completed_callback) {
    app_path_ = app_path;
  
    DCHECK(!application_request_.is_pending());
    application_request_ = application_request.Pass();
  
    DCHECK(app_completed_callback_runner_.is_null());
    app_completed_callback_runner_ = base::Bind(
        &base::TaskRunner::PostTask, base::ThreadTaskRunnerHandle::Get(),
        FROM_HERE, app_completed_callback);
  
    DCHECK(!thread_);
    std::string thread_name = "app_thread_" + app_path_.BaseName().AsUTF8Unsafe();
    thread_.reset(new base::DelegateSimpleThread(this, thread_name));
    thread_->Start();
  }
  
  void InProcessNativeRunner::Run() {
    DVLOG(2) << "Loading/running Mojo app in process from library: "
             << app_path_.value()
             << " thread id=" << base::PlatformThread::CurrentId();
  
    // TODO(vtl): ScopedNativeLibrary doesn't have a .get() method!
    base::NativeLibrary app_library = LoadNativeApplication(app_path_);
    app_library_.Reset(app_library);
    RunNativeApplication(app_library, application_request_.Pass());
    app_completed_callback_runner_.Run();
    app_completed_callback_runner_.Reset();
  }
  
  scoped_ptr<NativeRunner> InProcessNativeRunnerFactory::Create(
      const NativeApplicationOptions& /*options*/) {
    return make_scoped_ptr(new InProcessNativeRunner(context_));
  }
  
  }  // namespace shell
  