diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-03-03 12:50:40 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-03-03 12:50:40 +0000 |
| commit | 059e6cbc28d6865d14b50ea37397ece38d0c7aec (patch) | |
| tree | fd4325a974f54be00e52bd858c714283306b46fb /src/rabbit_amqqueue_process.erl | |
| parent | 3a3a22768e6002098ca99f5feb6429f9d9e764f5 (diff) | |
| download | rabbitmq-server-059e6cbc28d6865d14b50ea37397ece38d0c7aec.tar.gz | |
limit alpha->beta conversion through msg store credit flow
we also bump the IO_BATCH_SIZE; it's only used to limit beta->gamma
conversion, which is a fairly cheap operation (it only touches qi,
which has a very compact on-disk representation), and we want to make
sure that such conversion can keep up with the alpha->beta conversion.
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index ec1a977d..9d240a3f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1235,7 +1235,7 @@ handle_info({'EXIT', _Pid, Reason}, State) -> handle_info({bump_credit, Msg}, State) -> credit_flow:handle_bump_msg(Msg), - noreply(State); + noreply(backing_queue_timeout(State)); handle_info(Info, State) -> {stop, {unhandled_info, Info}, State}. |