blob: 29e78397ce2b30397826b304c00e2d9a7f17390a (
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
|
// 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 "ipc/ipc_perftest_support.h"
#include "ipc/mojo/ipc_channel_mojo.h"
#include "ipc/mojo/ipc_channel_mojo_host.h"
#include "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();
scoped_ptr<IPC::ChannelFactory> CreateChannelFactory(
const IPC::ChannelHandle& handle,
base::TaskRunner* runner) override {
host_.reset(new IPC::ChannelMojoHost(task_runner()));
return IPC::ChannelMojo::CreateServerFactory(host_->channel_delegate(),
handle);
}
bool DidStartClient() override {
bool ok = IPCTestBase::DidStartClient();
DCHECK(ok);
host_->OnClientLaunched(client_process());
return ok;
}
void set_io_thread_task_runner(base::TaskRunner* runner) {
io_thread_task_runner_ = runner;
}
private:
base::TaskRunner* io_thread_task_runner_;
scoped_ptr<IPC::ChannelMojoHost> host_;
};
MojoChannelPerfTest::MojoChannelPerfTest()
: io_thread_task_runner_() {
g_mojo_initializer.Get();
}
TEST_F(MojoChannelPerfTest, ChannelPingPong) {
RunTestChannelPingPong(GetDefaultTestParams());
}
TEST_F(MojoChannelPerfTest, ChannelProxyPingPong) {
RunTestChannelProxyPingPong(GetDefaultTestParams());
}
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,
IPCTestBase::GetChannelName("PerformanceClient"),
IPC::Channel::MODE_CLIENT,
listener));
}
MULTIPROCESS_IPC_TEST_CLIENT_MAIN(PerformanceClient) {
MojoTestClient client;
return client.RunMain();
}
} // namespace
|
