| Server IP : 182.53.201.61 / Your IP : 216.73.217.175 Web Server : Apache/2.2.15 (Fedora) System : Linux km10.dyndns.org 2.6.31.5-127.fc12.i686.PAE #1 SMP Sat Nov 7 21:25:57 EST 2009 i686 User : apache ( 48) PHP Version : 5.3.3 Disable Function : NONE MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /proc/11490/root/usr/lib/python2.6/ |
Upload File : |
ɎJc @ s- d Z d d k Z y d d k Z Wn e j
o e i e = n Xd d k Z d d k l Z d d k
l
Z l Z
d d k l Z d d k l Z d d d d
d d d
d d d d d d d d d d g Z e i Z e i Z e i Z e i Z [ e i d d e d d d d e Z d e f d YZ! e" a# e" a$ d Z% d! Z& e Z' d" Z( d# e! f d$ YZ) d% Z* d& e! f d' YZ+ d( Z, d) e! f d* YZ- d+ Z. d, e- f d- YZ/ d. Z0 d/ e! f d0 YZ1 d1 a2 d2 d3 Z3 e a4 h Z5 h Z6 d e! f d4 YZ7 d5 Z8 d6 e7 f d7 YZ9 d8 e7 f d9 YZ: d: Z; d; e7 f d< YZ< d= Z= e= Z> d> Z? e? Z@ d? ZA d d@ k lB ZB e: iC ZD y d dA k lE ZF Wn# e j
o d dB kG lF ZF n XdC ZH dD ZI e dE j o eI n d S(F s; Thread module emulating a subset of Java's threading model.iN( t wraps( t timet sleep( t
format_exc( t dequet activeCountt active_countt Conditiont
currentThreadt current_threadt enumeratet Eventt Lockt RLockt Semaphoret BoundedSemaphoret Threadt Timert
setprofilet settracet localt
stack_sizet ignoret categoryt modulet threadingt messages
sys.exc_cleart _Verbosec B s e Z d d Z d Z RS( c C s$ | d j o
t } n | | _ d S( N( t Nonet _VERBOSEt _Verbose__verbose( t selft verbose( ( s /usr/lib/python2.6/threading.pyt __init__; s
c G sB | i o4 | | } d t i | f } t i i | n d S( Ns %s: %s
( R R t namet _syst stderrt write( R t formatt args( ( s /usr/lib/python2.6/threading.pyt _note@ s
N( t __name__t
__module__R R! R( ( ( ( s /usr/lib/python2.6/threading.pyR 9 s c C s
| a d S( N( t
_profile_hook( t func( ( s /usr/lib/python2.6/threading.pyR T s c C s
| a d S( N( t _trace_hook( R, ( ( s /usr/lib/python2.6/threading.pyR X s c O s
t | | S( N( t _RLock( R' t kwargs( ( s /usr/lib/python2.6/threading.pyR
` s R. c B s\ e Z d d Z d Z d d Z e Z d Z d Z d Z d Z
d Z RS(
c C s2 t i | | t | _ d | _ d | _ d S( Ni ( R R! t _allocate_lockt
_RLock__blockR t
_RLock__ownert
_RLock__count( R R ( ( s /usr/lib/python2.6/threading.pyR! e s c C s- | i } d | i i | o | i | i f S( Ns <%s(%s, %d)>( R2 t __class__R) R" R3 ( R t owner( ( s /usr/lib/python2.6/threading.pyt __repr__k s
i c C s t } | i | j o( | i d | _ | i d | | d S| i i | } | o) | | _ d | _ | i d | | n | i d | | | S( Ni s! %s.acquire(%s): recursive successs %s.acquire(%s): initial successs %s.acquire(%s): failure( R R2 R3 R( R1 t acquire( R t blockingt met rc( ( s /usr/lib/python2.6/threading.pyR7 r s c C s| | i t j o t d n | i d | _ } | p* d | _ | i i | i d | n | i d | d S( Ns cannot release un-aquired locki s %s.release(): final releases %s.release(): non-final release( R2 R t RuntimeErrorR3 R R1 t releaseR( ( R t count( ( s /usr/lib/python2.6/threading.pyR< s
c C s | i d S( N( R< ( R t tt vt tb( ( s /usr/lib/python2.6/threading.pyt __exit__ s c C s? | \ } } | i i | | _ | | _ | i d | d S( Ns %s._acquire_restore()( R1 R7 R3 R2 R( ( R t count_ownerR= R5 ( ( s /usr/lib/python2.6/threading.pyt _acquire_restore s
c C sK | i d | | i } d | _ | i } d | _ | i i | | f S( Ns %s._release_save()i ( R( R3 R2 R R1 R< ( R R= R5 ( ( s /usr/lib/python2.6/threading.pyt
_release_save s
c C s | i t j S( N( R2 R ( R ( ( s /usr/lib/python2.6/threading.pyt _is_owned s N( R) R* R R! R6 R7 t __enter__R< RA RC RD RE ( ( ( s /usr/lib/python2.6/threading.pyR. c s
c O s
t | | S( N( t
_Condition( R' R/ ( ( s /usr/lib/python2.6/threading.pyR s RG c B st e Z d d d Z d Z d Z d Z d Z d Z d Z d d Z
d d Z d
Z e Z
RS( c C s t i | | | d j o
t } n | | _ | i | _ | i | _ y | i | _ Wn t j
o n Xy | i | _ Wn t j
o n Xy | i
| _
Wn t j
o n Xg | _ d S( N( R R! R R
t _Condition__lockR7 R< RD t AttributeErrorRC RE t _Condition__waiters( R t lockR ( ( s /usr/lib/python2.6/threading.pyR! s&
c C s
| i i S( N( RH RF ( R ( ( s /usr/lib/python2.6/threading.pyRF s c G s | i i | S( N( RH RA ( R R' ( ( s /usr/lib/python2.6/threading.pyRA s c C s d | i t | i f S( Ns <Condition(%s, %d)>( RH t lenRJ ( R ( ( s /usr/lib/python2.6/threading.pyR6 s c C s | i i d S( N( RH R< ( R ( ( s /usr/lib/python2.6/threading.pyRD s c C s | i i d S( N( RH R7 ( R t x( ( s /usr/lib/python2.6/threading.pyRC s c C s- | i i d o | i i t St Sd S( Ni ( RH R7 R< t Falset True( R ( ( s /usr/lib/python2.6/threading.pyRE s
c C sg | i p t d n t } | i | i i | | i } z| d j o | i | i d | n t | } d } xf t
o^ | i d } | o Pn | t } | d j o Pn t | d | d } t | q W| pA | i d | | y | i i
| WqQt j
o qQXn | i d | | Wd | i | Xd S( Ns cannot wait on un-aquired locks %s.wait(): got itgMb@?i i g?s %s.wait(%s): timed outs %s.wait(%s): got it( RE R; R0 R7 RJ t appendRD R R( t _timeRO t mint _sleept removet
ValueErrorRC ( R t timeoutt waitert saved_statet endtimet delayt gotitt remaining( ( s /usr/lib/python2.6/threading.pyt wait s<
i c C s | i p t d n | i } | | } | p | i d | d S| i d | | | d j o d p d x? | D]7 } | i y | i | Wq} t j
o q} Xq} Wd S( Ns cannot notify on un-aquired locks %s.notify(): no waiterss" %s.notify(): notifying %d waiter%si t st ( RE R; RJ R( R< RT RU ( R t nRJ t waitersRW ( ( s /usr/lib/python2.6/threading.pyt notify s
c C s | i t | i d S( N( Rb RL RJ ( R ( ( s /usr/lib/python2.6/threading.pyt notifyAll s N( R) R* R R! RF RA R6 RD RC RE R] Rb Rc t
notify_all( ( ( s /usr/lib/python2.6/threading.pyRG s * c O s
t | | S( N( t
_Semaphore( R' R/ ( ( s /usr/lib/python2.6/threading.pyR & s Re c B s; e Z d d d Z d d Z e Z d Z d Z RS( i c C sL | d j o t d n t i | | t t | _ | | _ d S( Ni s$ semaphore initial value must be >= 0( RU R R! R R t _Semaphore__condt _Semaphore__value( R t valueR ( ( s /usr/lib/python2.6/threading.pyR! - s
c C s t } | i i xs | i d j o6 | p Pn | i d | | | i | i i q W| i d | _ | i d | | i t } | i i | S( Ni s) %s.acquire(%s): blocked waiting, value=%si s %s.acquire: success, value=%s( RN Rf R7 Rg R( R] RO R< ( R R8 R: ( ( s /usr/lib/python2.6/threading.pyR7 4 s
c C sQ | i i | i d | _ | i d | | i | i i | i i d S( Ni s %s.release: success, value=%s( Rf R7 Rg R( Rb R< ( R ( ( s /usr/lib/python2.6/threading.pyR< I s
c C s | i d S( N( R< ( R R> R? R@ ( ( s /usr/lib/python2.6/threading.pyRA R s N( R) R* R R! R7 RF R< RA ( ( ( s /usr/lib/python2.6/threading.pyRe ) s
c O s
t | | S( N( t _BoundedSemaphore( R' R/ ( ( s /usr/lib/python2.6/threading.pyR V s Ri c B s& e Z d Z d d d Z d Z RS( s6 Semaphore that checks that # releases is <= # acquiresi c C s t i | | | | | _ d S( N( Re R! t _initial_value( R Rh R ( ( s /usr/lib/python2.6/threading.pyR! [ s c C s- | i | i j o
t d n t i | S( Ns! Semaphore released too many times( Rg Rj RU Re R< ( R ( ( s /usr/lib/python2.6/threading.pyR< _ s
N( R) R* t __doc__R R! R< ( ( ( s /usr/lib/python2.6/threading.pyRi Y s c O s
t | | S( N( t _Event( R' R/ ( ( s /usr/lib/python2.6/threading.pyR e s Rl c B sA e Z d d Z d Z e Z d Z d Z d d Z RS( c C s/ t i | | t t | _ t | _ d S( N( R R! R R t _Event__condRN t _Event__flag( R R ( ( s /usr/lib/python2.6/threading.pyR! l s c C s | i S( N( Rn ( R ( ( s /usr/lib/python2.6/threading.pyt isSetq s c C s< | i i z t | _ | i i Wd | i i Xd S( N( Rm R7 RO Rn Rd R< ( R ( ( s /usr/lib/python2.6/threading.pyt setv s
c C s/ | i i z
t | _ Wd | i i Xd S( N( Rm R7 RN Rn R< ( R ( ( s /usr/lib/python2.6/threading.pyt clear~ s
c C sD | i i z" | i p | i i | n Wd | i i Xd S( N( Rm R7 Rn R] R< ( R RV ( ( s /usr/lib/python2.6/threading.pyR] s
N( R) R* R R! Ro t is_setRp Rq R] ( ( ( s /usr/lib/python2.6/threading.pyRl h s i s Thread-%dc C s t d a | t S( Ni ( t _counter( t template( ( s /usr/lib/python2.6/threading.pyt _newname s
c B s e Z e Z e i Z e i Z d d d d d d d Z
d Z d Z d Z
d Z d Z d Z d Z d Z d Z d d
Z e d Z e i d Z e d
Z d Z e Z e d Z e i d Z d Z d Z d Z d Z RS( c C s | d j p
t d t i | | | d j o
h } n | | _ t | p t | _ | | _ | | _ | i
| _ d | _ t
| _ t | _ t t | _ t | _ t i | _ d S( Ns# group argument must be None for now( R t AssertionErrorR R! t _Thread__targett strRu t
_Thread__namet
_Thread__argst _Thread__kwargst _set_daemont _Thread__daemonict _Thread__identR t _Thread__startedRN t _Thread__stoppedR R t _Thread__blockRO t _Thread__initializedR# R$ t _Thread__stderr( R t groupt targetR" R' R/ R ( ( s /usr/lib/python2.6/threading.pyR! s
c C s
t i S( N( R t daemon( R ( ( s /usr/lib/python2.6/threading.pyR| s c C s | i p
t d d } | i i o
d } n | i o
d } n | i o | d 7} n | i d j o | d | i 7} n d | i i | i
| f S( Ns Thread.__init__() was not calledt initialt startedt stoppeds daemons %ss <%s(%s, %s)>( R Rv R Rr R R} R~ R R4 R) Ry ( R t status( ( s /usr/lib/python2.6/threading.pyR6 s
c C s | i p t d n | i i o t d n | i d | t i | t | <t i t | i
d | i i d S( Ns thread.__init__() not calleds thread already starteds %s.start(): starting thread( ( R R; R Rr R( t _active_limbo_lockR7 t _limboR< t _start_new_threadt _Thread__bootstrapR] ( R ( ( s /usr/lib/python2.6/threading.pyt start s
c C sB z( | i o | i | i | i n Wd | ` | ` | ` Xd S( N( Rw Rz R{ ( R ( ( s /usr/lib/python2.6/threading.pyt run s
c C s; y | i Wn& | i o t d j o d S n Xd S( N( t _Thread__bootstrap_innerR} R# R ( R ( ( s /usr/lib/python2.6/threading.pyt __bootstrap s
c C s t | _ d S( N( t
_get_identR~ ( R ( ( s /usr/lib/python2.6/threading.pyt
_set_ident s c C s% z| i | i i t i | t | i <t | =t i | i d | t
o! | i d | t i t
n t
o! | i d | t i t
n z2y | i Wn
t j
o | i d | n | i d | t o$ t i i d | i t f q| i \ } } } z | i d | i d IJ| i d IJxD | o< | i d
| i i i | i | i i i f IJ| i } qVW| i d | | f IJWd ~ ~ ~ Xn X| i d | Wd | i XWd t i i z& | i y t t! =Wn n XWd QXXd S(
Ns %s.__bootstrap(): thread starteds( %s.__bootstrap(): registering trace hooks* %s.__bootstrap(): registering profile hooks# %s.__bootstrap(): raised SystemExits% %s.__bootstrap(): unhandled exceptions Exception in thread %s:
%s
s Exception in thread s2 (most likely raised during interpreter shutdown):s" Traceback (most recent call last):s File "%s", line %s, in %ss %s: %ss %s.__bootstrap(): normal return(" R R Rp R R7 t _activeR~ R R< R( R- R# R R+ R R t
SystemExitR$ R% R" t _format_exct _Thread__exc_infoR t tb_framet f_codet co_filenamet tb_linenot co_namet tb_nextt _Thread__exc_clearRA RF t
_Thread__stopR ( R t exc_typet exc_valuet exc_tb( ( s /usr/lib/python2.6/threading.pyt __bootstrap_inner sb
c C s4 | i i t | _ | i i | i i d S( N( R R7 RO R Rd R< ( R ( ( s /usr/lib/python2.6/threading.pyt __stopE s
c C sW y& t i i z t t =Wd QXWn* t j
o d t i j o qS n Xd S( sA Remove current thread from the dict of currently running threads.Nt dummy_threading( R RA RF R R t KeyErrorR# t modules( R ( ( s /usr/lib/python2.6/threading.pyt __deleteK s c C sL | i p t d n | i i p t d n | t j o t d n | i p | i d | n | i i z | d j o3 x | i p | i i
q W| i d | no t | } x^ | i pC | t } | d j o | i d | Pn | i i
| q W| i d | Wd | i i Xd S( Ns Thread.__init__() not calleds' cannot join thread before it is starteds cannot join current threads% %s.join(): waiting until thread stopss %s.join(): thread stoppedi s %s.join(): timed out(
R R; R Rr R R R( R R7 R R] RQ R< ( R RV t deadlineRZ ( ( s /usr/lib/python2.6/threading.pyt joinn s2
c C s | i p
t d | i S( Ns Thread.__init__() not called( R Rv Ry ( R ( ( s /usr/lib/python2.6/threading.pyR" s c C s' | i p
t d t | | _ d S( Ns Thread.__init__() not called( R Rv Rx Ry ( R R" ( ( s /usr/lib/python2.6/threading.pyR" s c C s | i p
t d | i S( Ns Thread.__init__() not called( R Rv R~ ( R ( ( s /usr/lib/python2.6/threading.pyt ident s c C s, | i p
t d | i i o | i S( Ns Thread.__init__() not called( R Rv R Rr R ( R ( ( s /usr/lib/python2.6/threading.pyt isAlive s c C s | i p
t d | i S( Ns Thread.__init__() not called( R Rv R} ( R ( ( s /usr/lib/python2.6/threading.pyR s c C sG | i p t d n | i i o t d n | | _ d S( Ns Thread.__init__() not calleds) cannot set daemon status of active thread( R R; R Rr R} ( R t daemonic( ( s /usr/lib/python2.6/threading.pyR s
c C s | i S( N( R ( R ( ( s /usr/lib/python2.6/threading.pyt isDaemon s c C s
| | _ d S( N( R ( R R ( ( s /usr/lib/python2.6/threading.pyt setDaemon s c C s | i S( N( R" ( R ( ( s /usr/lib/python2.6/threading.pyt getName s c C s
| | _ d S( N( R" ( R R" ( ( s /usr/lib/python2.6/threading.pyt setName s N( ( R) R* RN R R# t exc_infoR t exc_clearR R R! R| R6 R R R R R R t _Thread__deleteR t propertyR" t setterR R t is_aliveR R R R R ( ( ( s /usr/lib/python2.6/threading.pyR s4
K # ! c O s
t | | S( N( t _Timer( R' R/ ( ( s /usr/lib/python2.6/threading.pyR s R c B s/ e Z d Z g h d Z d Z d Z RS( s Call a function after a specified number of seconds:
t = Timer(30.0, f, args=[], kwargs={})
t.start()
t.cancel() # stop the timer's action if it's still waiting
c C sA t i | | | _ | | _ | | _ | | _ t | _ d S( N( R R! t intervalt functionR' R/ R t finished( R R R R' R/ ( ( s /usr/lib/python2.6/threading.pyR! s
c C s | i i d S( s( Stop the timer if it hasn't finished yetN( R Rp ( R ( ( s /usr/lib/python2.6/threading.pyt cancel s c C sN | i i | i | i i p | i | i | i n | i i d S( N( R R] R Rr R R' R/ Rp ( R ( ( s /usr/lib/python2.6/threading.pyR s ( R) R* Rk R! R R ( ( ( s /usr/lib/python2.6/threading.pyR s t _MainThreadc B s# e Z d Z d Z d Z RS( c C sO t i | d d | i i | i t i | t t <t i d S( NR" t
MainThread(
R R! R Rp R R R7 R R R< ( R ( ( s /usr/lib/python2.6/threading.pyR! s
c C s t S( N( RN ( R ( ( s /usr/lib/python2.6/threading.pyR| s c C sn | i t } | o | i d | n x | o | i t } q1 W| i d | | i d S( Ns %s: waiting for other threadss %s: exiting( R t _pickSomeNonDaemonThreadR( R R ( R R> ( ( s /usr/lib/python2.6/threading.pyt _exitfunc s
( R) R* R! R| R ( ( ( s /usr/lib/python2.6/threading.pyR s c C s5 x. t D]# } | i o | i o | Sq
Wd S( N( R
R R R ( R> ( ( s /usr/lib/python2.6/threading.pyR s
t _DummyThreadc B s& e Z d Z d Z d d Z RS( c C s[ t i | d t d | ` | i i | i t i | t t
<t i d S( NR" s Dummy-%d( R R! Ru R R Rp R R R7 R R R< ( R ( ( s /usr/lib/python2.6/threading.pyR!
s
c C s t S( N( RO ( R ( ( s /usr/lib/python2.6/threading.pyR| s c C s t p
t d d S( Ns cannot join a dummy thread( RN Rv ( R RV ( ( s /usr/lib/python2.6/threading.pyR s N( R) R* R! R| R R ( ( ( s /usr/lib/python2.6/threading.pyR s c C s- y t t SWn t j
o t SXd S( N( R R R R ( ( ( s /usr/lib/python2.6/threading.pyR ! s c C s. t i t t t t } t i | S( N( R R7 RL R R R< ( R= ( ( s /usr/lib/python2.6/threading.pyR * s
c C s. t i t i t i } t i | S( N( R R7 R t valuesR R< ( t active( ( s /usr/lib/python2.6/threading.pyR
2 s
( R ( t _local( R c C s t a h } t } t i i z xJ t i D]< } | | j o t } | | _ | | | <q7 t | _
q7 Wt i t i t i
| t t d j p t Wd QXd S( Ni ( R0 R R RA RF R t
itervaluesR R~ RO R R Rq t updateRL Rv ( t
new_activet currentt threadR ( ( s /usr/lib/python2.6/threading.pyt _after_forkI s
c C s d t f d Y} d t f d Y} d t f d Y} d } d } d } | | } g } xA t | D]3 } | | | } d
| d | _ | i | qs W| | | | }
x" | D] } | i t d q W|
i x | D] } | i q W|
i d S(
Nt BoundedQueuec B s# e Z d Z d Z d Z RS( c S sV t i | t | _ t | i | _ t | i | _ | | _ t | _ d S( N(
R R! R
t monR R: t wct limitR t queue( R R ( ( s /usr/lib/python2.6/threading.pyR! q s
c S s | i i x; t | i | i j o! | i d | | i i q W| i i | | i d | t | i | i i
| i i d S( Ns put(%s): queue fulls put(%s): appended, length now %d( R R7 RL R R R( R R] RP R: Rb R< ( R t item( ( s /usr/lib/python2.6/threading.pyt puty s
c S s | i i x) | i p | i d | i i q W| i i } | i d | t | i | i i | i i
| S( Ns get(): queue emptys get(): got %s, %d left( R R7 R R( R: R] t popleftRL R Rb R< ( R R ( ( s /usr/lib/python2.6/threading.pyt get s
( R) R* R! R R ( ( ( s /usr/lib/python2.6/threading.pyR o s t ProducerThreadc B s e Z d Z d Z RS( c S s) t i | d d | | _ | | _ d S( NR" t Producer( R R! R t quota( R R R ( ( s /usr/lib/python2.6/threading.pyR! s c S sj d d k l } d } xM | | i j o< | d } | i i d | i | f t | d q Wd S( Ni( t randomi i s %s.%dgh㈵>( R R R R R" RS ( R R t counter( ( s /usr/lib/python2.6/threading.pyR s
( R) R* R! R ( ( ( s /usr/lib/python2.6/threading.pyR s t ConsumerThreadc B s e Z d Z d Z RS( c S s) t i | d d | | _ | | _ d S( NR" t Consumer( R R! R R= ( R R R= ( ( s /usr/lib/python2.6/threading.pyR! s c S s@ x9 | i d j o( | i i } | GH| i d | _ q Wd S( Ni i ( R= R R ( R R ( ( s /usr/lib/python2.6/threading.pyR s
( R) R* R! R ( ( ( s /usr/lib/python2.6/threading.pyR s i i i s Producer-%di gư>( R R t rangeR" RP R RS R ( R R R t NPt QLt NIt Qt Pt iR> t C( ( s /usr/lib/python2.6/threading.pyt _testm s.
t __main__(J Rk t sysR# R t ImportErrorR R) t warningst functoolsR R RQ R RS t tracebackR R t collectionsR t __all__t start_new_threadR t
allocate_lockR0 t get_identR t errort ThreadErrort filterwarningst DeprecationWarningRN R t objectR R R+ R- R R R R
R. R RG R Re R Ri R Rl Rs Ru R R R R R R R R R R R R R R
R R t _shutdownR R t _threading_localR R ( ( ( s /usr/lib/python2.6/threading.pyt <module> s
K u - & $ $ R