123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401 |
- -module(syn_groups_SUITE).
- -export([all/0]).
- -export([init_per_suite/1, end_per_suite/1]).
- -export([groups/0, init_per_group/2, end_per_group/2]).
- -export([init_per_testcase/2, end_per_testcase/2]).
- -export([
- single_node_leave/1,
- single_node_kill/1,
- single_node_publish/1,
- single_node_multi_call/1
- ]).
- -export([
- two_nodes_kill/1,
- two_nodes_publish/1,
- two_nodes_multi_call/1
- ]).
- -export([recipient_loop/1]).
- -export([called_loop/1]).
- -include_lib("common_test/include/ct.hrl").
- all() ->
- [
- {group, single_node_process_groups},
- {group, two_nodes_process_groups}
- ].
- groups() ->
- [
- {single_node_process_groups, [shuffle], [
- single_node_leave,
- single_node_kill,
- single_node_publish,
- single_node_multi_call
- ]},
- {two_nodes_process_groups, [shuffle], [
- two_nodes_kill,
- two_nodes_publish,
- two_nodes_multi_call
- ]}
- ].
- init_per_suite(Config) ->
-
- [
- {slave_node_short_name, syn_slave}
- | Config
- ].
- end_per_suite(_Config) -> ok.
- init_per_group(two_nodes_process_groups, Config) ->
-
- SlaveNodeShortName = proplists:get_value(slave_node_short_name, Config),
- {ok, SlaveNode} = syn_test_suite_helper:start_slave(SlaveNodeShortName),
-
- [
- {slave_node, SlaveNode}
- | Config
- ];
- init_per_group(_GroupName, Config) -> Config.
- end_per_group(two_nodes_process_groups, Config) ->
-
- SlaveNodeShortName = proplists:get_value(slave_node_short_name, Config),
-
- syn_test_suite_helper:stop_slave(SlaveNodeShortName);
- end_per_group(_GroupName, _Config) ->
- ok.
- init_per_testcase(_TestCase, Config) ->
- Config.
- end_per_testcase(_TestCase, Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
- syn_test_suite_helper:clean_after_test(SlaveNode).
- single_node_leave(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
-
- [] = syn:get_members(<<"my group">>),
- false = syn:member(Pid, <<"my group">>),
-
- ok = syn:join(<<"my group">>, Pid),
-
- [Pid] = syn:get_members(<<"my group">>),
- true = syn:member(Pid, <<"my group">>),
-
- ok = syn:leave(<<"my group">>, Pid),
-
- [] = syn:get_members(<<"my group">>),
- false = syn:member(Pid, <<"my group">>),
-
- syn_test_suite_helper:kill_process(Pid).
- single_node_kill(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
-
- [] = syn:get_members(<<"my group">>),
- false = syn:member(Pid, <<"my group">>),
-
- ok = syn:join(<<"my group">>, Pid),
-
- [Pid] = syn:get_members(<<"my group">>),
- true = syn:member(Pid, <<"my group">>),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- [] = syn:get_members(<<"my group">>),
- false = syn:member(Pid, <<"my group">>).
- single_node_publish(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- ResultPid = self(),
- F = fun() -> recipient_loop(ResultPid) end,
- Pid1 = syn_test_suite_helper:start_process(F),
- Pid2 = syn_test_suite_helper:start_process(F),
-
- ok = syn:join(<<"my group">>, Pid1),
- ok = syn:join(<<"my group">>, Pid2),
-
- syn:publish(<<"my group">>, {test, message}),
-
- receive
- {received, Pid1, {test, message}} -> ok
- after 2000 ->
- ok = published_message_was_not_received_by_pid1
- end,
- receive
- {received, Pid2, {test, message}} -> ok
- after 2000 ->
- ok = published_message_was_not_received_by_pid2
- end,
-
- syn_test_suite_helper:kill_process(Pid1),
- syn_test_suite_helper:kill_process(Pid2).
- single_node_multi_call(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid1 = syn_test_suite_helper:start_process(fun() -> called_loop(pid1) end),
- Pid2 = syn_test_suite_helper:start_process(fun() -> called_loop(pid2) end),
- PidUnresponsive = syn_test_suite_helper:start_process(),
-
- ok = syn:join(<<"my group">>, Pid1),
- ok = syn:join(<<"my group">>, Pid2),
- ok = syn:join(<<"my group">>, PidUnresponsive),
-
- {Replies, BadPids} = syn:multi_call(<<"my group">>, get_pid_name),
-
- 2 = length(Replies),
- pid1 = proplists:get_value(Pid1, Replies),
- pid2 = proplists:get_value(Pid2, Replies),
- [PidUnresponsive] = BadPids,
-
- syn_test_suite_helper:kill_process(Pid1),
- syn_test_suite_helper:kill_process(Pid2),
- syn_test_suite_helper:kill_process(PidUnresponsive).
- two_nodes_kill(Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
-
- application:set_env(mnesia, schema_location, ram),
- rpc:call(SlaveNode, mnesia, schema_location, [ram]),
-
- ok = syn:start(),
- ok = syn:init(),
- ok = rpc:call(SlaveNode, syn, start, []),
- ok = rpc:call(SlaveNode, syn, init, []),
- timer:sleep(100),
-
- PidLocal = syn_test_suite_helper:start_process(),
- PidSlave = syn_test_suite_helper:start_process(SlaveNode),
-
- [] = syn:get_members(<<"my group">>),
- false = syn:member(PidLocal, <<"my group">>),
- false = syn:member(PidSlave, <<"my group">>),
- [] = rpc:call(SlaveNode, syn, get_members, [<<"my group">>]),
- false = rpc:call(SlaveNode, syn, member, [PidLocal, <<"my group">>]),
- false = rpc:call(SlaveNode, syn, member, [PidSlave, <<"my group">>]),
-
- ok = syn:join(<<"my group">>, PidSlave),
- ok = rpc:call(SlaveNode, syn, join, [<<"my group">>, PidLocal]),
-
- [PidSlave, PidLocal] = syn:get_members(<<"my group">>),
- [PidSlave, PidLocal] = rpc:call(SlaveNode, syn, get_members, [<<"my group">>]),
-
- syn_test_suite_helper:kill_process(PidLocal),
- syn_test_suite_helper:kill_process(PidSlave),
- timer:sleep(100),
-
- [] = syn:get_members(<<"my group">>),
- false = syn:member(PidLocal, <<"my group">>),
- false = syn:member(PidSlave, <<"my group">>),
- [] = rpc:call(SlaveNode, syn, get_members, [<<"my group">>]),
- false = rpc:call(SlaveNode, syn, member, [PidLocal, <<"my group">>]),
- false = rpc:call(SlaveNode, syn, member, [PidSlave, <<"my group">>]).
- two_nodes_publish(Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
-
- application:set_env(mnesia, schema_location, ram),
- rpc:call(SlaveNode, mnesia, schema_location, [ram]),
-
- ok = syn:start(),
- ok = syn:init(),
- ok = rpc:call(SlaveNode, syn, start, []),
- ok = rpc:call(SlaveNode, syn, init, []),
- timer:sleep(100),
-
- ResultPid = self(),
- F = fun() -> recipient_loop(ResultPid) end,
- PidLocal = syn_test_suite_helper:start_process(F),
- PidSlave = syn_test_suite_helper:start_process(SlaveNode, F),
-
- ok = syn:join(<<"my group">>, PidSlave),
- ok = rpc:call(SlaveNode, syn, join, [<<"my group">>, PidLocal]),
-
- syn:publish(<<"my group">>, {test, message}),
-
- receive
- {received, PidLocal, {test, message}} -> ok
- after 2000 ->
- ok = published_message_was_not_received_by_pidlocal
- end,
- receive
- {received, PidSlave, {test, message}} -> ok
- after 2000 ->
- ok = published_message_was_not_received_by_pidslave
- end,
-
- syn_test_suite_helper:kill_process(PidLocal),
- syn_test_suite_helper:kill_process(PidSlave).
- two_nodes_multi_call(Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
-
- application:set_env(mnesia, schema_location, ram),
- rpc:call(SlaveNode, mnesia, schema_location, [ram]),
-
- ok = syn:start(),
- ok = syn:init(),
- ok = rpc:call(SlaveNode, syn, start, []),
- ok = rpc:call(SlaveNode, syn, init, []),
- timer:sleep(100),
-
- PidLocal = syn_test_suite_helper:start_process(fun() -> called_loop(pid1) end),
- PidSlave = syn_test_suite_helper:start_process(SlaveNode, fun() -> called_loop(pid2) end),
- PidUnresponsive = syn_test_suite_helper:start_process(),
-
- ok = syn:join(<<"my group">>, PidLocal),
- ok = syn:join(<<"my group">>, PidSlave),
- ok = syn:join(<<"my group">>, PidUnresponsive),
- timer:sleep(100),
-
- {Replies, BadPids} = syn:multi_call(<<"my group">>, get_pid_name),
-
- 2 = length(Replies),
- pid1 = proplists:get_value(PidLocal, Replies),
- pid2 = proplists:get_value(PidSlave, Replies),
- [PidUnresponsive] = BadPids,
-
- syn_test_suite_helper:kill_process(PidLocal),
- syn_test_suite_helper:kill_process(PidSlave),
- syn_test_suite_helper:kill_process(PidUnresponsive).
- recipient_loop(Pid) ->
- receive
- Message -> Pid ! {received, self(), Message}
- end.
- called_loop(PidName) ->
- receive
- {syn_multi_call, CallerPid, get_pid_name} -> syn:multi_call_reply(CallerPid, PidName)
- end.
|