loic/clusterman
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/clusterman.git synced 2025-04-06 03:56:27 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Minor changes

Browse source
This commit is contained in:
Loic Guegan 2023-10-29 09:46:58 +01:00
parent f4da143142
commit ed8337414c
2 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
clusterman/commands/node.py
View file

@ -32,11 +32,10 @@ def scan(timeout):
print("Skipping {}".format(ip)) print("Skipping {}".format(ip))
continue continue
print("Contacting {}...".format(ip),end='') print("Contacting {}...".format(ip),end='')
try: if not utils.ping_test(ip):
subprocess.run(["ping", "-c", "1", "-W", str(timeout), ip],capture_output=True,check=True)
nodes.append(ip) nodes.append(ip)
print("=> Found!!") print("=> Found!!")
except: else:
print() print()
with open(CONF.NODE_FILE, "w") as f: with open(CONF.NODE_FILE, "w") as f:
f.write(json.dumps(nodes,indent=4)) f.write(json.dumps(nodes,indent=4))
@ -52,10 +51,9 @@ def check(timeout):
fail=False fail=False
for ip in nodes: for ip in nodes:
print("Contacting {}...".format(ip),end='') print("Contacting {}...".format(ip),end='')
try: if not utils.ping_test(ip,timeout):
subprocess.run(["ping", "-c", "1", "-W", str(timeout), ip],capture_output=True,check=True)
print() print()
except: else:
fail=True fail=True
print("=> Not responding!!") print("=> Not responding!!")
if not fail: if not fail:

9
clusterman/utils.py
View file

@ -11,6 +11,15 @@ def ssh_exec(host,command,use_key=True):
output=subprocess.check_output(["ssh","-o", "StrictHostKeyChecking=no", "{}@{}".format(user,ip), command]) output=subprocess.check_output(["ssh","-o", "StrictHostKeyChecking=no", "{}@{}".format(user,ip), command])
return output.decode("utf-8") return output.decode("utf-8")
def ping_test(host, timeout=None):
t=CONF["timeout"]
if timeout is not None:
t=timeout
try:
subprocess.run(["ping", "-c", "1", "-W", str(t), host],capture_output=True,check=True)
return 0
except:
return 1
def get_node_list(): def get_node_list():
nodes_path=CONF.NODE_FILE nodes_path=CONF.NODE_FILE