diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-08 16:48:04 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-08 16:48:04 +0000 |
| commit | 4baa89636d8f36cb8a1991f4a9059fca16242f83 (patch) | |
| tree | 4da8e003e053732547aaa4dd961d53800e66483b | |
| parent | 3c9cd7c346a546a717bf7b06f8f92f722263c216 (diff) | |
| download | rabbitmq-server-bug25353.tar.gz | |
tidy upbug25353
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 21b4407d..5fbda9c5 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 }. |