| Index: third_party/mojo/src/mojo/public/cpp/bindings/tests/binding_unittest.cc
|
| diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/tests/binding_unittest.cc b/third_party/mojo/src/mojo/public/cpp/bindings/tests/binding_unittest.cc
|
| index 59d250199812f8c00e2b76cb32d513144e9eaf76..ef232797a43cd12e79e8f7f55b4079c1d4b30a07 100644
|
| --- a/third_party/mojo/src/mojo/public/cpp/bindings/tests/binding_unittest.cc
|
| +++ b/third_party/mojo/src/mojo/public/cpp/bindings/tests/binding_unittest.cc
|
| @@ -2,13 +2,8 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -// Note: This file tests both binding.h (mojo::Binding) and strong_binding.h
|
| -// (mojo::StrongBinding).
|
| -
|
| #include "mojo/public/cpp/bindings/binding.h"
|
| -#include "mojo/public/cpp/bindings/strong_binding.h"
|
| #include "mojo/public/cpp/environment/environment.h"
|
| -#include "mojo/public/cpp/system/macros.h"
|
| #include "mojo/public/cpp/utility/run_loop.h"
|
| #include "mojo/public/interfaces/bindings/tests/sample_interfaces.mojom.h"
|
| #include "mojo/public/interfaces/bindings/tests/sample_service.mojom.h"
|
| @@ -17,28 +12,10 @@
|
| namespace mojo {
|
| namespace {
|
|
|
| -class BindingTestBase : public testing::Test {
|
| - public:
|
| - BindingTestBase() {}
|
| - ~BindingTestBase() override {}
|
| -
|
| - RunLoop& loop() { return loop_; }
|
| -
|
| - private:
|
| - Environment env_;
|
| - RunLoop loop_;
|
| -
|
| - MOJO_DISALLOW_COPY_AND_ASSIGN(BindingTestBase);
|
| -};
|
| -
|
| class ServiceImpl : public sample::Service {
|
| public:
|
| - explicit ServiceImpl(bool* was_deleted = nullptr)
|
| - : was_deleted_(was_deleted) {}
|
| - ~ServiceImpl() override {
|
| - if (was_deleted_)
|
| - *was_deleted_ = true;
|
| - }
|
| + ServiceImpl() {}
|
| + ~ServiceImpl() override {}
|
|
|
| private:
|
| // sample::Service implementation
|
| @@ -49,29 +26,30 @@
|
| callback.Run(1);
|
| }
|
| void GetPort(InterfaceRequest<sample::Port> port) override {}
|
| -
|
| - bool* const was_deleted_;
|
| -
|
| - MOJO_DISALLOW_COPY_AND_ASSIGN(ServiceImpl);
|
| };
|
|
|
| -// BindingTest -----------------------------------------------------------------
|
| +class IntegerAccessorImpl : public sample::IntegerAccessor {
|
| + public:
|
| + IntegerAccessorImpl() {}
|
| + ~IntegerAccessorImpl() override {}
|
|
|
| -using BindingTest = BindingTestBase;
|
| + private:
|
| + // sample::IntegerAccessor implementation.
|
| + void GetInteger(const GetIntegerCallback& callback) override {
|
| + callback.Run(1, sample::ENUM_VALUE);
|
| + }
|
| + void SetInteger(int64_t data, sample::Enum type) override {}
|
| +};
|
|
|
| -TEST_F(BindingTest, Close) {
|
| - bool called = false;
|
| - sample::ServicePtr ptr;
|
| - auto request = GetProxy(&ptr);
|
| - ptr.set_connection_error_handler([&called]() { called = true; });
|
| - ServiceImpl impl;
|
| - Binding<sample::Service> binding(&impl, request.Pass());
|
| +class BindingTest : public testing::Test {
|
| + public:
|
| + BindingTest() {}
|
| + ~BindingTest() override {}
|
|
|
| - binding.Close();
|
| - EXPECT_FALSE(called);
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(called);
|
| -}
|
| + protected:
|
| + Environment env_;
|
| + RunLoop loop_;
|
| +};
|
|
|
| // Tests that destroying a mojo::Binding closes the bound message pipe handle.
|
| TEST_F(BindingTest, DestroyClosesMessagePipe) {
|
| @@ -87,85 +65,21 @@
|
| Binding<sample::Service> binding(&impl, request.Pass());
|
| ptr->Frobinate(nullptr, sample::Service::BAZ_OPTIONS_REGULAR, nullptr,
|
| called_cb);
|
| - loop().RunUntilIdle();
|
| + loop_.RunUntilIdle();
|
| EXPECT_TRUE(called);
|
| EXPECT_FALSE(encountered_error);
|
| }
|
| // Now that the Binding is out of scope we should detect an error on the other
|
| // end of the pipe.
|
| - loop().RunUntilIdle();
|
| + loop_.RunUntilIdle();
|
| EXPECT_TRUE(encountered_error);
|
|
|
| // And calls should fail.
|
| called = false;
|
| ptr->Frobinate(nullptr, sample::Service::BAZ_OPTIONS_REGULAR, nullptr,
|
| called_cb);
|
| - loop().RunUntilIdle();
|
| + loop_.RunUntilIdle();
|
| EXPECT_FALSE(called);
|
| -}
|
| -
|
| -// Tests that the binding's connection error handler gets called when the other
|
| -// end is closed.
|
| -TEST_F(BindingTest, ConnectionError) {
|
| - bool called = false;
|
| - {
|
| - ServiceImpl impl;
|
| - sample::ServicePtr ptr;
|
| - Binding<sample::Service> binding(&impl, GetProxy(&ptr));
|
| - binding.set_connection_error_handler([&called]() { called = true; });
|
| - ptr.reset();
|
| - EXPECT_FALSE(called);
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(called);
|
| - // We want to make sure that it isn't called again during destruction.
|
| - called = false;
|
| - }
|
| - EXPECT_FALSE(called);
|
| -}
|
| -
|
| -// Tests that calling Close doesn't result in the connection error handler being
|
| -// called.
|
| -TEST_F(BindingTest, CloseDoesntCallConnectionErrorHandler) {
|
| - ServiceImpl impl;
|
| - sample::ServicePtr ptr;
|
| - Binding<sample::Service> binding(&impl, GetProxy(&ptr));
|
| - bool called = false;
|
| - binding.set_connection_error_handler([&called]() { called = true; });
|
| - binding.Close();
|
| - loop().RunUntilIdle();
|
| - EXPECT_FALSE(called);
|
| -
|
| - // We can also close the other end, and the error handler still won't be
|
| - // called.
|
| - ptr.reset();
|
| - loop().RunUntilIdle();
|
| - EXPECT_FALSE(called);
|
| -}
|
| -
|
| -class ServiceImplWithBinding : public ServiceImpl {
|
| - public:
|
| - ServiceImplWithBinding(bool* was_deleted,
|
| - InterfaceRequest<sample::Service> request)
|
| - : ServiceImpl(was_deleted), binding_(this, request.Pass()) {
|
| - binding_.set_connection_error_handler([this]() { delete this; });
|
| - }
|
| -
|
| - private:
|
| - Binding<sample::Service> binding_;
|
| -
|
| - MOJO_DISALLOW_COPY_AND_ASSIGN(ServiceImplWithBinding);
|
| -};
|
| -
|
| -// Tests that the binding may be deleted in the connection error handler.
|
| -TEST_F(BindingTest, SelfDeleteOnConnectionError) {
|
| - bool was_deleted = false;
|
| - sample::ServicePtr ptr;
|
| - // This should delete itself on connection error.
|
| - new ServiceImplWithBinding(&was_deleted, GetProxy(&ptr));
|
| - ptr.reset();
|
| - EXPECT_FALSE(was_deleted);
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(was_deleted);
|
| }
|
|
|
| // Tests that explicitly calling Unbind followed by rebinding works.
|
| @@ -178,7 +92,7 @@
|
| auto called_cb = [&called](int32_t result) { called = true; };
|
| ptr->Frobinate(nullptr, sample::Service::BAZ_OPTIONS_REGULAR, nullptr,
|
| called_cb);
|
| - loop().RunUntilIdle();
|
| + loop_.RunUntilIdle();
|
| EXPECT_TRUE(called);
|
|
|
| called = false;
|
| @@ -187,7 +101,7 @@
|
| // All calls should fail when not bound...
|
| ptr->Frobinate(nullptr, sample::Service::BAZ_OPTIONS_REGULAR, nullptr,
|
| called_cb);
|
| - loop().RunUntilIdle();
|
| + loop_.RunUntilIdle();
|
| EXPECT_FALSE(called);
|
|
|
| called = false;
|
| @@ -196,24 +110,9 @@
|
| // ...and should succeed again when the rebound.
|
| ptr->Frobinate(nullptr, sample::Service::BAZ_OPTIONS_REGULAR, nullptr,
|
| called_cb);
|
| - loop().RunUntilIdle();
|
| + loop_.RunUntilIdle();
|
| EXPECT_TRUE(called);
|
| }
|
| -
|
| -class IntegerAccessorImpl : public sample::IntegerAccessor {
|
| - public:
|
| - IntegerAccessorImpl() {}
|
| - ~IntegerAccessorImpl() override {}
|
| -
|
| - private:
|
| - // sample::IntegerAccessor implementation.
|
| - void GetInteger(const GetIntegerCallback& callback) override {
|
| - callback.Run(1, sample::ENUM_VALUE);
|
| - }
|
| - void SetInteger(int64_t data, sample::Enum type) override {}
|
| -
|
| - MOJO_DISALLOW_COPY_AND_ASSIGN(IntegerAccessorImpl);
|
| -};
|
|
|
| TEST_F(BindingTest, SetInterfacePtrVersion) {
|
| IntegerAccessorImpl impl;
|
| @@ -222,102 +121,5 @@
|
| EXPECT_EQ(3u, ptr.version());
|
| }
|
|
|
| -// StrongBindingTest -----------------------------------------------------------
|
| -
|
| -using StrongBindingTest = BindingTestBase;
|
| -
|
| -// Tests that destroying a mojo::StrongBinding closes the bound message pipe
|
| -// handle but does *not* destroy the implementation object.
|
| -TEST_F(StrongBindingTest, DestroyClosesMessagePipe) {
|
| - bool encountered_error = false;
|
| - bool was_deleted = false;
|
| - ServiceImpl impl(&was_deleted);
|
| - sample::ServicePtr ptr;
|
| - auto request = GetProxy(&ptr);
|
| - ptr.set_connection_error_handler(
|
| - [&encountered_error]() { encountered_error = true; });
|
| - bool called = false;
|
| - auto called_cb = [&called](int32_t result) { called = true; };
|
| - {
|
| - StrongBinding<sample::Service> binding(&impl, request.Pass());
|
| - ptr->Frobinate(nullptr, sample::Service::BAZ_OPTIONS_REGULAR, nullptr,
|
| - called_cb);
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(called);
|
| - EXPECT_FALSE(encountered_error);
|
| - }
|
| - // Now that the StrongBinding is out of scope we should detect an error on the
|
| - // other end of the pipe.
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(encountered_error);
|
| - // But destroying the StrongBinding doesn't destroy the object.
|
| - ASSERT_FALSE(was_deleted);
|
| -}
|
| -
|
| -class ServiceImplWithStrongBinding : public ServiceImpl {
|
| - public:
|
| - ServiceImplWithStrongBinding(bool* was_deleted,
|
| - InterfaceRequest<sample::Service> request)
|
| - : ServiceImpl(was_deleted), binding_(this, request.Pass()) {}
|
| -
|
| - StrongBinding<sample::Service>& binding() { return binding_; }
|
| -
|
| - private:
|
| - StrongBinding<sample::Service> binding_;
|
| -
|
| - MOJO_DISALLOW_COPY_AND_ASSIGN(ServiceImplWithStrongBinding);
|
| -};
|
| -
|
| -// Tests the typical case, where the implementation object owns the
|
| -// StrongBinding (and should be destroyed on connection error).
|
| -TEST_F(StrongBindingTest, ConnectionErrorDestroysImpl) {
|
| - sample::ServicePtr ptr;
|
| - bool was_deleted = false;
|
| - // Will delete itself.
|
| - new ServiceImplWithBinding(&was_deleted, GetProxy(&ptr));
|
| -
|
| - loop().RunUntilIdle();
|
| - EXPECT_FALSE(was_deleted);
|
| -
|
| - ptr.reset();
|
| - EXPECT_FALSE(was_deleted);
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(was_deleted);
|
| -}
|
| -
|
| -// Tests that even when the implementation object owns the StrongBinding, that
|
| -// the implementation can still be deleted (which should result in the message
|
| -// pipe being closed). Also checks that the connection error handler doesn't get
|
| -// called.
|
| -TEST_F(StrongBindingTest, ExplicitDeleteImpl) {
|
| - bool ptr_error_handler_called = false;
|
| - sample::ServicePtr ptr;
|
| - auto request = GetProxy(&ptr);
|
| - ptr.set_connection_error_handler(
|
| - [&ptr_error_handler_called]() { ptr_error_handler_called = true; });
|
| - bool was_deleted = false;
|
| - ServiceImplWithStrongBinding* impl =
|
| - new ServiceImplWithStrongBinding(&was_deleted, request.Pass());
|
| - bool binding_error_handler_called = false;
|
| - impl->binding().set_connection_error_handler(
|
| - [&binding_error_handler_called]() {
|
| - binding_error_handler_called = true;
|
| - });
|
| -
|
| - loop().RunUntilIdle();
|
| - EXPECT_FALSE(ptr_error_handler_called);
|
| - EXPECT_FALSE(was_deleted);
|
| -
|
| - delete impl;
|
| - EXPECT_FALSE(ptr_error_handler_called);
|
| - EXPECT_TRUE(was_deleted);
|
| - was_deleted = false; // It shouldn't be double-deleted!
|
| - loop().RunUntilIdle();
|
| - EXPECT_TRUE(ptr_error_handler_called);
|
| - EXPECT_FALSE(was_deleted);
|
| -
|
| - EXPECT_FALSE(binding_error_handler_called);
|
| -}
|
| -
|
| } // namespace
|
| } // mojo
|
|
|