summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2009-10-23 14:48:27 +0100
committerMatthew Sackman <matthew@lshift.net>2009-10-23 14:48:27 +0100
commit115f9c247483cbe53bd9a788f01b44e0b4643c5b (patch)
treea04051031a05746637c95a7b0626eab63aecfb5a /src
parentb1bd75a4062900c67213c39d94e3dd04547defdc (diff)
downloadrabbitmq-server-git-115f9c247483cbe53bd9a788f01b44e0b4643c5b.tar.gz
should definitely sync after truncating the ack journal
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_queue_index.erl1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl
index 67637ed2d7..d9302dde3c 100644
--- a/src/rabbit_queue_index.erl
+++ b/src/rabbit_queue_index.erl
@@ -252,6 +252,7 @@ flush_journal(State = #qistate { journal_ack_dict = JAckDict,
{Hdl, State3} = get_journal_handle(State2),
ok = file_handle_cache:position(Hdl, bof),
ok = file_handle_cache:truncate(Hdl),
+ ok = file_handle_cache:sync(Hdl),
{false, State3};
JAckCount1 > ?MAX_ACK_JOURNAL_ENTRY_COUNT ->
flush_journal(State2);