Return error if store offset reference is longer than 255 characters

This commit is contained in:
Arnaud Cogoluègnes 2024-10-11 14:55:44 +02:00
parent 0260862a27
commit 622dec011d
No known key found for this signature in database
GPG Key ID: D5C8C4DFAD43AFA8
1 changed files with 3 additions and 0 deletions

View File

@ -3463,6 +3463,9 @@ clean_state_after_stream_deletion_or_failure(MemberPid, Stream,
{not_cleaned, C2#stream_connection{stream_leaders = Leaders1}, S2}
end.
store_offset(Reference, _, _, C) when is_binary(Reference), byte_size(Reference) > ?MAX_REFERENCE_SIZE ->
rabbit_log:warning("Reference is too long to store offset: ~p", [byte_size(Reference)]),
C;
store_offset(Reference, Stream, Offset, Connection0) ->
case lookup_leader(Stream, Connection0) of
{error, Error} ->