Home | History | Annotate | Download | only in test 
      1 // Copyright 2015 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #include "mojo/edk/test/scoped_ipc_support.h"
      6 
      7 #include <utility>
      8 
      9 #include "base/message_loop/message_loop.h"
     10 #include "mojo/edk/embedder/embedder.h"
     11 
     12 namespace mojo {
     13 namespace edk {
     14 namespace test {
     15 
     16 namespace {
     17 base::TaskRunner* g_io_task_runner = nullptr;
     18 }
     19 
     20 base::TaskRunner* GetIoTaskRunner() {
     21   return g_io_task_runner;
     22 }
     23 
     24 namespace internal {
     25 
     26 ScopedIPCSupportHelper::ScopedIPCSupportHelper() {
     27 }
     28 
     29 ScopedIPCSupportHelper::~ScopedIPCSupportHelper() {
     30   ShutdownIPCSupport();
     31   run_loop_.Run();
     32 }
     33 
     34 void ScopedIPCSupportHelper::Init(
     35     ProcessDelegate* process_delegate,
     36     scoped_refptr<base::TaskRunner> io_thread_task_runner) {
     37   io_thread_task_runner_ = io_thread_task_runner;
     38   InitIPCSupport(process_delegate, io_thread_task_runner_);
     39 }
     40 
     41 void ScopedIPCSupportHelper::OnShutdownCompleteImpl() {
     42   run_loop_.Quit();
     43 }
     44 
     45 }  // namespace internal
     46 
     47 ScopedIPCSupport::ScopedIPCSupport(
     48     scoped_refptr<base::TaskRunner> io_thread_task_runner) {
     49   g_io_task_runner = io_thread_task_runner.get();
     50   helper_.Init(this, std::move(io_thread_task_runner));
     51 }
     52 
     53 ScopedIPCSupport::~ScopedIPCSupport() {
     54 }
     55 
     56 void ScopedIPCSupport::OnShutdownComplete() {
     57   helper_.OnShutdownCompleteImpl();
     58 }
     59 
     60 }  // namespace test
     61 }  // namespace edk
     62 }  // namespace mojo
     63