403Webshell
Server IP : 198.38.94.13  /  Your IP : 216.73.217.33
Web Server : Apache
System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : revivere ( 1140)
PHP Version : 8.2.33
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /opt/saltstack/salt/lib/python3.10/site-packages/zmq/utils/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /opt/saltstack/salt/lib/python3.10/site-packages/zmq/utils/__pycache__/monitor.cpython-310.pyc
o

;j��@s�dZddlmZddlZddlmZmZmZddlZddl	Zddl
mZGdd�de�Zddd�Z
ddd�Ze	dd dd��Ze	dd!dd��Z	dd"dd�ZddgZdS)#zJModule holding utility and convenience functions for zmq event monitoring.�)�annotationsN)�	Awaitable�	TypedDict�overload)�_check_versionc@s&eZdZUded<ded<ded<dS)�_MonitorMessage�int�event�value�bytes�endpointN)�__name__�
__module__�__qualname__�__annotations__�rr�E/opt/saltstack/salt/lib/python3.10/site-packages/zmq/utils/monitor.pyrs
r�msg�list[bytes]�returncCs^t|�dkst|d�dkrtd|����t�d|d�\}}t�|�t�|�|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�zInvalid event message format: z=hi�)r	r
r)�len�RuntimeError�struct�unpack�zmq�Event)rZevent_idr
r	rrr�parse_monitor_messages�r�
awaitable_msg�Awaitable[list[bytes]]c�s�|IdH}t|�S)zyLike parse_monitor_msg, but awaitable

    Given awaitable message, return awaitable for the parsed monitor message.
    N)r)r rrrr�_parse_monitor_msg_async6s�
r"�socket�zmq.asyncio.Socket�flagsr�Awaitable[_MonitorMessage]cC�dS�Nr�r#r%rrr�recv_monitor_messageC�r*�zmq.Socket[bytes]cCr'r(rr)rrrr*Jr+�
zmq.Socket�,_MonitorMessage | Awaitable[_MonitorMessage]cCs.tdd�|�|�}t|t�rt|�St|�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 : str
        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.Socket
        The PAIR socket (created by other.get_monitor_socket()) on which to recv the message
    flags : int
        standard zmq recv flags

    Returns
    -------
    event : dict
        event description as dict with the keys `event`, `value`, and `endpoint`.
    )�rzlibzmq event API)rZrecv_multipart�
isinstancerr"r)r#r%rrrrr*Qs

"

)rrrr)r r!rr)r)r#r$r%rrr&)r#r,r%rrr)r#r-r%rrr.)�__doc__�
__future__rr�typingrrrrZzmq.asyncioZ	zmq.errorrrrr"r*�__all__rrrr�<module>s&

 
���/

Youez - 2016 - github.com/yon3zu
LinuXploit