← Back
Editing: proxydevice.cpython-311.pyc
� mc�c" � � � d Z ddlZddlmZmZmZ G d� d� � Z G d� dee� � Z G d� d ee� � Z G d � d ee� � Z g d �Z dS ) z Proxy classes and functions.� N)�Device� ProcessDevice� ThreadDevicec �J � e Zd ZdZej fd�Zd� Zd� Zd� Z d� Z d� Z d� Z d S ) � ProxyBasez"Base class for overriding methods.c �l � t j | ||�� � || _ g | _ g | _ g | _ d S )N)�in_type�out_type)r �__init__�mon_type� _mon_binds� _mon_connects� _mon_sockopts)�selfr r r s �9/usr/lib/python3/dist-packages/zmq/devices/proxydevice.pyr zProxyBase.__init__ s= � ����g��A�A�A�A� �� � ��� ��� ����� c �: � | j � |� � dS )zaEnqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details. N)r �append�r �addrs r �bind_monzProxyBase.bind_mon s � � �� � �t�$�$�$�$�$r c �\ � | j |g|�R i |��}| � d||fz � � |S )z�Enqueue a random port on the given interface for binding on mon_socket. See zmq.Socket.bind_to_random_port for details. .. versionadded:: 18.0 z%s:%i)�_reserve_random_portr )r r �args�kwargs�ports r �bind_mon_to_random_portz!ProxyBase.bind_mon_to_random_port sF � � )�t�(��?��?�?�?��?�?�� � � �g��t� �,�-�-�-�� r c �: � | j � |� � dS )zgEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N)r r r s r � connect_monzProxyBase.connect_mon* s! � � ��!�!�$�'�'�'�'�'r c �> � | j � ||f� � dS )zfEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N)r r )r �opt�values r �setsockopt_monzProxyBase.setsockopt_mon1 s% � � ��!�!�3��,�/�/�/�/�/r c �r � t j | � � \ }}| j }|� | j � � }| j � |� � | j D ]\ }}|� ||� � � | j D ]}|� |� � �| j D ]}|� |� � �|||fS �N) r �_setup_sockets�_context�socketr �_socketsr r � setsockoptr �bindr �connect)r �ins�outs�ctx�monsr! r" �ifaces r r& zProxyBase._setup_sockets8 s� � ��)�$�/�/� ��T��m���z�z�$�-�(�(�� � � � �T�"�"�"� �,� (� (�J�C�� �O�O�C�� '� '� '� '��_� � �E� �I�I�e� � � � ��'� � �E� �L�L�� � � � ��D�$�� r c �b � | � � � \ }}}t j |||� � d S r% )r& �zmq�proxy)r r- r. r0 s r � run_devicezProxyBase.run_deviceJ s3 � � �-�-�/�/���T�4� � �#�t�T�"�"�"�"�"r N) �__name__� __module__� __qualname__�__doc__r3 �PUBr r r r r# r& r5 � r r r r s� � � � � � �,�,�36�7� � � � �%� %� %� � � � (� (� (�0� 0� 0� � � �$#� #� #� #� #r r c � � e Zd ZdZdS )�Proxya� Threadsafe Proxy object. See zmq.devices.Device for most of the spec. This subclass adds a <method>_mon version of each <method>_{in|out} method, for configuring the monitor socket. A Proxy is a 3-socket ZMQ Device that functions just like a QUEUE, except each message is also sent out on the monitor socket. A PUB socket is the most logical choice for the mon_socket, but it is not required. N�r6 r7 r8 r9 r; r r r= r= O s � � � � � � � � � r r= c � � e Zd ZdZdS )� ThreadProxyz&Proxy in a Thread. See Proxy for more.Nr> r; r r r@ r@ ] s � � � � � �0�0�0�0r r@ c � � e Zd ZdZdS )� ProcessProxyz'Proxy in a Process. See Proxy for more.Nr> r; r r rB rB a s � � � � � �1�1�1�1r rB )r= r@ rB ) r9 r3 �zmq.devices.basedevicer r r r r= r@ rB �__all__r; r r �<module>rE s� �� "� "� � � � � F� F� F� F� F� F� F� F� F� F�B#� B#� B#� B#� B#� B#� B#� B#�J � � � � �I�v� � � � 1� 1� 1� 1� 1�)�\� 1� 1� 1�2� 2� 2� 2� 2�9�m� 2� 2� 2� � � ���r
Save File
Cancel