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, |