File: //usr/lib/python3/dist-packages/apt/progress/__pycache__/text.cpython-38.pyc
U
&��c�) � @ s d Z ddlmZ ddlZddlZddlZddlZz0ddlZddlm Z m
Z
m Z e e e
e W n e k
rt Y nX ddl
Z
ddlmZ e dddgZejjd k r�eZneZd
d � ZG d d
� d
e�ZG dd� deje�ZG dd� deje�ZG dd� dej e�Z dS )z'Progress reporting for text interfaces.� )�print_functionN)�Callable�Optional�Union)�base�AcquireProgress�
CdromProgress�
OpProgress� c C s" t �| �}|| kr t �| d�}|S )z>Translate the message, also try apt if translation is missing.Zapt)�apt_pkg�gettext)�msg�res� r �3/usr/lib/python3/dist-packages/apt/progress/text.py�_2 s
r c @ s$ e Zd ZdZd dd�Zd
dd�ZdS ) � TextProgressz.Internal Base class for text progress classes.Nc C s |pt j| _d| _d S )Nr )�sys�stdout�_file�_width��selfZoutfiler r r �__init__> s zTextProgress.__init__TFc C sx | j �d� | j �|� | jt|�krB| j �| jt|� d � n|rXt| jt|��| _|rj| j �d� n
| j �� dS )z8Write the message on the terminal, fill remaining space.�
� �
N)r �writer �len�max�flush)r r
�newlineZmaximizer r r �_writeC s zTextProgress._write)N)TF)�__name__�
__module__� __qualname__�__doc__r r" r r r r r ; s
r c @ s, e Zd ZdZd dd�Zd
dd�Zdd� ZdS ) r z\Operation progress reporting.
This closely resembles OpTextProgress in libapt-pkg.
Nc C s" t �| |� tj�| � d| _d S )N� )r r r r �old_opr r r r r [ s zOpProgress.__init__c C sL t j�| |� | jr&| jr&| �| j� | �d| j| jf dd� | j| _dS )z1Called periodically to update the user interface.z %s... %i%%
FTN)r r �updateZ major_changer( r" �op�percent)r r+ r r r r) a s
zOpProgress.updatec C s8 t j�| � | jr.| �td�d| jf dd� d| _dS )z,Called once an operation has been completed.z %c%s... Doner Tr' N)r r �doner( r" r �r r r r r, j s zOpProgress.done)N)N)r# r$ r% r& r r) r, r r r r r U s
c @ sZ e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )r z'AcquireProgress for the text interface.Nc C s2 t �| |� tj�| � d | _d| _td�| _d S )N�P � )r r r r �_signalr �long�_idr r r r r v s
zAcquireProgress.__init__c C s4 t j�| � t�tj| j�| _| �� td�| _dS )z�Start an Acquire progress.
In this case, the function sets up a signal handler for SIGWINCH, i.e.
window resize signals. And it also sets id to 1.
r/ N) r r �start�signal�SIGWINCH�_winchr0 r1 r2 r- r r r r3 ~ s zAcquireProgress.startc G sh t | jd�rdt�| j�� �rdddl}ddl}ddl}|�| j|j d�}|�
d|�\}}}}|d | _ dS )z)Signal handler for window resize signals.�filenor Ns Zhhhhr/ ) �hasattrr �os�isattyr7 �fcntl�termios�structZioctlZ
TIOCGWINSZZunpackr )r Zdummyr; r< r= Zbuf�colr r r r6 � s zAcquireProgress._winchc C sH t j�| |� td�|j }|jjr:|dt�|jj� 7 }| � |� dS )z@Called when an item is update (e.g. not modified on the server).zHit � [%sB]N)
r r �ims_hitr � description�owner�filesizer � size_to_strr" �r �item�liner r r r@ � s
zAcquireProgress.ims_hitc C s^ t j�| |� |jj|jjkr4| �td�|j � n&| �td�|j � | �d|jj � dS )z Called when an item is failed.zIgn zErr z %sN)
r r �failrB �statusZ STAT_DONEr" r rA Z
error_text)r rF r r r rH � s
zAcquireProgress.failc C sx t j�| |� |jjrdS | j|j_| jd7 _td�d|jj|jf }|jj rj|dt
� |jj � 7 }| � |� dS )z/Called when some of the item's data is fetched.Nr/ zGet:z%s %sr? )
r r �fetchrB �completer2 �idr rA rC r rD r" rE r r r rJ � s
zAcquireProgress.fetchc C s t j�| |� t| jd�r.t�| j�� �s.dS | j| j d t
| j | j � }d}d| }d}| j
r�tt
| j | j �| j
�}dt�| j
�t�|�f }|jD �].}d}|js�|jr�d|j }t|�t|� t|� | jkr� �q�||7 }d}q�d}|jjj�r |d |jjj|jjf 7 }n|d
|jj 7 }|jjj�rJ|d |jjj 7 }|d t�|j � 7 }|j �r�|jjj �s�|d
t�|j �|j d |j f 7 }|d7 }t|�t|� t|� | jk�r� �q�q�||7 }q�|�s�|t d�7 }| j
�r || jt|� t|� d | 7 }| � |d� dS )z�Periodically invoked while the Acquire process is underway.
Return False if the user asked to cancel the whole Acquire process.r7 Tg Y@Fz%i%%r' z %sB/s %sz [%s]z [%i %sz [%sz %sz %sBz /%sB %i%%�]z
[Working]r )!r r �pulser8 r r9 r: r7 Z
current_bytesZ
current_items�floatZ total_bytesZ total_items� current_cpsr1 r rD � time_to_strZworkersZ current_itemrI r r rB rL Z shortdescrA Zactive_subprocessZ current_sizeZ
total_sizerK r r" ) r rB r+ ZshownZtval�endZetaZworker�valr r r rN � sh ��� �
�
�
" zAcquireProgress.pulsec C s0 t j�| ||� | �td�||f � t� dkS )z7Prompt the user to change the inserted removable media.zUMedia change: please insert the disc labeled
'%s'
in the drive '%s' and press enter
)�c�C)r r � media_changer" r �input)r ZmediumZdriver r r rV � s
�z AcquireProgress.media_changec C s^ t j�| � | �td�t�| j�t�| j �t�| j
�f � d�� ddl }|� |j
| j� dS )z/Invoked when the Acquire process stops running.zFetched %sB in %s (%sB/s)
r r N)r r �stopr" r r rD Z
fetched_bytesrQ Z elapsed_timerP �rstripr4 r5 r0 )r r4 r r r rX s
��zAcquireProgress.stop)N)
r# r$ r% r& r r3 r6 r@ rH rJ rN rV rX r r r r r s s
E c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r zText CD-ROM progress.c C sF t j�| � | �td�d� zttd��W S tk
r@ Y dS X dS )z,Ask the user to provide a name for the disc.zBPlease provide a name for this Disc, such as 'Debian 2.1r1 Disk 1'F�:N)r r �ask_cdrom_namer" r �strrW �KeyboardInterruptr- r r r r[ s
�z CdromProgress.ask_cdrom_namec C s$ t j�| ||� |r | �|d� dS )zSet the current progress.FN)r r r) r" )r �textZcurrentr r r r) # s zCdromProgress.updatec C sH t j�| � | �td�d� ztt� dk�W S tk
rB Y dS X dS )z"Ask the user to change the CD-ROM.z1Please insert a Disc in the drive and press enterFr' N)r r � change_cdromr" r �boolrW r] r- r r r r_ * s
�zCdromProgress.change_cdromN)r# r$ r% r& r[ r) r_ r r r r r s ) r& Z
__future__r �ior9 r4 r �types�typingr r r � ImportErrorr Z apt.progressr �__all__� version_info�majorZ raw_inputrW �intr1 r �objectr r r r r r r r �<module> s6
#