Skip to content

Commit 9145b53

Browse files
Merge pull request #10688 from rabbitmq/bump-init-max-frame-size
Bump initial maximum frame size
2 parents 01a39a5 + 97fdf36 commit 9145b53

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

deps/rabbit/src/rabbit_amqp_reader.erl

+6-4
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,10 @@
2525
-define(CLOSING_TIMEOUT, 30_000).
2626
-define(SILENT_CLOSE_DELAY, 3_000).
2727

28+
%% Allow for potentially large sets of tokens during the SASL exchange.
29+
%% https://docs.oasis-open.org/amqp/amqp-cbs/v1.0/csd01/amqp-cbs-v1.0-csd01.html#_Toc67999915
30+
-define(INITIAL_MAX_FRAME_SIZE, 8192).
31+
2832
-type protocol() :: amqp | sasl.
2933
-type channel_number() :: non_neg_integer().
3034

@@ -104,10 +108,8 @@ unpack_from_0_9_1(
104108
connected_at = ConnectedAt,
105109
user = none,
106110
timeout = HandshakeTimeout,
107-
%% "Prior to any explicit negotiation, the maximum
108-
%% frame size is 512 (MIN-MAX-FRAME-SIZE)" [2.4.1]
109-
incoming_max_frame_size = ?MIN_MAX_FRAME_1_0_SIZE,
110-
outgoing_max_frame_size = ?MIN_MAX_FRAME_1_0_SIZE,
111+
incoming_max_frame_size = ?INITIAL_MAX_FRAME_SIZE,
112+
outgoing_max_frame_size = ?INITIAL_MAX_FRAME_SIZE,
111113
channel_max = 0,
112114
auth_mechanism = none,
113115
auth_state = none}}.

0 commit comments

Comments
 (0)