3

VS�_(�@s>dZd
dl
Z
d
dlZd
dlmZ
dd�Zddd�
ZddgZdS)	zJModule holding utility and convenience functions for zmq event monitoring.�N)
�_check_versionc
Cs\t|�
d
kst|d�
dkr(t
d|�
�
tjd|d�dtjd|d�d|dd�}
|
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�
)�event�valueZendpoint)�len�RuntimeError�struct�unpack)�msgr�r
�/usr/lib64/python3.6/monitor.py�parse_monitor_messages




rcCstdd�
|j
|
�
}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
    
    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)rr
)rZrecv_multipartr)Zsocket�flagsrr
r
r�recv_monitor_message(s

r)
r
)�__doc__r
ZzmqZ	zmq.errorrrr�__all__r
r
r
r�<module>s