File: //opt/alt/python37/lib/python3.7/site-packages/loguru/__pycache__/_handler.cpython-37.pyc
B
�P�eZ1 � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ ddlm Z ddl
m Z dd� Z d d
� Z
d d � ZG d
d� de�ZG dd� d�ZdS )� N)�contextmanager)�Thread� )� Colorizer)�create_handler_lockc C s t �| �}||�|�fS )N)r �prepare_format�colorize)�format_�
ansi_level�colored� r �@/opt/alt/python37/lib/python3.7/site-packages/loguru/_handler.py�prepare_colored_format
s
r c C s t �| �}|�� S )N)r r �strip)r r r r r
�prepare_stripped_format s
r c C s t jdd�| �S )N�@ )�maxsize)� functools� lru_cache)�functionr r r
�memoize s r c @ s e Zd ZdZdS )�Message)�recordN)�__name__�
__module__� __qualname__� __slots__r r r r
r s r c @ s� e Zd Zdd� Zdd� Zedd� �Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z e dd� �Z
edd� �Zdd� Zdd� Zdd� ZdS ) �Handlerc C s� || _ || _|| _|| _|| _|| _|| _|| _| | _|
| _ | | _
| | _ |
| _ || _
d | _i | _d | _d| _t� | _t�� | _d | _d | _d | _d | _d | _d | _ | jr�| jr�t t �| _q�t t �| _n.| jr�x&| j
D ]}| � |� q�W n | j�!� | _| j�r�| j d k�r(t"�#� | _t"�$� | _t"�%� | _n$| j �#� | _| j �$� | _| j �%� | _t� | _t&�'� | _t(| j)dd| j d�| _ | j �*� d S )NFTzloguru-writer-%d)�target�daemon�name)+�_name�_sink�_levelno�
_formatter�_is_formatter_dynamic�_filter� _colorize�
_serialize�_enqueueZ_multiprocessing_context�_error_interceptor�_exception_formatter�_id�_levels_ansi_codes�_decolorized_format�_precolorized_formats�_memoize_dynamic_format�_stoppedr �_lock� threading�local�_lock_acquired�_queue� _queue_lock�_confirmation_event�_confirmation_lock�_owner_process_pid�_threadr r r �
update_formatr �multiprocessing� SimpleQueue�Event�Lock�os�getpidr �_queued_writer�start)�selfZsinkr �levelno� formatterZis_formatter_dynamic�filter_r � serialize�enqueueZmultiprocessing_contextZerror_interceptorZexception_formatterZid_Zlevels_ansi_codes�
level_namer r r
�__init__ s^
zHandler.__init__c C s d| j | j| jf S )Nz(id=%d, level=%d, sink=%s))r, r# r! )rE r r r
�__repr__k s zHandler.__repr__c c sJ t | jdd�rtd��d| j_z | j� dV W dQ R X W dd| j_X dS )zNAcquire the lock, but fail fast if its already acquired by the current thread.�acquiredFa
Could not acquire internal lock because it was already in use (deadlock avoided). This likely happened because the logger was re-used inside a sink, a signal handler or a '__del__' method. This is not permitted because the logger and its handlers are not re-entrant.TN)�getattrr5 � RuntimeErrorrN r2 )rE r r r
�_protected_lockn s zHandler._protected_lockc C s� �yX| j |d jkrd S | jd k r0| �|�s0d S | jr@| �|�}|�� }|d sZd|d< n4|d \}} }
| j} | j|| |
|d�} d�| �|d< |d k r�|j |d kr�d }|r�|d ks�| j
s�|d }
n| j | }|� |�}
�n| j�rt| j
�s| �
|�}|�|�}
np|d k�r2| j | }| �
||�\}}|�|�}
n@| j | }| �
||�\} }| j|d ||d�}||d< |�|�}
n�| j
�s�| j}|�|�}
nf|d k�r�| j | }| j| }|�|�}
n<| j | }| j| }| jj|d ||d�}||d< |�|�}
| j�r| �|
|�}
t|
�}||_| �� �4 | j�r,d S | j�rB| j�|� n | j� |� W d Q R X W n0 t k
�r� | j � � �sz� | j � |� Y nX d S )N�level� exception� )�from_decorator�message)r
�colored_message)!r# �nor& r% r$ �copyr+ �format_exception�join�strippedr' r- r r0 �
format_mapZmake_coloring_messager. r/ r( �_serialize_recordr r rQ r1 r) r6 �putr" �write� Exceptionr* Z should_catch�print)rE r �level_idrU Zis_rawrW Zdynamic_formatZformatter_record�type_�value�tbrG �lines� formattedr
Zprecomputed_format�_Zcoloring_messageZ
str_recordr r r
�emit s�
z Handler.emitc C sl | � � �Z d| _| jrT| jt�� kr(d S | j�d � | j� � t
| jd�rT| j� � | j �
� W d Q R X d S )NT�close)rQ r1 r) r: rA rB r6 r_ r; r[ �hasattrrk r" �stop)rE r r r
rm � s
z Handler.stopc C s@ | j s
d S | j�& | j�d� | j�� | j�� W d Q R X d S )NT)r) r9 r6 r_ r8 �wait�clear)rE r r r
�complete_queue� s
zHandler.complete_queuec C sF | j r| jt�� krg S | j r$| jn| �� }|� | j�� S Q R X d S )N)r) r: rA rB r7 rQ r" �tasks_to_complete)rE �lockr r r
rq � s
zHandler.tasks_to_completec C s0 | j r | jrd S | j| }| j�|�| j|< d S )N)r' r% r- r$ r r/ )rE rc Z ansi_coder r r
r< � s
zHandler.update_formatc C s | j S )N)r# )rE r r r
rF � s zHandler.levelnoc C s� |d }|d k r6|j d kr d n|j j|jt|j�d�}| |d |d �� d�||d |d j|d jd�|d |d j|d j|d j d
�|d |d |d
|d |d j
|d jd�|d j
|d jd�|d |d � � d�d�
d�}t j
|tdd�d S )NrS )�typere � traceback�elapsed)�repr�seconds�extra�file)r �pathr rR )�iconr rX �linerV �moduler �process)�idr �thread�time)rv � timestamp)
ru rS rx ry r rR r| rV r} r r~ r� r� )�textr F)�default� ensure_ascii�
)rs r re �boolrt �
total_secondsr rz r{ rX r r� �json�dumps�str)r� r rS Z serializabler r r
r^ � s. zHandler._serialize_recordc C s� d }| j }| j}x�y |�� }W n2 tk
rP |� | j�d � W d Q R X wY nX |d kr\P |dkrp| j�� q|�: y| j� |� W n" tk
r� | j�|j
� Y nX W d Q R X qW d S )NT) r6 r7 �getra r* rb r8 �setr" r` r )rE rV �queuerr r r r
rC " s(
zHandler._queued_writerc C sL | j �� }d |d< d |d< d |d< | jrHd |d< d |d< d |d< d |d< |S )Nr2 r5 r0 r" r; Z_owner_processr7 )�__dict__rY r) )rE �stater r r
� __getstate__? s
zHandler.__getstate__c C sR | j �|� t� | _t�� | _| jr,t� | _| j rN| j
rDt t �| _
n
t t�| _
d S )N)r� �updater r2 r3 r4 r5 r) r7 r% r' r r r0 r )rE r� r r r
� __setstate__K s
zHandler.__setstate__N)r r r rL rM r rQ rj rm rp rq r< �propertyrF � staticmethodr^ rC r� r� r r r r
r s K U
' r )r r� r= rA r3 �
contextlibr r Z
_colorizerr Z_locks_machineryr r r r r� r r r r r r
�<module> s