| Index: mojo/system/channel_unittest.cc
|
| diff --git a/mojo/system/channel_unittest.cc b/mojo/system/channel_unittest.cc
|
| index 18329a853f107bdf355250086f4bdbd4627fdc24..e7100968ca432820fe57481f5603124dc5ada0b0 100644
|
| --- a/mojo/system/channel_unittest.cc
|
| +++ b/mojo/system/channel_unittest.cc
|
| @@ -194,10 +194,12 @@ TEST_F(ChannelTest, CloseBeforeRun) {
|
| base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
|
| EXPECT_EQ(TRISTATE_TRUE, init_result());
|
|
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalProxy());
|
| + scoped_refptr<ChannelEndpoint> channel_endpoint;
|
| + scoped_refptr<MessagePipe> mp(
|
| + MessagePipe::CreateLocalProxy(&channel_endpoint));
|
|
|
| - MessageInTransit::EndpointId local_id = channel()->AttachEndpoint(
|
| - make_scoped_refptr(new ChannelEndpoint(mp.get(), 1)));
|
| + MessageInTransit::EndpointId local_id =
|
| + channel()->AttachEndpoint(channel_endpoint);
|
| EXPECT_EQ(Channel::kBootstrapEndpointId, local_id);
|
|
|
| mp->Close(0);
|
| @@ -232,10 +234,12 @@ TEST_F(ChannelTest, ShutdownAfterAttach) {
|
| base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
|
| EXPECT_EQ(TRISTATE_TRUE, init_result());
|
|
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalProxy());
|
| + scoped_refptr<ChannelEndpoint> channel_endpoint;
|
| + scoped_refptr<MessagePipe> mp(
|
| + MessagePipe::CreateLocalProxy(&channel_endpoint));
|
|
|
| - MessageInTransit::EndpointId local_id = channel()->AttachEndpoint(
|
| - make_scoped_refptr(new ChannelEndpoint(mp.get(), 1)));
|
| + MessageInTransit::EndpointId local_id =
|
| + channel()->AttachEndpoint(channel_endpoint);
|
| EXPECT_EQ(Channel::kBootstrapEndpointId, local_id);
|
|
|
| // TODO(vtl): Currently, we always "expect" a |RunMessagePipeEndpoint()| after
|
| @@ -282,10 +286,12 @@ TEST_F(ChannelTest, WaitAfterAttachRunAndShutdown) {
|
| base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
|
| EXPECT_EQ(TRISTATE_TRUE, init_result());
|
|
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalProxy());
|
| + scoped_refptr<ChannelEndpoint> channel_endpoint;
|
| + scoped_refptr<MessagePipe> mp(
|
| + MessagePipe::CreateLocalProxy(&channel_endpoint));
|
|
|
| - MessageInTransit::EndpointId local_id = channel()->AttachEndpoint(
|
| - make_scoped_refptr(new ChannelEndpoint(mp.get(), 1)));
|
| + MessageInTransit::EndpointId local_id =
|
| + channel()->AttachEndpoint(channel_endpoint);
|
| EXPECT_EQ(Channel::kBootstrapEndpointId, local_id);
|
|
|
| EXPECT_TRUE(channel()->RunMessagePipeEndpoint(local_id,
|
|
|