| 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/setroubleshoot/ |
Upload File : |
Jc @ 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 Z d d k
Td d k l Z d d k
Td d k Td d k l Z l Z d d k Td d d d d d
d d d
d d d d d g Z e Z e i d Z e i d Z e i d Z e d d Z d d Z d Z d Z d Z d Z d Z! d Z" d Z# d Z$ d e i% f d! YZ& e i' e& d" e( f d# YZ) e) d$ e* e) d% e+ e) d& e* g Z, d' e( f d( YZ- d) e( f d* YZ. e. Z/ d+ Z0 d, Z1 d- Z2 d. Z3 d e( f d/ YZ4 d0 e( f d1 YZ5 d e5 f d2 YZ6 d3 d9 d4 YZ7 d e( f d5 YZ8 d e5 e8 f d6 YZ9 d7 e( f d8 YZ: d S(: iN( t *( t
get_config( t xml_child_elementst xml_get_child_elements_by_namet
rpc_methodt rpc_arg_typet rpc_callbackt
rpc_signalt interface_registryt parse_socket_address_listt get_default_portt get_socket_list_from_configt get_local_server_socket_addresst ConnectionStatet RpcManaget
RpcChannelt ListeningServert
SocketAddresss content-length:(\d+)s
s ([a-zA-Z0-9_-]+):(.*)
t generalt
i18n_encodingc C s1 g } t i d } t o t i d | n | p | St i d | } x | D] } | p qU n | i | } | o^ | i d i } | i d } t i | } | d j o t i d | | qU q n t i
} | } t | | | }
| i |
qU Wt o t i d | |
n | S( Ns \s*{(unix|inet)}(.+)s% parse_socket_address_list: input='%s's [\s,]+i i s( unknown socket family - %s in address %ss$ parse_socket_address_list: %s --> %s( t ret compilet debugt log_communicationt splitt searcht groupt lowerR t
map_familyt Nonet warningt Sockett AF_INETt append( t addr_stringt default_portt socket_addressest family_ret addrst cfg_addrt matcht
family_tagt addresst familyt socket_address( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR B s4
c C s t d d t } | S( Nt
connectionR# ( R t int( R# ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR
_ s c C s# t | d } } t | } | S( Nt address_list( R R ( t cfg_sectionR" R$ ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR c s c C s, t d } t | d j o d S| d S( Nt client_connect_toi ( R t lenR ( t addr_list( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR h s c C s g } | t i @o | i d n | t i @o | i d n | t i @o | i d n | t i @o | i d n | t i @o | i d n | t i @o | i d n d | d i | f S( Nt INt OUTt PRIt ERRt HUPt NVALs (%d)[%s]t ,( t gobjectt IO_INR! t IO_OUTt IO_PRIt IO_ERRt IO_HUPt IO_NVALt join( t io_conditiont names( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt io_condition_to_stringm s c K sO d t | } x. | i D] \ } } | d | | f 7} q W| d 7} | S( Ns content-length: %d
s %s: %s
s
( R2 t items( t bodyt kwdst hdrt keyt value( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt
rpc_header s
c C s t | d | d | } | | S( Nt rpc_idt type( RL ( RM RN RG RI ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt rpc_message s c
C s^ d } } } } z t i | } | i } | i d } | i d } t i | | } t | d } t t | } x | D] } | i d } | i d } t
| i d }
| i |
} | i d j o< | d j o | i | d | } q#| i | i
} n
| i
} | | |
<q WWd | d j o | i n X| | | f S( Nt interfacet methodt argt nameRN t positiont xmlt obj_name( R t libxml2t parseDoct getRootElementt propR t get_rpc_defR t preextend_listR2 R. t positional_argst obj_typet contentt freeDoc(
t cmdRP RQ t argst doct rpc_deft arg_nodest arg_nodet arg_namet arg_typet arg_positiont rpc_argt arg_value( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt convert_rpc_xml_to_args s0
c
G s d } } z| i } | i } t i d } t i d } | i d | | i d | | i | d } x| i D] } | i }
| | } t i d } | i
| | i d |
| i d t | t | t i
o! | i d d
| i
| na t | d o- | i d d
| i
| i | |
n$ | i d d | i t | | d
7} qz W| i d t | | i d t d d
} Wd | d j o | i n X| S( Ns 1.0Ra RP RQ i RR RS RT RN RU t
get_xml_nodest stringi t arg_countt encodingt format( R RP RQ RW t newDoct newNodet setPropt setRootElementR] RS t addChildt strt
isinstancet xmlNodet hasattrRm t
addContentt serializeR R` (
RM Rd Rb t text_docRc RP RQ t rootRT Rj Rg Rk Rf ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt convert_rpc_to_xml s@
c B s@ e Z d Z d Z d Z d Z d Z d Z d Z e e Be Be Be Be Be BZ e e BZ
e e Be Be BZ h d e 6d e 6d e 6d
e 6d e 6d e 6d
e 6Z e e e e e e e g Z
h e i e i e i e i e i f f d 6Z d Z d Z d Z d Z d Z d Z d Z d d d d d Z RS( i i i i i i i t
CONNECTINGt OPENt
AUTHENTICATEDR8 t ERRORt TIMEOUTt RETRYt changedc C s9 t i i | d | _ d | _ d | _ | i d S( Ni ( R; t GObjectt __init__t flagsR t result_codet
result_msgt clear_result( t self( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
c C s# d | i | i | i | i f S( Ns' flags=%s, result_code=%d, result_msg=%s( t flags_to_stringR R R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt __str__ s c C s | i d | i d S( Ni ( t updatet ALL_FLAGS( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt clear s c C sa | d j o
d } n g } x4 t i D]) } | | @o | i t i | q' q' Wd i | S( Ni R: ( R R
t connection_statesR! t map_connection_enum_to_stringRB ( R t valRD t state( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
c C s d | _ d | _ d S( Ni t ( R R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR
s c C s | | _ | | _ d S( N( R R ( R R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt
set_result s c C s | i | i f S( N( R R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt
get_result s i R c C s t o< t o5 t i d | i i | | i | | i | n | i } | i | O_ | i | M_ | | _ | | _ | | i A} | i | @} | | @} | o | i d | i | | n d S( Ns+ %s.update: %s add_flags=%s, remove_flags=%sR (
R t FalseR t __class__t __name__R R R R t emit( R t add_flagst remove_flagsR R t previous_flagst
differencet flags_addedt
flags_removed( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s #
i i i i i i@ i ( R t
__module__R R R R8 R R R R t
GOOD_FLAGSt
PROBLEM_FLAGSR R R; t SIGNAL_RUN_LASTt TYPE_NONEt TYPE_INTt __gsignals__R R R R R R R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR
s:
+ t RpcArgc B s e Z d d d Z d Z RS( c C s | | _ | | _ d S( N( RS R^ ( R RS R^ ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR 1 s c C sM | i d j o
d } n
| i } | i d j o | Sd | | i f Sd S( Nt name_undefineds %s:%s( RS R R^ ( R RS ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR 5 s
N( R R R R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR 0 s RQ t err_codet err_msgt
RpcDefinitionc B sP e Z d Z d Z d Z d Z d Z d Z d Z d Z RS( c C sK | | _ | | _ | | _ d | _ | d j o
g | _ n
| | _ d S( N( RN RP RQ R t callbackR] ( R RN RP RQ t rpc_args( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR D s
c C s g } | i d j oY xV | i D]G } | i d j o! | i d | i | i f q | i | i q Wn d | i | i | i d i | f } | i d j o | d | i 7} n | S( Ns %s:%ss [%s] %s:%s (%s)R: RQ s callback=%s(
R] R R^ R! RS RN RP RQ RB R ( R Rb Rj t text( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR N s
!(c C s
| | _ d S( N( RN ( R RN ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt set_type[ s c C s= | i d j o t i | i } | | i =n | | _ d S( N( R R R t
get_interfaceRP ( R R t interface_dict( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt set_callback^ s c C s | i d j o t d | i n | i d j oI d | i } t d | i | d } t i | i | | | | _ | St i | i | i S( NRQ s" %s rpc types do not have callbackss %s_default_callbackt
method_return(
RN t
ValueErrorR R RQ R RP R t register_rpc_defR[ ( R t
callback_namet callback_def( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_callback_defd s
c C sj | d j oY t t | | i t | _ d } x2 | D]& } | i | } | | _ | d 7} q8 Wn d S( Ni i ( R R\ R2 R] R RS ( R t arg_namesRT Rg Rj ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt set_positional_argso s
c G sj | d j oY t t | | i t | _ d } x2 | D]& } | i | } | | _ | d 7} q8 Wn d S( Ni i ( R R\ R2 R] R R^ ( R t obj_typesRT R^ Rj ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt set_arg_obj_typesx s
c C s% g } | i D] } | | i q ~ S( N( R] RS ( R t _[1]Rj ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_positional_arg_names s (
R R R R R R R R R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR C s
t InterfaceRegistryc B sP e Z d Z d Z d Z d Z d Z d Z d Z d Z RS( c C s
h | _ d S( N( t
interfaces( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c C s t d | d t } h | d 6S( Nt error_returnt
_error_return( R t error_positional_args( R RP t error_return_def( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt
new_interface s c C sC | i i | } | d j o | i | } | | i | <n | S( N( R t getR R ( R t interface_nameRP ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
c C st d d k } | i } | i | d } | d d j o | d =n | i | | } | i | | i | | S( Nii R ( t inspectR t
getargspecR[ R R ( R RN RP t
method_ptrR RQ R] Rd ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt set_rpc_def s
c C s{ | i | } t | t j o
| i } n | i | } | d j o, t d | | d } | i | | | n | S( N( R RN t
MethodTypeR R R R R ( R RP RQ R Rd ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR[ s
c C s= | i | } t | t j o
| i } n | | | <d S( N( R RN R R ( R RP RQ Rd R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
c C s | i | } | d S( NR ( R ( R RP R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_error_rpc_def s c C s | i i } | i xd | D]\ } | i | } d | GH| i } | i x' | D] } | | } d t | GHqY Wq Wd S( Ns
Interface: %ss %s( R t keyst sortRw ( R t interface_namesR RP t method_namest method_nameRQ ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt dump_interfaces s
(
R R R R R R R[ R R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
c s f d } | S( Nc sn t i d | } | i t o* t o# t i d | i | i n f d } t | _ | S( NRQ s7 @rpc_method() interface=%s method=%s positional_args=%sc sT | i } t i } t | | } | | i | <| i | d | | | S( NRQ ( t
new_rpc_idR R[ t AsyncRpct async_rpc_cachet emit_rpc( R Rb RM Rd t async_rpc( RP RQ ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt rpc_func s
(
R R R R t verboset log_rpcRP R t Truet _rpc_definition( R Rd R ( RP ( RQ s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt decorator s ( ( RP R ( ( RP s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c s f d } | S( Nc sZ | i } t i | } | i t o' t o t i d | i | i n | S( Ns4 @rpc_arg_types() interface=%s method=%s arg_types=%s( R R R[ R R R R RP RQ ( R RQ Rd ( RP t arg_types( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
( ( RP R R ( ( RP R s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c s f d } | S( Nc sx t i d | } t o- t o& t i d | i | i | i n t i } | i | i t
| _ | S( NR s9 @rpc_callback() interface=%s method=%s positional_args=%s( R R R R R RP RQ R R[ R R R ( R t rpc_callback_defRd ( RP RQ ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s ( ( RP RQ R ( ( RP RQ s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c s f d } | S( Nc sn t i d | } | i t o* t o# t i d | i | i n f d } t | _ | S( Nt signals) interface=%s method=%s positional_args=%sc s8 | i } t i } | i | d | | d S( NR ( R R R[ R ( R Rb RM Rd ( RP RQ ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s (
R R R R R R RP R R R ( R Rd R ( RP ( RQ s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s ( ( RP R ( ( RP s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c B sn e Z d d e d d Z d Z d Z d Z d Z d Z e
d Z d Z d Z
RS(
c C ss t i | | _ | | _ | | _ | | _ t i | _ d | _
| | _ | d j o | i | i | n d S( N(
R R R+ R* t portR# R t SOCK_STREAMRN R t sockett
friendly_namet parse( R R+ R* R# R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
c C s t i d d t | i } | i d j o d S| i t i j o d | i | f S| i t i j o d | i | i
| f Sd Sd S( Ns ^.+ at (0x[0-9A-Fa-f]+)>$s \1R s {unix}%s socket=%ss {inet}%s:%s socket=%st unknown( R t subt reprR R+ R R t AF_UNIXR* R R ( R t socket_repr( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR
s c C sj | i d j o d S| i t i j o d | i S| i t i j o d | i | i f St d Sd S( NR s %ss %s:%st Unknown( R+ R R R R* R R t _( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt _get_default_friendly_name s c C s" | i d j o | i S| i S( N( R R R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_friendly_name" s c C s d d k } | i | S( Ni( t copy( R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR ' s c C sG | i t i j o | i S| i t i j o | i | i f Sd Sd S( N( R+ R R R* R R R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_py_address+ s
c C sK t | t j o4 | i } h t i d 6t i d 6i | } | S| S( Nt unixt inet( RN Rw R R R R R ( R+ ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR 3 s
#c C sT | | _ | t i j o | | _ d | _ n" | t i j o | i | n d S( N( R+ R R R* R R R t parse_inet_addr( R R+ t addr( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR ; s
c C s t i d | } | oh | i d } | i d } | d j o
| i } n | d j o
t } n | | _ | | _ n d | _ d | _ d S( Ns ^\s*([^:\s]+)\s*(:\s*([^\s]+))?i i t hostname( R R R R R# t get_hostnameR* R ( R R R( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR C s
N( R R R R
R R R R R R t staticmethodR R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s
t ConnectionIOc B sV e Z e i e i Be i Be i BZ d d e d Z
d Z d Z d Z
RS( c C s4 t | _ | | _ | | _ | | _ d | _ d S( N( R
t connection_stateR, t channel_typet channel_nameR t io_watch_id( R R R R, ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR Y s
c C s/ | i t i | i i | i | | _ d S( s- callback signature: (io_object, io_condition)N( t io_watch_removeR; t io_add_watchR, R t io_input_conditionsR ( R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt io_watch_adda s
c C s1 | i d j o t i | i d | _ n d S( N( R R R; t
source_remove( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR g s c C s | t i t i Bt i B@o | t i @o/ t } t | } | i t i d | | n | t i @o/ t } t | } | i t i
d | | n | t i @o/ t } t | } | i t i
d | | n t St
Sd S( Ni ( R; R@ R? RA t ERR_SOCKET_HUPt get_strerrort close_connectionR
R8 t ERR_SOCKET_ERRORR t ERR_IO_INVALIDR R ( R RC t errnot strerror( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt valid_io_conditionl s N( R R R; R< R@ R? RA R R R R R R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR V s
c B s8 e Z e Z d Z d Z d Z d Z d Z RS( i c C s, t i | d d d d d | | | _ d S( NR t listeningR t server_listeningR, ( R R t client_connection_handler_class( R R, R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c C sS | | _ | i i t i j o4 t i i | i i o t i | i i qS n t o t
i d | i n t i | i i | i i | i _ t
i
| i i i t
i t
i | i o# | i i i t i t i d n | i i i | i i | i i t i j o t i | i i d n | i i i | i | i i S( Ns new_listening_socket: %si i ( R, R+ R R t ost patht existsR* t removeR R R RN t fcntlt filenot F_SETFDt
FD_CLOEXECt allow_reuse_addresst
setsockoptt
SOL_SOCKETt SO_REUSEADDRt bindR t chmodt listent request_queue_size( R R, ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt new_listening_socket s $%
# c C sn y, | i | i | i _ | i | i Wn; t j
o/ } | i i t i t i
d t | t SXt
S( Ni( R" R, R R t handle_client_connectt ExceptionR R R
R R Rw R R ( R t e( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt open s %c
C s t o n y| i | p t S| t i @o ym | i \ } } t i | i t i t i | i
| i } | i | | | i
i d t i Wq$t i j
op } t | \ } } t i d | i | | t i j o
t i } n
t i } | i
i | d | | q$Xn WnV t j
oJ } t i d | i i t | | i
i t i d d t | n Xt S( Ni s5 closing client connection due to socket error(%s): %ss exception %s: %si( R R R R; R< t acceptR R R R R R, R& R R R
R R t errort get_error_from_socket_exceptionR t Errnot EPIPER8 R R$ t exceptionR R Rw R (
R R RC t
client_sockett client_addresst client_handlerR% R R
R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR# s.
& '( R R R R R! R R" R& R# ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s t RequestReceiverc B s5 e Z d Z d Z d Z d Z d Z RS( c C s | | _ | i d S( N( t dispatchFunct reset( R R1 ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c C s1 d | _ d | _ d | _ d | _ d | _ d S( Nii R ( t headerLent bodyLenR t headerRG t feed_buf( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR2 s
c C s t | i d j o d Sx t o | i d j o> t i | i } | o | i | _ | i q qs Pn t | i | i | i j ov | i } | i | i } | i | | !| _ | i | | _ d | _ d | _ t
o n | i | i | i q n Pq Wd S( Ni i(
R2 R6 R R3 t
header_end_reR t endt parse_headerR4 RG R R1 R5 ( R R( t bodyBegint bodyEnd( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt process s.
c C s | i | 7_ | i d S( N( R6 R< ( R t data( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt feed s c C s h | _ d } xk t i | i | | i d } | oA | i d } | i d i } | | i | <| i } q Pq t | i d | _ d S( Ni i i s content-length(
R5 t header_field_reR R6 R3 R t stripR8 R. R4 ( R t beginR( RJ RK ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR9 s
( R R R R2 R< R> R9 ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR0 s
! c B sG e Z d Z d Z d Z d Z d Z d Z d Z RS( c C s h | _ h | _ d | _ d S( Ni ( R t rpc_handlersRM ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c C s | i d 7_ t | i S( Ni ( RM Rw ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c C sg t i d t | i | i | i i } | i x( | D] } t i d | | i | q? Wd S( Ns* async_rpc_cache: %d entries, cur rpc_id=%ss %s: %s( R R R2 R RM R R ( R t rpc_idsRM ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt dump_async_rpc_cache s
c C s | i i d S( N( R R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt flush_async_rpc_cache s c C s t i d | | | d S( Ns
[%s] %d %s( R R( ( R RQ R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt default_errback" s c C s | d j o t i d t d S| i d j o% x | i D] } | | i q< Wn` | i d j oO t | i d j o% x2 | i D] } | | i q Wq | i | i n d S( Ns8 process_async_return(): rpc_id=%s not in async_rpc_cacheR R i (
R R R( RM t return_typet callbackst return_argsR2 t errbacksRF ( R R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt process_async_return% s
c C s | | i | <d S( N( RB ( R RP t handler( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt connect_rpc_interface3 s ( R R R R RD RE RF RK RM ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c B s e Z e d d e Z e d d e Z d d d Z d Z d Z d Z
d Z d Z d d d d
d Z
d Z d
Z d Z d Z d Z d Z RS( R t buf_sizet timeoutc C sQ t i | d | d | d d t i | t i | _ t | i | _ d S( NR R R, (
R R R R t threadingt Lockt
write_lockR0 t default_request_handlert receiver( R R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR < s
c C s d | i | i | i f S( Ns channel: name=%s addr=%s type=%s( R R, R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR B s c C s | i i d S( N( RR t acquire( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt acquire_write_lockE s c C s | i i d S( N( RR t release( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt release_write_lockH s c C s
| | _ d S( N( R ( R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt set_channel_typeK s c C s | i S( N( R ( R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_channel_typeN s i R c C s t o! t i d | i | i n | i | i i d j o d S| i i d j oa y6 | i i i t i | i i i
d | i _ Wq t i j
o } d | i _ q Xn | i i
| | t i B| | | i d S( Ns close_connection: %s( R R R, RD RE R R t shutdownR t SHUT_RDWRt closeR( R R R
R R ( R R R R R R% ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR Q s
c C s= | i i | d } | d j o d St | | d } | S( N( RB R R t getattr( R RP RQ t handler_objR ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt get_method_implementationd s
c G so t | i t | j o t i d t | | d St | | | } t | | | } | i | d S( Ns3 emit_rpc() arg length=%s does not match rpc_def(%s)( R2 R] R R( R RO t send_data( R RM RN Rd Rb t rpc_xmlt rpc_data( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR k s c C s | i i t i @p d St o n | i y~ d } xq | t | j o] | i i i | | } | d j o) | i
t i t t
d | i n | | } q: WWn t i j
o: } t i d | i | i | i i t i d St i j
ox } t | \ } } t i d | i | | i | t i j o
t i } n
t i } | i
| d | | d SX| i i d t i | i d S( Ni t details socket timeout: (%s)s& could not send data on socket (%s): %s( R R R
R R RV R2 R, R t sendR R8 t ProgramErrorR R RO R R( RX R R R) R* R+ R R ( R R= t totalSentt sentR% R R
R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyRa s s<
c C su t o n y| i | p t S| t i @o y> | i | i } t | d j o | i t i
t SWn} t i j
on } t
| \ } } t i d | i | | t i j o
t i
} n
t i } | i | d | | t SX| i i d t i | i i | n WnT t j
oH } t i d | i i t | | i t i d d t | t SXt S( Ni s socket error (%s): %ss exception %s: %si( R R R R; R< t recvt socket_buf_sizeR2 R R
R8 R R( R) R R, R* R+ R R R R RT R> R$ R, R R Rw R ( R R RC R= R% R R
R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt handle_client_io s4
c C s | i i | d } | d j o t i d | d St o< t o5 t i d | i i | | | i i
| i i | n t | \ } } } | | _
| | _ | i | d S( Ns1 handle_return(): rpc_id=%s not in async_rpc_caches/ %s.handle_return: rpc_id=%s type=%s %s.%s, {%s}( R t popR R R( R R R R Rd RP RQ Rl RG RI RK ( R RN RM RG R RP RQ Rb ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt
handle_return s
, c C s | i d d } | i d d } t o* t o# t i d | i i | | | n | d j p
| d j o | i | | | n
| d j o$t | \ } } } | i | | } | o y[ | | } | d j o
g } n t
i | | }
|
i } | i
| d | | Wqt j
o: } t
i | }
| i
| d |
| | i | i qXqt i } d | | i i f } t
i | }
| i
| d |
| | | n | d j o t | \ } } } | i | | } | o9 y | | Wqut j
o } t
i | }
quXqt i } d | | i i f } t
i | }
| i
| d |
| | | n t d
| | | f d S( NRM i RN s2 %s.default_request_handler: rpc_id=%s type=%s {%s}R R RQ s, method '%s' is not implemented in class '%s'R s unknown type(%s) for %s:%s( R R R R R R R Rm Rl R` R R[ R R Rf R R R
R* t ENOSYSR ( R R5 RG RM RN RP RQ Rb R RI t rpc_method_defR R% t
rpc_error_defR R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyRS sL
+
N( R R R R. Rj t socket_timeoutR R R RV RX RY RZ R R` R Ra Rk Rm RS ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR 8 s ! " R c B s# e Z d Z d Z d Z RS( c C s: | | _ | | _ d | _ d | _ g | _ g | _ d S( N( Rd RM R RI RG RH RJ ( R Rd RM ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s c C s | i i | d S( N( RH R! ( R R ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt add_callback s c C s | i i | d S( N( RJ R! ( R t errback( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt add_errback s ( R R R Rr Rt ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyR s ( (; RW R R R* R; R R R R RP t typest setroubleshoot.configR t setroubleshoot.errcodet setroubleshoot.logt setroubleshoot.xml_serializeR R t setroubleshoot.utilt __all__R R R t content_length_reR7 R? R R R R
R R RE RL RO Rl R R R
t
type_registert objectR Rw R. R R R R R R R R R R R R0 R R R ( ( ( s6 /usr/lib/python2.6/site-packages/setroubleshoot/rpc.pyt <module> sv
( (Q
*C;
V-JA*