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 | 59b7fbd0da63c268d7d205ae1e4e5121d21ca871 (patch) | |
| tree | 76feb3a350379fdc87380de55c1a2e027374d379 | |
| parent | 28b72d7e64d42a8ddd499e03ad884713f62e2c5c (diff) | |
| download | rabbitmq-server-59b7fbd0da63c268d7d205ae1e4e5121d21ca871.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 ca362901..b96ce3cf 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, |