diff options
| author | Kazuki Yamaguchi <k@rhe.jp> | 2015-04-21 14:50:32 +0900 |
|---|---|---|
| committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-04-21 14:50:32 +0900 |
| commit | 87fbdae4649f639a194b816453fafe57a4533d10 (patch) | |
| tree | a4cec87f95ffb41268c10735740df1934c83baa7 | |
| parent | b0ee7560616773a915a5897f51412476d258eb52 (diff) | |
| download | aclog-87fbdae4649f639a194b816453fafe57a4533d10.tar.gz | |
collector: cancel heartbeat timer when unbinded
| -rw-r--r-- | lib/collector/node_connection.rb | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/collector/node_connection.rb b/lib/collector/node_connection.rb index 799f175..1504b1c 100644 --- a/lib/collector/node_connection.rb +++ b/lib/collector/node_connection.rb @@ -18,6 +18,7 @@ module Collector end def unbind + @heartbeat_timer.cancel if @heartbeat_timer if @closing log(:info, "Connection was closed.") else @@ -129,6 +130,7 @@ module Collector log(:warn, "Node is dead.") NodeManager.unregister(self) @heartbeat_timer.cancel + @heartbeat_timer = nil @closing = true close_connection_after_writing return |