123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647 |
- -module(syn_registry_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_when_mnesia_is_ram_find_by_key/1,
- single_node_when_mnesia_is_ram_find_by_key_with_meta/1,
- single_node_when_mnesia_is_ram_find_by_pid/1,
- single_node_when_mnesia_is_ram_find_by_pid_with_meta/1,
- single_node_when_mnesia_is_ram_with_gen_server_name/1,
- single_node_when_mnesia_is_ram_re_register_error/1,
- single_node_when_mnesia_is_ram_unregister/1,
- single_node_when_mnesia_is_ram_process_count/1,
- single_node_when_mnesia_is_ram_callback_on_process_exit/1,
- single_node_when_mnesia_is_disc_find_by_key/1
- ]).
- -export([
- two_nodes_when_mnesia_is_ram_find_by_key/1,
- two_nodes_when_mnesia_is_ram_find_by_key_with_meta/1,
- two_nodes_when_mnesia_is_ram_process_count/1,
- two_nodes_when_mnesia_is_ram_callback_on_process_exit/1,
- two_nodes_when_mnesia_is_disc_find_by_pid/1
- ]).
- -export([registry_process_exit_callback_dummy/4]).
- -include_lib("common_test/include/ct.hrl").
- all() ->
- [
- {group, single_node_process_registration},
- {group, two_nodes_process_registration}
- ].
- groups() ->
- [
- {single_node_process_registration, [shuffle], [
- single_node_when_mnesia_is_ram_find_by_key,
- single_node_when_mnesia_is_ram_find_by_key_with_meta,
- single_node_when_mnesia_is_ram_find_by_pid,
- single_node_when_mnesia_is_ram_find_by_pid_with_meta,
- single_node_when_mnesia_is_ram_with_gen_server_name,
- single_node_when_mnesia_is_ram_re_register_error,
- single_node_when_mnesia_is_ram_unregister,
- single_node_when_mnesia_is_ram_process_count,
- single_node_when_mnesia_is_ram_callback_on_process_exit,
- single_node_when_mnesia_is_disc_find_by_key
- ]},
- {two_nodes_process_registration, [shuffle], [
- two_nodes_when_mnesia_is_ram_find_by_key,
- two_nodes_when_mnesia_is_ram_find_by_key_with_meta,
- two_nodes_when_mnesia_is_ram_process_count,
- two_nodes_when_mnesia_is_ram_callback_on_process_exit,
- two_nodes_when_mnesia_is_disc_find_by_pid
- ]}
- ].
- init_per_suite(Config) ->
-
- [
- {slave_node_short_name, syn_slave}
- | Config
- ].
- end_per_suite(_Config) -> ok.
- init_per_group(two_nodes_process_registration, 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_registration, 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_when_mnesia_is_ram_find_by_key(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
-
- undefined = syn:find_by_key(<<"my proc">>),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>).
- single_node_when_mnesia_is_ram_with_gen_server_name(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- undefined = syn:whereis_name(<<"my proc">>),
-
- {ok, Pid} = syn_test_gen_server:start_link(self(), {via, syn, <<"my proc">>}),
-
- Pid = syn:whereis_name(<<"my proc">>),
-
- call_received = gen_server:call({via, syn, <<"my proc">>}, message_is_ignored),
-
- gen_server:cast({via, syn, <<"my proc">>}, message_is_ignored),
- ok = receive
- cast_received -> ok
- after
- 1000 -> error_receiving_cast_message
- end,
-
- syn:send(<<"my proc">>, message_is_ignored),
- ok = receive
- info_received -> ok
- after
- 1000 -> error_receiving_info_message
- end,
-
- syn_test_gen_server:stop({via, syn, <<"my proc">>}),
- ok = receive
- stop_received -> ok
- after
- 1000 -> error_stopping_process
- end,
-
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>).
- single_node_when_mnesia_is_ram_find_by_key_with_meta(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid1 = syn_test_suite_helper:start_process(),
- Pid2 = syn_test_suite_helper:start_process(),
-
- undefined = syn:find_by_key(<<"my proc 1">>, with_meta),
- undefined = syn:find_by_key(<<"my proc 2">>, with_meta),
-
- Meta = [{some, 1}, {meta, <<"data">>}],
- ok = syn:register(<<"my proc 1">>, Pid1, Meta),
- ok = syn:register(<<"my proc 2">>, Pid2),
-
- {Pid1, Meta} = syn:find_by_key(<<"my proc 1">>, with_meta),
- {Pid2, undefined} = syn:find_by_key(<<"my proc 2">>, with_meta),
-
- syn_test_suite_helper:kill_process(Pid1),
- syn_test_suite_helper:kill_process(Pid2),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc 1">>, with_meta),
- undefined = syn:find_by_key(<<"my proc 2">>, with_meta).
- single_node_when_mnesia_is_ram_find_by_pid(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- <<"my proc">> = syn:find_by_pid(Pid),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_pid(Pid).
- single_node_when_mnesia_is_ram_find_by_pid_with_meta(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid1 = syn_test_suite_helper:start_process(),
- Pid2 = syn_test_suite_helper:start_process(),
-
- undefined = syn:find_by_pid(Pid1, with_meta),
- undefined = syn:find_by_pid(Pid2, with_meta),
-
- Meta = [{some, 1}, {meta, <<"data">>}],
- ok = syn:register(<<"my proc 1">>, Pid1, Meta),
- ok = syn:register(<<"my proc 2">>, Pid2),
-
- {<<"my proc 1">>, Meta} = syn:find_by_pid(Pid1, with_meta),
- {<<"my proc 2">>, undefined} = syn:find_by_pid(Pid2, with_meta),
-
- syn_test_suite_helper:kill_process(Pid1),
- syn_test_suite_helper:kill_process(Pid2),
- timer:sleep(100),
-
- undefined = syn:find_by_pid(Pid1, with_meta),
- undefined = syn:find_by_pid(Pid2, with_meta).
- single_node_when_mnesia_is_ram_re_register_error(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
- Pid2 = syn_test_suite_helper:start_process(),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- ok = syn:register(<<"my proc">>, Pid, {with, meta}),
-
- {error, pid_already_registered} = syn:register(<<"my proc 2">>, Pid),
-
- {error, taken} = syn:register(<<"my proc">>, Pid2),
-
- {Pid, {with, meta}} = syn:find_by_key(<<"my proc">>, with_meta),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>),
-
- ok = syn:register(<<"my proc">>, Pid2),
-
- Pid2 = syn:find_by_key(<<"my proc">>),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_pid(Pid).
- single_node_when_mnesia_is_ram_unregister(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
-
- {error, undefined} = syn:unregister(<<"my proc">>),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
-
- ok = syn:unregister(<<"my proc">>),
-
- undefined = syn:find_by_key(<<"my proc">>),
- undefined = syn:find_by_pid(Pid),
-
- syn_test_suite_helper:kill_process(Pid).
- single_node_when_mnesia_is_ram_process_count(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
- ok = syn:init(),
-
- 0 = syn:registry_count(),
-
- Pid1 = syn_test_suite_helper:start_process(),
- Pid2 = syn_test_suite_helper:start_process(),
- Pid3 = syn_test_suite_helper:start_process(),
-
- ok = syn:register(1, Pid1),
- ok = syn:register(2, Pid2),
- ok = syn:register(3, Pid3),
-
- 3 = syn:registry_count(),
-
- syn_test_suite_helper:kill_process(Pid1),
- syn_test_suite_helper:kill_process(Pid2),
- syn_test_suite_helper:kill_process(Pid3),
- timer:sleep(100),
-
- 0 = syn:registry_count().
- single_node_when_mnesia_is_ram_callback_on_process_exit(_Config) ->
- CurrentNode = node(),
-
- application:set_env(mnesia, schema_location, ram),
-
- syn_test_suite_helper:set_environment_variables(),
-
- ok = syn:start(),
- ok = syn:init(),
-
- ResultPid = self(),
- global:register_name(syn_register_process_SUITE_result, ResultPid),
-
- Pid = syn_test_suite_helper:start_process(),
-
- Meta = {some, meta},
- ok = syn:register(<<"my proc">>, Pid, Meta),
-
- syn_test_suite_helper:kill_process(Pid),
-
- receive
- {exited, CurrentNode, <<"my proc">>, Pid, Meta, killed} -> ok
- after 2000 ->
- ok = registry_process_exit_callback_was_not_called_from_local_node
- end,
-
- global:unregister_name(syn_register_process_SUITE_result).
- single_node_when_mnesia_is_disc_find_by_key(_Config) ->
-
- application:set_env(mnesia, schema_location, disc),
-
- mnesia:create_schema([node()]),
-
- ok = syn:start(),
- ok = syn:init(),
-
- Pid = syn_test_suite_helper:start_process(),
-
- undefined = syn:find_by_key(<<"my proc">>),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>).
- two_nodes_when_mnesia_is_ram_find_by_key(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),
-
- Pid = syn_test_suite_helper:start_process(),
-
- undefined = syn:find_by_key(<<"my proc">>),
- undefined = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc">>]),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
- Pid = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc">>]),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>),
- undefined = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc">>]).
- two_nodes_when_mnesia_is_ram_find_by_key_with_meta(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),
-
- Pid1 = syn_test_suite_helper:start_process(),
- Pid2 = syn_test_suite_helper:start_process(),
-
- undefined = syn:find_by_key(<<"my proc 1">>),
- undefined = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc 1">>]),
- undefined = syn:find_by_key(<<"my proc 2">>),
- undefined = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc 2">>]),
-
- Meta = [{some, 1}, {meta, <<"data">>}],
- ok = syn:register(<<"my proc 1">>, Pid1, Meta),
- ok = syn:register(<<"my proc 2">>, Pid2),
-
- {Pid1, Meta} = syn:find_by_key(<<"my proc 1">>, with_meta),
- {Pid1, Meta} = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc 1">>, with_meta]),
- {Pid2, undefined} = syn:find_by_key(<<"my proc 2">>, with_meta),
- {Pid2, undefined} = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc 2">>, with_meta]),
-
- syn_test_suite_helper:kill_process(Pid1),
- syn_test_suite_helper:kill_process(Pid2),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc 1">>),
- undefined = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc 1">>]),
- undefined = syn:find_by_key(<<"my proc 2">>),
- undefined = rpc:call(SlaveNode, syn, find_by_key, [<<"my proc 2">>]).
- two_nodes_when_mnesia_is_ram_process_count(Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
- CurrentNode = node(),
-
- 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),
-
- 0 = syn:registry_count(),
- 0 = rpc:call(SlaveNode, syn, registry_count, []),
- 0 = syn:registry_count(CurrentNode),
- 0 = syn:registry_count(SlaveNode),
- 0 = rpc:call(SlaveNode, syn, registry_count, [CurrentNode]),
- 0 = rpc:call(SlaveNode, syn, registry_count, [SlaveNode]),
-
- PidLocal1 = syn_test_suite_helper:start_process(),
- PidLocal2 = syn_test_suite_helper:start_process(),
- PidSlave = syn_test_suite_helper:start_process(SlaveNode),
-
- ok = syn:register(1, PidLocal1),
- ok = syn:register(2, PidLocal2),
- ok = syn:register(3, PidSlave),
- timer:sleep(100),
-
- 3 = syn:registry_count(),
- 3 = rpc:call(SlaveNode, syn, registry_count, []),
- 2 = syn:registry_count(CurrentNode),
- 1 = syn:registry_count(SlaveNode),
- 2 = rpc:call(SlaveNode, syn, registry_count, [CurrentNode]),
- 1 = rpc:call(SlaveNode, syn, registry_count, [SlaveNode]),
-
- syn_test_suite_helper:kill_process(PidLocal1),
- syn_test_suite_helper:kill_process(PidLocal2),
- syn_test_suite_helper:kill_process(PidSlave),
- timer:sleep(100),
-
- 0 = syn:registry_count(),
- 0 = rpc:call(SlaveNode, syn, registry_count, []),
- 0 = syn:registry_count(CurrentNode),
- 0 = syn:registry_count(SlaveNode),
- 0 = rpc:call(SlaveNode, syn, registry_count, [CurrentNode]),
- 0 = rpc:call(SlaveNode, syn, registry_count, [SlaveNode]).
- two_nodes_when_mnesia_is_ram_callback_on_process_exit(Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
- CurrentNode = node(),
-
- application:set_env(mnesia, schema_location, ram),
- rpc:call(SlaveNode, mnesia, schema_location, [ram]),
-
- syn_test_suite_helper:set_environment_variables(),
- syn_test_suite_helper:set_environment_variables(SlaveNode),
-
- ok = syn:start(),
- ok = syn:init(),
- ok = rpc:call(SlaveNode, syn, start, []),
- ok = rpc:call(SlaveNode, syn, init, []),
- timer:sleep(100),
-
- ResultPid = self(),
- global:register_name(syn_register_process_SUITE_result, ResultPid),
-
- PidLocal = syn_test_suite_helper:start_process(),
- PidSlave = syn_test_suite_helper:start_process(SlaveNode),
-
- Meta = {some, meta},
- ok = syn:register(<<"local">>, PidLocal, Meta),
- ok = syn:register(<<"slave">>, PidSlave),
-
- syn_test_suite_helper:kill_process(PidLocal),
- syn_test_suite_helper:kill_process(PidSlave),
-
- receive
- {exited, CurrentNode, <<"local">>, PidLocal, Meta, killed} -> ok
- after 2000 ->
- ok = registry_process_exit_callback_was_not_called_from_local_node
- end,
- receive
- {exited, SlaveNode, <<"slave">>, PidSlave, undefined, killed} -> ok
- after 2000 ->
- ok = registry_process_exit_callback_was_not_called_from_slave_node
- end,
-
- global:unregister_name(syn_register_process_SUITE_result).
- two_nodes_when_mnesia_is_disc_find_by_pid(Config) ->
-
- SlaveNode = proplists:get_value(slave_node, Config),
-
- application:set_env(mnesia, schema_location, disc),
- rpc:call(SlaveNode, mnesia, schema_location, [disc]),
-
- mnesia:create_schema([node(), SlaveNode]),
-
- ok = syn:start(),
- ok = syn:init(),
- ok = rpc:call(SlaveNode, syn, start, []),
- ok = rpc:call(SlaveNode, syn, init, []),
- timer:sleep(100),
-
- Pid = syn_test_suite_helper:start_process(),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- <<"my proc">> = syn:find_by_pid(Pid),
- <<"my proc">> = rpc:call(SlaveNode, syn, find_by_pid, [Pid]),
-
- syn_test_suite_helper:kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_pid(Pid),
- undefined = rpc:call(SlaveNode, syn, find_by_pid, [Pid]).
- registry_process_exit_callback_dummy(Key, Pid, Meta, Reason) ->
- global:send(syn_register_process_SUITE_result, {exited, node(), Key, Pid, Meta, Reason}).
|