Merge pull request #192 from rabbitmq/send-file-improvements

Optimizations for readers

Author: acogoluegnes

src/osiris.erl

@@ -82,7 +82,8 @@
 -type entry() :: binary() | batch().
 -type reader_options() :: #{transport => tcp | ssl,
                             chunk_selector => all | user_data,
-                            filter_spec => osiris_bloom:filter_spec()
+                            filter_spec => osiris_bloom:filter_spec(),
+                            read_ahead => boolean()
                            }.
 
 -export_type([name/0,

src/osiris_bloom.erl

@@ -9,6 +9,7 @@
 
          init_matcher/1,
          is_match/2,
+         filter_size/1,
 
          bit_set/2,
          make_hash/2
@@ -90,6 +91,10 @@ is_match(_Filter, undefined) ->
     %% if no reader filter is set
     true.
 
+-spec filter_size(mstate()) -> non_neg_integer().
+filter_size(#matcher{current_bit_size = BitSz}) ->
+    BitSz div 8.
+
 
 -spec init(filter_size()) -> state().
 init(SizeB) when is_integer(SizeB) andalso