diff options
Diffstat (limited to 'chromium/content/browser/mojo/mojo_application_host.cc')
-rw-r--r-- | chromium/content/browser/mojo/mojo_application_host.cc | 71 |
1 files changed, 71 insertions, 0 deletions
diff --git a/chromium/content/browser/mojo/mojo_application_host.cc b/chromium/content/browser/mojo/mojo_application_host.cc new file mode 100644 index 00000000000..90187b9b92f --- /dev/null +++ b/chromium/content/browser/mojo/mojo_application_host.cc @@ -0,0 +1,71 @@ +// 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 "content/browser/mojo/mojo_application_host.h" + +#include "content/common/mojo/mojo_messages.h" +#include "content/public/browser/browser_thread.h" +#include "ipc/ipc_sender.h" +#include "mojo/embedder/platform_channel_pair.h" + +namespace content { +namespace { + +base::PlatformFile PlatformFileFromScopedPlatformHandle( + mojo::embedder::ScopedPlatformHandle handle) { +#if defined(OS_POSIX) + return handle.release().fd; +#elif defined(OS_WIN) + return handle.release().handle; +#endif +} + +} // namespace + +MojoApplicationHost::MojoApplicationHost() : did_activate_(false) { +} + +MojoApplicationHost::~MojoApplicationHost() { +} + +bool MojoApplicationHost::Init() { + DCHECK(!child_service_provider_.get()) << "Already initialized!"; + + mojo::embedder::PlatformChannelPair channel_pair; + + mojo::ScopedMessagePipeHandle message_pipe = channel_init_.Init( + PlatformFileFromScopedPlatformHandle(channel_pair.PassServerHandle()), + BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO)); + if (!message_pipe.is_valid()) + return false; + + // Forward this to the client once we know its process handle. + client_handle_ = channel_pair.PassClientHandle(); + + child_service_provider_.reset( + BindToPipe(new ServiceProviderImpl(), message_pipe.Pass())); + return true; +} + +bool MojoApplicationHost::Activate(IPC::Sender* sender, + base::ProcessHandle process_handle) { + DCHECK(!did_activate_); + DCHECK(client_handle_.is_valid()); + + base::PlatformFile client_file = + PlatformFileFromScopedPlatformHandle(client_handle_.Pass()); + did_activate_ = sender->Send(new MojoMsg_Activate( + IPC::GetFileHandleForProcess(client_file, process_handle, true))); + return did_activate_; +} + +void MojoApplicationHost::ServiceProviderImpl::ConnectToService( + const mojo::String& service_url, + const mojo::String& service_name, + mojo::ScopedMessagePipeHandle handle, + const mojo::String& requestor_url) { + // TODO(darin): Provide something meaningful here. +} + +} // namespace content |