plico.rpc package¶
Submodules¶
plico.rpc.abstract_remote_procedure_call module¶
plico.rpc.dummy_remote_procedure_call module¶
plico.rpc.dummy_sockets module¶
plico.rpc.sockets module¶
plico.rpc.zmq_ports module¶
plico.rpc.zmq_remote_procedure_call module¶
- class plico.rpc.zmq_remote_procedure_call.ZmqRemoteProcedureCall(timeModule=<module 'time' (built-in)>)¶
Bases:
AbstractRemoteProcedureCall
- handleRequest(obj, socket, multi=False)¶
Handle one or more requests on a REP socket, with the format sent by sendRequest()
- publishPickable(socket, pickableObject)¶
- publisherSocket(port, connect=False, host='*', hwm=1)¶
Create a PUB-style socket for data publishers. If <connect> is true, connects to a XPUB/XSUB forwarding device.
- receivePickable(socket, timeoutInSec=10)¶
- receiveWithTimeout(socket, timeoutInSeconds=1)¶
- recvCameraFrame(socket, timeoutInSec=10)¶
- replySocket(port, host='*')¶
Create a REP-style socket for servers
- requestSocket(host, port)¶
Create a REQ-style socket for clients
- sendCameraFrame(socket, frame)¶
- sendRequest(socket, cmd, args=(), timeout=10)¶
Perform client request/reply Request is a ZMQ multipart message:
command string
pickled argument list
Reply is a pickled object
- subscriberSocket(host, port, filt=b'', conflate=False)¶
Create a SUB-style socket for data receivers
- tcpAddress(host, port)¶
- xpubsubSockets(hostSub, portSub, hostPub, portPub)¶
Creates frontend and backend for a XPUB/XSUB forwarding device
- exception plico.rpc.zmq_remote_procedure_call.ZmqRpcTimeoutError¶
Bases:
Exception