valitydev/riak_test
14
0
Fork 0
mirror of https://github.com/valitydev/riak_test.git synced 2024-11-06 08:35:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added explicit wait_for_service riak_pipe on pipe* tests...

Browse Source 
... which didn't call the 2-arity version of deploy_nodes. NB
the /2 version implicitly waits on whatever services are specified.
This commit is contained in:
Alex Berghage 2015-04-06 10:36:06 -05:00
parent 2151fa6914
commit 5c5931b567
5 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/pipe_verify_basics.erl
View File

@ -42,6 +42,8 @@ confirm() ->
lager:info("Build ~b node cluster", [?NODE_COUNT]),
Nodes = rt:build_cluster(?NODE_COUNT),
[rt:wait_for_service(Node, riak_pipe) || Node <- Nodes],
rt:load_modules_on_nodes([?MODULE], Nodes),
verify_order(Nodes),

2
tests/pipe_verify_examples.erl
View File

@ -31,6 +31,8 @@ confirm() ->
lager:info("Build ~b node cluster", [?NODE_COUNT]),
Nodes = rt:build_cluster(?NODE_COUNT),
[rt:wait_for_service(Node, riak_pipe) || Node <- Nodes],
verify_example(Nodes),
verify_example_transform(Nodes),
verify_example_reduce(Nodes),

2
tests/pipe_verify_exceptions.erl
View File

@ -47,6 +47,8 @@ confirm() ->
lager:info("Build ~b node cluster", [?NODE_COUNT]),
Nodes = rt:build_cluster(?NODE_COUNT),
[rt:wait_for_service(Node, riak_pipe) || Node <- Nodes],
rt:load_modules_on_nodes([?MODULE, rt_pipe], Nodes),
verify_xbad1(Nodes),

2
tests/pipe_verify_restart_input_forwarding.erl
View File

@ -54,6 +54,8 @@ confirm() ->
lager:info("Build ~b node cluster", [?NODE_COUNT]),
Nodes = rt:build_cluster(?NODE_COUNT),
[rt:wait_for_service(Node, riak_pipe) || Node <- Nodes],
rt:load_modules_on_nodes([?MODULE, rt_pipe], Nodes),
verify_worker_restart_failure_input_forwarding(Nodes),

2
tests/pipe_verify_sink_types.erl
View File

@ -41,6 +41,8 @@ confirm() ->
lager:info("Build ~b node cluster", [?NODE_COUNT]),
Nodes = rt:build_cluster(?NODE_COUNT),
[rt:wait_for_service(Node, riak_pipe) || Node <- Nodes],
verify_raw(Nodes),
verify_fsm(Nodes),
verify_fsm_timeout(Nodes),