Skip to content

Commit fdf5f03

Browse files
committed
take 'Connection Refused' as a successful ping probe
1 parent 05f9784 commit fdf5f03

File tree

2 files changed

+18
-7
lines changed

2 files changed

+18
-7
lines changed

Diff for: clients/client-linux.py

+10-4
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import os
2929
import sys
3030
import json
31+
import errno
3132
import subprocess
3233
import threading
3334
try:
@@ -181,11 +182,16 @@ def _ping_thread(host, mark, port):
181182
try:
182183
b = timeit.default_timer()
183184
socket.create_connection((IP, port), timeout=1).close()
184-
pingTime[mark] = int((timeit.default_timer()-b)*1000)
185+
pingTime[mark] = int((timeit.default_timer() - b) * 1000)
185186
packet_queue.put(1)
186-
except:
187-
lostPacket += 1
188-
packet_queue.put(0)
187+
except socket.error as error:
188+
if error.errno == errno.ECONNREFUSED:
189+
pingTime[mark] = int((timeit.default_timer() - b) * 1000)
190+
packet_queue.put(1)
191+
#elif error.errno == errno.ETIMEDOUT:
192+
else:
193+
lostPacket += 1
194+
packet_queue.put(0)
189195

190196
if packet_queue.qsize() > 30:
191197
lostRate[mark] = float(lostPacket) / packet_queue.qsize()

Diff for: clients/client-psutil.py

+8-3
Original file line numberDiff line numberDiff line change
@@ -168,9 +168,14 @@ def _ping_thread(host, mark, port):
168168
socket.create_connection((IP, port), timeout=1).close()
169169
pingTime[mark] = int((timeit.default_timer() - b) * 1000)
170170
packet_queue.put(1)
171-
except:
172-
lostPacket += 1
173-
packet_queue.put(0)
171+
except socket.error as error:
172+
if error.errno == errno.ECONNREFUSED:
173+
pingTime[mark] = int((timeit.default_timer() - b) * 1000)
174+
packet_queue.put(1)
175+
#elif error.errno == errno.ETIMEDOUT:
176+
else:
177+
lostPacket += 1
178+
packet_queue.put(0)
174179

175180
if packet_queue.qsize() > 30:
176181
lostRate[mark] = float(lostPacket) / packet_queue.qsize()

0 commit comments

Comments
 (0)