diff options
| author | Kazuki Yamaguchi <k@rhe.jp> | 2015-04-19 11:36:36 +0900 |
|---|---|---|
| committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-04-19 11:36:36 +0900 |
| commit | 27092adb3e512f6dc5c991302cf0ad80e12e6594 (patch) | |
| tree | 9aea2184e256a1608df2d1413ca0be879409884d | |
| parent | 155333d139f49e284cef8e069daf7e5ad8f4dbd5 (diff) | |
| download | aclog-27092adb3e512f6dc5c991302cf0ad80e12e6594.tar.gz | |
collector: unbind inactive worker_nodes
| -rw-r--r-- | lib/collector/node_connection.rb | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/collector/node_connection.rb b/lib/collector/node_connection.rb index 4791df6..d12f567 100644 --- a/lib/collector/node_connection.rb +++ b/lib/collector/node_connection.rb @@ -6,6 +6,9 @@ module Collector @@_id = 0 def initialize(queue) + # comm_inactivity_timeout exceed -> heatbeat -> (when alive) -> continue + # -> (when not) -> unbind + self.comm_inactivity_timeout = 10 @unpacker = MessagePack::Unpacker.new(symbolize_keys: true) @connection_id = (@@_id += 1) @authenticated = false |