openstack/deb-python-kafka
Code Issues Proposed changes

Drop unused last_failure time from BrokerConnection

Browse Source
This commit is contained in:
Dana Powers
2016-12-17 10:39:34 -08:00
parent 48b31b4289
commit 0a0449e2de
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
kafka/conn.py
View File

@@ -154,8 +154,8 @@ class BrokerConnection(object):
sasl_plain_password (str): password for sasl PLAIN authentication. sasl_plain_password (str): password for sasl PLAIN authentication.
Default: None Default: None
""" """
self.host = host
self.hostname = host self.hostname = host
self.host = host
self.port = port self.port = port
self.afi = afi self.afi = afi
self._init_host = host self._init_host = host
@@ -194,7 +194,6 @@ class BrokerConnection(object):
self._receiving = False self._receiving = False
self._next_payload_bytes = 0 self._next_payload_bytes = 0
self.last_attempt = 0 self.last_attempt = 0
self.last_failure = 0
self._processing = False self._processing = False
self._correlation_id = 0 self._correlation_id = 0
self._gai = None self._gai = None
@@ -363,7 +362,6 @@ class BrokerConnection(object):
except ssl.SSLError as e: except ssl.SSLError as e:
log.exception('%s: Failed to wrap socket in SSLContext!', str(self)) log.exception('%s: Failed to wrap socket in SSLContext!', str(self))
self.close(e) self.close(e)
self.last_failure = time.time()
def _try_handshake(self): def _try_handshake(self):
assert self.config['security_protocol'] in ('SSL', 'SASL_SSL') assert self.config['security_protocol'] in ('SSL', 'SASL_SSL')
@@ -496,7 +494,6 @@ class BrokerConnection(object):
self._sock.close() self._sock.close()
self._sock = None self._sock = None
self.state = ConnectionStates.DISCONNECTED self.state = ConnectionStates.DISCONNECTED
self.last_failure = time.time()
self._receiving = False self._receiving = False
self._next_payload_bytes = 0 self._next_payload_bytes = 0
self._rbuffer.seek(0) self._rbuffer.seek(0)