diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-21 23:46:19 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-21 23:46:19 +0000 |
| commit | fe99c0f21a1f2207f21ce2890c1b9857aaa5d6c7 (patch) | |
| tree | 76feb3a350379fdc87380de55c1a2e027374d379 | |
| parent | fd950f4dceb64dfc146c7648046b1cd0c4f7f5dc (diff) | |
| download | rabbitmq-server-git-fe99c0f21a1f2207f21ce2890c1b9857aaa5d6c7.tar.gz | |
assert after fold
| -rw-r--r-- | src/rabbit_variable_queue.erl | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index ca3629018f..b96ce3cf6d 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -641,13 +641,12 @@ ack(AckTags, State) -> fold(undefined, State, _AckTags) -> State; fold(MsgFun, State = #vqstate{pending_ack = PA}, AckTags) -> - lists:foldl( - fun(SeqId, State1) -> - {MsgStatus, State2} = - read_msg(gb_trees:get(SeqId, PA), State1), - MsgFun(MsgStatus#msg_status.msg, SeqId), - State2 - end, State, AckTags). + a(lists:foldl(fun(SeqId, State1) -> + {MsgStatus, State2} = + read_msg(gb_trees:get(SeqId, PA), State1), + MsgFun(MsgStatus#msg_status.msg, SeqId), + State2 + end, State, AckTags)). requeue(AckTags, #vqstate { delta = Delta, q3 = Q3, |