summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Klishin <michael@novemberain.com>2015-10-31 10:38:11 +0300
committerMichael Klishin <michael@novemberain.com>2015-10-31 10:38:11 +0300
commit0cc96cb8ca93a6bda9d6e3c00dc7047fbbf62731 (patch)
treeec4018949465e7cb3d18b62c95794c76da55ab94 /src
parenta74006936b7aaccd952d73b80561259430065170 (diff)
parent84dec3da91283e3a0bb153ac4437e2600ea1a96d (diff)
downloadrabbitmq-server-git-0cc96cb8ca93a6bda9d6e3c00dc7047fbbf62731.tar.gz
Merge pull request #397 from rabbitmq/rabbitmq-server-91
Disable disk monitor in unsupported platforms
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_disk_monitor.erl13
1 files changed, 10 insertions, 3 deletions
diff --git a/src/rabbit_disk_monitor.erl b/src/rabbit_disk_monitor.erl
index 518000eb64..c65631a24c 100644
--- a/src/rabbit_disk_monitor.erl
+++ b/src/rabbit_disk_monitor.erl
@@ -40,7 +40,8 @@
min_interval,
max_interval,
timer,
- alarmed
+ alarmed,
+ enabled
}).
%%----------------------------------------------------------------------------
@@ -96,7 +97,8 @@ init([Limit]) ->
State = #state{dir = Dir,
min_interval = ?DEFAULT_MIN_DISK_CHECK_INTERVAL,
max_interval = ?DEFAULT_MAX_DISK_CHECK_INTERVAL,
- alarmed = false},
+ alarmed = false,
+ enabled = true},
case {catch get_disk_free(Dir),
vm_memory_monitor:get_total_memory()} of
{N1, N2} when is_integer(N1), is_integer(N2) ->
@@ -104,12 +106,17 @@ init([Limit]) ->
Err ->
rabbit_log:info("Disabling disk free space monitoring "
"on unsupported platform:~n~p~n", [Err]),
- {stop, unsupported_platform}
+ {ok, State#state{enabled = false}}
end.
handle_call(get_disk_free_limit, _From, State = #state{limit = Limit}) ->
{reply, Limit, State};
+handle_call({set_disk_free_limit, _}, _From, #state{enabled = false} = State) ->
+ rabbit_log:info("Cannot set disk free limit: "
+ "disabled disk free space monitoring", []),
+ {reply, ok, State};
+
handle_call({set_disk_free_limit, Limit}, _From, State) ->
{reply, ok, set_disk_limits(State, Limit)};