HEX

File: //proc/self/root/lib/python3.6/site-packages/supervisor/__pycache__/events.cpython-36.opt-1.pyc
3

�k�`C�@s4ddlmZddlmZgZdd�Zdd�Zdd�Zd	d
�ZGdd�d�Z	Gd
d�de	�Z
Gdd�de
�ZGdd�de
�ZGdd�de	�Z
Gdd�de
�ZGdd�de
�ZGdd�de	�ZGdd�de	�ZGdd�de�ZGdd �d e�ZGd!d"�d"�ZGd#d$�d$e	�ZGd%d&�d&e�ZGd'd(�d(e�ZGd)d*�d*e�ZGd+d,�d,e�ZGd-d.�d.e�ZGd/d0�d0e�ZGd1d2�d2e�ZGd3d4�d4e�ZGd5d6�d6e�ZGd7d8�d8e	�ZGd9d:�d:e�Z Gd;d<�d<e�Z!Gd=d>�d>e	�Z"Gd?d@�d@e"�Z#GdAdB�dBe"�Z$GdCdD�dDe"�Z%e#e$e%gZ&GdEdF�dF�Z'dGdH�Z(dIdJ�Z)dKS)L�)�getProcessStateDescription)�	as_stringcCstj||f�dS)N)�	callbacks�append)�type�callback�r�/usr/lib/python3.6/events.py�	subscribesr
cCstj||f�dS)N)r�remove)rrrrr	�unsubscribe	srcCs(x"tD]\}}t||�r||�qWdS)N)r�
isinstance)�eventrrrrr	�notifys
rcCsgtdd�<dS)N)rrrrr	�clearsrc@seZdZdZdS)�Eventz Abstract event type N)�__name__�
__module__�__qualname__�__doc__rrrr	rsrc@s$eZdZdZdZdd�Zdd�ZdS)�ProcessLogEventz
 Abstract NcCs||_||_||_dS)N)�process�pid�data)�selfrrrrrr	�__init__szProcessLogEvent.__init__cCs~d}|jjdk	r|jjjj}yt|j�}Wntk
rHd|j}YnXtd�}|t|jjj�t|�|jt|j�|f}|S)N�zUndecodable: %rz0processname:%s groupname:%s pid:%s channel:%s
%s)	r�group�config�namerr�UnicodeDecodeErrorr�channel)r�	groupnamerZfmt�resultrrr	�payload s
zProcessLogEvent.payload)rrrrr!rr$rrrr	rsrc@seZdZdZdS)�ProcessLogStdoutEvent�stdoutN)rrrr!rrrr	r%1sr%c@seZdZdZdS)�ProcessLogStderrEvent�stderrN)rrrr!rrrr	r'4sr'c@s(eZdZdZdZdZdd�Zdd�ZdS)	�ProcessCommunicationEventz
 Abstract s<!--XSUPERVISOR:BEGIN-->s<!--XSUPERVISOR:END-->cCs||_||_||_dS)N)rrr)rrrrrrr	r=sz"ProcessCommunicationEvent.__init__c
Csbd}|jjdk	r|jjjj}yt|j�}Wntk
rHd|j}YnXd|jjj||j|fS)NrzUndecodable: %rz%processname:%s groupname:%s pid:%s
%s)rrrrrrr r)rr"rrrr	r$Bsz!ProcessCommunicationEvent.payloadN)rrrrZBEGIN_TOKENZ	END_TOKENrr$rrrr	r)7s
r)c@seZdZdZdS)�ProcessCommunicationStdoutEventr&N)rrrr!rrrr	r*Psr*c@seZdZdZdS)�ProcessCommunicationStderrEventr(N)rrrr!rrrr	r+Ssr+c@seZdZdd�Zdd�ZdS)�RemoteCommunicationEventcCs||_||_dS)N)rr)rrrrrr	rWsz!RemoteCommunicationEvent.__init__cCsd|j|jfS)Nz
type:%s
%s)rr)rrrr	r$[sz RemoteCommunicationEvent.payloadN)rrrrr$rrrr	r,Vsr,c@seZdZdZdd�ZdS)�SupervisorStateChangeEventz Abstract class cCsdS)Nrr)rrrr	r$`sz"SupervisorStateChangeEvent.payloadN)rrrrr$rrrr	r-^sr-c@seZdZdS)�SupervisorRunningEventN)rrrrrrr	r.csr.c@seZdZdS)�SupervisorStoppingEventN)rrrrrrr	r/fsr/c@seZdZdd�ZdS)�EventRejectedEventcCs||_||_dS)N)rr)rrrrrr	rjszEventRejectedEvent.__init__N)rrrrrrrr	r0isr0c@s2eZdZdZdZdZd
dd�Zdd�Zdd	�ZdS)�ProcessStateEventz' Abstract class, never raised directly NTcCs ||_||_||_|j�|_dS)N)r�
from_state�expected�get_extra_values�extra_values)rrr2r3rrr	rrszProcessStateEvent.__init__cCsbd}|jjdk	r|jjjj}d|jjjfd|fdt|j�fg}|j|j�djdd�|D��}|S)NrZprocessnamer"r2� cSsg|]\}}d||f�qS)z%s:%sr)�.0r�valrrr	�
<listcomp>�sz-ProcessStateEvent.payload.<locals>.<listcomp>)	rrrrrr2�extendr5�join)rr"�L�srrr	r$zszProcessStateEvent.payloadcCsgS)Nr)rrrr	r4�sz"ProcessStateEvent.get_extra_values)T)	rrrrZfrmZtorr$r4rrrr	r1ns

r1c@seZdZdS)�ProcessStateFatalEventN)rrrrrrr	r>�sr>c@seZdZdS)�ProcessStateUnknownEventN)rrrrrrr	r?�sr?c@seZdZdd�ZdS)�"ProcessStateStartingOrBackoffEventcCsdt|jj�fgS)NZtries)�intrZbackoff)rrrr	r4�sz3ProcessStateStartingOrBackoffEvent.get_extra_valuesN)rrrr4rrrr	r@�sr@c@seZdZdS)�ProcessStateBackoffEventN)rrrrrrr	rB�srBc@seZdZdS)�ProcessStateStartingEventN)rrrrrrr	rC�srCc@seZdZdd�ZdS)�ProcessStateExitedEventcCsdt|j�fd|jjfgS)Nr3r)rAr3rr)rrrr	r4�sz(ProcessStateExitedEvent.get_extra_valuesN)rrrr4rrrr	rD�srDc@seZdZdd�ZdS)�ProcessStateRunningEventcCsd|jjfgS)Nr)rr)rrrr	r4�sz)ProcessStateRunningEvent.get_extra_valuesN)rrrr4rrrr	rE�srEc@seZdZdd�ZdS)�ProcessStateStoppingEventcCsd|jjfgS)Nr)rr)rrrr	r4�sz*ProcessStateStoppingEvent.get_extra_valuesN)rrrr4rrrr	rF�srFc@seZdZdd�ZdS)�ProcessStateStoppedEventcCsd|jjfgS)Nr)rr)rrrr	r4�sz)ProcessStateStoppedEvent.get_extra_valuesN)rrrr4rrrr	rG�srGc@seZdZdd�Zdd�ZdS)�ProcessGroupEventcCs
||_dS)N)r)rrrrr	r�szProcessGroupEvent.__init__cCs
d|jS)Nz
groupname:%s
)r)rrrr	r$�szProcessGroupEvent.payloadN)rrrrr$rrrr	rH�srHc@seZdZdS)�ProcessGroupAddedEventN)rrrrrrr	rI�srIc@seZdZdS)�ProcessGroupRemovedEventN)rrrrrrr	rJ�srJc@s eZdZdZdd�Zdd�ZdS)�	TickEventz
 Abstract cCs||_||_dS)N)�when�supervisord)rrLrMrrr	r�szTickEvent.__init__cCs
d|jS)Nzwhen:%s)rL)rrrr	r$�szTickEvent.payloadN)rrrrrr$rrrr	rK�srKc@seZdZdZdS)�
Tick5Event�N)rrr�periodrrrr	rN�srNc@seZdZdZdS)�Tick60Event�<N)rrrrPrrrr	rQ�srQc@seZdZdZdS)�
Tick3600EventiN)rrrrPrrrr	rS�srSc@sxeZdZeZeZeZe	Z
eZe
ZeZeZeZeZeZeZeZeZeZ e!Z"e#Z$e%Z&e'Z(e)Z*e+Z,e-Z.e/Z0e1Z2e3Z4e5Z6e7Z8dS)�
EventTypesN)9rrrrZEVENTr1Z
PROCESS_STATErGZPROCESS_STATE_STOPPEDrDZPROCESS_STATE_EXITEDrCZPROCESS_STATE_STARTINGrFZPROCESS_STATE_STOPPINGrBZPROCESS_STATE_BACKOFFr>ZPROCESS_STATE_FATALrEZPROCESS_STATE_RUNNINGr?ZPROCESS_STATE_UNKNOWNr)ZPROCESS_COMMUNICATIONr*ZPROCESS_COMMUNICATION_STDOUTr+ZPROCESS_COMMUNICATION_STDERRrZPROCESS_LOGr%ZPROCESS_LOG_STDOUTr'ZPROCESS_LOG_STDERRr,ZREMOTE_COMMUNICATIONr-ZSUPERVISOR_STATE_CHANGEr.ZSUPERVISOR_STATE_CHANGE_RUNNINGr/Z SUPERVISOR_STATE_CHANGE_STOPPINGrKZTICKrNZTICK_5rQZTICK_60rSZ	TICK_3600rHZ
PROCESS_GROUPrIZPROCESS_GROUP_ADDEDrJZPROCESS_GROUP_REMOVEDrrrr	rT�s6rTcCs(x"tjj�D]\}}||kr|SqWdS)N)rT�__dict__�items)Z	requestedr�typrrr	�getEventNameByType�srXcCstt||�dS)N)�setattrrT)rrrrr	�register�srZN)*Zsupervisor.statesrZsupervisor.compatrrr
rrrrrr%r'r)r*r+r,r-r.r/r0r1r>r?r@rBrCrDrErFrGrHrIrJrKrNrQrSZTICK_EVENTSrTrXrZrrrr	�<module>sN