|
Server : Apache/2.2.17 (Unix) mod_ssl/2.2.17 OpenSSL/0.9.8e-fips-rhel5 DAV/2 PHP/5.2.17 System : Linux localhost 2.6.18-419.el5 #1 SMP Fri Feb 24 22:47:42 UTC 2017 x86_64 User : nobody ( 99) PHP Version : 5.2.17 Disable Function : NONE Directory : /proc/21573/root/usr/lib/python2.4/site-packages/setroubleshoot/ |
Upload File : |
m
3Uc @ s d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k
Z
d k Td k l
Z
d k Td k Td k l Z l Z 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/ Z0 d* Z1 d+ Z2 d, Z3 d- Z4 d e) f d. YZ5 d/ e) f d0 YZ6 d e6 f d1 YZ7 d2 f d3 YZ8 d e) f d4 YZ9 d e6 e9 f d5 YZ: d6 e) f d7 YZ; d S(8 N( t *( s
get_config( s xml_child_elementss 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 s4 g }
t i d } t o t i d | n | p |
Sn t i d | } x | D] } | p qX n | i
| } | o^ | i d i
} | i d } t i | } | d j o t i d | | qX q n t i } | } t | | | } |
i | qX 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 socket_addressest ret compilet family_ret debugt log_communicationt addr_stringt splitt addrst cfg_addrt searcht matcht groupt lowert
family_tagt addressR t
map_familyt familyt Nonet warningt Sockett AF_INETt default_portt socket_addresst append( R R' R R R( R" R R R R R ( ( t6 /usr/lib/python2.4/site-packages/setroubleshoot/rpc.pyR C s4
c C s t d d t } | S( Nt
connectionR' ( t
get_configt intR' ( R' ( ( R* R ` s c C s# t | d } } t | } | S( Nt address_list( R, t cfg_sectionR R R ( R/ R R ( ( R* R d s c C s/ t d } t | d j o d Sn | d S( Nt client_connect_toi ( R t addr_listt lenR# ( R1 ( ( R* R i 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 namest io_conditiont gobjectt IO_INR) t IO_OUTt IO_PRIt IO_ERRt IO_HUPt IO_NVALt join( R; R: ( ( R* t io_condition_to_stringn 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 bodyt hdrt kwdst itemst keyt value( RE RG RJ RI RF ( ( R* t
rpc_header s
c C s t | d | d | } | | S( Nt rpc_idt type( RK RE RL RM RF ( RL RM RE RF ( ( R* t 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 nameRM t positiont xmlt obj_name( R# RO RP t argst doct libxml2t parseDoct cmdt getRootElementt propR t get_rpc_deft rpc_deft xml_get_child_elements_by_namet arg_nodest preextend_listR2 t arg_nodet arg_namet arg_typeR- t arg_positiont positional_argst rpc_argt obj_typet arg_valuet contentt freeDoc(
RZ RV R` Rb RW R^ Ri Re RO Rd Rg RP Rc ( ( R* t convert_rpc_xml_to_args s2
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.0RZ RO RP i RQ RR RS RM RT t
get_xml_nodest stringi t arg_countt encodingt format( R# t text_docRW R^ RO RP RX t newDoct newNodet roott setPropt setRootElementRS Rf Rg RR Rc RV Ri Rb t addChildt strt
isinstancet xmlNodet hasattrRm t
addContentt serializeR Rk (
RL R^ RV Ri RW Rr Rb RO RS Rg Ru RP Rc ( ( R* t convert_rpc_to_xml sB
c B sl t Z d d >Z d d >Z d d >Z d d >Z d d >Z d d >Z d d >Z e e Be Be Be Be Be BZ e e BZ
e e Be Be BZ h e d <e d <e d
<e d <e d <e d
<e d <Z e e e e e e e g Z
h d e i e i e i e i e i f f <Z d Z d Z d Z d Z d Z d Z d Z d d d d d Z RS( Ni i i i i i i t
CONNECTINGt OPENt
AUTHENTICATEDR7 t ERRORt TIMEOUTt RETRYt changedc C s9 t i i | d | _ d | _ d | _ | i d S( Ni ( R< t GObjectt __init__t selft flagsR# t result_codet
result_msgt clear_result( R ( ( R* R s
c C s# d | i | i | i | i f S( Ns' flags=%s, result_code=%d, result_msg=%s( R t flags_to_stringR R R ( R ( ( R* t __str__ s c C s | i d | i d S( Ni ( R t updatet ALL_FLAGS( R ( ( R* t 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 R9 ( t valR# R: R
t connection_statest stateR) t map_connection_enum_to_stringRC ( R R R R: ( ( R* R s
c C s d | _ d | _ d S( Ni t ( R R R ( R ( ( R* R s c C s | | _ | | _ d S( N( R R R ( R R R ( ( R* t
set_result s c C s | i | i f S( N( R R R ( R ( ( R* t
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 R t __class__t __name__R t add_flagst remove_flagsR t previous_flagsR R t
differencet flags_addedt
flags_removedt emit( R R R R R R R R R ( ( R* R s #
( R t
__module__R R R R7 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 ( ( ( R* R
s*
E
0 t RpcArgc B s t Z d d d Z d Z RS( Nc C s | | _ | | _ d S( N( RR R Rh ( R RR Rh ( ( R* R 2 s c C sP | i d j o
d } n
| i } | i d j o | Sn d | | i f Sd S( Nt name_undefineds %s:%s( R RR R# Rh ( R RR ( ( R* R 6 s
( R R R# R R ( ( ( R* R 1 s RP t err_codet err_msgt
RpcDefinitionc B sP t Z d Z d Z d Z d Z d Z d Z d Z d Z RS( Nc C sK | | _ | | _ | | _ d | _ | d j o
g | _ n
| | _ d S( N( RM R RO RP R# t callbackt rpc_argsRf ( R RM RO RP R ( ( R* R E 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)R9 RP s callback=%s( RV R Rf R# Rg Rh R) RR RM RO RP RC t textR ( R R RV Rg ( ( R* R O s
!(c C s
| | _ d S( N( RM R ( R RM ( ( R* t set_type\ s c C s= | i d j o t i | i } | | i =n | | _ d S( N( R R R# R t
get_interfaceRO t interface_dict( R R R ( ( R* t set_callback_ s c C s | i d j o t d | i n | i d j oL d | i } t d | i | d } t
i | i | | | | _ | Sn t
i | i | i S( NRP s" %s rpc types do not have callbackss %s_default_callbackt
method_return(
R RM t
ValueErrorR R# RP t
callback_nameR RO t callback_defR t register_rpc_defR] ( R R R ( ( R* t get_callback_defe s
c C sj | d j oY t t | | i t | _ d } x2 | D]& } | i | } | | _
| d 7} q8 Wn d S( Ni i ( t arg_namesR# Ra R2 R Rf R RS Rc Rg RR ( R R Rg RS Rc ( ( R* t set_positional_argsp s
c G sj | d j oY t t | | i t | _ d } x2 | D]& } | i | } | | _ | d 7} q8 Wn d S( Ni i (
t obj_typesR# Ra R2 R Rf R RS Rh Rg ( R R Rg Rh RS ( ( R* t set_arg_obj_typesy s
c C s% g } | i D] } | | i q ~ S( N( t _[1]R Rf Rg RR ( R R Rg ( ( R* t get_positional_arg_names s (
R R R R R R R R R R ( ( ( R* R D s
t InterfaceRegistryc B sP t Z d Z d Z d Z d Z d Z d Z d Z d Z RS( Nc C s
h | _ d S( N( R t
interfaces( R ( ( R* R s c C s" t d | d t } h d | <S( Nt error_returnt
_error_return( R RO t error_positional_argst error_return_def( R RO R ( ( R* t
new_interface s c C sC | i i | } | d j o | i | } | | i | <n | S( N( R R t gett interface_nameRO R# R ( R R RO ( ( R* R s
c C sh | i } t i | d } | d d j o | d =n | i | | } | i
| | i | | S( Ni R (
t
method_ptrR RP t inspectt
getargspecRf R R] RO R^ R RM R ( R RM RO R R^ Rf RP ( ( R* t 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 R RO R RM RP t
MethodTypeR R R^ R# R R ( R RO RP R^ R ( ( R* R] s
c C s= | i | } t | t j o
| i } n | | | <d S( N( R R RO R RM RP R R R^ ( R RO RP R^ R ( ( R* R s
c C s | i | } | d S( NR ( R R RO R ( R RO R ( ( R* t 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 R t keyst interface_namest sortR RO t method_namest method_nameRP Ry ( R R R R RO R RP ( ( R* t dump_interfaces s
(
R R R R R R R] R R R ( ( ( R* R s
c s d } | S( Nc sk t i d | } | i t o* t o# t i d | i | i
n d } t | _
| S( NRP s7 @rpc_method() interface=%s method=%s positional_args=%sc sT | i } t i } t | | } | | i
| <| i | d | | | S( NRP (
R t
new_rpc_idRL R R] RO RP R^ t AsyncRpct async_rpct async_rpc_cachet emit_rpcRV ( R RV RL R^ R ( RO RP ( R* t rpc_func s
( R R RO R R^ R RP R t verboset log_rpcR R t Truet _rpc_definition( R R^ R RP ( RO ( RP R* t decorator s ( R ( RO R ( ( RO R* R s c s 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 RP R R] RO R^ R t arg_typesR R R ( R R^ RP ( RO R ( R* R s
( R ( RO R R ( ( RO R R* R s c s 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 RO R t rpc_callback_defR R R RP R R] R^ R R R ( R R R^ ( RO RP ( R* R s ( R ( RO RP R ( ( RO RP R* R s c s d } | S( Nc sk t i d | } | i t o* t o# t i d | i | i
n d } t | _
| S( Nt signals) interface=%s method=%s positional_args=%sc s8 | i } t i } | i | d | | d S( NR (
R R RL R R] RO RP R^ R RV ( R RV RL R^ ( RO RP ( R* R s ( R R RO R R^ R RP R R R R R R R ( R R^ R RP ( RO ( RP R* R s ( R ( RO R ( ( RO R* R s c B sn t 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(
Nc C ss t i | | _ | | _ | | _ | | _ t i | _ d | _ | | _ | d j o | i
| i | n d S( N( R R! R" R R R' t portR% t SOCK_STREAMRM R# t sockett
friendly_namet parse( R R" R R' R ( ( R* R s
c C s t i d d t | i } | i d j o d Sn[ | i t i j o d | i
| f Sn3 | i t i j o d | i
| i | f Sn d 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 t socket_reprR" R# R% t AF_UNIXR R& R ( R R ( ( R* R
s c C ss | i d j o d SnX | i t i j o d | i Sn6 | i t i j o d | i | i f Sn t d Sd S( NR# s %ss %s:%st Unknown( R R" R# R% R R R& R t _( R ( ( R* t _get_default_friendly_name s c C s% | i d j o | i Sn | i S( N( R R R# R ( R ( ( R* t get_friendly_name" s c C s
t i | S( N( t copyR ( R ( ( R* R ' s c C sM | i t i j o | i Sn, | i t i j o | i | i f Sn d Sd S( N( R R" R% R R R& R R# ( R ( ( R* t get_py_address* s
c C sR t | t j o; | i } h d t i <d t i <i | } | Sn | S( Nt unixt inet( RM R" Ry R R% R R& R ( R" ( ( R* R! 2 s
'c C sT | | _ | t i j o | | _ d | _ n" | t i j o | i | n d S( N(
R" R R% R t addrR R# R R& t parse_inet_addr( R R" R ( ( R* R : 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 R R# R R' t get_hostnameR ( R R R R ( ( R* R B s
( R R R# R R R R R R R t staticmethodR! R R ( ( ( R* R s
t ConnectionIOc B sV t Z e i e i Be i Be i BZ d d e d Z
d Z d Z d Z
RS( Nc C s4 t | _ | | _ | | _ | | _ d | _ d S( N( R
R t connection_stateR( t channel_typet channel_nameR# t io_watch_id( R R R R( ( ( R* R X s
c C s/ | i t i | i i | i | | _ d S( s- callback signature: (io_object, io_condition)N( R t io_watch_removeR< t io_add_watchR( R t io_input_conditionsR R ( R R ( ( R* t io_watch_add` s
c C s1 | i d j o t i | i d | _ n d S( N( R R R# R< t
source_remove( R ( ( R* R f 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 Sn t Sd S( Ni ( R; R< RA R@ RB t ERR_SOCKET_HUPt errnot get_strerrort strerrorR t close_connectionR
R7 t ERR_SOCKET_ERRORR t ERR_IO_INVALIDR R ( R R; R R
( ( R* t valid_io_conditionk s ( R R R< R= RA R@ RB R R# R R R R R ( ( ( R* R U s
c B s8 t Z e Z d Z d Z d Z d Z d Z RS( Ni c C s, t i | d d d d d | | | _ d S( NR t listeningR t server_listeningR( ( R R R R( t client_connection_handler_class( R R( R ( ( R* R s c C s. | | _ | 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 _ | 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% R t ost patht existsR t removeR R R RM t allow_reuse_addresst
setsockoptt
SOL_SOCKETt SO_REUSEADDRt bindR t chmodt listent request_queue_size( R R( ( ( R* t new_listening_socket s $
# c C sq y, | i | i | i _ | i | i Wn> t j
o2 } | i i t
i t
i d t
| t Sn Xt S( Ni( R R R( R R t handle_client_connectt Exceptiont eR R R
R R Ry R R ( R R! ( ( R* t open s % c
C sf t o n y | i | p t Sn | t i @o yN | i \ } } | i | i } | i | | | i i d t i Wqt i j
op } t | \ } } t i d | i | | t i j o
t i } n
t i } | i i | d | | qXn 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 R< R= R t acceptt
client_sockett client_addressR R( t client_handlerR" R R R
R R% t errorR! t get_error_from_socket_exceptionR R
R t Errnot EPIPER7 R R R t exceptionR R Ry R (
R R R; R R
R$ R R& R! R% ( ( R* R s,
& '( R R R R R R R R" R ( ( ( R* R
s t RequestReceiverc B s5 t Z d Z d Z d Z d Z d Z RS( Nc C s | | _ | i d S( N( t dispatchFuncR t reset( R R- ( ( R* R s c C s1 d | _ d | _ d | _ d | _ d | _ d S( Nii R ( R t headerLent bodyLenR# t headerRE t feed_buf( R ( ( R* R. s
c C s t | i d j o d Sn x t o | i d j o> t i | i } | o | i | _ | i q! qv 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 R R2 R R/ t
header_end_reR R t endt parse_headerR0 t bodyBegint bodyEndRE R R- R1 ( R R6 R7 R ( ( R* t process s.
c C s | i | 7_ | i d S( N( R R2 t dataR8 ( R R9 ( ( R* t feed s c C s h | _ d } xm t i | i | | i d } | oA | i d } | i d i
} | | i | <| i } q Pq Wt
| i d | _ d S( Ni i i s content-length( R R1 t begint header_field_reR R2 R/ R R RI t stripRJ R4 R- R0 ( R R; RJ RI R ( ( R* R5 s
( R R R R. R8 R: R5 ( ( ( R* R, s
! c B sG t Z d Z d Z d Z d Z d Z d Z d Z RS( Nc C s h | _ h | _ d | _ d S( Ni ( R R t rpc_handlersRL ( R ( ( R* R
s c C s | i d 7_ t | i S( Ni ( R RL Ry ( R ( ( R* R 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 R RL R t rpc_idsR ( R R? RL ( ( R* t dump_async_rpc_cache s
c C s | i i d S( N( R R R ( R ( ( R* t flush_async_rpc_cache s c C s t i d | | | d S( Ns
[%s] %d %s( R R' RP R R ( R RP R R ( ( R* t default_errback s c C s | d j o t i d t d Sn | 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 R' RL t return_typet callbacksR t return_argsR2 t errbacksR RB ( R R R ( ( R* t process_async_return# s
c C s | | i | <d S( N( t handlerR R> RO ( R RO RH ( ( R* t connect_rpc_interface1 s ( R R R R R@ RA RB RG RI ( ( ( R* R s c B s t 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( NR 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 R R# R t threadingt Lockt
write_lockR, t default_request_handlert receiver( R R R ( ( R* R : s
c C s d | i | i | i f S( Ns channel: name=%s addr=%s type=%s( R R R( R ( R ( ( R* R @ s c C s | i i d S( N( R RN t acquire( R ( ( R* t acquire_write_lockC s c C s | i i d S( N( R RN t release( R ( ( R* t release_write_lockF s c C s
| | _ d S( N( R R ( R R ( ( R* t set_channel_typeI s c C s | i S( N( R R ( R ( ( R* t get_channel_typeL s i R c C s t o! t i d | i | i n | i | i i d j o d Sn | 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 R( R@ RA R R# t shutdownR% t SHUT_RDWRt closeR' R! R R R R R
R R R R ( R R R R R R! ( ( R* R O s
c C s@ | i i | d } | d j o d Sn t | | d } | S( N( R R> R RO R# t handler_objt getattrRP R ( R RO RP RZ R ( ( R* t get_method_implementationb s
c G sr t | i t | j o! t i d t | | d Sn t | | | } t | | | } | i
| d S( Ns3 emit_rpc() arg length=%s does not match rpc_def(%s)( R2 R^ Rf RV R R' R RL t rpc_xmlRN RM t rpc_dataR t send_data( R RL RM R^ RV R] R^ ( ( R* R i s c C s | i i t i @p d Sn t 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 Sn t i j
o{ } t | \ } } t i d | i
| | i | t i j o
t i } n
t i } | i | d | | d Sn X| 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 R RR t totalSentR2 R9 R( R t sendt sentR R7 t ProgramErrorR R% RK R! R R' RT R R R( R R
R) R* R R R ( R R9 Ra R! R
R R Rc ( ( R* R_ q s<
c C s t o n y| i | p t Sn | t i @o yA | i | i } t | d j o | i t
i t Sn Wn t i j
oq } t | \ } } t i d | i | | t i j o
t
i } n
t
i } | i | d | | t Sn X| i i d t
i | i i | n WnW t j
oK } t i! d | i" i# t$ | | i t
i d d t$ | t Sn Xt% S( Ni s socket error (%s): %ss exception %s: %si(& R R R R; R R< R= R t recvt socket_buf_sizeR9 R2 R R
R7 R% R' R! R( R R
R R( R) R* R R R R R RP R: R R+ R R Ry R ( R R R; R R
R R9 R! ( ( R* t handle_client_io s4
c C s | i i | d } | d j o t i d | d Sn t 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 R t popRL R# R R R' R R R R RM R^ RO RP RE Rl RV RC RE RG ( R RM RL RE RV R RO RP ( ( R* t
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( NRL i RM s2 %s.default_request_handler: rpc_id=%s type=%s {%s}R R RP s, method '%s' is not implemented in class '%s'R s unknown type(%s) for %s:%s(% R1 R RL R# RM R R R R R R RE Ri Rl RO RP RV R\ R RE R R] t rpc_method_defR R R Rd R! R t
rpc_error_defR R
R) t ENOSYSR R R ( R R1 RE R RE R RM RP Rk Rj RV R RO R! RL R ( ( R* RO sL
+
( R R R, R- Rf t socket_timeoutR# R R RR RT RU RV R R\ R R_ Rg Ri RO ( ( ( R* R 6 s ! " R c B s# t Z d Z d Z d Z RS( Nc C s: | | _ | | _ d | _ d | _ g | _ g | _ d S( N( R^ R RL R# RE RC RD RF ( R R^ RL ( ( R* R s c C s | i i | d S( N( R RD R) R ( R R ( ( R* t add_callback s c C s | i i | d S( N( R RF R) t errback( R Ro ( ( R* t add_errback s ( R R R Rn Rp ( ( ( R* R s (< R RX R R R R) R< R R R% RL t typest setroubleshoot.configR, t setroubleshoot.errcodet setroubleshoot.logt setroubleshoot.xml_serializet xml_child_elementsR_ t setroubleshoot.utilt __all__R R R t content_length_reR3 R< R R# R R R R RD RK RN Rl R R R
t
type_registert objectR Ry R- R R R R R R R R R R R
R, R R R (, R R R_ RX R R R R R R, Rl Rx RK R R R R
R R3 R Rv R) R R
R R% RN R R< RD R, R R R R RL R Ry R R R R< R R ( ( R* t ? s^
0 ( (Q
*C:
U-IA*