Index: ipc/ipc_channel_mojo_unittest.cc |
diff --git a/ipc/ipc_channel_mojo_unittest.cc b/ipc/ipc_channel_mojo_unittest.cc |
index 9b28e39937ca3d2e041f3264133f8271642e4063..5e75fbd7cfd5b00ea06ca2544d566b3aea8eb49f 100644 |
--- a/ipc/ipc_channel_mojo_unittest.cc |
+++ b/ipc/ipc_channel_mojo_unittest.cc |
@@ -848,12 +848,17 @@ class ListenerWithIndirectProxyAssociatedInterface |
: driver_binding_(this), ping_receiver_binding_(this) {} |
~ListenerWithIndirectProxyAssociatedInterface() override {} |
+ // IPC::Listener: |
bool OnMessageReceived(const IPC::Message& message) override { return true; } |
- void RegisterInterfaceFactory(IPC::ChannelProxy* proxy) { |
- proxy->AddAssociatedInterface( |
- base::Bind(&ListenerWithIndirectProxyAssociatedInterface::BindRequest, |
- base::Unretained(this))); |
+ void OnAssociatedInterfaceRequest( |
+ const std::string& interface_name, |
+ mojo::ScopedInterfaceEndpointHandle handle) override { |
+ DCHECK(!driver_binding_.is_bound()); |
+ DCHECK_EQ(interface_name, IPC::mojom::IndirectTestDriver::Name_); |
+ IPC::mojom::IndirectTestDriverAssociatedRequest request; |
+ request.Bind(std::move(handle)); |
+ driver_binding_.Bind(std::move(request)); |
} |
void set_ping_handler(const base::Closure& handler) { |
@@ -873,11 +878,6 @@ class ListenerWithIndirectProxyAssociatedInterface |
ping_handler_.Run(); |
} |
- void BindRequest(IPC::mojom::IndirectTestDriverAssociatedRequest request) { |
- DCHECK(!driver_binding_.is_bound()); |
- driver_binding_.Bind(std::move(request)); |
- } |
- |
mojo::AssociatedBinding<IPC::mojom::IndirectTestDriver> driver_binding_; |
mojo::AssociatedBinding<IPC::mojom::PingReceiver> ping_receiver_binding_; |
@@ -893,7 +893,6 @@ TEST_F(IPCChannelProxyMojoTest, ProxyThreadAssociatedInterfaceIndirect) { |
ListenerWithIndirectProxyAssociatedInterface listener; |
CreateProxy(&listener); |
- listener.RegisterInterfaceFactory(proxy()); |
RunProxy(); |
base::RunLoop loop; |
@@ -939,12 +938,6 @@ class ListenerWithSyncAssociatedInterface |
void set_sync_sender(IPC::Sender* sync_sender) { sync_sender_ = sync_sender; } |
- void RegisterInterfaceFactory(IPC::ChannelProxy* proxy) { |
- proxy->AddAssociatedInterface( |
- base::Bind(&ListenerWithSyncAssociatedInterface::BindRequest, |
- base::Unretained(this))); |
- } |
- |
void RunUntilQuitRequested() { |
base::RunLoop loop; |
quit_closure_ = loop.QuitClosure(); |
@@ -989,6 +982,17 @@ class ListenerWithSyncAssociatedInterface |
return true; |
} |
+ void OnAssociatedInterfaceRequest( |
+ const std::string& interface_name, |
+ mojo::ScopedInterfaceEndpointHandle handle) override { |
+ DCHECK(!binding_.is_bound()); |
+ DCHECK_EQ(interface_name, IPC::mojom::SimpleTestDriver::Name_); |
+ |
+ IPC::mojom::SimpleTestDriverAssociatedRequest request; |
+ request.Bind(std::move(handle)); |
+ binding_.Bind(std::move(request)); |
+ } |
+ |
void BindRequest(IPC::mojom::SimpleTestDriverAssociatedRequest request) { |
DCHECK(!binding_.is_bound()); |
binding_.Bind(std::move(request)); |
@@ -1027,7 +1031,6 @@ TEST_F(IPCChannelProxyMojoTest, SyncAssociatedInterface) { |
ListenerWithSyncAssociatedInterface listener; |
CreateProxy(&listener); |
listener.set_sync_sender(proxy()); |
- listener.RegisterInterfaceFactory(proxy()); |
RunProxy(); |
// Run the client's simple sanity check to completion. |
@@ -1071,11 +1074,6 @@ class SimpleTestClientImpl : public IPC::mojom::SimpleTestClient, |
void set_driver(IPC::mojom::SimpleTestDriver* driver) { driver_ = driver; } |
void set_sync_sender(IPC::Sender* sync_sender) { sync_sender_ = sync_sender; } |
- void BindRequest(IPC::mojom::SimpleTestClientAssociatedRequest request) { |
- DCHECK(!binding_.is_bound()); |
- binding_.Bind(std::move(request)); |
- } |
- |
void WaitForValueRequest() { |
run_loop_.reset(new base::RunLoop); |
run_loop_->Run(); |
@@ -1119,6 +1117,17 @@ class SimpleTestClientImpl : public IPC::mojom::SimpleTestClient, |
return true; |
} |
+ void OnAssociatedInterfaceRequest( |
+ const std::string& interface_name, |
+ mojo::ScopedInterfaceEndpointHandle handle) override { |
+ DCHECK(!binding_.is_bound()); |
+ DCHECK_EQ(interface_name, IPC::mojom::SimpleTestClient::Name_); |
+ |
+ IPC::mojom::SimpleTestClientAssociatedRequest request; |
+ request.Bind(std::move(handle)); |
+ binding_.Bind(std::move(request)); |
+ } |
+ |
bool use_sync_sender_ = false; |
mojo::AssociatedBinding<IPC::mojom::SimpleTestClient> binding_; |
IPC::Sender* sync_sender_ = nullptr; |
@@ -1133,8 +1142,6 @@ DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT_WITH_CUSTOM_FIXTURE(SyncAssociatedInterface, |
SimpleTestClientImpl client_impl; |
CreateProxy(&client_impl); |
client_impl.set_sync_sender(proxy()); |
- proxy()->AddAssociatedInterface(base::Bind(&SimpleTestClientImpl::BindRequest, |
- base::Unretained(&client_impl))); |
RunProxy(); |
IPC::mojom::SimpleTestDriverAssociatedPtr driver; |