diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-06-17 16:31:01 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-06-17 16:31:01 +0100 |
| commit | a3215a0525acc7e3de7b07b12d316b9c5b98fe6b (patch) | |
| tree | 2612c537f898e286eb19f7e776bdbd66227a6c66 | |
| parent | 1182174aee17523fc53d651df95c5384b4df3f97 (diff) | |
| download | rabbitmq-server-a3215a0525acc7e3de7b07b12d316b9c5b98fe6b.tar.gz | |
FunAcc0 ==> FunAcc
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 6dbd95c2..6869846d 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -170,7 +170,7 @@ record_current_channel_tx(ChPid, Txn) -> %% that wasn't happening already) store_ch_record((ch_record(ChPid))#cr{txn = Txn}). -deliver_queue(Funs = {PredFun, DeliverFun}, FunAcc0, +deliver_queue(Funs = {PredFun, DeliverFun}, FunAcc, State = #q{q = #amqqueue{name = QName}, active_consumers = ActiveConsumers, blocked_consumers = BlockedConsumers, @@ -182,12 +182,12 @@ deliver_queue(Funs = {PredFun, DeliverFun}, FunAcc0, C = #cr{limiter_pid = LimiterPid, unsent_message_count = Count, unacked_messages = UAM} = ch_record(ChPid), - IsMsgReady = PredFun(FunAcc0, State), + IsMsgReady = PredFun(FunAcc, State), case (IsMsgReady andalso rabbit_limiter:can_send( LimiterPid, self(), AckRequired )) of true -> {{Msg, IsDelivered, AckTag}, FunAcc1, State1} = - DeliverFun(AckRequired, FunAcc0, State), + DeliverFun(AckRequired, FunAcc, State), ?LOGDEBUG("AMQQUEUE ~p DELIVERY:~n~p~n", [QName, Msg]), rabbit_channel:deliver( ChPid, ConsumerTag, AckRequired, @@ -226,15 +226,15 @@ deliver_queue(Funs = {PredFun, DeliverFun}, FunAcc0, ActiveConsumers, BlockedConsumers), deliver_queue( - Funs, FunAcc0, + Funs, FunAcc, State#q{active_consumers = NewActiveConsumers, blocked_consumers = NewBlockedConsumers}); false -> %% no message was ready, so we don't need to block anyone - {FunAcc0, State} + {FunAcc, State} end; {empty, _} -> - {FunAcc0, State} + {FunAcc, State} end. deliver_from_queue_pred({IsEmpty, _AutoAcks}, _State) -> |