diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-07-18 17:46:15 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-07-18 17:46:15 +0100 |
| commit | b9c4358dd46d35c20aebbf618596859ad5310f33 (patch) | |
| tree | 05199b42500282e75df5245475f659d633b37f85 /src | |
| parent | dbc24ef0f0d803077ded2be9c9016cfbf7c61992 (diff) | |
| download | rabbitmq-server-git-b9c4358dd46d35c20aebbf618596859ad5310f33.tar.gz | |
use new frame_error function
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 514069bcc7..ade6122fdf 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -617,11 +617,11 @@ post_process_frame(_Frame, _ChPid, State) -> -define(FRAME_SIZE_FUDGE, ?EMPTY_FRAME_SIZE). handle_input(frame_header, <<Type:8,Channel:16,PayloadSize:32>>, - #v1{connection = #connection{frame_max = FrameMax}}) + State = #v1{connection = #connection{frame_max = FrameMax}}) when FrameMax /= 0 andalso PayloadSize > FrameMax - ?EMPTY_FRAME_SIZE + ?FRAME_SIZE_FUDGE -> - throw({frame_too_large, Type, Channel, PayloadSize, - FrameMax - ?EMPTY_FRAME_SIZE}); + frame_error({frame_too_large, PayloadSize, FrameMax - ?EMPTY_FRAME_SIZE}, + Type, Channel, <<>>, State); handle_input(frame_header, <<Type:8,Channel:16,PayloadSize:32>>, State) -> ensure_stats_timer( switch_callback(State, {frame_payload, Type, Channel, PayloadSize}, |