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/sugar/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

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

;j�@s\dZddlmZddlZddlmZddlmZddlm	Z	Gdd�d�Z
e
�Zdd	gZdS)
z(Tracker for zero-copy messages with 0MQ.�)�annotationsN)�Event)�Frame)�NotDonec@sDeZdZUdZded<ded<ddd	�Zed
d��Zdddd�ZdS)�MessageTrackera�A class for tracking if 0MQ is done using one or more messages.

    When you send a 0MQ message, it is not sent immediately. The 0MQ IO thread
    sends the message at some later time. Often you want to know when 0MQ has
    actually sent the message though. This is complicated by the fact that
    a single 0MQ message can be sent multiple times using different sockets.
    This class allows you to track all of the 0MQ usages of a message.

    Parameters
    ----------
    towatch : Event, MessageTracker, zmq.Frame
        This objects to track. This class can track the low-level
        Events used by the Message class, other MessageTrackers or
        actual Messages.
    z
set[Event]�eventszset[MessageTracker]�peers�towatch�%tuple[MessageTracker | Event | Frame]cGs�t�|_t�|_|D]6}t|t�r|j�|�q
t|t�r$|j�|�q
t|t�r8|js0t	d��|j�|j�q
t
dt|�����dS)a\Create a message tracker to track a set of messages.

        Parameters
        ----------
        *towatch : tuple of Event, MessageTracker, Message instances.
            This list of objects to track. This class can track the low-level
            Events used by the Message class, other MessageTrackers or
            actual Messages.
        zNot a tracked messagez&Require Events or Message Frames, not N)�setrr�
isinstancer�addrrZtracker�
ValueError�	TypeError�type)�selfr	�obj�r�E/opt/saltstack/salt/lib/python3.10/site-packages/zmq/sugar/tracker.py�__init__#s



�zMessageTracker.__init__cCs6|jD]	}|��sdSq|jD]}|jsdSqdS)z9Is 0MQ completely done with the message(s) being tracked?FT)r�is_setr�done)r�evtZpmrrrr;s
�
�zMessageTracker.done����timeout�float | intcCs�t��}|dus|dkrd}n|}|jD] }|dkrt�|j|d�|��s(t�t��}|||8}|}q|jD]}|dkr@t�|j|d�t��}|||8}|}q8dS)a�Wait for 0MQ to be done with the message or until `timeout`.

        Parameters
        ----------
        timeout : float
            default: -1, which means wait forever.
            Maximum time in (s) to wait before raising NotDone.

        Returns
        -------
        None
            if done before `timeout`

        Raises
        ------
        NotDone
            if `timeout` reached before I am done.
        Fri�:	)rN)�timerr�waitrr)rrZtic�	remainingrZtocZpeerrrrrFs*

�zMessageTracker.waitN)r	r
)r)rr)	�__name__�
__module__�__qualname__�__doc__�__annotations__r�propertyrrrrrrrs



r�_FINISHED_TRACKER)
r"�
__future__rr�	threadingrZzmq.backendrZ	zmq.errorrrr%�__all__rrrr�<module>sc

Youez - 2016 - github.com/yon3zu
LinuXploit