From 86de9ce276c8b9dff45dcfb3fad641122cd7fdad Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 17 Jun 2020 11:07:54 -0400 Subject: [PATCH] Do not answer deploy solicit without quorum If we are not in quorum, we cannot provide credible answers to deployment. --- confluent_server/confluent/discovery/protocols/ssdp.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/confluent_server/confluent/discovery/protocols/ssdp.py b/confluent_server/confluent/discovery/protocols/ssdp.py index d90c4742..ac76a399 100644 --- a/confluent_server/confluent/discovery/protocols/ssdp.py +++ b/confluent_server/confluent/discovery/protocols/ssdp.py @@ -168,6 +168,10 @@ def snoop(handler, byehandler=None, protocol=None, uuidlookup=None): if len(headline) < 3: continue if headline[0] == 'ST' and headline[-1].startswith(' urn:xcat.org:service:confluent:'): + try: + cfm.check_quorum() + except Exception: + continue for query in headline[-1].split('/'): if query.startswith('uuid='): curruuid = query.split('=', 1)[1].lower()