Skip to content
Snippets Groups Projects
Commit 1efa1200 authored by Adrien Béraud's avatar Adrien Béraud
Browse files

dhtcluster: allow to resize cluster

parent a99ca1cf
Branches
No related tags found
No related merge requests found
...@@ -153,7 +153,7 @@ class ClusterShell(cmd.Cmd): ...@@ -153,7 +153,7 @@ class ClusterShell(cmd.Cmd):
return True return True
def do_node(self, arg): def do_node(self, arg):
if not arg: if not arg:
setNode() self.setNode()
else: else:
nodenum = int(arg) nodenum = int(arg)
node = self.net.get(nodenum-1) node = self.net.get(nodenum-1)
...@@ -161,6 +161,14 @@ class ClusterShell(cmd.Cmd): ...@@ -161,6 +161,14 @@ class ClusterShell(cmd.Cmd):
print("Invalid node number:", nodenum, " (accepted: 1-", len(self.net.nodes), ")") print("Invalid node number:", nodenum, " (accepted: 1-", len(self.net.nodes), ")")
else: else:
self.setNode(node, nodenum) self.setNode(node, nodenum)
def do_resize(self, arg):
if not arg:
return
try:
nodenum = int(arg)
self.net.resize(nodenum)
except Exception as e:
print("Can't resize:", e)
def do_ll(self, arg): def do_ll(self, arg):
if self.node: if self.node:
print('Node', self.node.getNodeId().decode()) print('Node', self.node.getNodeId().decode())
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment