/usr/lib/python2.6/site-packages/supervisor/medusa
Edit: /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyc (9536B)
Ñò
FATc @ s¥ d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z d d k l Z e i
e i ƒ d ƒ d Z d e i
f d „ ƒ YZ d d d „ ƒ YZ d
e i f d „ ƒ YZ d e i
f d
„ ƒ YZ d e i f d „ ƒ YZ e d j o d d d „ ƒ YZ d d d „ ƒ YZ d e i j o e Z d Z n
e Z d Z e ƒ Z e ƒ e _ e e _ e e e ƒ Z e i ƒ n d S( iÿÿÿÿN( t scanning_producer( t countert .i t rpc_channelc B sq e Z d Z d Z d Z d Z e ƒ Z e ƒ Z e ƒ Z d „ Z
d „ Z d „ Z d „ Z
d „ Z d „ Z RS(
s Simple RPC server.s length states packet statei c C s© | | _ | | _ t i i | | ƒ | i | _ | i d ƒ g | _ h | _ t
| ƒ } | i | ƒ t i
| f ƒ } | i d t | ƒ | f ƒ | i i ƒ d S( Ni s %08x%s( t roott addrt asynchatt
async_chatt __init__t STATE_LENGTHt pstatet set_terminatort buffert proxiest idt
new_referencet marshalt dumpst pusht lent client_countert increment( t selfR t connR t ridt p( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR J s
c C sB t | ƒ } | i i | d ƒ \ } } | | d f | i |
e Z d Z d Z d Z d „ Z d „ Z d „ Z d „ Z RS( s Simple RPC servers length states packet statec C sK | | _ | | _ t i i | | ƒ | i | _ | i d ƒ g | _ d S( Ni ( R R R R R R R
R R ( R R R R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR ì s
c G s d S( N( ( R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR! ô s c C s | i i | ƒ d S( N( R R" ( R R# ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR$ ÷ s c
C s' g t i | i d ƒ | _ } | i | i j o/ t i | d ƒ } | i | ƒ | i | _ nà | i d ƒ | i | _ t i | ƒ \ } } | i
} d } y3 x | D] } t | | ƒ } q¨ Wt
| | ƒ } Wn t t i ƒ ƒ } d } n Xt i | | f ƒ } | i d t | ƒ | ƒ d S( NR% i i s %08x( R( R) R R
R R* R R+ R R, R R R. R- R0 R1 R2 R R R (
R R# R= t patht paramst oRA R RC RM ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyRN ú s(
( RO RP RQ R R+ R R! R$ RN ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR_ Þ s t fastrpc_serverc B s e Z d d „ Z d „ Z RS( R% i," c C sG | i t i t i ƒ | i ƒ | i | ƒ | i d ƒ | | _ d S( Ni€ ( RU RV RW RX RY RZ R[ R ( R R R\ ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR s
c C s) | i ƒ \ } } t | i | | ƒ d S( N( R] R_ R ( R R R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyR^ s ( R% i," ( RO RP R R^ ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyRc s t __main__t thingc B s e Z d „ Z RS( c C s d t | ƒ GHd S( Ns a thing has gone away %08x( R ( R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyt __del__& s ( RO RP Rf ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyRe % s t sample_calcc B s, e Z d „ Z d „ Z d „ Z d „ Z RS( c G s t d „ | d ƒ S( Nc S s | | S( ( ( t at b( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyt , s i ( t reduce( R t values( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyt product+ s c G s t d „ | d ƒ S( Nc S s | | S( ( ( Rh Ri ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyRj / s i ( Rk ( R Rl ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyt sum. s c C s
t | ƒ S( N( t eval( R R( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyRo 1 s c C s t ƒ S( N( Re ( R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyt make_a_thing4 s ( RO RP Rm Rn Ro Rp ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyRg ) s s -fR% i," i*" ( ( ( ( R% i," ( R% i*" ( R RV R( t sysR9 R1 R t producersR R t splitt gethostnameR3 R R RS t
dispatcherRT R_ Rc RO Re Rg t argvt server_classR\ R t calct rst loop( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_server.pyt " s6 „ 6