xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-11 08:15:24 +00:00
Code Issues Projects Releases Wiki Activity

Correct some issues in the ssdp snoop

Browse Source 
We still need the node attributes even if
forcing reply.

Further,, sometimes eventlet returns None, tolerate
that better.
This commit is contained in:
Jarrod Johnson 2021-10-19 13:12:35 -04:00
parent f8f60052d0
commit 0725717359
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
confluent_server/confluent/discovery/protocols/ssdp.py
View File

@ -150,7 +150,9 @@ def snoop(handler, byehandler=None, protocol=None, uuidlookup=None):
newmacs = set([])
deferrednotifies = []
machandlers = {}
r, _, _ = select.select((net4, net6), (), (), 60)
r = select.select((net4, net6), (), (), 60)
if r:
r = r[0]
while r:
for s in r:
(rsp, peer) = s.recvfrom(9000)
@ -201,13 +203,13 @@ def snoop(handler, byehandler=None, protocol=None, uuidlookup=None):
currmac = query.split('=', 1)[1].lower()
node = uuidlookup(currmac)
if node:
cfg = cfm.ConfigManager(None)
cfd = cfg.get_node_attributes(
node, ['deployment.pendingprofile', 'collective.managercandidates'])
if not forcereply:
# Do not bother replying to a node that
# we have no deployment activity
# planned for
cfg = cfm.ConfigManager(None)
cfd = cfg.get_node_attributes(
node, ['deployment.pendingprofile', 'collective.managercandidates'])
if not cfd.get(node, {}).get(
'deployment.pendingprofile', {}).get('value', None):
break
@ -234,7 +236,9 @@ def snoop(handler, byehandler=None, protocol=None, uuidlookup=None):
reply = reply.encode('utf8')
s.sendto(reply, peer)
break
r, _, _ = select.select((net4, net6), (), (), 0.2)
r = select.select((net4, net6), (), (), 0.2)
if r:
r = r[0]
if deferrednotifies:
eventlet.sleep(2.2)
mac = neighutil.get_hwaddr(peer[0])