|
Server : Apache/2.2.2 (Fedora) System : Linux App1.pathumtani.go.th 2.6.20-1.2320.fc5smp #1 SMP Tue Jun 12 19:40:16 EDT 2007 i686 User : apache ( 48) PHP Version : 5.2.9 Disable Function : NONE Directory : /proc/self/root/usr/lib/python2.4/site-packages/urlgrabber/ |
Upload File : |
mò
+VCc @ sÄ d k Z d k Z d k Z d k Z d f d „ ƒ YZ d e f d „ ƒ YZ e Z d e f d „ ƒ YZ d f d „ ƒ YZ d e f d
„ ƒ YZ d f d „ ƒ YZ
d
d „ Z d
d d „ Z d S( Nt BaseMeterc B sh t Z d „ Z d d d d d d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z RS( Nc C sa d | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _
t ƒ | _ d S( Nf0.29999999999999999i (
t selft
update_periodt Nonet filenamet urlt basenamet textt sizet
start_timet last_amount_readt last_update_timet
RateEstimatort re( R ( ( t7 /usr/lib/python2.4/site-packages/urlgrabber/progress.pyt __init__ s c C s | | _ | | _ | | _ | | _ | | _ | d j o t | ƒ d | _ n | d j o t
i
ƒ } n | | _ | i i
| | ƒ d | _ | | _ | i | ƒ d S( Nt Bi ( R R R R R R R t
format_numbert fsizet nowt timeR R
t startR
R t _do_start( R R R R R R R ( ( R R ) s
c C s d S( N( ( R R ( ( R R ; s c C s| | d j o t i ƒ } n | | i | i j p | i o9 | i i | | ƒ | | _ | | _ | i
| | ƒ n d S( N( R R R R R R R
t updatet amount_readR
t
_do_update( R R R ( ( R R > s
" c C s d S( N( ( R R R ( ( R R I s c C sV | d j o t i ƒ } n | i i | | ƒ | | _ | | _ | i | | ƒ d S( N(
R R R R R
R R R
R t _do_end( R R R ( ( R t endL s
c C s d S( N( ( R R R ( ( R R S s (
t __name__t
__module__R R R R R R R R ( ( ( R R s
t TextMeterc B s/ t Z e i d „ Z d d „ Z d d „ Z RS( Nc C s t i | ƒ | | _ d S( N( R R R t fo( R R ( ( R R W s
c C sð | i i ƒ } t | ƒ }
t | ƒ } | i d j o
| i } n
| i } | i d j o d | | |
f } n\ | i i ƒ } t | ƒ } | i i ƒ } d t d | ƒ } d | | d | | | f } | i i | ƒ | i i ƒ d S( Ns
%-60.60s %5sB %s t =i s(
%-25.25s %3i%% |%-25.25s| %5sB %8s ETA id ( R R
t elapsed_timet etimet format_timet fetimeR R t freadR R R R t outt remaining_timet rtimet frtimet
fraction_readt fract intt barR t writet flush( R R R R( R+ R R% R" R) R- R$ R& ( ( R R [ s
c C s¶ t | i i ƒ ƒ } t | ƒ } | i d j o
| i } n
| i
} | i d j o d | | | f } n$ d d } d | d | | | f } | i i | d ƒ | i i ƒ d S( Ns
%-60.60s %5sB %s R i s(
%-25.25s %3i%% |%-25.25s| %5sB %8s id s
( R# R R
R! t
total_timeR R t
total_sizeR R R R R& R- R R. R/ ( R R R R0 R- R1 R R& ( ( R R s s
( R R t syst stderrR R R R ( ( ( R R V s t MultiFileHelperc B sA t Z d „ Z d „ Z d „ Z d „ Z d d „ Z d „ Z RS( Nc C s t i | ƒ | | _ d S( N( R R R t master( R R5 ( ( R R ‡ s
c C s | i i | | ƒ d S( N( R R5 t start_meterR ( R R ( ( R R ‹ s c C s | i i | | ƒ d S( N( R R5 t update_meterR ( R R R ( ( R R Ž s c C s? t | | i ƒ | _ t | i ƒ | _ | i i | | ƒ d S( N(
R# R R R t ftotal_timeR R
t ftotal_sizeR5 t end_meter( R R R ( ( R R ’ s c C s | i i | | | ƒ d S( N( R R5 t
failure_metert messageR ( R R< R ( ( R t failure— s c C s | i i | | ƒ d S( N( R R5 t
message_meterR< ( R R< ( ( R R< š s ( R R R R R R R R= R< ( ( ( R R4 † s t MultiFileMeterc B sÅ t Z e Z d „ Z d d d d „ Z d „ Z d d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( Nc C s‹ g | _ g | _ t i ƒ | _ d | _ d | _ d | _ d | _
d | _ d | _ d | _
d | _ d | _ d | _ t ƒ | _ d S( Nf0.29999999999999999i ( R t meterst in_progress_meterst threadt
allocate_lockt _lockR R t numfilest finished_filest failed_filest
open_filesR1 t failed_sizeR t finished_file_sizeR R R
( R ( ( R R Ÿ s c C s’ | d j o t i ƒ } n | | _ d | _ d | _ d | _ | | _ d | _ | | _
d | _ | | _ | i
i | | ƒ | i | ƒ d S( Ni ( R R R RE R RF RG RH R1 RI R RJ R R
R R ( R RE R1 R ( ( R R ° s
c C s d S( N( ( R R ( ( R R ¾ s c C s. | d j o t i ƒ } n | i | ƒ d S( N( R R R R R ( R R ( ( R R Á s
c C s d S( N( ( R R ( ( R R Å s c C s | i i ƒ d S( N( R RD t acquire( R ( ( R t lockÈ s c C s | i i ƒ d S( N( R RD t release( R ( ( R t unlockÉ s c C s# | i | ƒ } | i i | ƒ | S( N( R t helperclasst newmeterR@ t append( R RP ( ( R t newMeterÍ s c C s | i i | ƒ d S( N( R R@ t removet meter( R RT ( ( R t removeMeterÒ s c C s‰ | | i j o t d ƒ ‚ n | i i ƒ z7 | | i j o# | i i | ƒ | i d 7_ n Wd | i i ƒ X| i
| | ƒ d S( Ns attempt to use orphaned meteri ( RT R R@ t
ValueErrorRD RK RA RQ RH RM t _do_start_meterR ( R RT R ( ( R R6 × s
c C s d S( N( ( R RT R ( ( R RW ã s c C s| | | i j o t d ƒ ‚ n | | i | i j p | i o6 | i i | i ƒ | ƒ | | _ | i
| | ƒ n d S( Ns attempt to use orphaned meter( RT R R@ RV R R R R
R t _amount_readt _do_update_meter( R RT R ( ( R R7 æ s " c C s d S( N( ( R RT R ( ( R RY ï s c C s° | | i j o t d ƒ ‚ n | i i ƒ z^ y | i i | ƒ Wn t j
o n X| i d 8_ | i d 7_ | i
| i 7_
Wd | i i ƒ X| i
| | ƒ d S( Ns attempt to use orphaned meteri ( RT R R@ RV RD RK RA RS RH RF RJ R
RM t
_do_end_meterR ( R RT R ( ( R R: ò s
c C s d S( N( ( R RT R ( ( R RZ s c C sÚ | | i j o t d ƒ ‚ n | i i ƒ z… y | i i | ƒ Wn t j
o n X| i d 8_ | i d 7_ | i
o& | i d j o | i | i
7_ n
d | _ Wd | i i
ƒ X| i | | | ƒ d S( Ns attempt to use orphaned meteri ( RT R R@ RV RD RK RA RS RH RG R RI R RM t _do_failure_meterR< R ( R RT R< R ( ( R R; s
c C s d S( N( ( R RT R< R ( ( R R[ s c C s d S( N( ( R RT R< ( ( R R> s c C s. | i } x | i D] } | | i 7} q W| S( N( R RJ t totRA t mR
( R R] R\ ( ( R RX s
( R R R4 RO R R R R R R RL RN RR RU R6 RW R7 RY R: RZ R; R[ R> RX ( ( ( R R? s( t TextMultiFileMeterc B sD t Z e i d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( Nc C s | | _ t i | ƒ d S( N( R R R? R ( R R ( ( R R $ s c
C sT | i i ƒ z2d } | i }
| i p d } d t |
ƒ | d } | i
i } | i
}
d | i
i ƒ p d d } | i
i ƒ } | i
i ƒ } | d j o
d } n | | } t | ƒ d } t |
ƒ d } t | d ƒ } t | d ƒ } d | |
| | | | | | | f } | i i d | ƒ | i i ƒ Wd | i i! ƒ Xd S( NsD files: %3i/%-3i %3i%% data: %6.6s/%-6.6s %3i%% time: %8.8s/%8.8si id f0.48999999999999999i R s %-79.79ss
(" R RD RK t formatRF t dfRE t tft floatt pfR
R
t ddR1 t tdR* t pdR! t dtR' t rtR t ttR t fddt ftdR# t fdtt fttR& R R. R/ RM ( R RT R R& Rh Rm Rc Rk Rf Ra Re Rd R_ R` Rg Rj Rl Ri ( ( R RY ) s.
& c C s | i i ƒ z d } | i } | i }
t |
ƒ d } | i i ƒ } t | d ƒ } t |
| ƒ d } d | | | | | f } | i i d | d ƒ Wd | i i ƒ X| i | | ƒ d S( Ns %-30.30s %6.6s %8.8s %9.9sR i s B/ss %-79.79ss
s
( R RD RK R_ RT R t fnR
R R R R
R! t etR# t fett frateR& R R. RM RY R ( R RT R Rq R_ R Rp Ro R& Rn R ( ( R RZ D s
c C sõ | i i ƒ zÐ d } | i } t | ƒ t d ƒ t d ƒ f j o | i ƒ } n | p
d g } n d | | d | d p d f } | i i d | d ƒ x* | d D] } | i i d
| d ƒ q W| i i ƒ Wd | i | | ƒ Xd S( Ns %-30.30s %6.6s %st u s %-79st FAILEDi s
s
i s ( R RD RK R_ RT R Rn t typeR< t
splitlinesR& R R. R] RM RY R ( R RT R< R R_ R] Rn R& ( ( R R[ U s
%
" c C s& | i i ƒ z Wd | i i ƒ Xd S( N( R RD RK RM ( R RT R< ( ( R R> d s
c C sS | i d | ƒ | i i ƒ z! | i i d ƒ | i i ƒ Wd | i i ƒ Xd S( Ns
(
R RY R R RD RK R R. R/ RM ( R R ( ( R R k s
(
R R R2 R3 R RY RZ R[ R> R ( ( ( R R^ # s R c B sq t Z d d „ Z d d d „ Z d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d
„ Z d d „ Z RS(
Nf5.0c C s
| | _ d S( N( t timescaleR ( R Rv ( ( R R x s c C sN | d j o t i ƒ } n | | _ | | _ | | _ d | _ d | _ d S( Ni ( R R R t totalR R R R
t ave_rate( R Rw R ( ( R R { s
c C sž | d j o t i ƒ } n | d j o# | | _ d | _ d | _ d Sn | | i } | | i } | | _ | | _ | i
| | | i | i ƒ | _ d S( Ni ( R R R R R R R
Rx t time_difft read_difft _temporal_rolling_aveRv ( R R R Rz Ry ( ( R R ƒ s
c C s | i S( s/ get the average transfer rate (in bytes/second)N( R Rx ( R ( ( R t average_rate— s c C s | i | i S( sE the time between the start of the transfer and the most recent updateN( R R R ( R ( ( R R! › s c C s3 | i p | i o d Sn | i | i | i S( s estimated time remainingN( R Rx Rw R R
( R ( ( R R' Ÿ s c C sH | i d j o d Sn- | i d j o d Sn t | i ƒ | i Sd S( s[ the fraction of the data that has been read
(can be None for unknown transfer size)i f1.0N( R Rw R Rb R
( R ( ( R R* ¤ s c C s7 | | } | d j o
d } n | i | | | | ƒ S( sq a temporal rolling average performs smooth averaging even when
updates come at irregular intervals. This is performed by scaling
the "epsilon" according to the time since the last update.
Specifically, epsilon = time_diff / timescale
As a general rule, the average will take on a completely new value
after 'timescale' seconds.i f1.0N( Ry Rv t epsilonR t _rolling_aveRz t last_ave( R Ry Rz R Rv R} ( ( R R{ s
c C sh y | | } Wn t j
o
d } n X| d j o | Sn | d j o | Sn | | d | | S( sK perform a "rolling average" iteration
a rolling average "folds" new data into an existing average with
some weight, epsilon. epsilon must be between 0.0 and 1.0 (inclusive)
a value of 0.0 means only the old value (initial value) counts,
and a value of 1.0 means only the newest value is considered.i N( Rz Ry t recent_ratet ZeroDivisionErrorR R R} ( R Ry Rz R R} R€ ( ( R R~ ¹ s
f15.0c C st | d j o d Sn t t i | | ƒ t i d ƒ ƒ } t | ƒ } | d j o | Sn t t | ƒ | ?| >ƒ S( s— round the remaining time, depending on its size
If rt is between n*start_time and (n+1)*start_time round downward
to the nearest multiple of n (for any counting number n).
If rt < start_time, round down to the nearest 1.
For example (for start_time = 15.0):
2.7 -> 2.0
25.2 -> 25.0
26.4 -> 26.0
35.3 -> 34.0
63.6 -> 60.0
i f0.0i N( Rh R, t matht logR t shiftRb ( R Rh R R„ ( ( R t _round_remaining_timeÊ s
&
(
R R R R R R R| R! R' R* R{ R~ R… ( ( ( R R w s i c C s“ | d j p
| d j o | o d Sq d Sn_ t | ƒ } | d } | d } | o) | d } | d } d | | | f Sn d | | f Sd S( Ni s --:--:--s --:--i< s %02i:%02i:%02is %02i:%02i( t secondsR t use_hoursR, t minutest hours( R† R‡ R‰ Rˆ ( ( R R# Þ s
t c C s d d d d d d d d d g } | o
d
} n d } d } d
} t | ƒ d } x3 | | j o% | | j o | d } | | } qW Wt | ƒ t d ƒ j p t | ƒ t d ƒ j o
d } n | d j o
d } n d } | t
| p d
ƒ | | | f S( s4 Turn numbers into human-readable metric-like numbersRr t kt Mt Gt Tt Pt Et Zt Yf1000.0f1024.0iç i i l s %i%s%sf9.9499999999999993s %.1f%s%ss %.0f%s%sN( t symbolst SIt stept thresht deptht lent max_deptht numberRt R_ Rb t space( Rš R” R› R— R_ R“ R– R• R™ ( ( R R í s$ !
2
(
R2 R R‚ RB R R t text_progress_meterR4 R? R^ R R# R (
R RB R^ R? R R# R2 R4 Rœ R R R‚ R ( ( R t ? s ;.†Tg