xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-14 17:48:26 +00:00
Code Issues Projects Releases Wiki Activity

updating server side for use with nodegroupattrib

Browse Source
This commit is contained in:
Allen Lin37 2017-04-13 17:36:41 -04:00
parent 43211cf9a7
commit 2042bcb8f0
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
confluent_server/confluent/config/configmanager.py
View File

@ -896,6 +896,11 @@ class ConfigManager(object):
if node not in self._cfgstore['nodes']:
self._cfgstore['nodes'][node] = {'groups': [group]}
_mark_dirtykey('nodes', node, self.tenant)
elif 'value' in self._cfgstore['nodes'][node]['groups']:
tmplist=self._cfgstore['nodes'][node]['groups']['value'].split(",")
tmplist.insert(0, unicode(group))
self._cfgstore['nodes'][node]['groups']['value']=",".join(tmplist)
_mark_dirtykey('nodes', node, self.tenant)
elif group not in self._cfgstore['nodes'][node]['groups']:
self._cfgstore['nodes'][node]['groups'].insert(0, group)
_mark_dirtykey('nodes', node, self.tenant)
@ -1138,14 +1143,18 @@ class ConfigManager(object):
raise ValueError("node {0} does not exist".format(node))
for attrname in attribmap[node].iterkeys():
attrval = attribmap[node][attrname]
print attrval
print allattributes.node[attrname]
try:
if (allattributes.node[attrname]['type'] == 'list' and
type(attrval) in (str, unicode)):
type(attrval) in (str, unicode)) and type(attrval)==list:
attrval = attrval.split(",")
except KeyError:
pass
if attrname == 'groups':
for group in attribmap[node]['groups'].split(","):
if type(attribmap[node]['groups']) != list:
attribmap[node]['groups']=attribmap[node]['groups'].split(",")
for group in attribmap[node]['groups']:
if group not in self._cfgstore['nodegroups']:
raise ValueError(
"group {0} does not exist".format(group))