�
�3�Zc@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
l	Z	dd
l
Z
ddlTddlm
Z

ddlTddlmZmZ
ddlTddddd	d
ddd
dddddgZe
jd�
Ze
jd�
Ze
jd�
Ze
dd�Zd
d�
Zd�Zd�Zd�Zd�Zd�Zd�Z d�Z!d �Z"dej#f
d!��YZ$ej%e$�

d"e&f
d#��YZ'e'd$e(�e'd%e)�e'd&e(�gZ*d'e&f
d(��YZ+d)e&f
d*��YZ,e,�Z-d+�Z.d,�Z/d-�Z0d.�Z1de&f
d/��YZ2d0e&f
d1��YZ3de3f
d2��YZ4d3d9d4��YZ5de&f
d5��YZ6de3e6fd6��YZ7d7e&f
d8��YZ8d
S(:i����N(
t
*(
t
get_config(txml_child_elementstxml_get_child_elements_by_namet
rpc_methodtrpc_arg_typetrpc_callbackt
rpc_signaltinterface_registrytparse_socket_address_listtget_default_porttget_socket_list_from_configtget_local_server_socket_addresstConnectionStatet	RpcManaget
RpcChanneltListeningServert
SocketAddressscontent-length:(\d+)s

s([a-zA-Z0-9_-]+):(.*)
tgeneralt
i18n_encodingcCs
g}tj
d
�
}td|�

|s-|Stjd|�}x�|D]�}|sXqFn|j|�
}|r�|jd�
j�}|jd�
}tj|�
}	|	dkr�td||f�

qFq�nt
j}	|}t|	||
�}
|j|
�

qFWtd||
f�

|S(Ns\s*{(unix|inet)}(.+)s%parse_socket_address_list: input='%s's[\s,]+i
is(unknown socket family - %s in address %ss$parse_socket_address_list: %s --> %s(
tretcompilet	log_debugtsplittsearchtgrouptlowerRt
map_familytNonetSockettAF_INETtappend(taddr_stringtdefault_porttsocket_addressest	family_retaddrstcfg_addrtmatcht
family_tagtaddresstfamilytsocket_address((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR	As.














		


c
Cstd
dt
�}|S(Nt
connectionR!(R
tint(
R!((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR
^s

c
Cst|d
�}
t
|
�
}|S(Ntaddress_list(R
R	(tcfg_sectionR R"((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyRbs


c
Cs*td
�
}t
|�
dkr"dS|dS(Ntclient_connect_toi(RtlenR(
t	addr_list((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyRgs


c
Cs�g}
|tj
@r#|
jd
�

n|tj@r@|
jd�

n|tj@r]|
jd�

n|tj@rz|
jd�

n|tj@r�|
jd�

n|tj@r�|
jd�

nd|dj|
�
fS(	NtINtOUTtPRItERRtHUPtNVALs(%d)[%s]t
,(	tgobjecttIO_INRtIO_OUTtIO_PRItIO_ERRtIO_HUPtIO_NVALtjoin(tio_conditiontnames((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytio_condition_to_stringls

















c
KsOd
t|�
}x.|
j
�D] \}}|d||f7}qW|d7}|S(Nscontent-length: %d
s%s: %s
s
(R0titems(tbodytkwdsthdrtkeytvalue((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt
rpc_headers






cCs t|d
|d|
�
}||S(Ntrpc_idttype(
RJ(RKRLRERG((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytrpc_message�s

c

CsX
d}
}}}z
t
j|�
}|j�}|jd
�
}
|jd�
}tj|
|�}t|d�}tt	|�
�
}x�|D]�}|jd�
}|jd�
}	t
|jd�
�
}
|j|
}|jdk	r
|	dkr

|j|d|�

}q
|j|j
�
}n	|j
}|||
<q�WWd|dk	rJ
|j�
nX|
||fS(	Nt	interfacetmethodtargtnameRLtpositiontxmltobj_name(Rtlibxml2tparseDoctgetRootElementtpropRtget_rpc_defRtpreextend_listR0R,tpositional_argstobj_typetcontenttfreeDoc(
tcmdRNROtargstdoctrpc_deft	arg_nodestarg_nodetarg_nametarg_typetarg_positiontrpc_argt	arg_value((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytconvert_rpc_xml_to_args�s.




	










	

c
Gs�
d}}z�
|
j
}|
j}tjd
�
}tjd�
}|jd|�
|jd|�
|j|�

d}x
|
jD]�}	|	j	}
||}tjd�
}|j
|�

|jd|
�
|jdt|�
�
t|tj
�r
|jd	d
�
|j
|�

n^t|d�rB
|jd	d
�
|j
|j||
��

n#|jd	d�
|jt|�
�

|d
7}qzW|jdt|�
�
|jdtdd
�}Wd|dk	r�
|j�
nX|S(Ns1.0R_RNROiRPRQRRRLRSt
get_xml_nodeststringi
t	arg_counttencodingtformat(RRNRORUtnewDoctnewNodetsetProptsetRootElementR[RQtaddChildtstrt
isinstancetxmlNodethasattrRkt
addContentt	serializeRR^(
RKRbR`ttext_docRaRNROtrootRRRhReRiRd((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytconvert_rpc_to_xml�s>



	
	






	

















cBs@
eZ
dZdZdZdZdZdZdZeeBeBeBeBeBeBZ	eeBZ
eeBeBeBZide6de6d	e6d
e6de6de6d
e6ZeeeeeeegZ
i
ejejejejejffd6Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zddddd�ZRS( i
iiiiiit
CONNECTINGtOPENt
AUTHENTICATEDR6tERRORtTIMEOUTtRETRYtchangedc

Cs9tj
j|�

d
|_d|_d|_|j�
dS(Ni(R9tGObjectt__init__tflagsRtresult_codet
result_msgtclear_result(
tself((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��s


	
	
	
c

Cs#d
|j|j
�
|j|jfS(Ns'flags=%s, result_code=%d, result_msg=%s(tflags_to_stringR�R�R�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt__str__�s

c

Cs|jd
|j
�
dS(Ni(tupdatet	ALL_FLAGS(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytclear
s
cCs]|
dkrd
}
ng}x2t
jD]'}|
|@r%|jt
j|�

q%q%Wdj|�
S(NiR8(RR
tconnection_statesRtmap_connection_enum_to_stringR@(R�tvalRBtstate((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
	




c

Csd
|_d|_
dS(Nit(R�R�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
	
cCs|
|_||_
dS(
N(R�R�(R�R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt
set_result
s
	
c

Cs|j|j
fS(
N(R�R�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt
get_result
s
iR�c	Cs�|j}|j|
O_|j|M_||_
||_||jA}|j|@}||@}|r�|jd
|j||�
ndS(NR�(R�R�R�temit(	R�t	add_flagstremove_flagsR�R�tprevious_flagst
differencetflags_addedt
flags_removed((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
	
	
	





iiiii i@i�(t__name__t
__module__R~RR�R6R�R�R�R�t
GOOD_FLAGSt
PROBLEM_FLAGSR�R�R9tSIGNAL_RUN_LASTt	TYPE_NONEtTYPE_INTt__gsignals__R�R�R�R�R�R�R�R�(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR
�s:

















+							tRpcArgcBs eZ
ddd�Zd
�ZRS(cCs|
|_||_
dS(
N(RQR\(R�RQR\((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�-
s
	
c
CsI|jdkrd
}
n	|j}
|jdkr4|
Sd|
|jfSdS(Ntname_undefineds%s:%s(RQRR\(R�RQ((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�1
s

		

N(R�R�RR�R�(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�,
s
ROterr_codeterr_msgt
RpcDefinitionc
BsPeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	RS(cCsI|
|_||_
||_d|_|dkr<g|_n	||_dS(
N(RLRNRORtcallbackR[(R�RLRNROtrpc_args((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�@
s
	
	
	
	

c
Cs�g}
|jdk	rkxS|jD]E}|jdk	rT|
jd
|j|jf�

q|
j|j�

qWnd|j|j|jdj|
�
f}|jdkr�|d|j	7}n|S(Ns%s:%ss[%s] %s:%s (%s)R8ROs callback=%s(
R[RR\RRQRLRNROR@R�(R�R`Rhttext((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�J
s




 
(


cCs
|
|_dS(
N(
RL(R�RL((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytset_typeW
s
cCs;|jdk	r.tj|j�
}||j=n|
|_dS(
N(R�RRt
get_interfaceRN(R�R�tinterface_dict((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytset_callbackZ
s




c
Cs�|jd
kr%t
d|j�
�
n|jdkr|d|j}
td|j|
d�}tj|j|
|�
|
|_|Stj	|j|j�S(NROs"%s rpc types do not have callbackss%s_default_callbackt
method_return(
RLt
ValueErrorR�RROR�RNRtregister_rpc_defRY(R�t
callback_nametcallback_def((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_callback_def`
s







	

cCsh|
dk	rdt
t|
�
|jt�|_d
}x1|
D]&}|j|}||_|d7}q7WndS(Nii
(RRZR0R[R�RQ(R�t	arg_namesRRReRh((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytset_positional_argsk
s







	
c
Gsh|
dk	rdt
t|
�
|jt�|_d
}x1|
D]&}|j|}||_|d7}q7WndS(Nii
(RRZR0R[R�R\(R�t	obj_typesRRR\Rh((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytset_arg_obj_typest
s







	
c
Csg|jD]}
|
j
^q
S(
N(R[RQ(R�Rh((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_positional_arg_names}
s
(
R�R�R�R�R�R�R�R�R�R�(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�?
s
	
	
							tInterfaceRegistryc
BsPeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	RS(c

Cs
i|_dS(
N(
t
interfaces(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s
cCs td
|
dt
�}i
|d6S(Nterror_returnt
_error_return(R�terror_positional_args(R�RNterror_return_def((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt
new_interface�
s

cCsA|jj
|
�
}|dkr=|j|
�
}||j|
<n|S(
N(R�tgetRR�(R�tinterface_nameRN((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s





cCsrd
dl}|j
}|j|�
d}|ddkrB|d=n|j||�}|j|
�

|j|�

|S(Ni����iR�(tinspectR�t
getargspecRYR�R�(R�RLRNt
method_ptrR�ROR[Rb((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytset_rpc_def�
s

	








cCsw|j|
�
}t
|�
tkr-|j}n|j|�
}|dkrstd|
|d�}|j|
||�
n|S(
N(R�RLt
MethodTypeR�R�RR�R�(R�RNROR�Rb((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyRY�
s







cCs;|j|
�
}t
|�
tkr-|j}n|||<dS(
N(R�RLR�R�(R�RNRORbR�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s



cCs|j|
�
}|d
S(NR�(
R�(R�RNR�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_error_rpc_def�
s

c
Cs�|jj
�}
|
j�
xd|
D]\}|j|}d
|GH|j
�}|j�
x'|D]}||}dt|�
GHqYWq WdS(Ns
Interface: %ss    %s(R�tkeystsortRu(R�tinterface_namesR�RNtmethod_namestmethod_nameRO((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytdump_interfaces�
s







	







(
R�R�R�R�R�R�RYR�R�R�(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s
					
		c
s�f
d
�}
|
S(Nc
s=tj
d
�
|�}
|j��
�fd�}t|_|S(NROc
sT|j�}t
j��
�}t||�}||j|<|j|d
||
�
|S(NRO(t
new_rpc_idRRYtAsyncRpctasync_rpc_cachetemit_rpc(R�R`RKRbt	async_rpc(RNRO(s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytrpc_func�
s






(RR�R�tTruet_rpc_definition(R�RbR�(
RN(
ROs8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt	decorator�
s


	
	
((RNR�((
RNs8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
c
s��
fd
�}|S(Nc
s,|j}
t
j�
|
�}|j��
|S(
N(R�RRYR�(R�RORb(t	arg_typesRN(s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s
	



((RNR�R�((R�RNs8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
cs��
fd
�}|S(Nc
sDtj
d
�|�}
tj��
�}|j|
j�

t|_|S(NR�(RR�RYR�ROR�R�(R�trpc_callback_defRb(RNRO(s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s




	
((RNROR�((RNROs8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
c
s�f
d
�}
|
S(Nc
s=tj
d
�
|�}
|j��
�fd�}t|_|S(Ntsignalc
s8|j�}t
j��
�}|j|d
||
�
dS(NR�(R�RRYR�(R�R`RKRb(RNRO(s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s


(RR�R�R�R�(R�RbR�(
RN(
ROs8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s


	
	
((RNR�((
RNs8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
	cBsneZ
d	d	e�d	d�Zd
�Zd�Zd�Zd�Zd�Z	e
d��
Zd�Zd�Z
RS(
cCsqtj
|
�
|_||_||_||_tj|_d|_
||_|dk	rm|j|j|�
ndS(
N(
RRR)R(tportR!RtSOCK_STREAMRLRtsockett
friendly_nametparse(R�R)R(R!R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s

	
	
	

	
	
c
Cs�tj
d
dt|j�
�}
|jdkr1dS|jtjkrTd|j|
fS|jtj	kr}d|j|j
|
fSdSdS(Ns^.+ at (0x[0-9A-Fa-f]+)>$s\1Rs{unix}%s socket=%ss{inet}%s:%s socket=%stunknown(RtsubtreprR�R)RRtAF_UNIXR(RR�(R�tsocket_repr((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��
s






c

Csd|jdkrd
S|jtjkr0d|jS|jtjkrVd|j|jfStd�
SdS(NRs%ss%s:%stUnknown(R)RRR�R(RR�t
_(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt_get_default_friendly_names





c

Cs |jdkr|j�S|jS(
N(R�RR�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_friendly_names



c
Csd
dl}
|
j|�
S(Ni����(
tcopy(R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�s

c

CsC|jt
jkr|jS|jt
jkr;|j|jfSdSdS(
N(R)RR�R(RR�R(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_py_addresss




c

CsIt|�
t
krE|j�}itjd
6tjd6j|�
}|S|S(Ntunixtinet(RLRuRRR�RR�(
R)((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR#s


#

cCsP|
|_|
t
jkr-||_d|_n|
t
jkrL|j|�

ndS(
N(R)RR�R(RR�Rtparse_inet_addr(R�R)taddr((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�+s
	

	


cCs�tj
d
|
�}|r{|jd�
}
|jd�
}|dkrN|j}n|
dkrft�}
n|
|_||_nd|_d|_dS(Ns^\s*([^:\s]+)\s*(:\s*([^\s]+))?i
ithostname(RRRRR!tget_hostnameR(R�(R�R�R&R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�3s






	
	
N(R�R�RR
R�R�R�R�R�R�tstaticmethodRR�R�(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�
s
		
				tConnectionIOcBsVeZ
ejejBejBejBZdde	�d�Z
d
�Zd�Zd�Z
RS(cCs4t�|_
||_|
|_||_d|_dS(
N(R
tconnection_stateR*tchannel_typetchannel_nameRtio_watch_id(R�R�R�R*((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�Is


	
	
	
cCs/|j�
t
j|jj|j|
�|_d
S(s-callback signature: (io_object, io_condition)N(tio_watch_removeR9tio_add_watchR*R�tio_input_conditionsR�(R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytio_watch_addQs


c

Cs/|jdk	r+tj|j�

d|_ndS(
N(R�RR9t
source_remove(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�Ws


cCs�|
tj
tjBtjB@r�|
tj
@rVt}t|�
}|jtjd
||�
n|
tj@r�t	}t|�
}|jtj
d
||�
n|
tj@r�t}t|�
}|jtj
d
||�
ntSt
SdS(Ni(R9R>R=R?tERR_SOCKET_HUPtget_strerrortclose_connectionR
R6tERR_SOCKET_ERRORR�tERR_IO_INVALIDtFalseR�(R�RAterrnotstrerror((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytvalid_io_condition\s













N(R�R�R9R:R>R=R?R�RRR�R�R�R
(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�Fs

		c
Bs8eZ
eZdZd
�Zd�Zd�Zd�ZRS(icCs,tj
|d
dddd|
�

||_dS(NR�t	listeningR�tserver_listeningR*(R�R�tclient_connection_handler_class(R�R*R
((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�xs

cCsd
|
|_|jj
tjkr�tjj|jj�
rLtj|jj�

q�tjj	|
j�
}tjj|�
s�tj
|�

q�ntj|jj
|jj�|j_t
j
|jjj�t
jt
j�
|jr�|jjjtjtjd
�
n|jjj|jj��

|jj
tjkrD
tj|jjd�
n|jjj|j�

|jjS(Ni
i�
(R*R)RR�tostpathtexistsR(tremovetdirnametmakedirsR�RLtfcntltfilenotF_SETFDt
FD_CLOEXECtallow_reuse_addresst
setsockoptt
SOL_SOCKETtSO_REUSEADDRtbindR�tchmodtlistentrequest_queue_size(R�R*R

((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytnew_listening_socket|s 
	



$
%
	
"



c
Csly,|j|j
�
|j
_|j|j�

Wn9tk
rg
}

|jjtj	tj
d
t|
�
�
tSXt
S(Ni����(R
R*R�R�thandle_client_connectt	ExceptionR�R�R
R�RRuR
R�(R�t
e((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytopen�s




%

c
Cs�
y
|j|�
st
S|tj@r
ym|
j�\}}tj|j�tjtj�
|j	|j
�
}|j||�
|jj
d
tj�
Wq
tjk
r

}
t|�
\}}tjtjd|j
|f�
|tjkr�tj}	n	tj}	|jj
|	d
||�
q
XnWn^tk
r|

}
tjtjd|jjt|�
f�
|jj
tjd
dt|�
�
n
XtS(Nis5closing client connection due to socket error(%s): %ssexception %s: %si����(R
R
R9R:tacceptR
R
R
R
R
R*R"
R�R�R
R�Rterrortget_error_from_socket_exceptiontsyslogtLOG_ERRtErrnotEPIPER6R�R 
t	__class__R�RuR�(
R�R�RAt
client_sockettclient_addresstclient_handlerR!
R
R
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR
�s*











 

	
$
)
&(	R�R�R
R
R
R�R
R"
R
(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyRss
				tRequestReceiverc
Bs5eZ
d�Zd
�Zd�Zd�Zd�ZRS(cCs|
|_|j
�
dS(
N(tdispatchFunctreset(R�R/
((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��s
	
c

Cs1d
|_d|_
d|_d|_d|_dS(Ni����iR�(t	headerLentbodyLenRtheaderREtfeed_buf(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR0
�s

	
	
	
	
c
Cs�t|j
�
d
krdSx�tr�|jd
krltj|j
�
}
|
rh|
j�|_|j�
qqlPnt|j
�
|j|jkr�|j}|j|j}|j
||!|_	|j
||_
d|_d|_|j
|j|j	�
qnPqWdS(Nii����(R0R4
R�R1
t
header_end_reRtendtparse_headerR2
RER/
R3
(R�R&t	bodyBegintbodyEnd((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytprocess�s(

	





	



	
	

cCs|j|
7_|j
�
dS(
N(R4
R:
(R�tdata((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytfeed�s

c
Cs�i|_d
}
xit
j|j|
|jd�}|rw|jd�
}|jd�
j�}||j|<|j�}
qPqt|jd�
|_	dS(Nii
iscontent-length(
R3
theader_field_reRR4
R1
RtstripR6
R,R2
(R�tbeginR&RHRI((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR7
�s
	









(R�R�R�R0
R:
R<
R7
(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR.
�s

				c
BsGeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(c

Csi|_i|_
d
|_dS(Ni(R�trpc_handlersRK(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��s
	
	
c

Cs|jd
7_t
|j�
S(Ni
(RKRu(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��s

c
Csitd
t
|j�
|jf�

|jj�}
|
j�
x)|
D]!}td||j|f�

q@WdS(Ns*async_rpc_cache: %d entries, cur rpc_id=%ss%s: %s(RR0R�RKR�R�(R�trpc_idsRK((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytdump_async_rpc_caches

 





c


Cs|jj
�
dS(
N(R�R�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytflush_async_rpc_cache	s
cCs$tjtj
d
|
||f�
dS(Ns
[%s] %d %s(R&
R'
(R�ROR�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytdefault_errbacks
cCs�|
dkr't
j
t
jd
t�
dS|
jdkrZx||
jD]}||
j�
q@Wn[|
jdkr�t|
j�
dkr�x1|
jD]}||
j�
q�Wq�|j	|
j�
ndS(Ns8process_async_return(): rpc_id=%s not in async_rpc_cacheR�R�i(
RR&
R'
RKtreturn_typet	callbackstreturn_argsR0terrbacksRD
(R�R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytprocess_async_returns









cCs||j|
<dS(
N(
R@
(R�RNthandler((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytconnect_rpc_interfaces
(	R�R�R�R�RB
RC
RD
RI
RK
(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�s
						cBs�eZ
edd
e�Zedde�Zddd�Zd�Zd�Z	d�Z
d�Zd�Zd	d	d	d
d�Z
d�Zd
�Zd�Zd�Zd�Zd�ZRS(R�tbuf_sizettimeoutcCsQtj
|d
|
d|dd�

tj
|�

tj�|_t|j�
|_	dS(NR�R�R*(
R�R�RRt	threadingtLockt
write_lockR.
tdefault_request_handlertreceiver(R�R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�&s




c

Csd
|j|j
|jfS(Ns channel: name=%s addr=%s type=%s(R�R*R�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�,s
c


Cs|jj
�
dS(
N(RP
tacquire(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytacquire_write_lock/s
c


Cs|jj
�
dS(
N(RP
trelease(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytrelease_write_lock2s
cCs
|
|_dS(
N(
R�(R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytset_channel_type5s
c


Cs|jS(
N(
R�(
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_channel_type8s
iR�cCs�td
|j
�

|j�
|j
jdkr1dS|j
jdk	r�y6|j
jjtj�

|j
jj�
d|j
_Wq�tj	k
r�
}
d|j
_q�Xn|j
j|
|tj
B||�
|j�
dS(Nsclose_connection: %s(RR*RC
R�RtshutdownRt	SHUT_RDWRtcloseR$
R�R�R
R�R�(R�R�R�R�R�R!
((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR
;s














cCs;|jj
|
d�}|dkr%dSt||d�}|S(
N(R@
R�Rtgetattr(R�RNROthandler_objR�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytget_method_implementationLs





cGswt|j
�
t|�
krBtjtjd
t|�
|f�
dSt|
||�}t|
||�}|j|�

dS(Ns3emit_rpc() arg length=%s does not match rpc_def(%s)(R0R[R&
R'
R}RMt	send_data(R�RKRLRbR`trpc_xmltrpc_data((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR�Ss

#



cCs�
|jj
tj@sdS|j�
yzd
}xm|t|
�
kr�|jjj|
|�
}|d
kr�|j	tj
�

ttd|j�

�
n||}q-WWn�t
jk
r�
}
tjtjd|j�
|j�
|jjtj�

dSt
jk
rw

}
t|�
\}}tjtjd|j|f�
|j�
|tjkrT
tj
}n	tj}|j	|d
||�
dSX|jjd
tj�
|j�
dS(Nitdetailssocket timeout: (%s)s&could not send data on socket (%s): %s(R�R�R
RRT
R0R*R�tsendR
R6tProgramErrorR
RRM
R&
R'
RV
R�R�R$
R%
R(
R)
R�R�(R�R;
t	totalSenttsentR!
R
R
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR_
[s6




















 



	



cCsr
y
|j|�
st
S|tj@r
y<|
j|j�
}t|�
d
kr^|jtj	�

t
SWn�t
jk
r�
}
t|�
\}}t
j
t
jd|j|f�
|tjkr�tj	}n	tj}|j|d
||�
t
SX|jjd
tj�
|jj|�

nWn\tk
rm

}
t
j
t
jd|jjt|�
f�
|jtjd
dt|�
�
t
SXtS(Nissocket error (%s): %ssexception %s: %si����(R
R
R9R:trecvtsocket_buf_sizeR0R
R
R6RR$
R%
R&
R'
R*R(
R)
R�R�R�R�RR
R<
R 
R*
R�RuR�(R�R�RAR;
R!
R
R
R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pythandle_client_ioys0










 

	




)

cCs�|jj
|d�}|dkr<tjtjd
|�
dStd|jj||
|jj	|jj
|f�

t|�
\}}}|
|_||_
|j|�

dS(Ns1handle_return(): rpc_id=%s not in async_rpc_caches/%s.handle_return: rpc_id=%s type=%s %s.%s, {%s}(R�tpopRR&
R'
RR*
R�RbRNRORjRE
RG
RI
(R�RLRKRER�RNROR`((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt
handle_return�s



2
	
	
cCst|
jd
d�}|
jdd�}td|jj|||f�

|dks\|dkrr|j|||�
n�
|dkr�
t|�
\}}}|j||�}|rN
yY||�}	|	dkr�g}	ntj	||�}
|
j
�}|j|d||	�
Wq�
tk
rJ

}
tj
|�
}
|j|d|
||j|j�
q�
Xqptj}d||jjf}tj
|�
}
|j|d|
|||�
n�|d	krWt|�
\}}}|j||�}|r
y||�
WqTtk
r
}
tj
|�
}
qTXqptj}d||jjf}tj
|�
}
|j|d|
|||�
ntd
|||f�
�
dS(NRKiRLs2%s.default_request_handler: rpc_id=%s type=%s {%s}R�R�ROs,method '%s' is not implemented in class '%s'R�sunknown type(%s) for %s:%s(R�RRR*
R�Rk
RjR^
RRYR�R�Rd
R�R
R
R(
tENOSYSR�(R�R3
RERKRLRNROR`R�RG
trpc_method_defR�R!
t
rpc_error_defR�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyRQ
�sH

 







	





)	










	


N(R�R�R
R,Rh
tsocket_timeoutRR�R�RT
RV
RW
RX
R
R^
R�R_
Ri
Rk
RQ
(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR"s

										
R�c
Bs#eZ
d�Zd
�Zd�ZRS(cCs:|
|_||_
d|_d|_g|_g|_dS(
N(RbRKRRG
RE
RF
RH
(R�RbRK((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��s
	
	
	
	
	
cCs|jj
|
�

dS(
N(RF
R(R�R�((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytadd_callback�s
cCs|jj
|
�

dS(
N(RH
R(R�terrback((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pytadd_errback�s
(R�R�R�Rp
Rr
(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyR��s
		((9RURR&
R
R(
R9R
R�RR
RN
ttypestsetroubleshoot.configR
tsetroubleshoot.errcodetsetroubleshoot.xml_serializeRRtsetroubleshoot.utilt__all__Rtcontent_length_reR5
R=
RRR	R
RRRCRJRMRjR}R�R
t
type_registertobjectR�RuR,R�R�R�RRRRRRR�RR.
RRR�(((s8/usr/lib64/python2.7/site-packages/setroubleshoot/rpc.pyt<module>st
























	


							(	(N
*C;				
	V-G>*�