Loading tests/perf/__init__.py +3 −3 Original line number Diff line number Diff line Loading @@ -28,7 +28,7 @@ class ReceiverThread(threading.Thread): if seqno in self.received: self.duplicates = self.duplicates + 1 else: self.received.update(set([seqno])) self.received.add(seqno) self.receivedPackets[int(seqno)] = datetime.datetime.now() time.sleep(0.000001) Loading @@ -37,7 +37,7 @@ class SenderThread(threading.Thread): def __init__(self, seqnoDigits, packetCount): threading.Thread.__init__(self) self.sock = prrt.PrrtSocket(7005, True) self.sock.target_delay = 1000**3 self.sock.target_delay = 0.1 * 1000**2 self.packetCount = packetCount self.seqnoDigits = seqnoDigits Loading Loading @@ -92,7 +92,7 @@ class TestSetup(object): self.duplicate = duplicate self.reorder = reorder self.reorder_correlation = reorder_correlation self.processing_delay = 0.01 # in ms self.processing_delay = 0.00001 # in ms def netem_config(self): # http://www.linuxfoundation.org/collaborate/workgroups/networking/netem Loading Loading
tests/perf/__init__.py +3 −3 Original line number Diff line number Diff line Loading @@ -28,7 +28,7 @@ class ReceiverThread(threading.Thread): if seqno in self.received: self.duplicates = self.duplicates + 1 else: self.received.update(set([seqno])) self.received.add(seqno) self.receivedPackets[int(seqno)] = datetime.datetime.now() time.sleep(0.000001) Loading @@ -37,7 +37,7 @@ class SenderThread(threading.Thread): def __init__(self, seqnoDigits, packetCount): threading.Thread.__init__(self) self.sock = prrt.PrrtSocket(7005, True) self.sock.target_delay = 1000**3 self.sock.target_delay = 0.1 * 1000**2 self.packetCount = packetCount self.seqnoDigits = seqnoDigits Loading Loading @@ -92,7 +92,7 @@ class TestSetup(object): self.duplicate = duplicate self.reorder = reorder self.reorder_correlation = reorder_correlation self.processing_delay = 0.01 # in ms self.processing_delay = 0.00001 # in ms def netem_config(self): # http://www.linuxfoundation.org/collaborate/workgroups/networking/netem Loading