mirror of
https://github.com/xcat2/confluent.git
synced 2026-09-28 16:20:54 +00:00
Tolerate a target that won't TCP SLP
This commit is contained in:
@@ -64,4 +64,5 @@ class NodeHandler(object):
|
||||
except IOError as ie:
|
||||
if ie.errno == errno.ECONNREFUSED:
|
||||
return None
|
||||
raise
|
||||
return self._fp
|
||||
@@ -307,7 +307,10 @@ def _add_attributes(parsed):
|
||||
net = socket.socket(socket.AF_INET6, socket.SOCK_STREAM)
|
||||
else:
|
||||
net = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
net.connect(target)
|
||||
try:
|
||||
net.connect(target)
|
||||
except socket.error:
|
||||
return
|
||||
net.sendall(attrq)
|
||||
rsp = net.recv(8192)
|
||||
net.close()
|
||||
|
||||
Reference in New Issue
Block a user