summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarek Majkowski <majek@lshift.net>2009-10-12 12:23:17 +0100
committerMarek Majkowski <majek@lshift.net>2009-10-12 12:23:17 +0100
commitbb701c9574cfe868c360fe997fb22e9a3c339a80 (patch)
tree56c76e1ff586f4f0b22aa008b0f49e353cdbc891
parent1774eddd2409c737ddbc801ae8a79547b44d3e5e (diff)
downloadrabbitmq-server-bb701c9574cfe868c360fe997fb22e9a3c339a80.tar.gz
QA fixes
-rw-r--r--src/vm_memory_monitor.erl18
1 files changed, 6 insertions, 12 deletions
diff --git a/src/vm_memory_monitor.erl b/src/vm_memory_monitor.erl
index cdd53236..5c97664b 100644
--- a/src/vm_memory_monitor.erl
+++ b/src/vm_memory_monitor.erl
@@ -175,20 +175,14 @@ parse_line_linux(Line) ->
%% you're in big trouble anyway.
get_vm_limit() ->
case erlang:system_info(wordsize) of
- 4 -> 2*1024*1024*1024;
- 8 -> infinity
+ 4 -> 2*1024*1024*1024; % 2 GiB for 32 bits
+ 8 -> 64*1024*1024*1024*1024 % 64 TiB for 64 bits
end.
-min(A,B) ->
- case A<B of
- true -> A;
- false -> B
- end.
-
-
get_mem_limit(MemFraction, TotalMemory) ->
- min(TotalMemory * MemFraction, get_vm_limit()).
+ lists:min([erlang:trunc(TotalMemory * MemFraction),
+ get_vm_limit()]).
init([MemFraction]) ->
TotalMemory = case get_total_memory(os:type()) of
@@ -200,8 +194,8 @@ init([MemFraction]) ->
M -> M
end,
MemLimit = get_mem_limit(MemFraction, TotalMemory),
- rabbit_log:info("Memory alarm set to ~p, ~p bytes.~n",
- [MemFraction, MemLimit]),
+ rabbit_log:info("Memory limit set to ~pMiB.~n",
+ [erlang:trunc(MemLimit/1048576)]),
TRef = start_timer(?DEFAULT_MEMORY_CHECK_INTERVAL),
State = #state { total_memory = TotalMemory,
memory_limit = MemLimit,