diff options
| author | Gabriele Santomaggio <gabriele.santomaggio@erlang-solutions.com> | 2016-09-26 15:07:27 +0200 |
|---|---|---|
| committer | Gabriele Santomaggio <gabriele.santomaggio@erlang-solutions.com> | 2016-09-26 15:07:27 +0200 |
| commit | 5bbc6dd4d73aaf96173cc60a9ad7feb8ef695dc1 (patch) | |
| tree | 8a38cc21e36f8c9da35b0400b0ca0d839cacb2b6 /src | |
| parent | c78daa7b6e239dde9f8c965ea81dfc325830efbe (diff) | |
| download | rabbitmq-server-git-5bbc6dd4d73aaf96173cc60a9ad7feb8ef695dc1.tar.gz | |
defaul value for run_count
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 5259b5a142..f943a66c04 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -307,7 +307,8 @@ %% default queue or lazy queue mode, - % number of executions to reach the GC, see: maybe_execute_gc/1 + % number of executions to reach the GC_THRESHOLD, + % see: maybe_execute_gc/1 run_count }). @@ -1348,7 +1349,8 @@ init(IsDurable, IndexState, DeltaCount, DeltaBytes, Terms, io_batch_size = IoBatchSize, - mode = default }, + mode = default, + run_count = 0}, a(maybe_deltas_to_betas(State)). blank_rates(Now) -> @@ -2284,7 +2286,7 @@ ifold(Fun, Acc, Its, State) -> maybe_execute_gc(State = #vqstate {run_count = RunCount}) -> case RunCount >= ?GC_THRESHOLD of - true -> garbage_collect(), + true -> garbage_collect(), State#vqstate{run_count = 0}; false -> State#vqstate{run_count = RunCount + 1} |