diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2015-01-09 17:49:05 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2015-01-09 17:49:05 +0000 |
| commit | d8c664480f50ee184d6dc60903377f51ef8e644c (patch) | |
| tree | 2ec8a0c9a237929e4578806b402e1456e977b293 /src/rabbit_msg_store.erl | |
| parent | 687c9fec8c94d5d5565a1b08605d483449271eb0 (diff) | |
| parent | cd4c9e37d9b30bf2ed6a8b877d86cdc3d9f29a0e (diff) | |
| download | rabbitmq-server-master.tar.gz | |
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) }; |