summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHubert Plociniczak <hubert@lshift.net>2008-09-09 17:05:01 +0100
committerHubert Plociniczak <hubert@lshift.net>2008-09-09 17:05:01 +0100
commit4d4a9a044f7bb013efed85b070ec755f8a854fd1 (patch)
treed23f0db59cd91b22c1cec6c4ab3bec400f3d41f9
parentcee9b87eed4228d2e9d54b7eb40c5eaf2fc4b327 (diff)
downloadrabbitmq-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.
-rw-r--r--src/rabbit_multi.erl9
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