xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-29 13:00:03 +00:00
Code Issues Projects Releases Wiki Activity

Extend rescan to cover remote switches

Browse Source
This commit is contained in:
Jarrod Johnson 2022-11-03 13:31:57 -04:00
parent 327a45ef33
commit 7e02987a8c
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
confluent_server/confluent/discovery/core.py
View File

@ -1446,13 +1446,14 @@ def _periodic_recheck(configmanager):
def rescan():
_map_unique_ids()
global scanner
mycfm = cfm.ConfigManager(None)
myname = collective.get_myname()
if scanner:
return
else:
scanner = eventlet.spawn(blocking_scan)
for remagent in get_subscriptions():
affluent.
affluent.renotify_my(remagent, mycfm, myname)
def blocking_scan():

3
confluent_server/confluent/plugins/hardwaremanagement/affluent.py
View File

@ -58,7 +58,8 @@ def renotify_me(node, configmanager, myname):
creds = configmanager.get_node_attributes(
node, ['secret.hardwaremanagementuser', 'secret.hardwaremanagementpassword'], decrypt=True)
wc = WebClient(node, configmanager, creds)
wc.wc.grab_json_response('/affluent/cert_authorities/{0}'.format(myname), cacert)
res, status = wc.wc.grab_json_response_with_status('/affluent/systems/renotify', {'subscriber': myname})
def subscribe_discovery(node, configmanager, myname):
creds = configmanager.get_node_attributes(