fixup! max_frame_length -> max_frame_size

Author: deadtrickster

deps/rabbitmq_stomp/src/rabbit_stomp_reader.erl

@@ -25,7 +25,7 @@
                         timeout]).
 
 -record(reader_state, {socket, conn_name, parse_state, processor_state, state,
-                       conserve_resources, recv_outstanding, max_frame_length, frame_length,
+                       conserve_resources, recv_outstanding, max_frame_size, frame_length,
                        stats_timer, parent, connection, heartbeat_sup, heartbeat,
                        timeout_sec %% heartbeat timeout value used, 0 means
                                    %% heartbeats are disabled
@@ -69,7 +69,7 @@ init([SupHelperPid, Ref, Configuration]) ->
             _ = register_resource_alarm(),
 
             LoginTimeout = application:get_env(rabbitmq_stomp, login_timeout, 10_000),
-            MaxFrameLength = application:get_env(rabbitmq_stomp, max_frame_length, 192 * 1024),
+            MaxFrameSize = application:get_env(rabbitmq_stomp, max_frame_size, 192 * 1024),
             erlang:send_after(LoginTimeout, self(), login_timeout),
 
             gen_server2:enter_loop(?MODULE, [],
@@ -81,7 +81,7 @@ init([SupHelperPid, Ref, Configuration]) ->
                                 processor_state    = ProcState,
                                 heartbeat_sup      = SupHelperPid,
                                 heartbeat          = {none, none},
-                                max_frame_length   = MaxFrameLength,
+                                max_frame_size     = MaxFrameSize,
                                 frame_length       = 0,
                                 state              = running,
                                 conserve_resources = false,
@@ -225,26 +225,26 @@ process_received_bytes([], State) ->
     {ok, State};
 process_received_bytes(Bytes,
                        State = #reader_state{
-                         max_frame_length = MaxFrameLength,
+                         max_frame_size = MaxFrameSize,
                          frame_length     = FrameLength,
                          processor_state  = ProcState,
                          parse_state      = ParseState}) ->
     case rabbit_stomp_frame:parse(Bytes, ParseState) of
         {more, ParseState1} ->
             FrameLength1 = FrameLength + byte_size(Bytes),
-            case FrameLength1 > MaxFrameLength of
+            case FrameLength1 > MaxFrameSize of
                 true ->
-                    log_reason({network_error, {frame_too_big, {FrameLength1, MaxFrameLength}}}, State),
+                    log_reason({network_error, {frame_too_big, {FrameLength1, MaxFrameSize}}}, State),
                     {stop, normal, State};
                 false ->
                     {ok, State#reader_state{parse_state = ParseState1,
                                             frame_length = FrameLength1}}
             end;
         {ok, Frame, Rest} ->
             FrameLength1 = FrameLength + byte_size(Bytes) - byte_size(Rest),
-            case FrameLength1 > MaxFrameLength of
+            case FrameLength1 > MaxFrameSize of
                 true ->
-                    log_reason({network_error, {frame_too_big, {FrameLength1, MaxFrameLength}}}, State),
+                    log_reason({network_error, {frame_too_big, {FrameLength1, MaxFrameSize}}}, State),
                     {stop, normal, State};
                 false ->
                     case rabbit_stomp_processor:process_frame(Frame, ProcState) of

deps/rabbitmq_stomp/test/connections_SUITE.erl

@@ -180,7 +180,7 @@ login_timeout(Config) ->
 frame_size(Config) ->
     rabbit_ct_broker_helpers:rpc(
       Config, 0,
-      application, set_env, [rabbitmq_stomp, max_frame_length, 80]),
+      application, set_env, [rabbitmq_stomp, max_frame_size, 80]),
     StompPort = get_stomp_port(Config),
     {ok, Client} = rabbit_stomp_client:connect("1.2", "guest", "guest", StompPort,
                                                [{"heart-beat", "5000,7000"}]),
@@ -199,7 +199,7 @@ frame_size(Config) ->
 frame_size_huge(Config) ->
     rabbit_ct_broker_helpers:rpc(
       Config, 0,
-      application, set_env, [rabbitmq_stomp, max_frame_length, 700]),
+      application, set_env, [rabbitmq_stomp, max_frame_size, 700]),
     StompPort = get_stomp_port(Config),
     {ok, Client} = rabbit_stomp_client:connect("1.2", "guest", "guest", StompPort,
                                                [{"heart-beat", "5000,7000"}]),

deps/rabbitmq_stomp/test/python_SUITE.erl

@@ -67,7 +67,7 @@ end_per_testcase(Test, Config) ->
 main(Config) ->
     rabbit_ct_broker_helpers:rpc(
       Config, 0,
-      application, set_env, [rabbitmq_stomp, max_frame_length, 17 * 1024 * 1024]),
+      application, set_env, [rabbitmq_stomp, max_frame_size, 17 * 1024 * 1024]),
     run(Config, filename:join("src", "main_runner.py")).
 
 implicit_connect(Config) ->