loic/clusterman
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/clusterman.git synced 2025-04-05 11:36:25 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Minor changes

Browse source
This commit is contained in:
Loïc Guégan 2023-10-27 13:54:45 +02:00
parent 839f4d5a30
commit cd4e28906b
1 changed files with 17 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
clusterman/commands/node.py
View file

@ -64,29 +64,25 @@ def scan(timeout):
CONF.save()
def check(timeout):
nodes_path=CONF.NODE_FILE
nodes=None
if os.path.exists(nodes_path):
with open(nodes_path) as f:
nodes=json.load(f)
else:
nodes=get_node_list()
if len(nodes) <= 0:
print("Please perform a scan before")
exit(0)
if not nodes == None:
fail=False
for ip in nodes:
print("Contacting {}...".format(ip),end='')
try:
subprocess.run(["ping", "-c", "1", "-W", str(timeout), ip],capture_output=True,check=True)
nodes.append(ip)
print()
except:
fail=True
print("=> Not responding!!")
if not fail:
print("Success: All nodes are reachable")
else:
print("Error: Some of your nodes are not reachable")
# Perform ping check
fail=False
for ip in nodes:
print("Contacting {}...".format(ip),end='')
try:
subprocess.run(["ping", "-c", "1", "-W", str(timeout), ip],capture_output=True,check=True)
nodes.append(ip)
print()
except:
fail=True
print("=> Not responding!!")
if not fail:
print("Success: All nodes are reachable")
else:
print("Error: Some of your nodes are not reachable")
def exec(command):
user="root" if len(CONF["ssh"]["user"]) <= 0 else CONF["ssh"]["user"]