diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-04-21 17:56:00 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-04-21 17:56:00 +0100 |
| commit | 9ceaa816c04422119c8010b1f41a24dafdeb3eb7 (patch) | |
| tree | e1ca367b70839eccc6a9782264598ab40dd83f68 /src | |
| parent | 9762dbe0416f67d34c9ff480ca38b62289bd31a5 (diff) | |
| download | rabbitmq-server-git-9ceaa816c04422119c8010b1f41a24dafdeb3eb7.tar.gz | |
*cough* *splutter* um. typo?
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_disk_queue.erl | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index 510a8590b6..32512c2bca 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -274,13 +274,14 @@ remove_messages(Q, MsgSeqIds, MnesiaDelete, State = # dqstate { msg_location = M ok = dets:insert(MsgLocation, {MsgId, RefCount - 1, File, Offset, TotalSize}), Files2 end, - {if MnesiaDelete -> - ok = mnesia:dirty_delete(rabbit_disk_queue, {Q, SeqId}), - lists:max([SeqId, MaxSeqId2]); - true -> - MaxSeqId2 - end, - Files3} + MaxSeqId3 = + if MnesiaDelete -> + ok = mnesia:dirty_delete(rabbit_disk_queue, {Q, SeqId}), + lists:max([SeqId, MaxSeqId2]); + true -> + MaxSeqId2 + end, + {Files3, MaxSeqId3} end, {sets:new(), 0}, MsgSeqIds), true = if MnesiaDelete -> [{Q, ReadSeqId, WriteSeqId}] = ets:lookup(Sequences, Q), |