
    Ih                    ^    d Z ddlmZ ddlmZmZmZ ddlmZ d Z	d Z
d Zd Zd	 Zd
 Zd Zy)zEvent-loop debugging tools.    )annotations)ERRREADWRITE)reprcallc                r    dj                  | t        z  rdnd| t        z  rdnd| t        z  rd      S d      S )z&Return description of event loop flag.z{}{}{}R W!)formatr   r   r   )flags    Q/var/www/html/planif/env/lib/python3.12/site-packages/kombu/asynchronous/debug.py	repr_flagr   	   s>    ??$+32"&,3B"&*36 6246 6    c                    | yt        | t              r| S t        | t              r| \  }}t        |j                  |      S | j                  S )Nz	<missing>)args)
isinstancestrtupler   __name__)objcbr   s      r   _rcbr      sG    
{#s
#uD$//<<r   c                N    dj                  t        |       t        |       z         S )z1Return description of active readers and writers., )joinrepr_readersrepr_writers)hs    r   repr_activer!      s    99\!_|A677r   c                8     dj                   fd|D              S )z.Return description of events returned by poll.r   c              3     K   | ]8  \  }}d j                  t        t        ||d            |t        |             : yw)z
{}({})->{}z(GONE)N)r   r   callback_forr   ).0fdflr    s      r   	<genexpr>zrepr_events.<locals>.<genexpr>"   sF      
 B	 	aR23RbM	
s   >A)r   )r    eventss   ` r   repr_eventsr*       s#    99 
   r   c                    | j                   j                         D cg c]-  \  }}d| dt        |       dt        t        t
        z         / c}}S c c}}w )z&Return description of pending readers.()->)readersitemsr   r   r   r   r    r&   r   s      r   r   r   +   sT     ))//+-B t1T"XJb4#:!6 78 - - -s   2Ac                    | j                   j                         D cg c]&  \  }}d| dt        |       dt        t               ( c}}S c c}}w )z&Return description of pending writers.r,   r-   r.   )writersr0   r   r   r   r1   s      r   r   r   1   sP     ))//+-B t1T"XJb5!1 23 - - -s   +Ac                    	 |t         z  r| j                  |   S |t        z  r)|| j                  v r| j                  S | j
                  |   S y# t        $ r |r|d   cY S  w xY w)z)Return the callback used for hub+fd+flag.r   N)r   r/   r   consolidateconsolidate_callbackr3   KeyError)r    r&   r   defaults       r   r$   r$   7   so    
$;99R= %<Q]]"---99R=    1:s   A "A A A!A!N)__doc__
__future__r   kombu.utils.eventior   r   r   kombu.utils.functionalr   r   r   r!   r*   r   r   r$    r   r   <module>r>      s7    ! " 0 0 +68
--r   