mirror of
https://github.com/xcat2/confluent.git
synced 2025-08-26 05:00:46 +00:00
Implement access to other banks
Provide backend support for other banks than primary.
This commit is contained in:
@@ -26,7 +26,8 @@ updatesbytarget = {}
|
||||
|
||||
def execupdate(handler, filename, updateobj):
|
||||
try:
|
||||
completion = handler(filename, progress=updateobj.handle_progress)
|
||||
completion = handler(filename, progress=updateobj.handle_progress,
|
||||
bank=updateobj.bank)
|
||||
if completion is None:
|
||||
completion = 'complete'
|
||||
updateobj.handle_progress({'phase': completion, 'progress': 100.0})
|
||||
@@ -35,7 +36,9 @@ def execupdate(handler, filename, updateobj):
|
||||
'detail': str(e)})
|
||||
|
||||
class Updater(object):
|
||||
def __init__(self, node, handler, filename, tenant=None, name=None):
|
||||
def __init__(self, node, handler, filename, tenant=None, name=None,
|
||||
bank=None):
|
||||
self.bank = bank
|
||||
self.node = node
|
||||
self.phase = 'initializing'
|
||||
self.detail = ''
|
||||
|
@@ -399,6 +399,7 @@ class InputFirmwareUpdate(ConfluentMessage):
|
||||
|
||||
def __init__(self, path, nodes, inputdata):
|
||||
self.filename = inputdata['filename']
|
||||
self.bank = inputdata.get('bank', None)
|
||||
self.nodes = nodes
|
||||
|
||||
|
||||
|
@@ -455,7 +455,8 @@ class IpmiHandler(object):
|
||||
|
||||
def handle_update(self):
|
||||
u = firmwaremanager.Updater(self.node, self.ipmicmd.update_firmware,
|
||||
self.inputdata.filename, self.tenant)
|
||||
self.inputdata.filename, self.tenant,
|
||||
bank=self.inputdata.bank)
|
||||
self.output.put(
|
||||
msg.CreatedResource(
|
||||
'nodes/{0}/inventory/firmware/updates/active/{1}'.format(
|
||||
|
Reference in New Issue
Block a user