summaryrefslogtreecommitdiffstats
path: root/external_libs/python/pyzmq-14.7.0/examples/heartbeat/ping.py
diff options
context:
space:
mode:
Diffstat (limited to 'external_libs/python/pyzmq-14.7.0/examples/heartbeat/ping.py')
-rw-r--r--external_libs/python/pyzmq-14.7.0/examples/heartbeat/ping.py35
1 files changed, 35 insertions, 0 deletions
diff --git a/external_libs/python/pyzmq-14.7.0/examples/heartbeat/ping.py b/external_libs/python/pyzmq-14.7.0/examples/heartbeat/ping.py
new file mode 100644
index 00000000..797cb8c2
--- /dev/null
+++ b/external_libs/python/pyzmq-14.7.0/examples/heartbeat/ping.py
@@ -0,0 +1,35 @@
+#!/usr/bin/env python
+"""For use with pong.py
+
+This script simply pings a process started by pong.py or tspong.py, to
+demonstrate that zmq remains responsive while Python blocks.
+
+Authors
+-------
+* MinRK
+"""
+from __future__ import print_function
+
+import sys
+import time
+import numpy
+import zmq
+
+ctx = zmq.Context()
+
+req = ctx.socket(zmq.REQ)
+req.connect('tcp://127.0.0.1:10111')
+
+#wait for connects
+time.sleep(1)
+n=0
+while True:
+ time.sleep(numpy.random.random())
+ for i in range(4):
+ n+=1
+ msg = 'ping %i' % n
+ tic = time.time()
+ req.send_string(msg)
+ resp = req.recv_string()
+ print("%s: %.2f ms" % (msg, 1000*(time.time()-tic)))
+ assert msg == resp