summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-08 16:48:04 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-08 16:48:04 +0000
commitabd42f6c74e17d0372bea603145a2cc3166018da (patch)
tree4da8e003e053732547aaa4dd961d53800e66483b
parent398f83c28589493ee303a33c11fe4e76c8e0ec6f (diff)
downloadrabbitmq-server-git-abd42f6c74e17d0372bea603145a2cc3166018da.tar.gz
tidy up
-rw-r--r--src/rabbit_mirror_queue_slave.erl4
1 files changed, 0 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index 21b4407d8d..5fbda9c521 100644
--- a/src/rabbit_mirror_queue_slave.erl
+++ b/src/rabbit_mirror_queue_slave.erl
@@ -580,15 +580,11 @@ ensure_rate_timer(State = #state { rate_timer_ref = undefined }) ->
TRef = erlang:send_after(?RAM_DURATION_UPDATE_INTERVAL,
self(), update_ram_duration),
State #state { rate_timer_ref = TRef };
-ensure_rate_timer(State = #state { rate_timer_ref = just_measured }) ->
- State #state { rate_timer_ref = undefined };
ensure_rate_timer(State) ->
State.
stop_rate_timer(State = #state { rate_timer_ref = undefined }) ->
State;
-stop_rate_timer(State = #state { rate_timer_ref = just_measured }) ->
- State #state { rate_timer_ref = undefined };
stop_rate_timer(State = #state { rate_timer_ref = TRef }) ->
erlang:cancel_timer(TRef),
State #state { rate_timer_ref = undefined }.