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