| Index: third_party/mojo/src/mojo/edk/system/channel_manager_unittest.cc
|
| diff --git a/third_party/mojo/src/mojo/edk/system/channel_manager_unittest.cc b/third_party/mojo/src/mojo/edk/system/channel_manager_unittest.cc
|
| index 86ab4a0adf1274fb762bfe395d2897008b989cf8..c5aa503789c747f5daabaf630f97499124bb8b88 100644
|
| --- a/third_party/mojo/src/mojo/edk/system/channel_manager_unittest.cc
|
| +++ b/third_party/mojo/src/mojo/edk/system/channel_manager_unittest.cc
|
| @@ -48,9 +48,12 @@
|
|
|
| embedder::PlatformChannelPair channel_pair;
|
|
|
| + scoped_refptr<ChannelEndpoint> cep;
|
| + scoped_refptr<MessagePipeDispatcher> d =
|
| + MessagePipeDispatcher::CreateRemoteMessagePipe(&cep);
|
| const ChannelId id = 1;
|
| - scoped_refptr<MessagePipeDispatcher> d =
|
| - cm.CreateChannelOnIOThread(id, channel_pair.PassServerHandle());
|
| + cm.CreateChannelOnIOThread(id, channel_pair.PassServerHandle(), cep);
|
| + cep = nullptr;
|
|
|
| scoped_refptr<Channel> ch = cm.GetChannel(id);
|
| EXPECT_TRUE(ch);
|
| @@ -74,13 +77,19 @@
|
|
|
| embedder::PlatformChannelPair channel_pair;
|
|
|
| + scoped_refptr<ChannelEndpoint> cep1;
|
| + scoped_refptr<MessagePipeDispatcher> d1 =
|
| + MessagePipeDispatcher::CreateRemoteMessagePipe(&cep1);
|
| const ChannelId id1 = 1;
|
| - scoped_refptr<MessagePipeDispatcher> d1 =
|
| - cm.CreateChannelOnIOThread(id1, channel_pair.PassServerHandle());
|
| + cm.CreateChannelOnIOThread(id1, channel_pair.PassServerHandle(), cep1);
|
| + cep1 = nullptr;
|
|
|
| + scoped_refptr<ChannelEndpoint> cep2;
|
| + scoped_refptr<MessagePipeDispatcher> d2 =
|
| + MessagePipeDispatcher::CreateRemoteMessagePipe(&cep2);
|
| const ChannelId id2 = 2;
|
| - scoped_refptr<MessagePipeDispatcher> d2 =
|
| - cm.CreateChannelOnIOThread(id2, channel_pair.PassClientHandle());
|
| + cm.CreateChannelOnIOThread(id2, channel_pair.PassClientHandle(), cep2);
|
| + cep2 = nullptr;
|
|
|
| scoped_refptr<Channel> ch1 = cm.GetChannel(id1);
|
| EXPECT_TRUE(ch1);
|
| @@ -164,9 +173,12 @@
|
|
|
| embedder::PlatformChannelPair channel_pair;
|
|
|
| + scoped_refptr<ChannelEndpoint> cep;
|
| + scoped_refptr<MessagePipeDispatcher> d =
|
| + MessagePipeDispatcher::CreateRemoteMessagePipe(&cep);
|
| const ChannelId id = 1;
|
| - scoped_refptr<MessagePipeDispatcher> d =
|
| - cm.CreateChannelOnIOThread(id, channel_pair.PassServerHandle());
|
| + cm.CreateChannelOnIOThread(id, channel_pair.PassServerHandle(), cep);
|
| + cep = nullptr;
|
|
|
| base::RunLoop run_loop;
|
| OtherThread thread(base::MessageLoopProxy::current(), &cm, id,
|
|
|