diff options
author | Hubert Plociniczak <hubert@lshift.net> | 2008-09-09 17:05:01 +0100 |
---|---|---|
committer | Hubert Plociniczak <hubert@lshift.net> | 2008-09-09 17:05:01 +0100 |
commit | 4d4a9a044f7bb013efed85b070ec755f8a854fd1 (patch) | |
tree | d23f0db59cd91b22c1cec6c4ab3bec400f3d41f9 /src/rabbit_multi.erl | |
parent | cee9b87eed4228d2e9d54b7eb40c5eaf2fc4b327 (diff) | |
download | rabbitmq-server-4d4a9a044f7bb013efed85b070ec755f8a854fd1.tar.gz |
Continue rotate_logs command even when
the command on specific node returns an error.
Display the error message in that case only.
Diffstat (limited to 'src/rabbit_multi.erl')
-rw-r--r-- | src/rabbit_multi.erl | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/rabbit_multi.erl b/src/rabbit_multi.erl index 4d00e660..8a6bfbe0 100644 --- a/src/rabbit_multi.erl +++ b/src/rabbit_multi.erl @@ -285,11 +285,10 @@ rotate_logs([], _, _) -> ok; rotate_logs([{Node, _} | Rest], BinarySuffix, RpcTimeout) -> io:format("Rotating logs for node ~p", [Node]), case rpc:call(Node, rabbit, rotate_logs, [BinarySuffix], RpcTimeout) of - {badrpc, Error} -> io:format(": ~p.~n", [Error]), - throw(rotate_logs_failed); - ok -> io:format(": ok.~n", []), - rotate_logs(Rest, BinarySuffix, RpcTimeout) - end. + {badrpc, Error} -> io:format(": ~p.~n", [Error]); + ok -> io:format(": ok.~n", []) + end, + rotate_logs(Rest, BinarySuffix, RpcTimeout). call_all_nodes(Func) -> case read_pids_file() of |