123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110 |
- -module(syn_test_suite_helper).
- -export([start_slave/1, start_slave/4]).
- -export([stop_slave/1, stop_slave/2]).
- -export([connect_node/1, disconnect_node/1]).
- -export([clean_after_test/0]).
- -export([start_process/0, start_process/1, start_process/2]).
- -export([kill_process/1]).
- -export([use_custom_handler/0]).
- -export([send_error_logger_to_disk/0]).
- -export([process_main/0]).
- start_slave(NodeShortName) ->
- {ok, Node} = ct_slave:start(NodeShortName, [{boot_timeout, 10}]),
- CodePath = code:get_path(),
- true = rpc:call(Node, code, set_path, [CodePath]),
- {ok, Node}.
- start_slave(NodeShortName, Host, Username, Password) ->
- {ok, Node} = ct_slave:start(Host, NodeShortName, [
- {boot_timeout, 10},
- {username, Username},
- {password, Password}
- ]),
- CodePath = code:get_path(),
- true = rpc:call(Node, code, set_path, [CodePath]),
- {ok, Node}.
- stop_slave(NodeShortName) ->
- {ok, _} = ct_slave:stop(NodeShortName).
- stop_slave(Host, NodeShortName) ->
- {ok, _} = ct_slave:stop(Host, NodeShortName).
- connect_node(Node) ->
- net_kernel:connect_node(Node).
- disconnect_node(Node) ->
- erlang:disconnect_node(Node).
- clean_after_test() ->
- Nodes = [node() | nodes()],
-
- lists:foreach(fun(Node) ->
- rpc:call(Node, syn, stop, []),
- rpc:call(Node, application, stop, [mnesia]),
-
- rpc:call(Node, application, unset_env, [syn, event_handler])
- end, Nodes),
-
- mnesia:delete_schema(Nodes).
- start_process() ->
- Pid = spawn(fun process_main/0),
- Pid.
- start_process(Node) when is_atom(Node) ->
- Pid = spawn(Node, fun process_main/0),
- Pid;
- start_process(Loop) when is_function(Loop) ->
- Pid = spawn(Loop),
- Pid.
- start_process(Node, Loop) ->
- Pid = spawn(Node, Loop),
- Pid.
- kill_process(Pid) ->
- exit(Pid, kill).
- use_custom_handler() ->
- application:set_env(syn, event_handler, syn_test_event_handler).
- send_error_logger_to_disk() ->
- error_logger:logfile({open, atom_to_list(node())}).
- process_main() ->
- receive
- _ -> process_main()
- end.
|