← Back
Editing: monitor.cpython-311.pyc
� mc�c� � �j � d Z ddlZddlmZmZmZmZ ddlZddlZddl m Z ddl m Z G d� de � � Z dee d e fd �Zd eee d e fd �Ze dd dded ee fd�� � Ze dd ej e ded e fd�� � Z dd ej ded ee ee f fd�ZddgZdS )zJModule holding utility and convenience functions for zmq event monitoring.� N)� Awaitable�List�Union�overload)� TypedDict)�_check_versionc �. � e Zd ZU eed< eed< eed< dS )�_MonitorMessage�event�value�endpointN)�__name__� __module__� __qualname__�int�__annotations__�bytes� � �3/usr/lib/python3/dist-packages/zmq/utils/monitor.pyr r s+ � � � � � � � �J�J�J� �J�J�J��O�O�O�O�Or r �msg�returnc � � t | � � dk st | d � � dk rt d| z � � �t j d| d � � \ }}t j |� � t j |� � | d d�}|S )a� decode zmq_monitor event messages. Parameters ---------- msg : list(bytes) zmq multipart message that has arrived on a monitor PAIR socket. First frame is:: 16 bit event id 32 bit event value no padding Second frame is the endpoint as a bytestring Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. � r � z Invalid event message format: %sz=hi� )r r r )�len� RuntimeError�struct�unpack�zmq�Event)r �event_idr r s r �parse_monitor_messager$ s� � �* �3�x�x�1�}�}��C��F� � �q�(�(��=��C�D�D�D� �m�E�3�q�6�2�2�O�H�e���8�$�$���5�!�!���F� � �E� �Lr � awaitable_msgc � �4 K � | � d{V ��}t |� � S )zyLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r$ )r% r s r �_parse_monitor_msg_asyncr' 5 s- � � � � � � � � � � �C� �� %� %�%r �socketzzmq.asyncio.Socket�flagsc � � d S �Nr �r( r) s r �recv_monitor_messager- B � � � �Cr c � � d S r+ r r, s r r- r- J r. r c � � t dd� � | � |� � }t |t � � rt |� � S t |� � S )u� Receive and decode the given raw message from the monitoring socket and return a dict. Requires libzmq ≥ 4.0 The returned dict will have the following entries: event : int, the event id as described in libzmq.zmq_socket_monitor value : int, the event value associated with the event, see libzmq.zmq_socket_monitor endpoint : string, the affected endpoint .. versionchanged:: 23.1 Support for async sockets added. When called with a async socket, returns an awaitable for the monitor message. Parameters ---------- socket : zmq PAIR socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : bitfield (int) standard zmq recv flags Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. )� r zlibzmq event API)r �recv_multipart� isinstancer r' r$ )r( r) r s r r- r- R sZ � �> �6�-�.�.�.� � � �� &� &�C� �#�y�!�!� -�'��,�,�,� !�� %� %�%r r$ r- )r )�__doc__r �typingr r r r r! � zmq.asyncio� zmq._typingr � zmq.errorr r r r$ r' r r- �Socket�__all__r r r �<module>r; s� �� P� P� � � � � 3� 3� 3� 3� 3� 3� 3� 3� 3� 3� 3� 3� � � � � � � � � !� !� !� !� !� !� $� $� $� $� $� $�� � � � �i� � � � �t�E�{� �� � � � �@ &� �T�%�[�)� &�� &� &� &� &� � �� � �� �� �� �� � � ��� � �� � �J�u� �� �� �� � � ��� �)&� )&� �J�)&� �)&� �?�I�o� 6� 6�7�)&� )&� )&� )&�X #�$:� ;���r
Save File
Cancel