diff options
| author | Kazuki Yamaguchi <k@rhe.jp> | 2015-04-19 12:19:59 +0900 |
|---|---|---|
| committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-04-19 12:19:59 +0900 |
| commit | f37f0c563ddd36c1627e9e42ceab902b364099a4 (patch) | |
| tree | 867c16bac254b1965f792cb17827e10a81c03a5f | |
| parent | b49780e801e27adb4f3063686f3dde57ff6e2df3 (diff) | |
| download | aclog-f37f0c563ddd36c1627e9e42ceab902b364099a4.tar.gz | |
collector: unregister connection when dead
| -rw-r--r-- | lib/collector/node_connection.rb | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/collector/node_connection.rb b/lib/collector/node_connection.rb index 3059577..799f175 100644 --- a/lib/collector/node_connection.rb +++ b/lib/collector/node_connection.rb @@ -127,6 +127,7 @@ module Collector def heartbeat if @heartbeats.size > 2 # 30 sec log(:warn, "Node is dead.") + NodeManager.unregister(self) @heartbeat_timer.cancel @closing = true close_connection_after_writing |