diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2014-06-13 12:01:52 +0100 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2014-06-13 12:01:52 +0100 |
commit | 3a35597189d6d96224501e34e405310dcd323712 (patch) | |
tree | bbceb3df137d6f24dab1c5af37b6e3b0cfeb8d78 | |
parent | c7e467573be3e4b9a59baf10b40846c07169c3f7 (diff) | |
parent | 4e9253c24fc2fa3d73c5e514dd1bcf7441fbaa57 (diff) | |
download | rabbitmq-server-3a35597189d6d96224501e34e405310dcd323712.tar.gz |
stable to default
-rw-r--r-- | src/rabbit_disk_monitor.erl | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_disk_monitor.erl b/src/rabbit_disk_monitor.erl index fbf13a90..031a04f0 100644 --- a/src/rabbit_disk_monitor.erl +++ b/src/rabbit_disk_monitor.erl @@ -107,8 +107,8 @@ init([Limit]) -> {stop, unsupported_platform} end. -handle_call(get_disk_free_limit, _From, State) -> - {reply, interpret_limit(State#state.limit), State}; +handle_call(get_disk_free_limit, _From, State = #state{limit = Limit}) -> + {reply, Limit, State}; handle_call({set_disk_free_limit, Limit}, _From, State) -> {reply, ok, set_disk_limits(State, Limit)}; @@ -153,29 +153,29 @@ code_change(_OldVsn, State, _Extra) -> % the partition / drive containing this directory will be monitored dir() -> rabbit_mnesia:dir(). -set_disk_limits(State, Limit) -> +set_disk_limits(State, Limit0) -> + Limit = interpret_limit(Limit0), State1 = State#state { limit = Limit }, rabbit_log:info("Disk free limit set to ~pMB~n", - [trunc(interpret_limit(Limit) / 1000000)]), + [trunc(Limit / 1000000)]), internal_update(State1). internal_update(State = #state { limit = Limit, dir = Dir, alarmed = Alarmed}) -> - CurrentFreeBytes = get_disk_free(Dir), - LimitBytes = interpret_limit(Limit), - NewAlarmed = CurrentFreeBytes < LimitBytes, + CurrentFree = get_disk_free(Dir), + NewAlarmed = CurrentFree < Limit, case {Alarmed, NewAlarmed} of {false, true} -> - emit_update_info("insufficient", CurrentFreeBytes, LimitBytes), + emit_update_info("insufficient", CurrentFree, Limit), rabbit_alarm:set_alarm({{resource_limit, disk, node()}, []}); {true, false} -> - emit_update_info("sufficient", CurrentFreeBytes, LimitBytes), + emit_update_info("sufficient", CurrentFree, Limit), rabbit_alarm:clear_alarm({resource_limit, disk, node()}); _ -> ok end, - State #state {alarmed = NewAlarmed, actual = CurrentFreeBytes}. + State #state {alarmed = NewAlarmed, actual = CurrentFree}. get_disk_free(Dir) -> get_disk_free(Dir, os:type()). |