diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-12-18 11:49:21 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-12-18 11:49:21 +0000 |
| commit | 509de3766e907871aefd699f4439025c9a7e7707 (patch) | |
| tree | a152c7891367641289e37bf991adf6f9ef579b83 | |
| parent | ae3a821babc64cb1c464fec9c9acebb3936ca2ae (diff) | |
| download | rabbitmq-server-509de3766e907871aefd699f4439025c9a7e7707.tar.gz | |
correct condition for doing GC
| -rw-r--r-- | src/rabbit_msg_store.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index b8373fd1..0b711b13 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -104,9 +104,8 @@ -define(FILE_EXTENSION, ".rdq"). -define(FILE_EXTENSION_TMP, ".rdt"). -define(CACHE_ETS_NAME, rabbit_disk_queue_cache). -%% We run GC whenever the amount of garbage is >= GARBAGE_FRACTION * -%% Total Valid Data --define(GARBAGE_FRACTION, 1.0). +%% We run GC whenever (garbage / sum_file_size) > ?GARBAGE_FRACTION +-define(GARBAGE_FRACTION, 0.5). -define(BINARY_MODE, [raw, binary]). -define(READ_MODE, [read]). @@ -938,7 +937,7 @@ maybe_compact(State = #msstate { sum_valid_data = SumValid, sum_file_size = SumFileSize, gc_pid = undefined, file_summary = FileSummary }) - when (SumFileSize - SumValid) > ?GARBAGE_FRACTION * SumValid -> + when (SumFileSize - SumValid) / SumFileSize > ?GARBAGE_FRACTION -> %% Pid = spawn_link(fun() -> %% io:format("GC process!~n") %% %% gen_server2:pcast(?SERVER, 9, {gc_finished, self(),}), |