diff options
author | Matthew Sackman <matthew@rabbitmq.com> | 2011-01-10 12:08:05 +0000 |
---|---|---|
committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-01-10 12:08:05 +0000 |
commit | bdfd33443d9e1f9e5e2e3828978d007f0a7756b3 (patch) | |
tree | 8729c8a5d93577fa12a7b7560ba73f0fb646825d | |
parent | ff602aaef4b62be882fc006e0ad914297fa47f9d (diff) | |
download | rabbitmq-server-bdfd33443d9e1f9e5e2e3828978d007f0a7756b3.tar.gz |
Fix bug
-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 8685ce67..b20b61e7 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -727,7 +727,8 @@ handle_cast({write, CRef, Guid}, ok = index_update_ref_count(Guid, RefCount + 1, State1), CTG2 = case {dict:find(CRef, CODC), File} of {{ok, _}, CurFile} -> CTG1; - {{ok, Fun}, _} -> Fun(gb_sets:singleton(Guid)), + {{ok, Fun}, _} -> Fun(gb_sets:singleton(Guid), + written), CTG; _ -> CTG1 end, |