diff options
| author | Marek Majkowski <majek@lshift.net> | 2009-10-23 10:59:29 -0400 |
|---|---|---|
| committer | Marek Majkowski <majek@lshift.net> | 2009-10-23 10:59:29 -0400 |
| commit | 1bc8295bf8cd4cf02cbe5c3fad9c05dd936e0e30 (patch) | |
| tree | 03e635eacb96a29541026722f9da48e36eb0e7e6 | |
| parent | bffe10e741cdc19f727ca8f50e22b3603a861254 (diff) | |
| download | rabbitmq-server-git-1bc8295bf8cd4cf02cbe5c3fad9c05dd936e0e30.tar.gz | |
dict->ets, and a refactoring
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index a540025494..d402ef97cc 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -826,11 +826,11 @@ handle_cast(send_memory_monitor_update, State) -> rabbit_memory_monitor:push_queue_duration(self(), BufSec), noreply(State#q{drain_ratio = DrainRatio1}); -handle_cast({set_bufsec_limit, BufSec}, State) -> +handle_cast({set_queue_duration, QueueDuration}, State) -> DrainRatio = State#q.drain_ratio, - DesiredQueueLength = case BufSec of + DesiredQueueLength = case QueueDuration of infinity -> infinity; - _ -> BufSec * DrainRatio#ratio.ratio * 1000000 + _ -> QueueDuration * DrainRatio#ratio.ratio * 1000000 end, %% Just to proove that something is happening. ?LOGDEBUG("Queue size is ~8p, should be ~p~n", |