2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-16 18:49:04 +00:00

Discontinue processing on cert mismatch

If cert mismatched, the client was shut out, but processing continued,
fix this mistake.
This commit is contained in:
Jarrod Johnson 2018-06-19 16:45:06 -04:00
parent 003358da5f
commit 624012774c

View File

@ -580,6 +580,7 @@ def handle_dispatch(connection, cert, dispatch):
if not util.cert_matches(
cfm.get_collective_member(dispatch['name'])['fingerprint'], cert):
connection.close()
return
configmanager = cfm.ConfigManager(dispatch['tenant'])
nodes = dispatch['nodes']
inputdata = dispatch['inputdata']