2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 17:43:14 +00:00

Remove explict console health check

This is a resource consumption problem.  Defer such measures until later.
Investigation uncovered that there may have been another culprit anyway,
will see if only the other change (to kick a zoned out connection attempt)
suffices.
This commit is contained in:
Jarrod Johnson 2016-05-23 13:49:46 -04:00
parent a046e4939f
commit 41e84c7c47

View File

@ -25,7 +25,6 @@ import eventlet.greenpool as greenpool
import eventlet.queue as queue
import pyghmi.constants as pygconstants
import pyghmi.exceptions as pygexc
import random
console = eventlet.import_patched('pyghmi.ipmi.console')
ipmicommand = eventlet.import_patched('pyghmi.ipmi.command')
import socket
@ -204,18 +203,12 @@ class IpmiConsole(conapi.Console):
self.bmc = connparams['bmc']
self.port = connparams['port']
self.connected = False
self.checker = None
# Cannot actually create console until 'connect', when we get callback
def __del__(self):
self.solconnection = None
def handle_data(self, data):
if self.checker:
# if we got data from remote, delay the ping check
self.checker.cancel()
self.checker = eventlet.spawn_after(290 + random.random() * 30,
self.ping)
if type(data) == dict:
if 'error' in data:
self.solconnection = None
@ -252,14 +245,8 @@ class IpmiConsole(conapi.Console):
self.connected = True
except socket.gaierror as err:
raise exc.TargetEndpointUnreachable(str(err))
if self.checker:
self.checker.cancel()
self.checker = eventlet.spawn_after(290 + random.random() * 30,
self.ping)
def close(self):
if self.checker:
self.checker.cancel()
if self.solconnection is not None:
# break the circular reference here
self.solconnection.out_handler = _donothing