
    kcC                        d dl mZ d dlmZ g Zd Zd Zd Zd Z G d d      Z	 G d	 d
e	      Z
 G d de
      Z G d de
      Z G d de	      Z G d de      Z G d de      Z G d de	      Z G d de	      Z G d de      Z G d de      Z G d d      Z G d d e	      Z G d! d"e      Z G d# d$e      Z G d% d&e      Z G d' d(e      Z G d) d*e      Z G d+ d,e      Z G d- d.e      Z G d/ d0e      Z G d1 d2e      Z G d3 d4e	      Z G d5 d6e      Z  G d7 d8e      Z! G d9 d:e	      Z" G d; d<e"      Z# G d= d>e"      Z$ G d? d@e"      Z%e#e$e%gZ& G dA dB      Z'dC Z(dD Z)yE)F    )getProcessStateDescription)	as_stringc                 2    t         j                  | |f       y N)	callbacksappendtypecallbacks     3/usr/lib/python3/dist-packages/supervisor/events.py	subscriber          dH%&    c                 2    t         j                  | |f       y r   )r   remover	   s     r   unsubscriber   	   r   r   c                 J    t         D ]  \  }}t        | |      s ||         y r   )r   
isinstance)eventr
   r   s      r   notifyr      s&    # heT"UOr   c                      g t         d d  y r   )r    r   r   clearr      s    IaLr   c                       e Zd ZdZy)Eventz Abstract event type N)__name__
__module____qualname____doc__r   r   r   r   r      s    r   r   c                        e Zd ZdZdZd Zd Zy)ProcessLogEvent
 Abstract Nc                 .    || _         || _        || _        y r   processpiddataselfr%   r&   r'   s       r   __init__zProcessLogEvent.__init__       	r   c                    d}| j                   j                  *| j                   j                  j                  j                  }	 t	        | j
                        }t	        d      }|t	        | j                   j                  j                        t	        |      | j                  t	        | j                        |fz  }|S # t        $ r d| j
                  z  }Y ~w xY w)N Undecodable: %rz0processname:%s groupname:%s pid:%s channel:%s
%s)	r%   groupconfignamer   r'   UnicodeDecodeErrorr&   channel)r)   	groupnamer'   fmtresults        r   payloadzProcessLogEvent.payload    s    	<<)**1166I	1TYY'D KL	$,,"5"5":":;!),dhh!$,,/7 7  " 	1$tyy0D	1s   B= =CC)r   r   r   r   r3   r*   r7   r   r   r   r!   r!      s    G
r   r!   c                       e Zd ZdZy)ProcessLogStdoutEventstdoutNr   r   r   r3   r   r   r   r9   r9   1       Gr   r9   c                       e Zd ZdZy)ProcessLogStderrEventstderrNr;   r   r   r   r>   r>   4   r<   r   r>   c                   $    e Zd ZdZdZdZd Zd Zy)ProcessCommunicationEventr"   s   <!--XSUPERVISOR:BEGIN-->s   <!--XSUPERVISOR:END-->c                 .    || _         || _        || _        y r   r$   r(   s       r   r*   z"ProcessCommunicationEvent.__init__=   r+   r   c                 Z   d}| j                   j                  *| j                   j                  j                  j                  }	 t	        | j
                        }d| j                   j                  j                  d|d| j                  d|S # t        $ r d| j
                  z  }Y Pw xY w)Nr-   r.   zprocessname:z groupname:z pid:
)r%   r/   r0   r1   r   r'   r2   r&   )r)   r4   r'   s      r   r7   z!ProcessCommunicationEvent.payloadB   s    	<<)**1166I	1TYY'D LL$$HH	 	 " 	1$tyy0D	1s   B B*)B*N)r   r   r   r   BEGIN_TOKEN	END_TOKENr*   r7   r   r   r   rA   rA   7   s    -K+I
r   rA   c                       e Zd ZdZy)ProcessCommunicationStdoutEventr:   Nr;   r   r   r   rH   rH   P   r<   r   rH   c                       e Zd ZdZy)ProcessCommunicationStderrEventr?   Nr;   r   r   r   rJ   rJ   S   r<   r   rJ   c                       e Zd Zd Zd Zy)RemoteCommunicationEventc                      || _         || _        y r   r
   r'   )r)   r
   r'   s      r   r*   z!RemoteCommunicationEvent.__init__W   s    		r   c                 :    d| j                   d| j                  S )Nztype:rD   rN   r)   s    r   r7   z RemoteCommunicationEvent.payload[   s     $		49955r   Nr   r   r   r*   r7   r   r   r   rL   rL   V   s    6r   rL   c                       e Zd ZdZd Zy)SupervisorStateChangeEventz Abstract class c                      y)Nr-   r   rP   s    r   r7   z"SupervisorStateChangeEvent.payload`   s    r   N)r   r   r   r   r7   r   r   r   rS   rS   ^   s
    r   rS   c                       e Zd Zy)SupervisorRunningEventNr   r   r   r   r   r   rV   rV   c       r   rV   c                       e Zd Zy)SupervisorStoppingEventNrW   r   r   r   rZ   rZ   f   rX   r   rZ   c                       e Zd Zd Zy)EventRejectedEventc                      || _         || _        y r   )r%   r   )r)   r%   r   s      r   r*   zEventRejectedEvent.__init__j   s    
r   N)r   r   r   r*   r   r   r   r\   r\   i   s    r   r\   c                   ,    e Zd ZdZdZdZddZd Zd Zy)ProcessStateEventz' Abstract class, never raised directly Nc                 X    || _         || _        || _        | j                         | _        y r   )r%   
from_stateexpectedget_extra_valuesextra_values)r)   r%   ra   rb   s       r   r*   zProcessStateEvent.__init__r   s*    $  !113r   c           	         d}| j                   j                  *| j                   j                  j                  j                  }d| j                   j                  j                  fd|fdt	        | j
                        fg}|j                  | j                         dj                  |D cg c]  \  }}|d| c}}      }|S c c}}w )Nr-   processnamer4   ra    :)	r%   r/   r0   r1   r   ra   extendrd   join)r)   r4   Lr1   valss         r   r7   zProcessStateEvent.payloadz   s    	<<)**1166IT\\00556i8P6tGHJ	""#HHD+44-DF Es   *C
c                     g S r   r   rP   s    r   rc   z"ProcessStateEvent.get_extra_values   s    	r   )T)	r   r   r   r   frmtor*   r7   rc   r   r   r   r_   r_   n   s    1
C	B4r   r_   c                       e Zd Zy)ProcessStateFatalEventNrW   r   r   r   rr   rr      rX   r   rr   c                       e Zd Zy)ProcessStateUnknownEventNrW   r   r   r   rt   rt      rX   r   rt   c                       e Zd Zd Zy)"ProcessStateStartingOrBackoffEventc                 F    dt        | j                  j                        fgS )Ntries)intr%   backoffrP   s    r   rc   z3ProcessStateStartingOrBackoffEvent.get_extra_values   s    #dll223455r   Nr   r   r   rc   r   r   r   rv   rv      s    6r   rv   c                       e Zd Zy)ProcessStateBackoffEventNrW   r   r   r   r}   r}      rX   r   r}   c                       e Zd Zy)ProcessStateStartingEventNrW   r   r   r   r   r      rX   r   r   c                       e Zd Zd Zy)ProcessStateExitedEventc                 `    dt        | j                        fd| j                  j                  fgS )Nrb   r&   )ry   rb   r%   r&   rP   s    r   rc   z(ProcessStateExitedEvent.get_extra_values   s*    S/05$,,:J:J2KLLr   Nr{   r   r   r   r   r      s    Mr   r   c                       e Zd Zd Zy)ProcessStateRunningEventc                 4    d| j                   j                  fgS Nr&   r%   r&   rP   s    r   rc   z)ProcessStateRunningEvent.get_extra_values       (()**r   Nr{   r   r   r   r   r          +r   r   c                       e Zd Zd Zy)ProcessStateStoppingEventc                 4    d| j                   j                  fgS r   r   rP   s    r   rc   z*ProcessStateStoppingEvent.get_extra_values   r   r   Nr{   r   r   r   r   r      r   r   r   c                       e Zd Zd Zy)ProcessStateStoppedEventc                 4    d| j                   j                  fgS r   r   rP   s    r   rc   z)ProcessStateStoppedEvent.get_extra_values   r   r   Nr{   r   r   r   r   r      r   r   r   c                       e Zd Zd Zd Zy)ProcessGroupEventc                     || _         y r   r/   )r)   r/   s     r   r*   zProcessGroupEvent.__init__   s	    
r   c                      d| j                   z  S )Nzgroupname:%s
r   rP   s    r   r7   zProcessGroupEvent.payload   s    $**,,r   NrQ   r   r   r   r   r      s    -r   r   c                       e Zd Zy)ProcessGroupAddedEventNrW   r   r   r   r   r      rX   r   r   c                       e Zd Zy)ProcessGroupRemovedEventNrW   r   r   r   r   r      rX   r   r   c                       e Zd ZdZd Zd Zy)	TickEventr"   c                      || _         || _        y r   )whensupervisord)r)   r   r   s      r   r*   zTickEvent.__init__   s    	&r   c                      d| j                   z  S )Nzwhen:%s)r   rP   s    r   r7   zTickEvent.payload   s    499$$r   N)r   r   r   r   r*   r7   r   r   r   r   r      s    '%r   r   c                       e Zd ZdZy)
Tick5Event   Nr   r   r   periodr   r   r   r   r      s    Fr   r   c                       e Zd ZdZy)Tick60Event<   Nr   r   r   r   r   r      s    Fr   r   c                       e Zd ZdZy)Tick3600Eventi  Nr   r   r   r   r   r      s    Fr   r   c                   x    e Zd ZeZeZeZe	Z
eZeZeZeZeZeZeZeZeZeZeZ e!Z"e#Z$e%Z&e'Z(e)Z*e+Z,e-Z.e/Z0e1Z2e3Z4e5Z6e7Z8y)
EventTypesN)9r   r   r   r   EVENTr_   PROCESS_STATEr   PROCESS_STATE_STOPPEDr   PROCESS_STATE_EXITEDr   PROCESS_STATE_STARTINGr   PROCESS_STATE_STOPPINGr}   PROCESS_STATE_BACKOFFrr   PROCESS_STATE_FATALr   PROCESS_STATE_RUNNINGrt   PROCESS_STATE_UNKNOWNrA   PROCESS_COMMUNICATIONrH   PROCESS_COMMUNICATION_STDOUTrJ   PROCESS_COMMUNICATION_STDERRr!   PROCESS_LOGr9   PROCESS_LOG_STDOUTr>   PROCESS_LOG_STDERRrL   REMOTE_COMMUNICATIONrS   SUPERVISOR_STATE_CHANGErV   SUPERVISOR_STATE_CHANGE_RUNNINGrZ    SUPERVISOR_STATE_CHANGE_STOPPINGr   TICKr   TICK_5r   TICK_60r   	TICK_3600r   PROCESS_GROUPr   PROCESS_GROUP_ADDEDr   PROCESS_GROUP_REMOVEDr   r   r   r   r      s    E%M426640445#B #B !K..38&<#'>$DFGI%M04r   r   c                 `    t         j                  j                         D ]  \  }}|| u s|c S  y r   )r   __dict__items)	requestedr1   typs      r   getEventNameByTyper      s1    ((..0 	c)Kr   c                 &    t        t        | |       y r   )setattrr   )r1   r   s     r   registerr      s    Je$r   N)*supervisor.statesr   supervisor.compatr   r   r   r   r   r   r   r!   r9   r>   rA   rH   rJ   rL   rS   rV   rZ   r\   r_   rr   rt   rv   r}   r   r   r   r   r   r   r   r   r   r   r   r   TICK_EVENTSr   r   r   r   r   r   <module>r      s   8 '	''
	 	e 2O O  2&? &? 6u 6 
	7 		8 	 
 2	. 		0 	6): 6	A 		 B 	M/ M+0 ++ 1 ++0 +- -	. 		0 	% % ) I  K85 5:
%r   