Index: components/nacl/loader/nacl_listener.cc |
diff --git a/components/nacl/loader/nacl_listener.cc b/components/nacl/loader/nacl_listener.cc |
index 5b6291158c1d8cd7d12964c3d9fec4d5e8450d68..daf5766c80a8fd7a25819dd2f73796f6aba52bc4 100644 |
--- a/components/nacl/loader/nacl_listener.cc |
+++ b/components/nacl/loader/nacl_listener.cc |
@@ -29,17 +29,22 @@ |
#include "components/nacl/loader/nacl_ipc_adapter.h" |
#include "components/nacl/loader/nacl_validation_db.h" |
#include "components/nacl/loader/nacl_validation_query.h" |
+#include "content/public/common/mojo_channel_switches.h" |
#include "ipc/attachment_broker_unprivileged.h" |
#include "ipc/ipc_channel_handle.h" |
#include "ipc/ipc_switches.h" |
#include "ipc/ipc_sync_channel.h" |
#include "ipc/ipc_sync_message_filter.h" |
+#include "mojo/edk/embedder/embedder.h" |
+#include "mojo/edk/embedder/scoped_ipc_support.h" |
#include "native_client/src/public/chrome_main.h" |
#include "native_client/src/public/nacl_app.h" |
#include "native_client/src/public/nacl_desc.h" |
#if defined(OS_POSIX) |
#include "base/file_descriptor_posix.h" |
+#include "base/posix/global_descriptors.h" |
+#include "content/public/common/content_descriptors.h" |
#endif |
#if defined(OS_LINUX) |
@@ -50,6 +55,7 @@ |
#include <io.h> |
#include "content/public/common/sandbox_init.h" |
+#include "mojo/edk/embedder/platform_channel_pair.h" |
#endif |
namespace { |
@@ -173,6 +179,20 @@ NaClListener::NaClListener() |
base::Thread::Options(base::MessageLoop::TYPE_IO, 0)); |
DCHECK(g_listener == NULL); |
g_listener = this; |
+ |
+ mojo_ipc_support_.reset(new mojo::edk::ScopedIPCSupport( |
+ io_thread_.task_runner().get())); |
+#if defined(OS_WIN) |
+ mojo::edk::ScopedPlatformHandle platform_channel( |
+ mojo::edk::PlatformChannelPair::PassClientHandleFromParentProcess( |
+ *base::CommandLine::ForCurrentProcess())); |
+#else |
+ mojo::edk::ScopedPlatformHandle platform_channel( |
+ mojo::edk::PlatformHandle( |
+ base::GlobalDescriptors::GetInstance()->Get(kMojoIPCChannel))); |
+#endif |
+ DCHECK(platform_channel.is_valid()); |
+ mojo::edk::SetParentPipeHandle(std::move(platform_channel)); |
} |
NaClListener::~NaClListener() { |
@@ -221,9 +241,13 @@ class FileTokenMessageFilter : public IPC::MessageFilter { |
}; |
void NaClListener::Listen() { |
- std::string channel_name = |
- base::CommandLine::ForCurrentProcess()->GetSwitchValueASCII( |
- switches::kProcessChannelID); |
+ mojo::ScopedMessagePipeHandle handle( |
+ mojo::edk::CreateChildMessagePipe( |
+ base::CommandLine::ForCurrentProcess()->GetSwitchValueASCII( |
+ switches::kMojoChannelToken))); |
+ DCHECK(handle.is_valid()); |
+ IPC::ChannelHandle channel_handle(handle.release()); |
+ |
channel_ = IPC::SyncChannel::Create(this, io_thread_.task_runner().get(), |
&shutdown_event_); |
filter_ = channel_->CreateSyncMessageFilter(); |
@@ -231,7 +255,7 @@ void NaClListener::Listen() { |
IPC::AttachmentBroker* global = IPC::AttachmentBroker::GetGlobal(); |
if (global && !global->IsPrivilegedBroker()) |
global->RegisterBrokerCommunicationChannel(channel_.get()); |
- channel_->Init(channel_name, IPC::Channel::MODE_CLIENT, true); |
+ channel_->Init(channel_handle, IPC::Channel::MODE_CLIENT, true); |
main_task_runner_ = base::ThreadTaskRunnerHandle::Get(); |
base::RunLoop().Run(); |
} |