andreas/heartbeat
Public Access
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

fix rrt handling

Browse Source
This commit is contained in:
Andreas Wrede
2016-04-23 13:16:30 -04:00
parent 49e3e1cb4a
commit e5cee3a288
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hbc
+3 -3
View File
@@ -63,7 +63,7 @@ class Conn:
self.lastack = 0 # time() last ACK was received self.lastack = 0 # time() last ACK was received
self.send = 0 self.send = 0
self.lastsend = 0 # time() last msg was sent self.lastsend = 0 # time() last msg was sent
self.rtts = [] self.rtts = [0]
self.sock=socket.socket(af, socket.SOCK_DGRAM) self.sock=socket.socket(af, socket.SOCK_DGRAM)
self.sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR, \ self.sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR, \
self.sock.getsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR) | 1) self.sock.getsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR) | 1)
@@ -91,8 +91,8 @@ class Conn:
def ack(self, msgDict): def ack(self, msgDict):
self.lastack = time.time() self.lastack = time.time()
self.lastacksent = float(msgDict.get('time','0')) self.lastacksent = float(msgDict.get('time','0'))
if verbose: print "ack RTT: %0.1f ms" % ((self.lastack - self.lastacksent) * 1000.0) if verbose: print "ack RTT: %0.1f ms" % ((self.lastack - self.lastsend) * 1000.0)
self.rtts.append(self.lastack - self.lastacksent) * 1000.0) self.rtts.append((self.lastack - self.lastsend) * 1000.0)
if len(self.rtts) > 10: if len(self.rtts) > 10:
del self.rtts[0] del self.rtts[0]
self.ackcount += 1 self.ackcount += 1