summaryrefslogtreecommitdiff
path: root/src/rabbit_error_logger_file_h.erl
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-03-24 12:24:49 +0000
committerSimon MacMullen <simon@rabbitmq.com>2014-03-24 12:24:49 +0000
commit502d1c63340e01b5c74f99d0f9b76bacec8d5bf6 (patch)
tree5484f1aff560316abfb888f64bc2d9a0c9497a79 /src/rabbit_error_logger_file_h.erl
parentdaf0162802ce27959dbbc0554af34da34173de54 (diff)
downloadrabbitmq-server-502d1c63340e01b5c74f99d0f9b76bacec8d5bf6.tar.gz
Don't let the truncate module have any opinion on how much to truncate.
Diffstat (limited to 'src/rabbit_error_logger_file_h.erl')
-rw-r--r--src/rabbit_error_logger_file_h.erl12
1 files changed, 8 insertions, 4 deletions
diff --git a/src/rabbit_error_logger_file_h.erl b/src/rabbit_error_logger_file_h.erl
index 2f66f98f..4ef3aeb1 100644
--- a/src/rabbit_error_logger_file_h.erl
+++ b/src/rabbit_error_logger_file_h.erl
@@ -15,6 +15,7 @@
%%
-module(rabbit_error_logger_file_h).
+-include("rabbit.hrl").
-behaviour(gen_event).
@@ -92,15 +93,14 @@ handle_event(Event = {error, _, {emulator, _, ["Discarding message" ++ _]}},
case get(discarding_message_seen) of
true -> {ok, State};
undefined -> put(discarding_message_seen, true),
- error_logger_file_h:handle_event(
- truncate:log_event(Event), State)
+ error_logger_file_h:handle_event(t(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(truncate:log_event(Event), State);
+ error_logger_file_h:handle_event(t(Event), State);
handle_event(Event, State) ->
- error_logger_file_h:handle_event(truncate:log_event(Event), State).
+ error_logger_file_h:handle_event(t(Event), State).
handle_info(Info, State) ->
error_logger_file_h:handle_info(Info, State).
@@ -113,3 +113,7 @@ terminate(Reason, State) ->
code_change(OldVsn, State, Extra) ->
error_logger_file_h:code_change(OldVsn, State, Extra).
+
+%%----------------------------------------------------------------------
+
+t(Term) -> truncate:log_event(Term, ?LOG_TRUNCATE_SIZE).