File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -656,9 +656,11 @@ gen_msg() ->
656656 gen_msg (1024 * 1024 ).
657657
658658gen_msg (MaxSize ) ->
659- % % This might generate false positives but very rarely
660- % % so we don't do anything to prevent them.
661- rand :bytes (rand :uniform (MaxSize )).
659+ Bytes = rand :bytes (rand :uniform (MaxSize )),
660+ % % We remove 255 to avoid false positives. In a running
661+ % % rabbit node we will not get false positives because
662+ % % we also check messages against the index.
663+ << <<case B of 255 -> 254 ; _ -> B end >> || <<B >> <= Bytes >>.
662664
663665gen_msg_file (Config , Blocks ) ->
664666 PrivDir = ? config (priv_dir , Config ),
@@ -668,8 +670,8 @@ gen_msg_file(Config, Blocks) ->
668670 {bin , Bin } ->
669671 Bin ;
670672 {pad , Size } ->
671- % % This might generate false positives although very unlikely .
672- rand : bytes ( Size ) ;
673+ % % Empty space between messages is expected to be zeroes .
674+ << 0 : Size / unit : 8 >> ;
673675 {msg , MsgId , Msg } ->
674676 Size = 16 + byte_size (Msg ),
675677 [<<Size :64 >>, MsgId , Msg , <<255 >>]
You can’t perform that action at this time.
0 commit comments