golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/zmq/green
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.py
1.3 KB
Del
OK
__pycache__
-
Del
OK
core.py
10.57 KB
Del
OK
device.py
943 B
Del
OK
eventloop
-
Del
OK
poll.py
2.88 KB
Del
OK
Edit: device.py
# Copyright (C) PyZMQ Developers # Distributed under the terms of the Modified BSD License. import zmq from zmq.green import Poller def device(device_type, isocket, osocket): """Start a zeromq device (gevent-compatible). Unlike the true zmq.device, this does not release the GIL. Parameters ---------- device_type : (QUEUE, FORWARDER, STREAMER) The type of device to start (ignored). isocket : Socket The Socket instance for the incoming traffic. osocket : Socket The Socket instance for the outbound traffic. """ p = Poller() if osocket == -1: osocket = isocket p.register(isocket, zmq.POLLIN) p.register(osocket, zmq.POLLIN) while True: events = dict(p.poll()) if isocket in events: osocket.send_multipart(isocket.recv_multipart()) if osocket in events: isocket.send_multipart(osocket.recv_multipart())
Save