diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-12-10 15:29:04 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-12-10 15:29:04 +0000 |
| commit | 6e557a98e926c545c0f6d57e76a678c8a8cd192d (patch) | |
| tree | 2cc09e159cd7d504dfdc1c3493414c76ecdb91a8 /src/rabbit_msg_store.erl | |
| parent | eba8bf97303221e65f0e6712f075f536ed6ac6d3 (diff) | |
| parent | 566fec739ced60f052016928eb6c28662d2b2f62 (diff) | |
| download | rabbitmq-server-6e557a98e926c545c0f6d57e76a678c8a8cd192d.tar.gz | |
stable to default
Diffstat (limited to 'src/rabbit_msg_store.erl')
| -rw-r--r-- | src/rabbit_msg_store.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index b829ae94..6c80ddcd 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -1299,7 +1299,8 @@ should_mask_action(CRef, MsgId, open_file(Dir, FileName, Mode) -> file_handle_cache:open(form_filename(Dir, FileName), ?BINARY_MODE ++ Mode, - [{write_buffer, ?HANDLE_CACHE_BUFFER_SIZE}]). + [{write_buffer, ?HANDLE_CACHE_BUFFER_SIZE}, + {read_buffer, ?HANDLE_CACHE_BUFFER_SIZE}]). close_handle(Key, CState = #client_msstate { file_handle_cache = FHC }) -> CState #client_msstate { file_handle_cache = close_handle(Key, FHC) }; |