openstack/deb-python-kafka
Code Issues Proposed changes

supplement socket.gaierror exception in BrokerConnection.connect() (#687)

Browse Source 
supplement socket.gaierror exception to include the host/port
This commit is contained in:
Erik Beebe
2016-05-17 09:04:05 -05:00
committed by Dana Powers
parent a7e9dfc405
commit d7fa0731a0
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
kafka/conn.py
View File

@@ -115,9 +115,16 @@ class BrokerConnection(object):
# library like python-adns, or move resolution onto its # library like python-adns, or move resolution onto its
# own thread. This will be subject to the default libc # own thread. This will be subject to the default libc
# name resolution timeout (5s on most Linux boxes) # name resolution timeout (5s on most Linux boxes)
self._gai = socket.getaddrinfo(self.host, self.port, try:
socket.AF_UNSPEC, self._gai = socket.getaddrinfo(self.host, self.port,
socket.SOCK_STREAM) socket.AF_UNSPEC,
socket.SOCK_STREAM)
except socket.gaierror as ex:
raise socket.gaierror('getaddrinfo failed for {0}:{1}, '
'exception was {2}. Is your advertised.host.name correct'
' and resolvable?'.format(
self.host, self.port, ex
))
self._gai_index = 0 self._gai_index = 0
else: else:
# if self._gai already exists, then we should try the next # if self._gai already exists, then we should try the next