Edit File: events.cpython-36.pyc
3 �k�`C � @ s4 d dl mZ d dlmZ g Zdd� Zdd� Zdd� Zd d � ZG d d � d �Z G d d� de �Z G dd� de �Z G dd� de �Z G dd� de �Z G dd� de �ZG dd� de �ZG dd� de �ZG dd � d e �ZG d d � d e�ZG d d � d e�ZG d!d"� d"�ZG d#d$� d$e �ZG d%d&� d&e�ZG d'd(� d(e�ZG d)d*� d*e�ZG d+d,� d,e�ZG d-d.� d.e�ZG d/d0� d0e�ZG d1d2� d2e�Z G d3d4� d4e�Z G d5d6� d6e�Z G d7d8� d8e �Z G d9d:� d:e �Z G d;d<� d<e �Z!G d=d>� d>e �Z"G d?d@� d@e"�Z#G dAdB� dBe"�Z$G dCdD� dDe"�Z%e#e$e%gZ&G dEdF� dF�Z'dGdH� Z(dIdJ� Z)dKS )L� )�getProcessStateDescription)� as_stringc C s t j| |f� d S )N)� callbacks�append)�type�callback� r � /usr/lib/python3.6/events.py� subscribe s r c C s t j| |f� d S )N)r �remove)r r r r r � unsubscribe s r c C s( x"t D ]\}}t| |�r|| � qW d S )N)r � isinstance)�eventr r r r r �notify s r c C s g t d d �< d S )N)r r r r r �clear s r c @ s e Zd ZdZdS )�Eventz Abstract event type N)�__name__� __module__� __qualname__�__doc__r r r r r s r c @ s$ e Zd ZdZdZdd� Zdd� ZdS )�ProcessLogEventz Abstract Nc C s || _ || _|| _d S )N)�process�pid�data)�selfr r r r r r �__init__ s zProcessLogEvent.__init__c C s~ d}| j jd k r | j jjj}yt| j�}W n tk rH d| j }Y nX td�}|t| j jj�t|�| jt| j�|f }|S )N� zUndecodable: %rz0processname:%s groupname:%s pid:%s channel:%s %s) r �group�config�namer r �UnicodeDecodeErrorr �channel)r � groupnamer Zfmt�resultr r r �payload s zProcessLogEvent.payload)r r r r r! r r$ r r r r r s r c @ s e Zd ZdZdS )�ProcessLogStdoutEvent�stdoutN)r r r r! r r r r r% 1 s r% c @ s e Zd ZdZdS )�ProcessLogStderrEvent�stderrN)r r r r! r r r r r' 4 s r' c @ s( e Zd ZdZdZdZdd� Zdd� ZdS ) �ProcessCommunicationEventz Abstract s <!--XSUPERVISOR:BEGIN-->s <!--XSUPERVISOR:END-->c C s || _ || _|| _d S )N)r r r )r r r r r r r r = s z"ProcessCommunicationEvent.__init__c C sb d}| j jd k r | j jjj}yt| j�}W n tk rH d| j }Y nX d| j jj|| j|f S )Nr zUndecodable: %rz%processname:%s groupname:%s pid:%s %s)r r r r r r r r )r r" r r r r r$ B s z!ProcessCommunicationEvent.payloadN)r r r r Z BEGIN_TOKENZ END_TOKENr r$ r r r r r) 7 s r) c @ s e Zd ZdZdS )� ProcessCommunicationStdoutEventr& N)r r r r! r r r r r* P s r* c @ s e Zd ZdZdS )� ProcessCommunicationStderrEventr( N)r r r r! r r r r r+ S s r+ c @ s e Zd Zdd� Zdd� ZdS )�RemoteCommunicationEventc C s || _ || _d S )N)r r )r r r r r r r W s z!RemoteCommunicationEvent.__init__c C s d| j | jf S )Nz type:%s %s)r r )r r r r r$ [ s z RemoteCommunicationEvent.payloadN)r r r r r$ r r r r r, V s r, c @ s e Zd ZdZdd� ZdS )�SupervisorStateChangeEventz Abstract class c C s dS )Nr r )r r r r r$ ` s z"SupervisorStateChangeEvent.payloadN)r r r r r$ r r r r r- ^ s r- c @ s e Zd ZdS )�SupervisorRunningEventN)r r r r r r r r. c s r. c @ s e Zd ZdS )�SupervisorStoppingEventN)r r r r r r r r/ f s r/ c @ s e Zd Zdd� ZdS )�EventRejectedEventc C s || _ || _d S )N)r r )r r r r r r r j s zEventRejectedEvent.__init__N)r r r r r r r r r0 i s r0 c @ s2 e Zd ZdZdZdZd dd�Zdd� Zdd � ZdS ) �ProcessStateEventz' Abstract class, never raised directly NTc C s || _ || _|| _| j� | _d S )N)r � from_state�expected�get_extra_values� extra_values)r r r2 r3 r r r r r s zProcessStateEvent.__init__c C sb d}| j jd k r | j jjj}d| j jjfd|fdt| j�fg}|j| j� djdd� |D ��}|S )Nr Z processnamer" r2 � c S s g | ]\}}d ||f �qS )z%s:%sr )�.0r �valr r r � <listcomp>� s z-ProcessStateEvent.payload.<locals>.<listcomp>) r r r r r r2 �extendr5 �join)r r" �L�sr r r r$ z s zProcessStateEvent.payloadc C s g S )Nr )r r r r r4 � s z"ProcessStateEvent.get_extra_values)T) r r r r ZfrmZtor r$ r4 r r r r r1 n s r1 c @ s e Zd ZdS )�ProcessStateFatalEventN)r r r r r r r r> � s r> c @ s e Zd ZdS )�ProcessStateUnknownEventN)r r r r r r r r? � s r? c @ s e Zd Zdd� ZdS )�"ProcessStateStartingOrBackoffEventc C s dt | jj�fgS )NZtries)�intr Zbackoff)r r r r r4 � s z3ProcessStateStartingOrBackoffEvent.get_extra_valuesN)r r r r4 r r r r r@ � s r@ c @ s e Zd ZdS )�ProcessStateBackoffEventN)r r r r r r r rB � s rB c @ s e Zd ZdS )�ProcessStateStartingEventN)r r r r r r r rC � s rC c @ s e Zd Zdd� ZdS )�ProcessStateExitedEventc C s dt | j�fd| jjfgS )Nr3 r )rA r3 r r )r r r r r4 � s z(ProcessStateExitedEvent.get_extra_valuesN)r r r r4 r r r r rD � s rD c @ s e Zd Zdd� ZdS )�ProcessStateRunningEventc C s d| j jfgS )Nr )r r )r r r r r4 � s z)ProcessStateRunningEvent.get_extra_valuesN)r r r r4 r r r r rE � s rE c @ s e Zd Zdd� ZdS )�ProcessStateStoppingEventc C s d| j jfgS )Nr )r r )r r r r r4 � s z*ProcessStateStoppingEvent.get_extra_valuesN)r r r r4 r r r r rF � s rF c @ s e Zd Zdd� ZdS )�ProcessStateStoppedEventc C s d| j jfgS )Nr )r r )r r r r r4 � s z)ProcessStateStoppedEvent.get_extra_valuesN)r r r r4 r r r r rG � s rG c @ s e Zd Zdd� Zdd� ZdS )�ProcessGroupEventc C s || _ d S )N)r )r r r r r r � s zProcessGroupEvent.__init__c C s d| j S )Nz groupname:%s )r )r r r r r$ � s zProcessGroupEvent.payloadN)r r r r r$ r r r r rH � s rH c @ s e Zd ZdS )�ProcessGroupAddedEventN)r r r r r r r rI � s rI c @ s e Zd ZdS )�ProcessGroupRemovedEventN)r r r r r r r rJ � s rJ c @ s e Zd ZdZdd� Zdd� ZdS )� TickEventz Abstract c C s || _ || _d S )N)�when� supervisord)r rL rM r r r r � s zTickEvent.__init__c C s d| j S )Nzwhen:%s)rL )r r r r r$ � s zTickEvent.payloadN)r r r r r r$ r r r r rK � s rK c @ s e Zd ZdZdS )� Tick5Event� N)r r r �periodr r r r rN � s rN c @ s e Zd ZdZdS )� Tick60Event�< N)r r r rP r r r r rQ � s rQ c @ s e Zd ZdZdS )� Tick3600Eventi N)r r r rP r r r r rS � s rS c @ sx e Zd ZeZeZeZe Z e Z e ZeZeZeZeZeZeZeZ e Z e Z e!Z"e#Z$e%Z&e'Z(e)Z*e+Z,e-Z.e/Z0e1Z2e3Z4e5Z6e7Z8dS )� EventTypesN)9r r r r ZEVENTr1 Z PROCESS_STATErG ZPROCESS_STATE_STOPPEDrD ZPROCESS_STATE_EXITEDrC ZPROCESS_STATE_STARTINGrF ZPROCESS_STATE_STOPPINGrB ZPROCESS_STATE_BACKOFFr> ZPROCESS_STATE_FATALrE ZPROCESS_STATE_RUNNINGr? ZPROCESS_STATE_UNKNOWNr) ZPROCESS_COMMUNICATIONr* Z PROCESS_COMMUNICATION_STDOUTr+ Z PROCESS_COMMUNICATION_STDERRr Z PROCESS_LOGr% ZPROCESS_LOG_STDOUTr' ZPROCESS_LOG_STDERRr, ZREMOTE_COMMUNICATIONr- ZSUPERVISOR_STATE_CHANGEr. Z SUPERVISOR_STATE_CHANGE_RUNNINGr/ Z SUPERVISOR_STATE_CHANGE_STOPPINGrK ZTICKrN ZTICK_5rQ ZTICK_60rS Z TICK_3600rH Z PROCESS_GROUPrI ZPROCESS_GROUP_ADDEDrJ ZPROCESS_GROUP_REMOVEDr r r r rT � s6 rT c C s( x"t jj� D ]\}}|| kr |S q W d S )N)rT �__dict__�items)Z requestedr �typr r r �getEventNameByType� s rX c C s t t| |� d S )N)�setattrrT )r r r r r �register� s rZ N)*Zsupervisor.statesr Zsupervisor.compatr r r r r r r r r% r' r) r* r+ r, r- r. r/ r0 r1 r> r? r@ rB rC rD rE rF rG rH rI rJ rK rN rQ rS Z TICK_EVENTSrT rX rZ r r r r �<module> sN
Back to File Manager