
     h                     T    d 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dS )zEvent-loop debugging tools.    )ERRREADWRITE)reprcallc                 x    d                     | t          z  rdnd| t          z  rdnd| t          z  rdnd          S )z&Return description of event loop flag.z{}{}{}R W!)formatr   r   r   )flags    T/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/kombu/asynchronous/debug.py	repr_flagr      sG    ??$+5332"&,633B"&*433"6 6 6    c                     | dS t          | t                    r| S t          | t                    r| \  }}t          |j        |          S | j        S )Nz	<missing>)args)
isinstancestrtupler   __name__)objcbr   s      r   _rcbr      s[    
{{#s 
#u 0D$////<r   c                 f    d                     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77r   c                 F     d                      fd|D                       S )z.Return description of events returned by poll.r   c              3      K   | ]H\  }}d                      t          t          ||d                    |t          |                    V  IdS )z
{}({})->{}z(GONE)N)r   r   callback_forr   ).0fdflr    s      r   	<genexpr>zrepr_events.<locals>.<genexpr>    sq        
 B	 	aR2233RbMM	
 	
     r   )r   )r    eventss   ` r   repr_eventsr*      sA    99    
      r   c                 H    d | j                                         D             S )z&Return description of pending readers.c                 x    g | ]7\  }}d | dt          |           dt          t          t          z             8S ()z->)r   r   r   r   r%   r&   r   s      r   
<listcomp>z repr_readers.<locals>.<listcomp>+   sV     - - -B 988T"XX884#:!6!688 - - -r   )readersitemsr   s    r   r   r   )   /    - -)//++- - - -r   c                 H    d | j                                         D             S )z&Return description of pending writers.c           
      h    g | ]/\  }}d | dt          |           dt          t                     0S r-   )r   r   r   r0   s      r   r1   z repr_writers.<locals>.<listcomp>1   sR     - - -B 433T"XX335!1!133 - - -r   )writersr3   r   s    r   r   r   /   r4   r   c                     	 |t           z  r| j        |         S |t          z  r|| j        v r| j        S | j        |         S dS # t          $ r |r
|d         cY S  w xY w)z)Return the callback used for hub+fd+flag.r   N)r   r2   r   consolidateconsolidate_callbackr7   KeyError)r    r&   r   defaults       r   r$   r$   5   s    
$; 	!9R= %< 	!Q]""--9R= 	! 	!     	1:s   A A A AAN)__doc__kombu.utils.eventior   r   r   kombu.utils.functionalr   r   r   r!   r*   r   r   r$    r   r   <module>rA      s    ! ! 0 0 0 0 0 0 0 0 0 0 + + + + + +6 6 6  8 8 8
  - - -- - -    r   