File Manager

003 File Manager

Current Path: /usr/local/lib/python3.8/site-packages/zmq/devices

usr / local / lib / python3.8 / site-packages / zmq / devices /

📁 ..
📄 __init__.py(731 B)
📁 __pycache__
📄 basedevice.py(8.2 KB)
📄 monitoredqueue.cpython-38.so(49.11 KB)
📄 monitoredqueue.pxd(6.24 KB)
📄 monitoredqueue.py(1022 B)
📄 monitoredqueuedevice.py(1.92 KB)
📄 proxydevice.py(2.79 KB)
📄 proxysteerabledevice.py(3.21 KB)

Editing: monitoredqueue.py

"""pure Python monitored_queue function

For use when Cython extension is unavailable (PyPy).

Authors
-------
* MinRK
"""

# Copyright (C) PyZMQ Developers
# Distributed under the terms of the Modified BSD License.

import zmq

def _relay(ins, outs, sides, prefix, swap_ids):
    msg = ins.recv_multipart()
    if swap_ids:
        msg[:2] = msg[:2][::-1]
    outs.send_multipart(msg)
    sides.send_multipart([prefix] + msg)

def monitored_queue(
    in_socket, out_socket, mon_socket, in_prefix=b'in', out_prefix=b'out'
):

swap_ids = in_socket.type == zmq.ROUTER and out_socket.type == zmq.ROUTER

poller = zmq.Poller()
    poller.register(in_socket, zmq.POLLIN)
    poller.register(out_socket, zmq.POLLIN)
    while True:
        events = dict(poller.poll())
        if in_socket in events:
            _relay(in_socket, out_socket, mon_socket, in_prefix, swap_ids)
        if out_socket in events:
            _relay(out_socket, in_socket, mon_socket, out_prefix, swap_ids)

__all__ = ['monitored_queue']

003 File Manager

Editing: monitoredqueue.py

Upload File

Create Folder