diff options
Diffstat (limited to 'mojo/edk/embedder/embedder.cc')
-rw-r--r-- | mojo/edk/embedder/embedder.cc | 158 |
1 files changed, 0 insertions, 158 deletions
diff --git a/mojo/edk/embedder/embedder.cc b/mojo/edk/embedder/embedder.cc deleted file mode 100644 index 0fdda5c..0000000 --- a/mojo/edk/embedder/embedder.cc +++ /dev/null @@ -1,158 +0,0 @@ -// 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/edk/embedder/embedder.h" - -#include <stdint.h> -#include <utility> - -#include "base/bind.h" -#include "base/location.h" -#include "base/logging.h" -#include "base/memory/ref_counted.h" -#include "base/rand_util.h" -#include "base/strings/string_number_conversions.h" -#include "base/task_runner.h" -#include "base/threading/thread_task_runner_handle.h" -#include "mojo/edk/embedder/embedder_internal.h" -#include "mojo/edk/embedder/entrypoints.h" -#include "mojo/edk/embedder/platform_channel_pair.h" -#include "mojo/edk/system/core.h" -#include "mojo/edk/system/node_controller.h" - -#if !defined(OS_NACL) -#include "crypto/random.h" -#endif - -namespace mojo { -namespace edk { - -class Core; -class PlatformSupport; - -namespace internal { - -Core* g_core; - -Core* GetCore() { return g_core; } - -} // namespace internal - -void SetMaxMessageSize(size_t bytes) { -} - -void SetParentPipeHandle(ScopedPlatformHandle pipe) { - CHECK(internal::g_core); - internal::g_core->InitChild(ConnectionParams(std::move(pipe))); -} - -void SetParentPipeHandleFromCommandLine() { - ScopedPlatformHandle platform_channel = - PlatformChannelPair::PassClientHandleFromParentProcess( - *base::CommandLine::ForCurrentProcess()); - CHECK(platform_channel.is_valid()); - SetParentPipeHandle(std::move(platform_channel)); -} - -ScopedMessagePipeHandle ConnectToPeerProcess(ScopedPlatformHandle pipe) { - return ConnectToPeerProcess(std::move(pipe), GenerateRandomToken()); -} - -ScopedMessagePipeHandle ConnectToPeerProcess(ScopedPlatformHandle pipe, - const std::string& peer_token) { - DCHECK(pipe.is_valid()); - DCHECK(!peer_token.empty()); - return internal::g_core->ConnectToPeerProcess(std::move(pipe), peer_token); -} - -void ClosePeerConnection(const std::string& peer_token) { - return internal::g_core->ClosePeerConnection(peer_token); -} - -void Init() { - MojoSystemThunks thunks = MakeSystemThunks(); - size_t expected_size = MojoEmbedderSetSystemThunks(&thunks); - DCHECK_EQ(expected_size, sizeof(thunks)); - - internal::g_core = new Core(); -} - -void SetDefaultProcessErrorCallback(const ProcessErrorCallback& callback) { - internal::g_core->SetDefaultProcessErrorCallback(callback); -} - -MojoResult CreatePlatformHandleWrapper( - ScopedPlatformHandle platform_handle, - MojoHandle* platform_handle_wrapper_handle) { - return internal::g_core->CreatePlatformHandleWrapper( - std::move(platform_handle), platform_handle_wrapper_handle); -} - -MojoResult PassWrappedPlatformHandle(MojoHandle platform_handle_wrapper_handle, - ScopedPlatformHandle* platform_handle) { - return internal::g_core->PassWrappedPlatformHandle( - platform_handle_wrapper_handle, platform_handle); -} - -MojoResult CreateSharedBufferWrapper( - base::SharedMemoryHandle shared_memory_handle, - size_t num_bytes, - bool read_only, - MojoHandle* mojo_wrapper_handle) { - return internal::g_core->CreateSharedBufferWrapper( - shared_memory_handle, num_bytes, read_only, mojo_wrapper_handle); -} - -MojoResult PassSharedMemoryHandle( - MojoHandle mojo_handle, - base::SharedMemoryHandle* shared_memory_handle, - size_t* num_bytes, - bool* read_only) { - return internal::g_core->PassSharedMemoryHandle( - mojo_handle, shared_memory_handle, num_bytes, read_only); -} - -void InitIPCSupport(scoped_refptr<base::TaskRunner> io_thread_task_runner) { - CHECK(internal::g_core); - internal::g_core->SetIOTaskRunner(io_thread_task_runner); -} - -scoped_refptr<base::TaskRunner> GetIOTaskRunner() { - return internal::g_core->GetNodeController()->io_task_runner(); -} - -void ShutdownIPCSupport(const base::Closure& callback) { - CHECK(internal::g_core); - internal::g_core->RequestShutdown(callback); -} - -#if defined(OS_MACOSX) && !defined(OS_IOS) -void SetMachPortProvider(base::PortProvider* port_provider) { - DCHECK(port_provider); - internal::g_core->SetMachPortProvider(port_provider); -} -#endif - -ScopedMessagePipeHandle CreateChildMessagePipe(const std::string& token) { - return internal::g_core->CreateChildMessagePipe(token); -} - -std::string GenerateRandomToken() { - char random_bytes[16]; -#if defined(OS_NACL) - // Not secure. For NaCl only! - base::RandBytes(random_bytes, 16); -#else - crypto::RandBytes(random_bytes, 16); -#endif - return base::HexEncode(random_bytes, 16); -} - -MojoResult SetProperty(MojoPropertyType type, const void* value) { - CHECK(internal::g_core); - return internal::g_core->SetProperty(type, value); -} - -} // namespace edk -} // namespace mojo |