/usr/lib/python2.6/site-packages/supervisor/medusa
Edit: /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyc (10346B)
Ñò
FATc @ sI 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 e i f d „ ƒ YZ d d d „ ƒ YZ d d d „ ƒ YZ d d
„ Z d d d „ ƒ YZ
d d „ Z d d k Z d e i
f d „ ƒ YZ e d j oa d e i j o
e Z n e Z d GHe ƒ Z d GHe i i d d d ƒ GHd GHe i i ƒ GHn d S( iÿÿÿÿNt RPC_Errorc B s e Z RS( ( t __name__t
__module__( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR + s t rpc_proxyc B s† e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
d d d
d d d d g Z d „ Z
RS( i c C s | | i d <| | i d
s
c C s} | d j o | i S| d j o | i S| d j o | i S| d j o | i S| d j o | i S| i d | ƒ Sd S( Nt __call__t __repr__t __getitem__t __setitem__t __len__i ( t __remote_call__t __remote_repr__t __remote_getitem__t __remote_setitem__t __remote_len__t __send_request__( R t attr( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt __getattr__F s
c C s | i d | | f ƒ S( Ni ( R ( R R t value( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt __setattr__X s c C s? y | i d d ƒ Wn$ d d k } | i ƒ } | GHn Xd S( Ni iÿÿÿÿ( R t Nonet who_callst compact_traceback( R R t info( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt __del__[ s c C s! | i d d ƒ } d | d d !S( Ni s i iÿÿÿÿ( R R ( R t r( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR c s c G s | i d | ƒ S( Ni ( R ( R t args( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR g s c C s | i d | ƒ S( Ni ( R ( R t key( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR j s c C s | i d | | f ƒ S( Ni ( R ( R R R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR m s c C s | i d d ƒ S( Ni ( R R ( R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR p s t callt getattrt setattrt reprt delt getitemt setitemt lenc G s | i o= | d } d | i i | i | i | t | d ƒ f GHn t i | i f | ƒ } | i i | ƒ | i i ƒ } t i
| ƒ \ } } | d j o( | i o
d | GHn t | i | ƒ S| d j o
t | ‚ n" | i o d t | ƒ GHn | Sd S( Ni s RPC: ==> %s:%08x:%s:%si s RPC: <== proxy(%08x)s RPC: <== %s(
t DEBUGR t addressR t _request_types_R# t marshalt dumpst send_packett receive_packett loadsR R ( R R t kindt packett dataR ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR u s(
( R R R( R R R R R R R R R R* R ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR : s t rpc_connectionc B s2 e Z h Z d „ Z d „ Z d „ Z d „ Z RS( c C s | | _ | i ƒ d S( N( R) t connect( R R) ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR œ s c C s5 t i t i t i ƒ } | i | i ƒ | | _ d S( N( t sockett AF_INETt SOCK_STREAMR4 R) ( R t s( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR4 s c C sr t i | i i d ƒ d ƒ } g } x; | o3 | i i d ƒ } | i | ƒ | t | ƒ } q' Wt i | d ƒ S( Ni i i t ( t stringt atoiR5 t recvt appendR' t join( R t
packet_lenR1 R2 ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR. ¥ s
c C s$ | i i d t | ƒ | f ƒ d S( Ns %08x%s( R5 t sendR' ( R R1 ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR- ® s ( R R t cacheR R4 R. R- ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR3 ˜ s
t localhosti*" c C sb t i i | ƒ pD t | ƒ } | i ƒ } t i | ƒ \ } t | | ƒ t i | t .( R: R> RF t id( R ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR
Ö s ( ( R R R R RG R
( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyRE ¾ s i," c C sA t i i | ƒ p# t | ƒ } t | ƒ t i | | i } x. t | ƒ o | i d ƒ } | | d ƒ q Wd S( Ni ( RT R' t popR ( R t whyt ft callback( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyR] s
c C s | i i | ƒ d S( N( RU R= ( R R2 ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt collect_incoming_data
s c C s£ g t i | i d ƒ | _ } | i | i j o/ t i | d ƒ } | i | ƒ | i | _ n? t i | ƒ \ } } | i
i d ƒ } | | | ƒ | i ƒ d S( NR9 i i (
R: R> RU RW RV R; RX t STATE_PACKETR+ R/ RT R_ R^ ( R R2 t
packet_lengthRH RI Rb ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt found_terminator s
c C s• | i p3 | i \ } } | i | | ƒ | i | i ƒ n t i | d ƒ } t i | | f ƒ } | i d t
| ƒ | f ƒ | i i | ƒ d S( NRJ s %08x%s(
RY t family_and_typeRS R4 R) R: t splitR+ R, t pushR' RT R= ( R t methodR Rb RZ RQ RF R1 ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt call_method s
( RN i¹ ( R R RV Rd R R[ R\ R^ R] Rc Rf Rk ( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyRM å s t __main__s -fs
connecting...s! calling .calc.sum (1,2,3)i i i s9 calling .calc.nonexistent(), expect an exception!( ( ( RB i*" ( ( RB i," ( R+ R5 R: t
exceptionst syst
StandardErrorR R R3 RD RE RL RO RP RM R t argvR4 t ct calct sumt nonexistent( ( ( s@ /usr/lib/python2.6/site-packages/supervisor/medusa/rpc_client.pyt s. ^
H