diff options
| author | Kazuki Yamaguchi <k@rhe.jp> | 2015-06-17 23:58:36 +0900 |
|---|---|---|
| committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-06-17 23:58:36 +0900 |
| commit | 8c9899d498f63139e7e56e57cad913d357aa986e (patch) | |
| tree | 47956ea43f1a49296d621601928a8845136508b5 | |
| parent | 2cb61dac88ebffc32ea7093786e2b35ea2602c77 (diff) | |
| download | aclog-8c9899d498f63139e7e56e57cad913d357aa986e.tar.gz | |
collector: CollectorProxyConnection must be 'not connected' when unbound
| -rw-r--r-- | lib/collector/collector_proxy_connection.rb | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/collector/collector_proxy_connection.rb b/lib/collector/collector_proxy_connection.rb index 1de2974..986fa8e 100644 --- a/lib/collector/collector_proxy_connection.rb +++ b/lib/collector/collector_proxy_connection.rb @@ -25,9 +25,11 @@ module Collector def unbind if @closing log(:info, "Connection was closed.") + @connected = false else if @connected log(:info, "Connection was closed unexpectedly.") + @connected = false end EM.add_timer(10) { try_reconnect } |