diff options
| author | Michael Klishin <michael@novemberain.com> | 2015-10-02 02:46:53 +0800 |
|---|---|---|
| committer | Michael Klishin <michael@novemberain.com> | 2015-10-02 02:46:53 +0800 |
| commit | fbaf08d111532a7b413732d2dd89571a0d4298a3 (patch) | |
| tree | 6a045f630f422ad827fed175bf48d94bfcfac010 /src | |
| parent | ea7a3751903601d2a1d31d4edfcbefc21fdb7d82 (diff) | |
| parent | 8bbd6d1e213eb1c2fb443223f5238925e4290516 (diff) | |
| download | rabbitmq-server-git-fbaf08d111532a7b413732d2dd89571a0d4298a3.tar.gz | |
Merge pull request #342 from rabbitmq/rabbitmq-server-341
closes the journal handle before erasing the queue index dir
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 936bff1e5b..176f65b18b 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -269,11 +269,11 @@ reset_state(#qistate{ dir = Dir, on_sync = OnSyncFun, on_sync_msg = OnSyncMsgFun, journal_handle = JournalHdl }) -> - ok = erase_index_dir(Dir), ok = case JournalHdl of undefined -> ok; _ -> file_handle_cache:close(JournalHdl) end, + ok = erase_index_dir(Dir), blank_state_dir_funs(Dir, OnSyncFun, OnSyncMsgFun). init(Name, OnSyncFun, OnSyncMsgFun) -> |