blob: dc96dd19a1448f11347acc769e6f372270a16f99 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "base/lazy_instance.h"
#include "base/run_loop.h"
#include "ipc/ipc_perftest_support.h"
#include "ipc/mojo/ipc_channel_mojo.h"
#include "ipc/mojo/ipc_channel_mojo_host.h"
#include "third_party/mojo/src/mojo/edk/embedder/test_embedder.h"
namespace {
// This is needed because we rely on //base/test:test_support_perf and
// it provides main() which doesn't have Mojo initialization. We need
// some way to call InitWithSimplePlatformSupport() only once before
// using Mojo.
struct MojoInitialier {
MojoInitialier() {
mojo::embedder::test::InitWithSimplePlatformSupport();
}
};
base::LazyInstance<MojoInitialier> g_mojo_initializer
= LAZY_INSTANCE_INITIALIZER;
class MojoChannelPerfTest : public IPC::test::IPCChannelPerfTestBase {
public:
typedef IPC::test::IPCChannelPerfTestBase Super;
MojoChannelPerfTest();
void TearDown() override {
IPC::test::IPCChannelPerfTestBase::TearDown();
}
scoped_ptr<IPC::ChannelFactory> CreateChannelFactory(
const IPC::ChannelHandle& handle,
base::SequencedTaskRunner* runner) override {
host_.reset(new IPC::ChannelMojoHost(runner));
return IPC::ChannelMojo::CreateServerFactory(host_->channel_delegate(),
runner, handle);
}
bool DidStartClient() override {
bool ok = IPCTestBase::DidStartClient();
DCHECK(ok);
host_->OnClientLaunched(client_process().Handle());
return ok;
}
private:
scoped_ptr<IPC::ChannelMojoHost> host_;
};
MojoChannelPerfTest::MojoChannelPerfTest() {
g_mojo_initializer.Get();
}
TEST_F(MojoChannelPerfTest, ChannelPingPong) {
RunTestChannelPingPong(GetDefaultTestParams());
base::RunLoop run_loop;
run_loop.RunUntilIdle();
}
TEST_F(MojoChannelPerfTest, ChannelProxyPingPong) {
RunTestChannelProxyPingPong(GetDefaultTestParams());
base::RunLoop run_loop;
run_loop.RunUntilIdle();
}
class MojoTestClient : public IPC::test::PingPongTestClient {
public:
typedef IPC::test::PingPongTestClient SuperType;
MojoTestClient();
scoped_ptr<IPC::Channel> CreateChannel(IPC::Listener* listener) override;
};
MojoTestClient::MojoTestClient() {
g_mojo_initializer.Get();
}
scoped_ptr<IPC::Channel> MojoTestClient::CreateChannel(
IPC::Listener* listener) {
return scoped_ptr<IPC::Channel>(IPC::ChannelMojo::Create(
NULL, task_runner(), IPCTestBase::GetChannelName("PerformanceClient"),
IPC::Channel::MODE_CLIENT, listener));
}
MULTIPROCESS_IPC_TEST_CLIENT_MAIN(PerformanceClient) {
MojoTestClient client;
int rv = client.RunMain();
base::RunLoop run_loop;
run_loop.RunUntilIdle();
return rv;
}
} // namespace
|
