Skip to content
Snippets Groups Projects
Commit 0faeb8f2 authored by Stefano Borini's avatar Stefano Borini Committed by GitHub
Browse files

Merge pull request #103 from force-h2020/remove-zmq-toy-server

Removed ZMQ toy server used for initial experimentation
parents d927c5ab afbe0cc4
No related branches found
No related tags found
No related merge requests found
import zmq
# Socket to talk to server
context = zmq.Context()
sub_socket = context.socket(zmq.SUB)
sub_socket.bind("tcp://*:12345")
sub_socket.setsockopt(zmq.SUBSCRIBE, "".encode("utf-8"))
sub_socket.setsockopt(zmq.LINGER, 0)
sync_socket = context.socket(zmq.REP)
sync_socket.setsockopt(zmq.LINGER, 0)
sync_socket.bind("tcp://*:12346")
poller = zmq.Poller()
poller.register(sub_socket)
poller.register(sync_socket)
WAITING = 0
RECEIVING = 1
state = WAITING
while True:
events = dict(poller.poll())
if sync_socket in events:
data = sync_socket.recv_string()
print("received ", data)
if data.startswith("HELLO\n"):
sync_socket.send_string(data)
state = RECEIVING
elif data.startswith("GOODBYE\n"):
sync_socket.send_string(data)
state = WAITING
else:
print("unknown request", data)
if sub_socket in events:
if state == RECEIVING:
string = sub_socket.recv_string()
split_data = string.split("\n")
print(split_data)
else:
print("data while waiting. discarding")
string = sub_socket.recv_string()
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment