�
&��cc@
s]
dZd
dl
mZ
d
dlZd
dlZd
dlZd
dlZy<d
dlZd
dlm	Z	m
Z
mZ
e
e	
e

e
Wnek
r�


n
Xd
dl
Z
d
dlmZ
e
dddgZejjd	kr�eZneZd
�Zdef
d��YZdejefd
��YZdejefd��YZdejefd��YZdS(s'Progress reporting for text interfaces.i����(
tprint_functionN(tCallabletOptionaltUnion(
tbasetAcquireProgresst
CdromProgresst
OpProgressic
C
s4tj
|�
}
|
|kr0tj
|d
�}
n|
S(s>Translate the message, also try apt if translation is missing.tapt(tapt_pkgtgettext(tmsgtres((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyt
_2s


tTextProgresscB
s)eZ
dZdd
�
Zeed�ZRS(s.Internal Base class for text progress classes.cC
s|
ptj
|_d
|_dS(Ni(tsyststdoutt_filet_width(tselftoutfile((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyt__init__>s
cC
s�|jj
d
�

|jj
|
�

|jt|
�
krY|jj
|jt|
�
d�

n$|r}t|jt|
�
�|_n|r�|jj
d�

n
|jj�
dS(s8Write the message on the terminal, fill remaining space.s

t
 s

N(RtwriteRtlentmaxtflush(RRtnewlinetmaximize((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyt_writeCs

$



N(t__name__t
__module__t__doc__tNoneRtTruetFalseR(((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR;s
cB
s/eZ
dZdd
�
Zdd�
Zd�ZRS(s\Operation progress reporting.

    This closely resembles OpTextProgress in libapt-pkg.
    cC
s-tj
||
�
tjj
|�

d
|_dS(Nt(RRRRtold_op(RR((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR[s

cC
sktj
j||
�
|jr8|jr8|j|j�

n|jd
|j|jftt	�
|j|_dS(s1Called periodically to update the user interface.s%s... %i%%
N(
RRtupdatetmajor_changeR%RtoptpercentR#R"(RR)((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR&as



#
c

C
sOtj
j|�

|jrB|jtd
�
d|jftt�
nd|_dS(s,Called once an operation has been completed.s%c%s... Dones

R$N(RRtdoneR%RR
R"(
R((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR*js
	
)
N(RRR R!RR&R*(((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRUs	cB
sbeZ
dZd
d
�
Zd�Zd�Zd�Zd�Zd�Z	d�Z
d�Zd	�ZRS(s'AcquireProgress for the text interface.cC
sEtj
||
�
tjj
|�

d|_d
|_td�
|_dS(NiPi
(	RRRRR!t_signalRtlongt_id(RR((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRvs


	
	
c

C
sHtj
j|�

tjtj|j�|_|j�
td
�
|_dS(s�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.
        i
N(	RRtstarttsignaltSIGWINCHt_winchR+R,R-(
R((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR.~s


c
G
s�t|j
d
�r�tj|j
j��
r�ddl}ddl}ddl}|j|j
|j	d�}|j
d|�\}
}}
}
|d|_ndS(	s)Signal handler for window resize signals.tfilenoi����NiRthhhhi
s        (thasattrRtostisattyR2tfcntlttermioststructtioctlt
TIOCGWINSZtunpackR(RtdummyR7R8R9tbuftcol((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR1�s*





cC
sctj
j||
�
td
�
|
j}|
jjrR|dtj|
jj�
7}n|j	|�

dS(s@Called when an item is update (e.g. not modified on the server).sHit s [%sB]N(
RRtims_hitR
tdescriptiontownertfilesizeR	tsize_to_strR(Rtitemtline((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR@�s



 
cC
s}tj
j||
�
|
jj|
jjkrH|jtd
�
|
j�

n1|jtd�
|
j�

|jd|
jj	�

dS(sCalled when an item is failed.sIgn sErr s  %sN(
RRtfailRBtstatust	STAT_DONERR
RAt
error_text(RRE((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRG�s



cC
s�tj
j||
�
|
jjr#d
S|j|
j_|jd7_td�
d|
jj|
jf}|
jj	r�|dt
j|
jj	�
7}n|j|�

d
S(s/Called when some of the item's data is fetched.Ni
sGet:s%s %ss [%sB](
RRtfetchRBtcompleteR-tidR
RARCR	RDR(RRERF((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRK�s



#

 c	C
s�tj
j||
�
t|jd
�rBtj|jj��
rBtS|j	|j
dt|j|j
�
}t}d|}d}|jr�tt|j|j	�
|j�
}dtj|j�
tj|�
f}nx�
|
jD]�
}d}|jsO
|jr�d|j}t|�
t|�
t|�
|jkr6
Pn||7}t}q�q�nt}|jjjr�
|d|jjj|jjf7}n|d|jj7}|jjjr�
|d	|jjj7}n|d
tj|j�
7}|jr+|jjj r+|dtj|j�
|jd|jf7}n|d7}t|�
t|�
t|�
|jkrbPq�||7}q�W|s�|t!d
�
7}n|jr�||jt|�
t|�
d|7}n|j"|t�
tS(s�Periodically invoked while the Acquire process is underway.

        Return False if the user asked to cancel the whole Acquire process.R2gY@s%i%%R$s	 %sB/s %ss [%s]s [%i %ss [%ss %ss %sBs	/%sB %i%%t
]s
 [Working]R(#RRtpulseR4RR5R6R2R"t
current_bytest
current_itemstfloatttotal_bytesttotal_itemsR#tcurrent_cpsR,R	RDttime_to_strtworkerstcurrent_itemRHRRRBRMt	shortdescRAtactive_subprocesstcurrent_sizet
total_sizeRLR
R(	RRBR)tshownttvaltendtetatworkertval((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRO�s\






	






	
	


)



	









)
	
,
cC
s@tj
j||
|�
|jtd
�
|
|f�

t�dkS(s7Prompt the user to change the inserted removable media.sUMedia change: please insert the disc labeled
 '%s'
in the drive '%s' and press enter
t
ct
C(RcRd(RRtmedia_changeRR
tinput(Rtmediumtdrive((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRe�s

c
C
s�tj
j|�

|jtd
�
tj|j�
tj|j	�
tj|j
�
fjd�
�

ddl}
|
j|
j
|j�
dS(s/Invoked when the Acquire process stops running.sFetched %sB in %s (%sB/s)
s

i����N(RRtstopRR
R	RDt
fetched_bytesRVtelapsed_timeRUtrstripR/R0R+(RR/((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRi
s


 
N(
RRR R!RR.R1R@RGRKROReRi(((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRss
	
				
		E		c
B
s)eZ
dZd
�Zd�Zd�ZRS(sText CD-ROM progress.c

C
sStj
j|�

|jtd
�
t�
yttd�
�
SWntk
rN


dSXdS(s,Ask the user to provide a name for the disc.sBPlease provide a name for this Disc, such as 'Debian 2.1r1 Disk 1't
:N(
RRtask_cdrom_nameRR
R#tstrRftKeyboardInterruptR!(
R((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRn
s






cC
s3tj
j||
|�
|
r/|j|
t�
nd
S(sSet the current progress.N(RRR&RR#(Rttexttcurrent((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR&#
s

c

C
sVtj
j|�

|jtd
�
t�
ytt�dk�
SWntk
rQ


tSXdS(s"Ask the user to change the CD-ROM.s1Please insert a Disc in the drive and press enterR$N(	RRtchange_cdromRR
R#tboolRfRp(
R((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyRs*
s






(RRR RnR&Rs(((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyR
s
		(R t
__future__RtioR5R/RttypesttypingR
RRtImportErrorR	tapt.progressRt__all__tversion_infotmajort	raw_inputRftintR,R
tobjectRRRR(((s5/usr/lib/python2.7/dist-packages/apt/progress/text.pyt<module>s4














			�