diff options
author | Simon MacMullen <simon@lshift.net> | 2010-04-28 11:00:27 +0100 |
---|---|---|
committer | Simon MacMullen <simon@lshift.net> | 2010-04-28 11:00:27 +0100 |
commit | 33303726a2eba1a29c9319f76d970e04d85f96a3 (patch) | |
tree | 565d5fe11744a165258e99dd2bee7e9e01a0c82f | |
parent | 7d1e53d37adea2cf7aadf6aff2e881ca28b2ecad (diff) | |
download | rabbitmq-server-33303726a2eba1a29c9319f76d970e04d85f96a3.tar.gz |
Remove gen_server2 use, bump up timeouts, tidy GoodRes / BadRes checking.
-rw-r--r-- | src/rabbit_tests.erl | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index f7674d8b..a070e42d 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -860,7 +860,7 @@ test_delegates_async(SecondaryNode) -> make_responder(FMsg) -> fun() -> receive Msg -> FMsg(Msg) - after 100 -> throw(timeout) + after 1000 -> throw(timeout) end end. @@ -874,16 +874,16 @@ await_response(Count) -> receive response -> ok, await_response(Count - 1) - after 100 -> + after 1000 -> io:format("Async reply not received~n"), throw(timeout) end. test_delegates_sync(SecondaryNode) -> - Sender = fun(Pid) -> gen_server2:call(Pid, invoked) end, + Sender = fun(Pid) -> gen_server:call(Pid, invoked) end, Responder = make_responder(fun({'$gen_call', From, invoked}) -> - gen_server2:reply(From, response) + gen_server:reply(From, response) end), BadResponder = make_responder(fun({'$gen_call', _From, invoked}) -> @@ -902,12 +902,10 @@ test_delegates_sync(SecondaryNode) -> RemoteBadPids = spawn_responders(SecondaryNode, BadResponder, 2), GoodRes = delegate:call(LocalGoodPids ++ RemoteGoodPids, Sender), - [{ok, response, _}, {ok, response, _}, - {ok, response, _}, {ok, response, _}] = GoodRes, - BadRes = delegate:call(LocalBadPids ++ RemoteBadPids, Sender), - [{error, _, _}, {error, _, _}, - {error, _, _}, {error, _, _}] = BadRes, + + true = lists:all(fun ({ok, response, _}) -> true end, GoodRes), + true = lists:all(fun ({error, _, _}) -> true end, BadRes), GoodResPids = [Pid || {_, _, Pid} <- GoodRes], BadResPids = [Pid || {_, _, Pid} <- BadRes], |