| 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 : /usr/lib/python2.6/site-packages/scservices/core/ |
Upload File : |
Ñò
î,ÂJc
@ s d d k Z d d k Z d Z d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d a e d j o¦ e i
ƒ a d d k Z e i
d ƒ d
a d „ Z xa e d ƒ D]S Z e ƒ Z e i d
e d e d e ƒe i d e d e d e ƒt d 7a q´ Wt i ƒ n d S( iÿÿÿÿNt AsyncCmdt
AsyncCmdQueuet AsyncCmdQueueHerderc B sG e Z e e i d d h d „ Z d „ Z d „ Z d „ Z d „ Z
RS( c C s~ | | _ | | _ | | _ | | _ | | _ | | _ d | _ d | _ d | _ d | _
| i o
d | _ n
d | _ d S( Nt ( t cmdt combined_stdoutt priorityt ready_cbt
ready_argst ready_kwargst Nonet pipet fileobjst exitcodet outputt
stderr_output( t selfR R R R R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt __init__ s
c C sA d | i i | i i t t | ƒ ƒ | i | i | i | i f S( NsB <%s.%s object at %s: cmd: %s exitcode: %s fileobjs: %s output: %s>( t __class__t
__module__t __name__t hext idR R
R R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt __repr__5 s c C s' | i o
t i } n
t i } t | i t t f ƒ o
t } n4 t | i t t
f ƒ o
t } n t d t ƒ ‚ t i
d | i d t i d | d t d | ƒ | _ | i i g | _ | i p | i i | i i ƒ n xA | i D]6 } t i | t i t i Bt i B| i d | i ƒqé Wd S( Ns cmd: %st argst stdoutt stderrt close_fdst shellR ( R t
subprocesst STDOUTt PIPEt
isinstanceR t strt unicodet Truet listt tuplet Falset TypeErrort PopenR R R t appendR t gobjectt io_add_watcht IO_INt IO_PRIt IO_HUPt on_fdR ( R t
stderr_argR t fd( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt run< s&
c C s | t i t i B@ob | i ƒ } | | i i j o | i | 7_ qw | | i i j o | i | 7_ qw t ‚ n | t i
@o9 | i i | ƒ t
| i ƒ d j o | i ƒ n t St S( Ni ( R* R, R- t readR R R R R t AssertionErrorR. R t removet lent _finishR& R# ( R R1 t conditiont incoming( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR/ [ s
c C sP | i i ƒ | i i | _ d | _ | i o | i | | i | i Ž n d S( N( R t waitt
returncodeR
R
R R R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR7 x s
N( ( R R R& R* t PRIORITY_DEFAULT_IDLER
R R R2 R/ R7 ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR s c B sk e Z d d e i d „ Z d „ Z d „ Z e d d d
h d „ Z d „ Z
d „ Z d „ Z d „ Z
RS( i c C sl | | _ | | _ | p t p
t ƒ a n t } n | | _ | i i i | ƒ t ƒ | _ g | _ d S( N(
t max_cmds_runningt default_priorityt defaultAsyncCmdQueueHerderR t herdert queuest addt sett cmds_runningt cmds_waiting( R R= R@ R> ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR ˆ s
c C s | i i i | ƒ d S( N( R@ RA R5 ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt __del__š s c C sG d | i i | i i t t | ƒ ƒ | i t | i ƒ t | i ƒ f S( Ns. <%s.%s object at %s: max: %d run: %d wait: %d>( R t _AsyncCmdQueue__moduleR R R R= R6 RD RE ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR s !c C s³ | p
| i } n | f | } t | t t f ƒ o1 t | d | d | d | i d | d | ƒ} n+ t | t ƒ o
| } n t d | ƒ ‚ | i i | ƒ | i i
ƒ d S( NR R R R R s
async_cmd: %s( R> R R! R" R t _ready_cbR' RE R) R@ t try_run( R t async_cmdR R R R R t cmd_obj( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt queue£ s
c O sL | o | | | | Ž n | i i | ƒ | i i | ƒ | i i ƒ d S( N( RD R5 R@ t cmd_readyRI ( R R R t pt k( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyRH µ s
c C s t | i ƒ | i j S( N( R6 RD R= ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt _can_run¿ s c C s t | i ƒ d j S( Ni ( R6 RE ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt waiting s c C sS | i ƒ o> | i ƒ o1 | i i d ƒ } | i i | ƒ | i ƒ | Sd Sd S( Ni ( RP RQ RE t popRD RB R2 R
( R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt run_oneÅ s
N( ( R R R
R* R< R RF R R& RL RH RP RQ RS ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR † s
c B s/ e Z d d „ Z d „ Z d „ Z d „ Z RS( i
c C s% | | _ t ƒ | _ t ƒ | _ d S( N( R= RC RD RA ( R R= ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR × s c C sG d | i i | i i t t | ƒ ƒ | i t | i ƒ t | i ƒ f S( Ns0 <%s.%s object at %s: max: %d run: %d queues: %d>( R R R R R R= R6 RD RA ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR Ü s !c C s t } x“ | o‹ t | i ƒ | i j or t } xe | i D]Z } | i ƒ o
t } n x: | i ƒ o, | i ƒ } | o | i i | ƒ qY PqY Wq9 Wq Wd S( N( R# R6 RD R= R& RA RQ RS RB ( R RQ t qR ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyRI â s
c C s | i i | ƒ d S( N( RD R5 ( R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyRM ù s ( R R R R RI RM ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR Õ s t __main__i i c O sF d GHd G| i GHd G| i GHt d 8a t d j o t i ƒ n d S( Ns
cmd finished:s cmd:s output:i ( R R RD t mainloopt quit( R RN RO ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyR
s
iÈ s sleep 5; echo "hello (%d)"R R s sleep 3; echo "good day (%d)"i ( s AsyncCmds
AsyncCmdQueues AsyncCmdQueueHerder( R R* t __all__t objectR R R R
R? R t MainLoopRV t syst setrecursionlimitRD R t xranget iRL R# R2 ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/asynccmd.pyt <module> s* hO+