123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352 |
- -module(syn_register_processes_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([process_main/0]).
- -export([
- single_node_when_mnesia_is_ram_find_by_key/1,
- single_node_when_mnesia_is_ram_find_by_pid/1,
- single_node_when_mnesia_is_ram_re_register_error/1,
- single_node_when_mnesia_is_ram_unregister/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_disc_find_by_pid/1
- ]).
- -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_pid,
- single_node_when_mnesia_is_ram_re_register_error,
- single_node_when_mnesia_is_ram_unregister,
- 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_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, SlaveNodeName} = syn_test_suite_helper:start_slave(SlaveNodeShortName),
-
- [
- {slave_node_name, SlaveNodeName}
- | Config
- ];
- init_per_group(_GroupName, Config) -> Config.
- end_per_group(two_nodes_mnesia_creation, 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) ->
-
- case proplists:get_value(slave_node_name, Config) of
- undefined -> syn_test_suite_helper:clean_after_test();
- SlaveNodeName -> syn_test_suite_helper:clean_after_test(SlaveNodeName)
- end.
- single_node_when_mnesia_is_ram_find_by_key(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
-
- Pid = start_process(),
-
- undefined = syn:find_by_key(<<"my proc">>),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
-
- kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>).
- single_node_when_mnesia_is_ram_find_by_pid(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
-
- Pid = start_process(),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- <<"my proc">> = syn:find_by_pid(Pid),
-
- kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_pid(Pid).
- single_node_when_mnesia_is_ram_re_register_error(_Config) ->
-
- application:set_env(mnesia, schema_location, ram),
-
- ok = syn:start(),
-
- Pid = start_process(),
- Pid2 = start_process(),
-
- ok = syn:register(<<"my proc">>, Pid),
- {error, taken} = syn:register(<<"my proc">>, Pid2),
-
- Pid = syn:find_by_key(<<"my proc">>),
-
- 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">>),
-
- 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(),
-
- Pid = 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),
-
- kill_process(Pid).
- single_node_when_mnesia_is_disc_find_by_key(_Config) ->
-
- application:set_env(mnesia, schema_location, disc),
-
- mnesia:create_schema([node()]),
-
- ok = syn:start(),
-
- Pid = start_process(),
-
- undefined = syn:find_by_key(<<"my proc">>),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
-
- kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>).
- two_nodes_when_mnesia_is_ram_find_by_key(Config) ->
-
- SlaveNodeName = proplists:get_value(slave_node_name, Config),
-
- application:set_env(mnesia, schema_location, ram),
- rpc:call(SlaveNodeName, mnesia, schema_location, [ram]),
-
- ok = syn:start(),
- ok = rpc:call(SlaveNodeName, syn, start, []),
- timer:sleep(100),
-
- Pid = start_process(),
-
- undefined = syn:find_by_key(<<"my proc">>),
- undefined = rpc:call(SlaveNodeName, syn, find_by_key, [<<"my proc">>]),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- Pid = syn:find_by_key(<<"my proc">>),
- Pid = rpc:call(SlaveNodeName, syn, find_by_key, [<<"my proc">>]),
-
- kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_key(<<"my proc">>),
- undefined = rpc:call(SlaveNodeName, syn, find_by_key, [<<"my proc">>]).
- two_nodes_when_mnesia_is_disc_find_by_pid(Config) ->
-
- SlaveNodeName = proplists:get_value(slave_node_name, Config),
-
- application:set_env(mnesia, schema_location, disc),
- rpc:call(SlaveNodeName, mnesia, schema_location, [disc]),
-
- mnesia:create_schema([node(), SlaveNodeName]),
-
- ok = syn:start(),
- ok = rpc:call(SlaveNodeName, syn, start, []),
- timer:sleep(100),
-
- Pid = start_process(),
-
- ok = syn:register(<<"my proc">>, Pid),
-
- <<"my proc">> = syn:find_by_pid(Pid),
- <<"my proc">> = rpc:call(SlaveNodeName, syn, find_by_pid, [Pid]),
-
- kill_process(Pid),
- timer:sleep(100),
-
- undefined = syn:find_by_pid(Pid),
- undefined = rpc:call(SlaveNodeName, syn, find_by_pid, [Pid]).
- start_process() ->
- Pid = spawn(?MODULE, process_main, []),
- Pid.
- kill_process(Pid) ->
- exit(Pid, kill).
- process_main() ->
- receive
- shutdown -> ok
- end.
|