diff options
| author | Jean-Sebastien Pedron <jean-sebastien@rabbitmq.com> | 2015-01-07 14:24:32 +0100 |
|---|---|---|
| committer | Jean-Sebastien Pedron <jean-sebastien@rabbitmq.com> | 2015-01-07 14:24:32 +0100 |
| commit | 233ef7c785545f9d390ce1941013942fb5e08af4 (patch) | |
| tree | e976562c2e479beaf1afd838d5e76c64e1ee9763 /src/rabbit_msg_store.erl | |
| parent | c4a404d65e8b67a4a8065309e02630c3ffc86542 (diff) | |
| parent | d4f28442e8f12a1eb822fbed8ac56b4fc3d676ea (diff) | |
| download | rabbitmq-server-233ef7c785545f9d390ce1941013942fb5e08af4.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) }; |