Merge pull request #1234 from rabbitmq/rabbitmq-server-1224

Introduce a new config parameter, total_memory_available_override_value, to override total amount of memory available to the node

Author: michaelklishin

docs/rabbitmq.config.example

@@ -246,6 +246,10 @@
    %%
    %% {memory_monitor_interval, 2500},
 
+   %% The total memory available can be calculated from the OS resources
+   %% - default option - or provided as a configuration parameter:
+   %% {total_memory_available_override_value, "5000MB"},
+
    %% Set disk free limit (in bytes). Once free disk space reaches this
    %% lower bound, a disk alarm will be set - see the documentation
    %% listed above for more details.

src/vm_memory_monitor.erl

@@ -81,13 +81,20 @@
 %%----------------------------------------------------------------------------
 
 get_total_memory() ->
-    try
-        get_total_memory(os:type())
-    catch _:Error ->
-            rabbit_log:warning(
-              "Failed to get total system memory: ~n~p~n~p~n",
-              [Error, erlang:get_stacktrace()]),
-            unknown
+    case application:get_env(rabbit, total_memory_available_override_value) of
+        {ok, Value} ->
+            case rabbit_resource_monitor_misc:parse_information_unit(Value) of
+                {ok, ParsedTotal} ->
+                    ParsedTotal;
+                {error, parse_error} ->
+                    rabbit_log:warning(
+                      "The override value for the total memmory available is "
+                      "not a valid value: ~p, getting total from the system.~n",
+                      [Value]),
+                    get_total_memory_from_os()
+            end;
+        undefined ->
+            get_total_memory_from_os()
     end.
 
 get_vm_limit() -> get_vm_limit(os:type()).
@@ -179,6 +186,15 @@ code_change(_OldVsn, State, _Extra) ->
 %%----------------------------------------------------------------------------
 %% Server Internals
 %%----------------------------------------------------------------------------
+get_total_memory_from_os() ->
+    try
+        get_total_memory(os:type())
+    catch _:Error ->
+            rabbit_log:warning(
+              "Failed to get total system memory: ~n~p~n~p~n",
+              [Error, erlang:get_stacktrace()]),
+            unknown
+    end.
 
 set_mem_limits(State, MemLimit) ->
     case erlang:system_info(wordsize) of