mirror of
https://github.com/zeromq/libzmq.git
synced 2025-10-20 14:02:41 +02:00
higher precision time measurement in python perf tests
This commit is contained in:
@@ -18,7 +18,7 @@
|
|||||||
#
|
#
|
||||||
|
|
||||||
import sys
|
import sys
|
||||||
from datetime import datetime
|
import time
|
||||||
import libpyzmq
|
import libpyzmq
|
||||||
|
|
||||||
def main ():
|
def main ():
|
||||||
@@ -41,15 +41,15 @@ def main ():
|
|||||||
msg = s.recv ()
|
msg = s.recv ()
|
||||||
assert len (msg) == message_size
|
assert len (msg) == message_size
|
||||||
|
|
||||||
start = datetime.now ()
|
start = time.clock ()
|
||||||
|
|
||||||
for i in range (1, message_count):
|
for i in range (1, message_count):
|
||||||
msg = s.recv ()
|
msg = s.recv ()
|
||||||
assert len (msg) == message_size
|
assert len (msg) == message_size
|
||||||
|
|
||||||
end = datetime.now()
|
end = time.clock ()
|
||||||
|
|
||||||
elapsed = (end - start).seconds * 1000000 + (end - start).microseconds
|
elapsed = (end - start) * 1000000
|
||||||
if elapsed == 0:
|
if elapsed == 0:
|
||||||
elapsed = 1
|
elapsed = 1
|
||||||
throughput = (1000000.0 * float (message_count)) / float (elapsed)
|
throughput = (1000000.0 * float (message_count)) / float (elapsed)
|
||||||
|
@@ -18,7 +18,7 @@
|
|||||||
#
|
#
|
||||||
|
|
||||||
import sys
|
import sys
|
||||||
from datetime import datetime
|
import time
|
||||||
import libpyzmq
|
import libpyzmq
|
||||||
|
|
||||||
def main ():
|
def main ():
|
||||||
@@ -40,16 +40,17 @@ def main ():
|
|||||||
|
|
||||||
msg = ''.join ([' ' for n in range (0, message_size)])
|
msg = ''.join ([' ' for n in range (0, message_size)])
|
||||||
|
|
||||||
start = datetime.now ()
|
start = time.clock ()
|
||||||
|
|
||||||
for i in range (0, roundtrip_count):
|
for i in range (0, roundtrip_count):
|
||||||
s.send (msg)
|
s.send (msg)
|
||||||
msg = s.recv ()
|
msg = s.recv ()
|
||||||
assert len (msg) == message_size
|
assert len (msg) == message_size
|
||||||
|
|
||||||
end = datetime.now ()
|
end = time.clock ()
|
||||||
delta = (end - start).microseconds + 1000000 * (end - start).seconds
|
|
||||||
latency = float (delta) / roundtrip_count / 2
|
elapsed = (end - start) * 1000000
|
||||||
|
latency = elapsed / roundtrip_count / 2
|
||||||
|
|
||||||
print "message size: %.0f [B]" % (message_size, )
|
print "message size: %.0f [B]" % (message_size, )
|
||||||
print "roundtrip count: %.0f" % (roundtrip_count, )
|
print "roundtrip count: %.0f" % (roundtrip_count, )
|
||||||
|
Reference in New Issue
Block a user