mirror of
https://github.com/xcat2/confluent.git
synced 2025-02-11 08:15:24 +00:00
Fix for post group failures
A node failure after group failure would erase the group from range. Further, correct an issue where an empty nodeset would trigger a bad behavior.
This commit is contained in:
parent
b91a194184
commit
8b150a9047
@ -221,22 +221,27 @@ class ReverseNodeRange(object):
|
||||
subsetgroups.sort(key=humanify_nodename)
|
||||
groupchunks = group_elements(subsetgroups)
|
||||
for gc in groupchunks:
|
||||
if not gc:
|
||||
continue
|
||||
bracketer = Bracketer(gc[0])
|
||||
for chnk in gc[1:]:
|
||||
bracketer.extend(chnk)
|
||||
ranges.append(bracketer.range)
|
||||
except Exception:
|
||||
subsetgroups.sort()
|
||||
ranges.extend(subsetgroups)
|
||||
try:
|
||||
nodes = sorted(self.nodes, key=humanify_nodename)
|
||||
nodechunks = group_elements(nodes)
|
||||
for nc in nodechunks:
|
||||
if not nc:
|
||||
continue
|
||||
bracketer = Bracketer(nc[0])
|
||||
for chnk in nc[1:]:
|
||||
bracketer.extend(chnk)
|
||||
ranges.append(bracketer.range)
|
||||
except Exception:
|
||||
ranges = sorted(self.nodes)
|
||||
ranges.extend(sorted(self.nodes))
|
||||
return ','.join(ranges)
|
||||
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user