diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-17 14:28:52 +0000 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-17 14:28:52 +0000 |
commit | b7b99017b78fc03bde5e0ad7ce1a94eb345c8cc2 (patch) | |
tree | 6cd8bb80f4ed7ff5c95f79153bbb89d89fa86cff | |
parent | 8bcbc0958fb3e0d687977adaa487cde1818bd101 (diff) | |
parent | 2a5cd5a35a456f6d9d25c4e0f35c652df13fc475 (diff) | |
download | rabbitmq-server-b7b99017b78fc03bde5e0ad7ce1a94eb345c8cc2.tar.gz |
Merge bug25965
-rw-r--r-- | src/rabbit_error_logger_file_h.erl | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/src/rabbit_error_logger_file_h.erl b/src/rabbit_error_logger_file_h.erl index d59641b0..9421b52e 100644 --- a/src/rabbit_error_logger_file_h.erl +++ b/src/rabbit_error_logger_file_h.erl @@ -79,6 +79,25 @@ init_file(File, PrevHandler) -> %% filter out "application: foo; exited: stopped; type: temporary" handle_event({info_report, _, {_, std_info, _}}, State) -> {ok, State}; +%% When a node restarts quickly it is possible the rest of the cluster +%% will not have had the chance to remove its queues from +%% Mnesia. That's why rabbit_amqqueue:recover/0 invokes +%% on_node_down(node()). But before we get there we can receive lots +%% of messages intended for the old version of the node. The emulator +%% logs an event for every one of those messages; in extremis this can +%% bring the server to its knees just logging "Discarding..." +%% again and again. So just log the first one, then go silent. +handle_event(Event = {error, _, {emulator, _, ["Discarding message" ++ _]}}, + State) -> + case get(discarding_message_seen) of + true -> {ok, State}; + undefined -> put(discarding_message_seen, true), + error_logger_file_h:handle_event(Event, State) + end; +%% Clear this state if we log anything else (but not a progress report). +handle_event(Event = {info_msg, _, _}, State) -> + erase(discarding_message_seen), + error_logger_file_h:handle_event(Event, State); handle_event(Event, State) -> error_logger_file_h:handle_event(Event, State). |