Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
lib
/
python3
/
dist-packages
/
compose
/
cli
/
__pycache__
/
Filename :
log_printer.cpython-310.pyc
back
Copy
o S �`� � @ s d dl Zd dlZd dlmZ d dlmZ d dlmZ d dl m Z d dl m Z d dl m Z d dlmZ d d lmZ d d lmZ d d lmZ G d d� d�Zd-dd�Zd.dd�ZG dd� d�Zdd� Zdd� Zdd � Z G d d � d ed d ��Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"d+d,� Z#dS )/� N)� namedtuple)�cycle)� attrgetter)�Empty)�Queue)�Thread)�APIError� )�colors)�ShutdownException)� split_bufferc @ s e Zd Zddd�Zdd� ZdS )� LogPresenterTc C s || _ || _|| _d S �N)� prefix_width� color_func� keep_prefix)�selfr r r � r �9/usr/lib/python3/dist-packages/compose/cli/log_printer.py�__init__ s zLogPresenter.__init__c C s> dj |d�}| jr |j�| j�}dj | �|d �d�| }|S )Nz{line}��linez {prefix} z |)�prefix)�formatr �name_without_project�ljustr r )r � containerr �to_logr r r r �present s zLogPresenter.presentN�T)�__name__� __module__� __qualname__r r r r r r r s r Tc c s@ � t | �}dd� }t|r|gnt�� �D ] }t|||�V qdS )znReturn an iterable of functions. Each function can be used to format the logs output of a container. c S s | S r r )�textr r r �no_color) s z&build_log_presenters.<locals>.no_colorN)�max_name_widthr r �rainbowr )� service_names� monochromer r r$ r r r r �build_log_presenters" s ��r) � c C s t dd� | D ��| S )z�Calculate the maximum width of container names so we can make the log prefixes line up like so: db_1 | Listening web_1 | Listening c s s � | ]}t |�V qd S r )�len)�.0�namer r r � <genexpr>7 s � z!max_name_width.<locals>.<genexpr>)�max)r' �max_index_widthr r r r% 0 s r% c @ s2 e Zd ZdZejddfdd�Zdd� Zdd � ZdS ) � LogPrinterz:Print logs from many containers to a single output stream.FNc C s, || _ || _|| _|| _|| _|pi | _d S r )� containers� presenters� event_stream�output� cascade_stop�log_args)r r2 r3 r4 r5 r6 r7 r r r r = s zLogPrinter.__init__c s� | j sd S t� }|| jf}t| j | j|�}t|| j| j|f� t|| j�D ](� t |� | jr@� fdd�| j D �}� |v r@� S � sH|sG d S q%| � � � q%d S )Nc s g | ] }|j � kr|j �qS r )r- )r, �contr r r � <listcomp>\ s z"LogPrinter.run.<locals>.<listcomp>) r2 r r7 �build_thread_mapr3 �start_producer_threadr4 � consume_queuer6 �remove_stopped_threads�write)r �queue� thread_args� thread_map�matching_containerr r r �runK s. � �zLogPrinter.runc C sJ z| j �|� W n ty | j �|�dd��� � Y nw | j �� d S )N�ascii�replace)r5 r> �UnicodeEncodeError�encode�decode�flush)r r r r r r> l s �zLogPrinter.write) r r! r" �__doc__�sys�stdoutr rC r> r r r r r1 : s � !r1 c C s. t | �� �D ]\}}|�� s| �|d � qd S r )�list�items�is_alive�pop)rA � container_id� tailer_threadr r r r= x s ��r= c C s& t t| |||fd�}d|_|�� |S �N)�target�argsT)r �tail_container_logs�daemon�start)r � presenterr? r7 �tailerr r r � build_thread~ s �r[ c s � �fdd�t | td�d�D �S )Nc s& i | ]}|j t|t� �g��R � �qS r )�idr[ �next)r, r �r3 r@ r r � <dictcomp>� s ��z$build_thread_map.<locals>.<dictcomp>r- )�key)�sortedr )�initial_containersr3 r@ r r^ r r: � s �r: c @ s2 e Zd Zedd� �Zedd� �Zeddd��ZdS ) � QueueItemc C s | |d d �S r r ��cls�itemr r r �new� � z QueueItem.newc C s | d d |�S r r )re �excr r r � exception� rh zQueueItem.exceptionNc C s | |dd �S )NTr rd r r r �stop� rh zQueueItem.stopr )r r! r" � classmethodrg rj rk r r r r rc � s rc � _QueueItemzitem is_stop excc C s� zt | |�D ]}|�t�|�| |��� qW n ty1 } z|�t�|�� W Y d }~d S d }~ww |�d�rD|�t�|�t | ���� |�t� | j �� d S )N�follow) �build_log_generator�putrc rg r � Exceptionrj �getr � wait_on_exitrk r- )r rY r? r7 rf �er r r rV � s ��� rV c C s8 | j d u r| jddddd�|��}t|�S | j }t|�S )NT)rL �stderr�streamr )� log_stream�logsr )r r7 rv r r r ro � s �ro c C sZ z | � � }d�| j|�W S ty, } zd�| j|jj|jjp d�W Y d }~S d }~ww )Nz{} exited with code {} z=Unexpected API error for {} (HTTP code {}) Response body: {} z[empty])�waitr r- r �response� status_coder# )r � exit_codert r r r rs � s ���rs c C s t t| d�}d|_|�� d S rS )r � watch_eventsrW rX )r@ �producerr r r r; � s r; c C s t � }|D ]x}|d dkr| �|d d � |d dkr*| �|d d � |�|d � |d dkr1q|d | v rH| |d �� r@q| �|d d � |d |v rl|d }|jsez|�� W n tyd Y nw |�|d � t|d t |�g|�R � | |d < qd S )N�actionrk r\ �dierX r ) �setrP �addrO � is_restarting�attach_log_streamr �remover[ r] )rA r4 r3 r@ �crashed_containers�eventr r r r r} � s: ����r} c c sd � z| j dd�}W n ty dV Y q tjy t� �w |jr'|j�|jr-|s-q|jV q)z?Consume the queue by reading lines off of it and yielding them.Tg�������?)�timeoutN)rr r �thread�errorr ri �is_stoprf )r? r6 rf r r r r< � s � � �r< r )r* )$�_threadr� rK � collectionsr � itertoolsr �operatorr r? r r � threadingr � docker.errorsr � r �compose.cli.signalsr � compose.utilsr r r) r% r1 r= r[ r: rc rV ro rs r; r} r< r r r r �<module> s4 > %