| Index: mojo/edk/embedder/multiprocess_embedder.cc
|
| diff --git a/mojo/edk/embedder/multiprocess_embedder.cc b/mojo/edk/embedder/multiprocess_embedder.cc
|
| index 25e6355c9f485a8e69ea9a6c43859de2516d11f7..496819181a9917ca0ba84d16c8186fffd05f91ed 100644
|
| --- a/mojo/edk/embedder/multiprocess_embedder.cc
|
| +++ b/mojo/edk/embedder/multiprocess_embedder.cc
|
| @@ -15,6 +15,7 @@
|
| #include "mojo/edk/system/channel.h"
|
| #include "mojo/edk/system/channel_manager.h"
|
| #include "mojo/edk/system/core.h"
|
| +#include "mojo/edk/system/handle.h"
|
| #include "mojo/edk/system/ipc_support.h"
|
| #include "mojo/edk/system/message_pipe_dispatcher.h"
|
| #include "mojo/edk/system/raw_channel.h"
|
| @@ -128,8 +129,9 @@ ScopedMessagePipeHandle ConnectToSlave(
|
| std::move(did_connect_to_slave_runner), &channel_id);
|
| *channel_info = new ChannelInfo(channel_id);
|
|
|
| - ScopedMessagePipeHandle rv(
|
| - MessagePipeHandle(internal::g_core->AddDispatcher(dispatcher.get())));
|
| + ScopedMessagePipeHandle rv(MessagePipeHandle(internal::g_core->AddHandle(
|
| + system::Handle(std::move(dispatcher),
|
| + system::MessagePipeDispatcher::kDefaultHandleRights))));
|
| CHECK(rv.is_valid());
|
| return rv;
|
| }
|
| @@ -154,8 +156,9 @@ ScopedMessagePipeHandle ConnectToMaster(
|
| std::move(did_connect_to_master_runner), &channel_id);
|
| *channel_info = new ChannelInfo(channel_id);
|
|
|
| - ScopedMessagePipeHandle rv(
|
| - MessagePipeHandle(internal::g_core->AddDispatcher(dispatcher.get())));
|
| + ScopedMessagePipeHandle rv(MessagePipeHandle(internal::g_core->AddHandle(
|
| + system::Handle(std::move(dispatcher),
|
| + system::MessagePipeDispatcher::kDefaultHandleRights))));
|
| CHECK(rv.is_valid());
|
| return rv;
|
| }
|
| @@ -176,8 +179,9 @@ ScopedMessagePipeHandle CreateChannelOnIOThread(
|
| channel_manager->CreateChannelOnIOThread((*channel_info)->channel_id,
|
| platform_handle.Pass());
|
|
|
| - ScopedMessagePipeHandle rv(
|
| - MessagePipeHandle(internal::g_core->AddDispatcher(dispatcher.get())));
|
| + ScopedMessagePipeHandle rv(MessagePipeHandle(internal::g_core->AddHandle(
|
| + system::Handle(std::move(dispatcher),
|
| + system::MessagePipeDispatcher::kDefaultHandleRights))));
|
| CHECK(rv.is_valid());
|
| return rv;
|
| }
|
| @@ -204,8 +208,9 @@ ScopedMessagePipeHandle CreateChannel(
|
| },
|
| std::move(did_create_channel_runner));
|
|
|
| - ScopedMessagePipeHandle rv(
|
| - MessagePipeHandle(internal::g_core->AddDispatcher(dispatcher.get())));
|
| + ScopedMessagePipeHandle rv(MessagePipeHandle(internal::g_core->AddHandle(
|
| + system::Handle(std::move(dispatcher),
|
| + system::MessagePipeDispatcher::kDefaultHandleRights))));
|
| CHECK(rv.is_valid());
|
| return rv;
|
| }
|
|
|