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 | 24dcac7bb10cf3f19ad15d5bd4d860124a58efcc (patch) | |
| tree | 8729c8a5d93577fa12a7b7560ba73f0fb646825d | |
| parent | 58a159e006bb20002eaebc217edfabf4efe8524c (diff) | |
| download | rabbitmq-server-git-24dcac7bb10cf3f19ad15d5bd4d860124a58efcc.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 8685ce67ce..b20b61e7b3 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, |