diff options
Diffstat (limited to 'mojo/public/cpp/bindings/tests/bindings_perftest.cc')
| -rw-r--r-- | mojo/public/cpp/bindings/tests/bindings_perftest.cc | 155 |
1 files changed, 151 insertions, 4 deletions
diff --git a/mojo/public/cpp/bindings/tests/bindings_perftest.cc b/mojo/public/cpp/bindings/tests/bindings_perftest.cc index db0dd05..6a50de4 100644 --- a/mojo/public/cpp/bindings/tests/bindings_perftest.cc +++ b/mojo/public/cpp/bindings/tests/bindings_perftest.cc @@ -8,7 +8,13 @@ #include "base/bind.h" #include "base/message_loop/message_loop.h" #include "base/run_loop.h" +#include "base/threading/thread_task_runner_handle.h" +#include "base/time/time.h" #include "mojo/public/cpp/bindings/binding.h" +#include "mojo/public/cpp/bindings/interface_endpoint_client.h" +#include "mojo/public/cpp/bindings/lib/message_builder.h" +#include "mojo/public/cpp/bindings/lib/multiplex_router.h" +#include "mojo/public/cpp/bindings/message.h" #include "mojo/public/cpp/test_support/test_support.h" #include "mojo/public/cpp/test_support/test_utils.h" #include "mojo/public/interfaces/bindings/tests/ping_service.mojom.h" @@ -81,9 +87,7 @@ void PingPongTest::OnPingDone() { } struct BoundPingService { - BoundPingService() : binding(&impl) { - binding.Bind(GetProxy(&service)); - } + BoundPingService() : binding(&impl) { binding.Bind(MakeRequest(&service)); } PingServiceImpl impl; test::PingServicePtr service; @@ -101,7 +105,7 @@ class MojoBindingsPerftest : public testing::Test { TEST_F(MojoBindingsPerftest, InProcessPingPong) { test::PingServicePtr service; PingServiceImpl impl; - Binding<test::PingService> binding(&impl, GetProxy(&service)); + Binding<test::PingService> binding(&impl, MakeRequest(&service)); PingPongTest test(std::move(service)); { @@ -133,5 +137,148 @@ TEST_F(MojoBindingsPerftest, InProcessPingPong) { } } +class PingPongPaddle : public MessageReceiverWithResponderStatus { + public: + PingPongPaddle(MessageReceiver* sender) : sender_(sender) {} + + void set_sender(MessageReceiver* sender) { sender_ = sender; } + + bool Accept(Message* message) override { + uint32_t count = message->header()->name; + if (!quit_closure_.is_null()) { + count++; + if (count >= expected_count_) { + end_time_ = base::TimeTicks::Now(); + quit_closure_.Run(); + return true; + } + } + + internal::MessageBuilder builder(count, 0, 8, 0); + bool result = sender_->Accept(builder.message()); + DCHECK(result); + return true; + } + + bool AcceptWithResponder(Message* message, + MessageReceiverWithStatus* responder) override { + NOTREACHED(); + return true; + } + + base::TimeDelta Serve(uint32_t expected_count) { + base::RunLoop run_loop; + + expected_count_ = expected_count; + quit_closure_ = run_loop.QuitClosure(); + + start_time_ = base::TimeTicks::Now(); + internal::MessageBuilder builder(0, 0, 8, 0); + bool result = sender_->Accept(builder.message()); + DCHECK(result); + + run_loop.Run(); + + return end_time_ - start_time_; + } + + private: + base::TimeTicks start_time_; + base::TimeTicks end_time_; + uint32_t expected_count_ = 0; + MessageReceiver* sender_; + base::Closure quit_closure_; +}; + +TEST_F(MojoBindingsPerftest, MultiplexRouterPingPong) { + MessagePipe pipe; + scoped_refptr<internal::MultiplexRouter> router0( + new internal::MultiplexRouter(std::move(pipe.handle0), + internal::MultiplexRouter::SINGLE_INTERFACE, + true, base::ThreadTaskRunnerHandle::Get())); + scoped_refptr<internal::MultiplexRouter> router1( + new internal::MultiplexRouter( + std::move(pipe.handle1), internal::MultiplexRouter::SINGLE_INTERFACE, + false, base::ThreadTaskRunnerHandle::Get())); + + PingPongPaddle paddle0(nullptr); + PingPongPaddle paddle1(nullptr); + + InterfaceEndpointClient client0( + router0->CreateLocalEndpointHandle(kMasterInterfaceId), &paddle0, nullptr, + false, base::ThreadTaskRunnerHandle::Get(), 0u); + InterfaceEndpointClient client1( + router1->CreateLocalEndpointHandle(kMasterInterfaceId), &paddle1, nullptr, + false, base::ThreadTaskRunnerHandle::Get(), 0u); + + paddle0.set_sender(&client0); + paddle1.set_sender(&client1); + + static const uint32_t kWarmUpIterations = 1000; + static const uint32_t kTestIterations = 1000000; + + paddle0.Serve(kWarmUpIterations); + + base::TimeDelta duration = paddle0.Serve(kTestIterations); + + test::LogPerfResult("MultiplexRouterPingPong", nullptr, + kTestIterations / duration.InSecondsF(), "pings/second"); +} + +class CounterReceiver : public MessageReceiverWithResponderStatus { + public: + bool Accept(Message* message) override { + counter_++; + return true; + } + + bool AcceptWithResponder(Message* message, + MessageReceiverWithStatus* responder) override { + NOTREACHED(); + return true; + } + + uint32_t counter() const { return counter_; } + + void Reset() { counter_ = 0; } + + private: + uint32_t counter_ = 0; +}; + +TEST_F(MojoBindingsPerftest, MultiplexRouterDispatchCost) { + MessagePipe pipe; + scoped_refptr<internal::MultiplexRouter> router(new internal::MultiplexRouter( + std::move(pipe.handle0), internal::MultiplexRouter::SINGLE_INTERFACE, + true, base::ThreadTaskRunnerHandle::Get())); + CounterReceiver receiver; + InterfaceEndpointClient client( + router->CreateLocalEndpointHandle(kMasterInterfaceId), &receiver, nullptr, + false, base::ThreadTaskRunnerHandle::Get(), 0u); + + static const uint32_t kIterations[] = {1000, 3000000}; + + for (size_t i = 0; i < 2; ++i) { + receiver.Reset(); + base::TimeTicks start_time = base::TimeTicks::Now(); + for (size_t j = 0; j < kIterations[i]; ++j) { + internal::MessageBuilder builder(0, 0, 8, 0); + bool result = + router->SimulateReceivingMessageForTesting(builder.message()); + DCHECK(result); + } + + base::TimeTicks end_time = base::TimeTicks::Now(); + base::TimeDelta duration = end_time - start_time; + CHECK_EQ(kIterations[i], receiver.counter()); + + if (i == 1) { + test::LogPerfResult("MultiplexRouterDispatchCost", nullptr, + kIterations[i] / duration.InSecondsF(), + "times/second"); + } + } +} + } // namespace } // namespace mojo |