diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-12-12 10:53:25 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-12-12 10:53:25 +0000 |
| commit | 10ead114dc3fe97e9e4887da61aba87f9a7ac7b0 (patch) | |
| tree | ec514a1ad3eccd8d4c490be89cced9716e65cef1 /src | |
| parent | f2107d6063d3ec9db364c77bcb7e29d90806d1f0 (diff) | |
| download | rabbitmq-server-git-10ead114dc3fe97e9e4887da61aba87f9a7ac7b0.tar.gz | |
Remove vestigial use of read_ahead.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index fa751d0c61..f087e761de 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -168,7 +168,6 @@ -define(PUB, {_, _, _}). %% {MsgId, MsgProps, IsPersistent} -define(READ_MODE, [binary, raw, read]). --define(READ_AHEAD_MODE, ?READ_MODE). -define(WRITE_MODE, [write | ?READ_MODE]). -define(READ_BUFFER_SIZE, 1048576). %% 1MB @@ -938,7 +937,7 @@ load_segment(KeepAcked, #segment { path = Path }) -> case rabbit_file:is_file(Path) of false -> Empty; true -> {ok, Hdl} = file_handle_cache:open( - Path, ?READ_AHEAD_MODE, + Path, ?READ_MODE, [{read_buffer, ?READ_BUFFER_SIZE}]), {ok, 0} = file_handle_cache:position(Hdl, bof), Res = load_segment_entries(Hdl, KeepAcked, Empty), @@ -1257,8 +1256,7 @@ transform_file(Path, Fun) when is_function(Fun)-> [{write_buffer, infinity}]), {ok, PathHdl} = file_handle_cache:open( - Path, [{read_ahead, Size} | ?READ_MODE], - [{read_buffer, ?READ_BUFFER_SIZE}]), + Path, ?READ_MODE, [{read_buffer, Size}]), {ok, Content} = file_handle_cache:read(PathHdl, Size), ok = file_handle_cache:close(PathHdl), |