3
ft` @ sp d dl mZ d dlmZmZ d dlmZ d dlmZ d dl m Z d dl
Z
d dl Z d dl
Z G dd de jjZdS ) )unicode_literals)
format_number format_time) _term_width)unicode)timeNc @ sr e Zd ZdZejjdejjdejjdejj diZ
e j dddfd d
Z
d d ZdddZdd Zdd Zdd ZdS )MultiFileProgressMeterz"Multi-file download progress meterZFAILEDZSKIPPEDZMIRRORZDRPMg333333?g ?g @c C sp || _ || _|| _|| _d| _d| _tjj | _d| _ d| _
d| _ g | _ i | _
d| _d| _d| _d| _d| _dS )zCreates a new progress meter instance
update_period -- how often to update the progress bar
tick_period -- how fast to cycle through concurrent downloads
rate_average -- time constant for average speed calculation
r N)fo
update_period tick_period rate_averageunknown_progres
total_drpmsysstdoutisatty done_drpm
done_files done_sizeactivestate last_time last_sizerate total_files
total_size)selfr r
r r r /usr/lib/python3.6/progress.py__init__& s" z MultiFileProgressMeter.__init__c C s t jjd|| j d S )NZ write_flush)dnfutilZ_terminal_messengerr )r msgr r r message? s z MultiFileProgressMeter.messager c C sF || _ || _|| _d| _d| _d| _g | _i | _d| _d| _ d | _
d S )Nr ) r r r r r r r r r r r )r r r Z total_drpmsr r r startB s z MultiFileProgressMeter.startc C s t }t|}t|j}t|}|| jkrD|df| j|< | jj| | j| \}}||f| j|< | j|| 7 _|| j | j kr|| j
kr|| _
| j | d S )Nr ) r r int
download_sizer r appendr r r
r _update)r payloaddonenowtextZtotalr$ oldr r r progressS s
z MultiFileProgressMeter.progressc C sJ | j rj|| j }| j| j }|dkrj|dkrj|| }| jd k rdt|| j d}|| | jd| }|| _|| _ | j| _| jsd S | jt|| j t
| j }| j dkrd| j d }t
| jdkr|d| j t
| j 7 }d|| j |f }| jo| j
rt| j
| j | j }nd}d| jr,t| jndt| j|f } t t
| }
|
d d
} | d kr0| j
r| jd | j
} t| j| d
| j
d
\}}
d
| d|
}d| | || f } |
| d 8 }
nj| jd }d}
|dk rdn|}d| d
|
}d| || f } |
| d 8 }
| jd | k r*| jd nd| _| jd|
|
|| f d S )Nr z%dz-%dz (%s/%d): %sz--:--z %5sB/s | %5sB %9s ETA
z--- d =-z%3d%% [%-*s]%s z
[%-*s]%sz%-*.*s%s)r r r r minr r r r% r lenr r r r r r divmodr
r# )r r+ Z
delta_timeZ
delta_sizer Zweightr, nZtime_etar" leftZblZpctpZbarr r r r( g sX
z MultiFileProgressMeter._updatec C s t }}t|}t|j}d}|tjjkr.n|tjjkrJ| jd7 _nt|| j kr| j j
|\}}| j j | ||8 }| j
d7 _
| j|7 _n(|tjjkr| j
d7 _
| j|7 _|r*|tjjkr| jdkrd| j| | j| j|f } nd| j| |f } t t| d }
d| |
|f } nl| jdkrHd| j
| j|f }t|| d} dtt|| t|t| f } t t| }
d |
|
|| f } | j| | j r| j| d S )
Nr r/ z[%s %d/%d] %s: z [%s] %s: z%s%-*s
z (%d/%d): %sgMbP?z %5sB/s | %5sB %9s
z%-*.*s%s)r r r% r& r callback
STATUS_MIRROR STATUS_DRPMr r popr remover r STATUS_ALREADY_EXISTSr STATUS_2_STRr r9 r maxr floatr r# r( ) r r) ZstatusZerr_msgr$ r+ r, sizer* r" r< Ztmr r r end sH
zMultiFileProgressMeter.endN)r )__name__
__module__ __qualname____doc__r r> Z
STATUS_FAILEDrC r? r@ rD r stderrr r# r$ r. r( rH r r r r r s
5r )Z
__future__r Zdnf.cli.formatr r Z dnf.cli.termr Z
dnf.pycompr r r Z dnf.callbackr Zdnf.utilr> ZDownloadProgressr r r r r s