Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
import socket, re, time, subprocess, sys
socket_path = "/tmp/sock"
#socket_path = "./tmp/sock"
def main():
hostname = sys.argv[1]
count = 1
wait = 5
total_pings = 0
successful_pings = 0
try:
while True:
start_time = time.time()
try:
# Run the ping command and capture the output
result = subprocess.check_output(["ping", "-W", str(wait), "-c", str(count), hostname], universal_newlines=True)
response_time = float(re.findall(r"time=([0-9.]+) ms", result)[0])
except subprocess.CalledProcessError as e:
# If ping fails return negative response_time
response_time = -1
# Calculate new loss_ratio
if response_time != -1:
successful_pings += 1
total_pings += 1
moving_loss_ratio = round(((total_pings - successful_pings) / float(total_pings) * 100), 2)
print("Total pings: {}".format(total_pings))
print("Successful pings: {}".format(successful_pings))
print("Packet loss: {}%".format(moving_loss_ratio))
print("Latency: {} ms".format(response_time))
# Write results in socket
try:
client_socket = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
client_socket.connect(socket_path)
client_socket.send(data.encode())
client_socket.close()
except Exception as e:
print(e)
# Calculate the time taken by ping
execution_time = time.time() - start_time
# Wait the rest of the time
wait_time = max(0, 6 - execution_time)
time.sleep(wait_time)
except KeyboardInterrupt:
print("Script terminated.")
if __name__ == "__main__":
main()