xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-24 00:23:53 +00:00
Code Issues Projects Releases Wiki Activity

Provide cleaner message for collective manager being unreachable

Browse Source
This commit is contained in:
Jarrod Johnson 2018-07-13 10:43:20 -04:00
parent 7f1e5d2302
commit 6f012b69a1
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
confluent_server/confluent/core.py
View File

@ -794,10 +794,14 @@ def handle_node_request(configmanager, inputdata, operation,
def dispatch_request(nodes, manager, element, configmanager, inputdata,
operation):
a = configmanager.get_collective_member(manager)
remote = socket.create_connection((a['address'], 13001))
remote = ssl.wrap_socket(remote, cert_reqs=ssl.CERT_NONE,
keyfile='/etc/confluent/privkey.pem',
certfile='/etc/confluent/srvcert.pem')
try:
remote = socket.create_connection((a['address'], 13001))
remote = ssl.wrap_socket(remote, cert_reqs=ssl.CERT_NONE,
keyfile='/etc/confluent/privkey.pem',
certfile='/etc/confluent/srvcert.pem')
except Exception:
raise exc.TargetEndpointUnreachable(
'Collective member {0} is unreachable'.format(a['name']))
if not util.cert_matches(a['fingerprint'], remote.getpeercert(
binary_form=True)):
raise Exception("Invalid certificate on peer")