Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(687)

Unified Diff: ipc/ipc_channel_mojo_unittest.cc

Issue 2653973002: Remove associated interface registration from ChannelProxy (Closed)
Patch Set: Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « content/renderer/render_thread_impl.cc ('k') | ipc/ipc_channel_proxy.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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;
« no previous file with comments | « content/renderer/render_thread_impl.cc ('k') | ipc/ipc_channel_proxy.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698