File: //proc/self/root/usr/lib/python3.6/site-packages/supervisor/__pycache__/loggers.cpython-36.pyc
3
�k�`�3 � @ s> d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
G dd� d�Z G d d
� d
�Z d d � Z
e
� Zd
d� ZG dd� d�ZG dd� de�ZG dd� d�ZG dd� de�ZG dd� de�ZG dd� d�ZG dd � d �ZG d d � d e�Zd,d d �Zd-Zefd#d$�Zd%d&� Zd'd(� Z d.d*d+�Z dS )/z�
Logger implementation loosely modeled on PEP 282. We don't use the
PEP 282 logger implementation in the stdlib ('logging') because it's
idiosyncratic and a bit slow for our purposes (we don't use threads).
� N)�syslog)�long)�is_text_stream)� as_stringc @ s( e Zd ZdZdZdZdZdZdZdZ dS ) � LevelsByName�2 �( � � �
� � N)
�__name__�
__module__� __qualname__�CRIT�ERRO�WARN�INFO�DEBG�TRAC�BLAT� r r � /usr/lib/python3.6/loggers.pyr s r c @ s6 e Zd ZejZejZejZ ej
Z ej Z
ejZejZdS )�LevelsByDescriptionN)r r r r r �criticalr �errorr �warnr �infor �debugr �tracer �blatherr r r r r s r c C s2 i } x(t jj� D ]\}}|jd�s|| |< qW | S )N�_)r �__dict__�items�
startswith)Zbynumber�nameZnumberr r r �
_levelNumbers' s
r' c C s t t| d �}|S )N)�getattrr )� descriptionZnumr r r �getLevelNumByDescription0 s r* c @ sP e Zd ZdZejZddd�Zdd� Zdd� Z d d
� Z
d d � Z d
d� Z dd� Z
dS )�Handlerz %(message)sNc C s || _ d| _d S )NF)�stream�closed)�selfr, r r r �__init__8 s zHandler.__init__c C s
|| _ d S )N)�fmt)r. r0 r r r � setFormat< s zHandler.setFormatc C s
|| _ d S )N)�level)r. r2 r r r �setLevel? s zHandler.setLevelc C sH y| j j� W n4 tk
rB } z|jd tjkr2� W Y d d }~X nX d S )Nr )r, �flush�IOError�args�errnoZEPIPE)r. �whyr r r r4 B s
z
Handler.flushc C sV | j sRt| jd�rBy| jj� }W n tk
r4 Y nX |dk rBd S | jj� d| _ d S )N�filenor
T)r- �hasattrr, r9 r5 �close)r. �fdr r r r; J s
z
Handler.closec C s� y�| j dko,t|jt�o,|j p,|jdd ik}t| j� }|rF|j}n | j |j� }|rb|jd�}y| jj |� W n t
k
r� | jj |� Y nX | j � W n | j � Y nX d S )Nz %(message)s�exc_infozutf-8)
r0 �
isinstance�msg�bytes�kwr r, �asdict�encode�write� UnicodeErrorr4 � handleError)r. �recordZbinaryZ
binary_streamr? r r r �emitY s"
z Handler.emitc C s. t j� }tj|d |d |d d t j� ~d S )Nr � � )�sysr= � traceback�print_exception�stderr)r. Zeir r r rF q s zHandler.handleError)N)r r r r0 r r r2 r/ r1 r3 r4 r; rH rF r r r r r+ 4 s
r+ c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) �
StreamHandlerNc C s t j| |� d S )N)r+ r/ )r. Zstrmr r r r/ w s zStreamHandler.__init__c C s t | jd�r| jj� d S )N�clear)r: r, rP )r. r r r �removez s zStreamHandler.removec C s d S )Nr )r. r r r �reopen~ s zStreamHandler.reopen)N)r r r r/ rQ rR r r r r rO v s
rO c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� ZdS )�BoundIO� c C s || _ || _d S )N)�maxbytes�buf)r. rU rV r r r r/ � s zBoundIO.__init__c C s d S )Nr )r. r r r r4 � s z
BoundIO.flushc C s | j � d S )N)rP )r. r r r r; � s z
BoundIO.closec C s> t |�}t | j�| | jkr,| j|d � | _| j|7 _d S )N)�lenrV rU )r. �bZblenr r r rD � s z
BoundIO.writec C s | j S )N)rV )r. r r r �getvalue� s zBoundIO.getvaluec C s
d| _ d S )NrT )rV )r. r r r rP � s z
BoundIO.clearN)rT ) r r r r/ r4 r; rD rY rP r r r r rS � s
rS c @ s* e Zd ZdZd
dd�Zdd� Zdd� Zd S ) � FileHandlerz3File handler which supports reopening of logs.
�abc C sv t j| � yt||�| _W nJ tk
rd } z.|dkrR|jtjkrRd}t||�| _n� W Y d d }~X nX || _|| _d S )Nr[ �wb) r+ r/ �openr, �OSErrorr7 ZESPIPE� baseFilename�mode)r. �filenamer` �er r r r/ � s
zFileHandler.__init__c C s" | j � t| j| j�| _d| _d S )NF)r; r] r_ r` r, r- )r. r r r rR � s zFileHandler.reopenc C sR | j � ytj| j� W n4 tk
rL } z|jd tjkr<� W Y d d }~X nX d S )Nr )r; �osrQ r_ r^ r6 r7 �ENOENT)r. r8 r r r rQ � s zFileHandler.removeN)r[ )r r r �__doc__r/ rR rQ r r r r rZ � s
rZ c @ sF e Zd Zddd�Zdd� Zd d
� Zd d � Zd
d� Zdd� Zdd� Z dS )�RotatingFileHandlerr[ i i r c C s6 |dkr d}t j| ||� || _|| _d| _d| _dS )a�
Open the specified file and use it as the stream for logging.
By default, the file grows indefinitely. You can specify particular
values of maxBytes and backupCount to allow the file to rollover at
a predetermined size.
Rollover occurs whenever the current log file is nearly maxBytes in
length. If backupCount is >= 1, the system will successively create
new files with the same pathname as the base file, but with extensions
".1", ".2" etc. appended to it. For example, with a backupCount of 5
and a base file name of "app.log", you would get "app.log",
"app.log.1", "app.log.2", ... through to "app.log.5". The file being
written to is always "app.log" - when it gets filled up, it is closed
and renamed to "app.log.1", and if files "app.log.1", "app.log.2" etc.
exist, then they are renamed to "app.log.2", "app.log.3" etc.
respectively.
If maxBytes is zero, rollover never occurs.
r r[ r N)rZ r/ �maxBytes� backupCountZcounterZevery)r. ra r` rg rh r r r r/ � s z RotatingFileHandler.__init__c C s t j| |� | j� dS )z�
Emit a record.
Output the record to the file, catering for rollover as described
in doRollover().
N)rZ rH �
doRollover)r. rG r r r rH � s zRotatingFileHandler.emitc C s
t j|�S )N)rc rQ )r. �fnr r r �_remove� s zRotatingFileHandler._removec C s t j||�S )N)rc �rename)r. �srcZtgtr r r �_rename� s zRotatingFileHandler._renamec C s t jj|�S )N)rc �path�exists)r. rj r r r �_exists� s zRotatingFileHandler._existsc C s� | j |�rNy| j|� W n4 tk
rL } z|jd tjkr<� W Y d d }~X nX y| j||� W n4 tk
r� } z|jd tjkr�� W Y d d }~X nX d S )Nr )rq rk r^ r6 r7 rd rn )r. �sfn�dfnr8 r r r �removeAndRename� s
z#RotatingFileHandler.removeAndRenamec C s� | j dkrdS | jj� | j ks"dS | jj� | jdkr�xRt| jd dd�D ]<}d| j|f }d| j|d f }tjj |�rJ| j
||� qJW | jd }| j
| j|� t | jd�| _dS )z<
Do a rollover, as described in __init__().
r NrI z%s.%dz.1r\ ���) rg r, �tellr; rh �ranger_ rc ro rp rt r] )r. �irr rs r r r ri s
z RotatingFileHandler.doRolloverNi � )r[ ry r )
r r r r/ rH rk rn rq rt ri r r r r rf � s
rf c @ s e Zd Zdd� Zdd� ZdS )� LogRecordc K s || _ || _|| _d | _d S )N)r2 r? rA �dictrepr)r. r2 r? rA r r r r/ s zLogRecord.__init__c C sx | j d krrtj� }|t|� d }tjdtj|��}d||f }t| j }t| j�}| j rd|| j }|||d�| _ | j S )Ni� z%Y-%m-%d %H:%M:%Sz%s,%03d)�message� levelname�asctime)
r{ �timer ZstrftimeZ localtime�LOG_LEVELS_BY_NUMr2 r r? rA )r. ZnowZmsecsZpart1r~ r} r? r r r rB s
zLogRecord.asdictN)r r r r/ rB r r r r rz s rz c @ sn e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS )�LoggerNc C s* |d krt j}|| _|d kr g }|| _d S )N)r r r2 �handlers)r. r2 r� r r r r/ , s zLogger.__init__c C s x| j D ] }|j� qW d S )N)r� r; )r. �handlerr r r r; 5 s z Logger.closec K s" t j| jkr | jt j|f|� d S )N)r r r2 �log)r. r? rA r r r r! 9 s zLogger.blatherc K s" t j| jkr | jt j|f|� d S )N)r r r2 r� )r. r? rA r r r r = s z Logger.tracec K s" t j| jkr | jt j|f|� d S )N)r r r2 r� )r. r? rA r r r r A s z Logger.debugc K s" t j| jkr | jt j|f|� d S )N)r r r2 r� )r. r? rA r r r r E s z Logger.infoc K s" t j| jkr | jt j|f|� d S )N)r r r2 r� )r. r? rA r r r r I s z Logger.warnc K s" t j| jkr | jt j|f|� d S )N)r r r2 r� )r. r? rA r r r r M s z Logger.errorc K s" t j| jkr | jt j|f|� d S )N)r r r2 r� )r. r? rA r r r r Q s zLogger.criticalc K s6 t ||f|�}x"| jD ]}||jkr|j|� qW d S )N)rz r� r2 rH )r. r2 r? rA rG r� r r r r� U s
z
Logger.logc C s | j j|� d S )N)r� �append)r. Zhdlrr r r �
addHandler[ s zLogger.addHandlerc C s t �d S )N)�NotImplementedError)r. r r r rY ^ s zLogger.getvalue)NN)r r r r/ r; r! r r r r r r r� r� rY r r r r r� + s
r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �
SyslogHandlerc C s t j| � td k std��d S )NzSyslog module not present)r+ r/ r �AssertionError)r. r r r r/ b s
zSyslogHandler.__init__c C s d S )Nr )r. r r r r; f s zSyslogHandler.closec C s d S )Nr )r. r r r rR i s zSyslogHandler.reopenc C s t j |� d S )N)r )r. r? r r r �_syslogl s zSyslogHandler._syslogc C s� yt|j � }|d }x^|jd�jd�D ]J}||d< | j| }y| j|� W q$ tk
rl | j|jd�� Y q$X q$W W n | j� Y nX d S )Nr| �
zUTF-8)rB �rstrip�splitr0 r� rE rC rF )r. rG Zparamsr| �liner? r r r rH p s
zSyslogHandler.emitN)r r r r/ r; rR r� rH r r r r r� a s
r� c C s t | �S )N)r� )r2 r r r � getLogger~ s r� rI � c C s< t |�}t|�}|j| j� |j|� | j|� |j| _dS )z2Attach a new BoundIO handler to an existing LoggerN)rS rO r3 r2 r1 r� rY )�loggerr0 rU �ior� r r r �handle_boundIO� s
r� c C s. t tj�}|j|� |j| j� | j|� dS )zDAttach a new StreamHandler with stdout handler to an existing LoggerN)rO rK �stdoutr1 r3 r2 r� )r� r0 r� r r r �
handle_stdout� s
r� c C s* t � }|j|� |j| j� | j|� dS )z1Attach a new Syslog handler to an existing LoggerN)r� r1 r3 r2 r� )r� r0 r� r r r �
handle_syslog� s
r� Fc C sT |dkrt � }n |dkr"t|�}nt|d||�}|j|� |j| j� | j|� dS )z�Attach a new file handler to an existing Logger. If the filename
is the magic name of 'syslog' then make it a syslog handler instead.r F�aN)r� rZ rf r1 r3 r2 r� )r� ra r0 ZrotatingrU Zbackupsr� r r r � handle_file� s
r� )Ni )Fr r ) re rc r7 rK r rL Zsupervisor.compatr r r r r r r' r� r* r+ rO rS rZ rf rz r� r� r� Z_2MBr� r� r� r� r r r r �<module> s8 B $Z6