kbtest resets connections after timeout

workspace
Brendan Howell 9 years ago
parent 88b9d48015
commit 8207a45654

@ -1,9 +1,24 @@
import time
import zmq import zmq
ctx = zmq.Context() ctx = zmq.Context()
send = ctx.socket(zmq.PUB)
send.connect("tcp://localhost:10100")
while True: while True:
msg = input("> ") msg = input("> ")
send.send_string(msg) send = ctx.socket(zmq.REQ)
send.connect("ipc://.screenless/" + msg[0:2] + ".ipc")
send.send_string(msg[2:])
print("sending ", msg[2:])
ret = None
trys = 0
while (not ret) and (trys < 10):
try:
ret = send.recv(flags=zmq.NOBLOCK)
print("got", ret)
except zmq.ZMQError:
trys += 1
time.sleep(0.05)
if not ret:
print("Error: timeout after 0.5 sec")
send.close()

Loading…
Cancel
Save