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
|
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 1996-2021. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions and
%% limitations under the License.
%%
%% %CopyrightEnd%
%%
-module(pool_SUITE).
-export([all/0, suite/0,groups/0,init_per_suite/1, end_per_suite/1,
init_per_group/2,end_per_group/2]).
-export([basic/1, link_race/1, echo/1]).
-include_lib("common_test/include/ct.hrl").
suite() -> [{ct_hooks,[{ts_install_cth,[{nodenames, 1}]}]}].
all() ->
[basic, link_race].
groups() ->
[].
init_per_suite(Config) ->
Config.
end_per_suite(_Config) ->
ok.
init_per_group(_GroupName, Config) ->
Config.
end_per_group(_GroupName, Config) ->
Config.
basic(Config) ->
{ok, Peer, Node, PoolNode} = init_pool(?FUNCTION_NAME, basic, Config),
Node = rpc:call(Node, pool, get_node, []),
PoolNode = rpc:call(Node, pool, get_node, []),
do_echo(Node),
do_echo(Node),
peer:stop(Peer),
ok.
link_race(Config) ->
{ok, Peer, Node, PoolNode} = init_pool(?FUNCTION_NAME, basic, Config),
Node = rpc:call(Node, pool, get_node, []),
PoolNode = rpc:call(Node, pool, get_node, []),
rpc:call(Node, pool, pspawn_link, [erlang, is_atom, [?MODULE]]),
peer:stop(Peer),
ok.
do_echo(Node) ->
EchoPid = rpc:call(Node, pool, pspawn, [?MODULE, echo, [self()]]),
Ref = EchoPid ! make_ref(),
receive Ref -> ok after 1000 -> ct:fail(receive M -> M after 0 -> timeout end) end.
echo(Parent) ->
receive Msg ->
Parent ! Msg
end.
init_pool(Case, Name, Config) ->
PrivDir = proplists:get_value(priv_dir, Config),
{ok, Peer, Node} = ?CT_PEER(#{name => Case}),
{ok, Hostname} = inet:gethostname(),
file:write_file(filename:join(PrivDir,".hosts.erlang"),"'"++Hostname++"'.\n"),
ok = rpc:call(Node, file, set_cwd, [PrivDir]),
[PoolNode] = rpc:call(Node, pool, start, [Name]),
Nodes = rpc:call(Node, pool, get_nodes, []),
[rpc:call(N, code, add_patha, [filename:dirname(code:which(?MODULE))]) || N <- Nodes],
{ok, Peer, Node, PoolNode}.
|
