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

Add hook for registering install completion

Browse Source 
This will allow watching the
profile for changes to know
when install is utterly complete.
This commit is contained in:
Jarrod Johnson 2020-05-13 16:29:10 -04:00
parent 393c3ac38e
commit 7dcad26002
2 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
confluent_server/confluent/config/attributes.py
View File

@ -175,6 +175,13 @@ node = {
'the network boot subsystem what should be offered when a potential '
'network boot request comes in')
},
'deployment.profile': {
'description': ('The profile that has most recently reported '
'completion of deployment. Note that an image may opt '
'to leave itself both current and pending, for example '
'a stateless profile would be both after first boot.')
},
'deployment.useinsecureprotocols': {
'description': ('What phase(s) of boot are permitted to use insecure protocols '
'(TFTP and HTTP without TLS. By default, HTTPS is allowed. However '

22
confluent_server/confluent/selfservice.py
View File

@ -106,13 +106,31 @@ def handle_request(env, start_response):
nodes.add(mgr)
nodes.add(collective.get_myname())
if isgeneric:
start_response('200 OK', (('Contennt-Type', 'text/plain'),))
start_response('200 OK', (('Content-Type', 'text/plain'),))
for node in util.natural_sort(nodes):
yield node + '\n'
else:
start_response('200 OK', (('Content-Type', retype),))
yield dumper(sorted(nodes))
elif env['PATH_INFO'] == '/self/updatestatus':
update = yaml.safe_load(reqbody)
if update['status'] != 'complete':
raise Exception('Unknown update status request')
currattr = cfg.get_node_attributes(nodename, 'deployment.*').get(
nodename, {})
pending = currattr.get('deployment.pendingprofile', {}).get('value', '')
updates = {}
if pending:
updates['deployment.pendingprofile'] = {'value': ''}
currprof = currattr.get('deployment.profile', {}).get('value', '')
if currprof != pending:
updates['deployment.profile'] = {'value': pending}
cfg.set_node_attributes({nodename: updates})
start_response('200 OK', ('Content-Type', 'text/plain'))
yield 'OK'
else:
start_response('500 Error', ('Content-Type', 'text/plain'))
yield 'No pending profile detected, unable to accept status update'
else:
start_response('404 Not Found', ())
yield 'Not found'