�
��^c@s=dd
lZdd
l
Z
dd
lZdZdZdZdZdZdZdZ	dZ
dZdZdZ
dZdZdZdZdZdZdZdZdZdZdejf
d	��YZd
ef
d��YZdef
d
��YZdef
d��YZdejf
d��YZd�Zd�Zd�Z da!d�Z"ddCd��YZ#d�Z$d�Z%d�Z&d�Z'd
a)d�Z*de#f
d��YZ+de#f
d ��YZ,d!e,f
d"��YZ-d#Z.dZ/d$Z0dZ1dZ2dZ3dZ4dZ5dZ6d%Z7d&Z8d'ef
d(��YZ9d)ef
d*��YZ:d+dDd,��YZ;d-e;e+fd.��YZ<d/e;e,fd0��YZ=d1e;e-fd2��YZ>d3e+f
d4��YZ?d5e,f
d6��YZ@d7e#f
d8��YZAd9dEd:��YZBd;eBf
d<��YZCd=eBf
d>��YZDd?�ZEd@�ZFdA�ZGdB�ZHd
S(Fi����Niii
iiitPackerc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(cCs*|
\}}|j|�

|j
|�

dS(
N(t	pack_enumtpack_opaque(tselftauthtflavortstuff((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt	pack_auth0s



cCsi|j|
�

|j
|�

|j|�

|j|�

|jt|�
�

x|D]}|j|�

qNWdS(
N(t	pack_uinttpack_stringtlen(Rtstamptmachinenametuidtgidtgidst
i((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytpack_auth_unix5s











cCsl|j|
�

|j
t�

|jt�

|j|�

|j|�

|j|�

|j|�

|j|�

dS(
N(RR
tCALLt
RPCVERSIONR(Rtxidtprogtverstproctcredtverf((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytpack_callheader>s














cCsE|j|
�

|j
t�

|jt�

|j|�

|j
t�

dS(
N(RR
tREPLYtMSG_ACCEPTEDRtSUCCESS(RRR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytpack_replyheaderIs









(t__name__t
__module__RRRR(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR.s				tBadRPCFormatc
BseZ
RS((RR (((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR!Sst
BadRPCVersionc
BseZ
RS((RR (((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR"TstGarbageArgsc
BseZ
RS((RR (((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR#UstUnpackerc
Bs#eZ
d�Zd
�Zd�ZRS(c
Cs"|j�}
|j
�}|
|fS(
N(tunpack_enumt
unpack_opaque(RRR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytunpack_authYs


c
Cs�|j�}
|j
�}|tkr7td
|f
�n|j�}|tkrbtd|f
�n|j�}|j�}|j�}|j�}|j�}|
|||||fS(Nsno CALL but %rsbad RPC version %r(tunpack_uintR%RR!RR"R'(RRttempRRRRR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytunpack_callheader^s












c
Cs�
|j�}
|j
�}|tkr7td
|f
�n|j
�}|tkr�|j
�}|tkr�|j�}|j�}td||ff
�n|tkr�|j�}td|f
�ntd|f
�n|tkr�td|f
�n|j�}|j
�}|t	kr%
td�n|t
krb
|j�}|j�}td||ff
�n|tkrz
td�n|tkr�
td	�n|t
kr�
td
|f
�n|
|fS(Nsno REPLY but %rsMSG_DENIED: RPC_MISMATCH: %rsMSG_DENIED: AUTH_ERROR: %rsMSG_DENIED: %rs'Neither MSG_DENIED nor MSG_ACCEPTED: %rscall failed: PROG_UNAVAILscall failed: PROG_MISMATCH: %rscall failed: PROC_UNAVAILscall failed: GARBAGE_ARGSscall failed: %r(R(R%RtRuntimeErrort
MSG_DENIEDtRPC_MISMATCHt
AUTH_ERRORRR'tPROG_UNAVAILt
PROG_MISMATCHtPROC_UNAVAILtGARBAGE_ARGSR(RRtmtypetstattlowthighR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytunpack_replyheadernsH



































(RR R'R*R7(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR$Ws		c
Csd
S(Nt((((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytmake_auth_null�s
cCs,t�}|j
||
|||�
|j�S(
N(RRtget_buf(tseedthostR
Rtgroupst
p((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytmake_auth_unix�s
	

cCs�y,d
dlm
}m}

|�}|
�}Wntk
rI


d}}n
Xd
dl}tt|j�t��
tj	�||g�S(Ni����(tgetuidtgetgidi(
tosR@RAtImportErrorttimeR?tintt
unix_epochtsockettgethostname(R@RAR
RRD((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytmake_auth_unix_default�s


	







c
Cs
td
krtSddl
}|j
�}
|j|
�
}|j|
�
}|j|�
|j|�
}d	\}}}}}	}
t|
|d�\}}
t|	|d�\}}	t||d�\}}||}|j|||||	|
d
d
d
f	�
adG|jt�
GHtS(
s9
Very painful calculation of when the Unix Epoch is.

    This is defined as the return value of time.time() on Jan 1st,
    1970, 00:00:00 GMT.

    On a Unix system, this should always return 0.0.  On a Mac, the
    calculations are needed -- and hard because of integer overflow
    and other limitations.

    ii����Ni�i
i<isUnix epoch:(i�i
i
iii(t_unix_epochRDt	localtimetgmtimetmktimetdivmodtctime(RDtnowtlocalttgmttoffsett
yt
mt
dthhtmmtss((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRF�s











*

tClientc
BsteZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
RS(cCsk|
|_||_
||_||_|j�
|j�
|j�
d
|_|j�
d|_
d|_dS(Ni(R<RRtportt
makesockett
bindsockett
connsockettlastxidt
addpackerstNoneRR(RR<RRR[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt__init__�s
	
	
	
	






	


	
c


Cs|jj
�
dS(
N(tsocktclose(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRd�s
c

Cs
td
�dS(Nsmakesocket not defined(
R+(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR\�sc

Cs |jj
|j|jf�

dS(
N(RctconnectR<R[(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR^�sc

Cs|jj
d�

dS(NR8i(R8i(Rctbind(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR]�sc

Cst�|_
td
�
|_dS(NR8(RtpackerR$tunpacker(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR`�s
cCsw|dkr$|dk	r$t
d
�n|j|
�

|rD||�

n|j�
|r`|�}nd}|jj�
|S(Ns!non-null args with null pack_func(Rat	TypeErrort
start_calltdo_callRhtdone(RRtargst	pack_functunpack_functresult((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt	make_call�s












cCse|jd
|_}|j
�}|j�}|j}|j�
|j||j|j|
||�
dS(Ni
(R_tmkcredtmkverfRgtresetRRR(RRRRRR>((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRj�s


	


c

Cs
td
�dS(Nsdo_call not defined(
R+(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRk
sc

Cs+|jdkr$tt�f|_n|jS(
N(RRat	AUTH_NULLR9(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRr	
s

c

Cs+|jdkr$tt�f|_n|jS(
N(RRaRuR9(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRs
s

c

Cs|jd
ddd�S(Ni(RqRa(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytcall_0
s
(RR RbRdR\R^R]R`RqRjRkRrRsRv(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRZ�s	
											cCs�t|�
}|
r|d
B}nt
t|d?d@�
�
t
t|d?d@�
�
t
t|d?d@�
�
t
t|d@�
�
}|j||�

dS(Nlii�ii(R
tchrREtsend(Rctlasttfragt
xtheader((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytsendfrag
s



^
cCst|d
|
�
dS(Ni
(
R}(Rctrecord((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt
sendrecord"
s
c
Cs�|jd
�
}
t
|
�
d
kr*t�
ntt|
d�
�
d>t|
d�
d>Bt|
d�
d>Bt|
d�
B}|d	@dk}t|d
@�
}d}xH|dkr�|j|�
}|s�t�
n|t
|�
}||}q�W||fS(Niiii
iiiiI�i���R8(trecvR
tEOFErrortlongtordRE(RcR|R{Ryt
nRztbuf((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytrecvfrag%
s


	L





	


c
Cs9d
}
d}x&|s4t|�
\}}|
|}
qW|
S(NR8i(
R�(RcR~RyRz((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt
recvrecord5
s


	


cCs�d\}}tdkr?ddl}||j�||anx�tt|�t|t�D]g}|ay|j|
|f�

tSWq\tjk
r�
\}}
|dkr�tj||f�q�q\Xq\Wtd�dS(NiXii����irscan't assign reserved port(iXi(	tlast_resv_port_triedRaRBtgetpidtrangeRfRGterrorR+(RcR<tFIRSTtLASTRBRterrnotmsg((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytbindresvportA
s












tRawTCPClientc
BseZ
d�Zd
�ZRS(c

Cstjtj
tj�|_dS(
N(RGtAF_INETtSOCK_STREAMRc(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR\W
s
c
Cs�|jj
�}
t|j|
�
t|j�
}|j}|j|�

|j�\}}||jkr~t	d
||jf�ndS(Ns#wrong xid in reply %r instead of %r(
RgR:RRcR�RhRtR7R_R+(Rtcalltreplyt
uRR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRkZ
s



	




(RR R\Rk(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�U
s	tRawUDPClientc
BseZ
d�Zd
�ZRS(c

Cstjtj
tj�|_dS(
N(RGR�t
SOCK_DGRAMRc(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR\k
s
c

Cs`
|jj
�}
|jj|
�

yd
dlm}
Wntk
rQ


dGHd}n
Xd}d}d}x�|jg
gg}}}|r�|||||�\}}}n|j|kr
|d}|dkr�td�n|d	kr�|d
}n|jj|
�

qgn|jj|�
}	|j	}
|
j
|	�

|
j�\}}||jkrW
qgnPqgWdS(Ni����(
tselects'WARNING: select not found, RPC may hangi i
iittimeoutii(
RgR:RcRxR�RCRaR+R�RhRtR7R_(
RR�R�tBUFSIZER�tcountt
rt
wR{R�R�RR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRkn
s:















!








	




(RR R\Rk(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�i
s	tRawBroadcastUDPClientc
Bs5eZ
d�Zd
�Zd�Zd�Zd�ZRS(cCs/tj
||
|||�
d|_d
|_dS(Ni(R�RbRat
reply_handlerR�(Rt	bcastaddrRRR[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRb�
s

	
c

Cs |jj
tjtjd
�
dS(Ni
(Rct
setsockoptRGt
SOL_SOCKETtSO_BROADCAST(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR^�
scCs
|
|_dS(
N(
R�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytset_reply_handler�
s
cCs
|
|_dS(
N(
R�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytset_timeout�
s
cCs�
|dkr$|dk	r$t
d
�n|j|
�

|rD||�

n|jj�}|jj||j|jf�
yddl	m	}
Wnt
k
r�


dGHd}n
Xd}g}|dkr�d�}	|	}nx"
|jg
gg}
}}|rC
|jdkr
||
||�\}
}}qC
||
|||j�\}
}}n|j|
krV
Pn|jj|�
\}
}|j
}|j|
�

|j�\}}||jkr�
q�n|�}
|j
j�
|j|
|f�

|jr�|j|
|�
q�q�W|S(Ns!non-null args with null pack_funci����(
R�s.WARNING: select not found, broadcast will hangi c
SsdS(
N((((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytdummy�
R8(RaRiRjRgR:RctsendtoR<R[R�RCR�trecvfromRhRtR7R_RltappendR�(RRRmRnRoR�R�R�trepliesR�R�R�R{R�tfromaddrR�RR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRq�
sJ



















	
	




$



	




	



	

(RR RbR^R�R�Rq(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR��
s
				i��
ioiitPortMapperPackerc
Bs#eZ
d�Zd
�Zd�ZRS(cCsJ|
\}}}}|j|�

|j|�

|j|�

|j|�

dS(
N(
R(RtmappingRRtprotR[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytpack_mapping�
s








cCs|j|
|j
�
dS(
N(t	pack_listR�(Rtlist((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt
pack_pmaplist�
s
cCsJ|
\}}}}|j|�

|j|�

|j|�

|j
|�

dS(
N(RR(RtcaRRRRm((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytpack_call_args�
s








(RR R�R�R�(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR��
s		tPortMapperUnpackerc
Bs#eZ
d�Zd
�Zd�ZRS(c
Cs@|j�}
|j�}|j�}|j�}|
|||fS(
N(
R((RRRR�R[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytunpack_mapping�
s





c

Cs|j|j
�
S(
N(tunpack_listR�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytunpack_pmaplists
c
Cs"|j�}
|j
�}|
|fS(
N(R(R&(RR[tres((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytunpack_call_results


(RR R�R�R�(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR��
s		tPartialPortMapperClientc
Bs>eZ
d�Zd
�Zd�Zd�Zd�Zd�ZRS(c

Cst�|_
td
�
|_dS(NR8(R�RgR�Rh(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR`s

cCs"|jt
|
|jj|jj�S(
N(RqtPMAPPROC_SETRgR�RhR((RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytSets

	
cCs"|jt
|
|jj|jj�S(
N(RqtPMAPPROC_UNSETRgR�RhR((RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytUnsets

	
cCs"|jt
|
|jj|jj�S(
N(RqtPMAPPROC_GETPORTRgR�RhR((RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytGetports

	
c

Cs|jt
dd|jj�S(
N(Rqt
PMAPPROC_DUMPRaRhR�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytDump!s


cCs"|jt
|
|jj|jj�S(
N(RqtPMAPPROC_CALLITRgR�RhR�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytCallit&s

	
(RR R`R�R�R�R�R�(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�s					tTCPPortMapperClientc
BseZ
d�ZRS(
cCstj
||
ttt�
dS(
N(R�Rbt	PMAP_PROGt	PMAP_VERSt	PMAP_PORT(RR<((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRb.s
	
(RR Rb(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�,stUDPPortMapperClientc
BseZ
d�ZRS(
cCstj
||
ttt�
dS(
N(R�RbR�R�R�(RR<((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRb5s
	
(RR Rb(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�3stBroadcastUDPPortMapperClientc
BseZ
d�ZRS(
cCstj
||
ttt�
dS(
N(R�RbR�R�R�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRb=s
	
(RR Rb(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�:st	TCPClientc
BseZ
d�ZRS(
cCsft|
�
}|j
||td
f�
}|j�
|d
krItd�ntj||
|||�
dS(Nisprogram not registered(R�R�tIPPROTO_TCPRdR+R�Rb(RR<RRtpmapR[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRbFs






(RR Rb(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�Dst	UDPClientc
BseZ
d�ZRS(
cCsft|
�
}|j
||td
f�
}|j�
|d
krItd�ntj||
|||�
dS(Nisprogram not registered(R�R�tIPPROTO_UDPRdR+R�Rb(RR<RRR�R[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRbQs






(RR Rb(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�OstBroadcastUDPClientc
Bs>eZ
d�Zd
�Zd�Zd�Zd�Zd�ZRS(cCsKt|
�
|_
|j
j|j�

||_||_d|_|j�
dS(
N(	R�R�R�tmy_reply_handlerRRRatuser_reply_handlerR`(RR�RR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRb\s


	
	
	
c


Cs|jj
�
dS(
N(R�Rd(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRdds
cCs
|
|_dS(
N(
R�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�gs
cCs|jj
|
�

dS(
N(R�R�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�js
cCsq|
\}}|jj
|�

|j�}|jj�
|jj||f�

|jdk	rm|j||�
ndS(
N(RhRtRoRlR�R�R�Ra(RR�R�R[R�Rp((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�ms







cCs�|jj
�
|r ||�

n|dkrAd
�}||_n	||_g|_|jj�}|jj|j|j	|
|f�
}|jS(Nc
SsdS(
N((((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�{R8(
RgRtRaRoR�R:R�R�RR(RRRmRnRoR�tpacked_argst
dummy_replies((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRqvs






	
	
	

	

(RR RbRdR�R�R�Rq(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�Zs						tServerc
BsYeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
RS(	cCsa|
|_||_
||_||_|j�
|j�
|jj�\|_|_|j�
dS(
N(	R<RRR[R\R]RctgetsocknameR`(RR<RRR[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyRb�s
	
	
	
	





c
CsL|j|j
|j|jf}
t|j�
}|j|
�
sHtd
�ndS(Nsregister failed(RRR�R[R�R<R�R+(RR�R>((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytregister�s



c
CsL|j|j
|j|jf}
t|j�
}|j|
�
sHtd
�ndS(Nsunregister failed(RRR�R[R�R<R�R+(RR�R>((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt
unregister�s



cCs�|jj
|
�

|jj
�
|jj�}|jj|�

|jj�}|tkr[dS|jjt�

|jj�}|t	kr�|jjt
�

|jjt�

|jjt	�

|jjt	�

|jj�S|jjt
�

|jjtt�f�

|jj�}||jkr7
|jjt�

|jj�S|jj�}||jkr�
|jjt�

|jj|j�

|jj|j�

|jj�S|jj�}d
t|�
}yt||�}Wn+tk
r�



|jjt�

|jj�SX|jj�}	|jj�}
y|�
Wn}ttfk
r�


|jj
�
|jj|�

|jjt�

|jjt
�

|jjtt�f�

|jjt�

n
X|jj�S(Nthandle_(RhRtRgR(RR%RRaRRR,R-R:RRRuR9RR/RR0treprtgetattrtAttributeErrorR1R'R�R#R2(RR�RR)RRRtmethnametmethRR((s$/usr/lib64/python2.7/Demo/rpc/rpc.pythandle�s\

















































c

Cs?y|jj
�
Wntk
r*


t�
n
X|jjt�

dS(
N(RhRlR+R#RgRR(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytturn_around�s







c


Cs|j�
dS(
N(
R�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pythandle_0�s
c

Cs
td
�dS(Nsmakesocket not defined(
R+(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR\�sc

Cs |jj
|j|jf�

dS(
N(RcRfR<R[(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR]�sc

Cst�|_
td
�
|_dS(NR8(RRgR$Rh(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR`�s
(RR RbR�R�R�R�R�R\R]R`(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR��s	
			3				t	TCPServerc
Bs5eZ
d�Zd
�Zd�Zd�Zd�ZRS(c

Cs(tjtj
tj�|_t|_dS(
N(RGR�R�RcR�R�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR\�s

c

Cs1|jj
d
�

x|j|jj��

qWdS(Ni(Rctlistentsessiontaccept(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytloop�s


cCs�|
\}\}}xsyt|�
}Wn1t
k
r9


Pn tjk
rX
}
d
G|GHPn
X|j|�
}|dk	rt||�
qqWdS(Ns
socket error:(R�R�RGR�R�RaR(Rt
connectionRcR<R[R�R�R�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR��s








	



c

Cs1|jj
d
�

x|j|jj��

qWdS(Ni(RcR�tforksessionR�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytforkingloops

cCs�d
dl}y#x|j
dd�\}}qWWn|jk
rE


n
Xd}z5|j�}|rs|
dj�
dS|j|
�

Wd|dkr�|jd�

nXdS(Ni����ii
(RBtwaitpidR�RatforkRdR�t_exit(RR�RBtpidtsts((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�
s

 








(RR R\R�R�R�R�(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR��s
				t	UDPServerc
Bs#eZ
d�Zd
�Zd�ZRS(c

Cs(tjtj
tj�|_t|_dS(
N(RGR�R�RcR�R�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR\&s

c


Csx|j�
qWdS(
N(
R�(
R((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�*s

c
CsM|jj
d
�
\}
}|j|
�
}|dk	rI|jj||�
ndS(Ni (RcR�R�RaR�(RR�t	host_portR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�.s



(RR R\R�R�(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�$s		cCsztd
�
}|j
�}
|
j�
xQ|
D]I\}}}}|G|G|tkrVdGn|tkridGn|G|GHq)WdS(NR8ttcptudp(R�R�tsortR�R�(R�R�RRR�R[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyttest7s









cCs}d
dl}|j
dr)|j
d}
nd}
d�}t|
�
}|j|�

|jd�

|jddtdf�
}dS(Ni����i
s<broadcast>cSs#|
\}}|d
t|�
GHdS(Ns
	(
R�(R�R�R<R[((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytrhKs

ii��
i(tsystargvR�R�R�R�R�(R�R�R�R�R�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt	testbcastEs




	




cCs�d
tf
d��Y}|dddd�}
y|
j
�
Wn tk
r[
}
dG|GdGHn
X|
j�
d	GHz|
j�
Wd|
j
�
d
GHXdS(Nt
Sc
BseZ
d�ZRS(
c
Ss@|jj
�}
|j�
d
Gt|
�
GH|jj|
|
�

dS(NsRPC function 1 called, arg(Rht
unpack_stringR�R�RgR	(Rtarg((s$/usr/lib64/python2.7/Demo/rpc/rpc.pythandle_1\s




(RR R�(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR�[s
R8i i
is
RuntimeError:s	(ignored)sService started...sService interrupted.(R�R�R+R�R�(R�t
sR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyttestsvrYs










cCs~d
dl}|j
dr)|j
d}
nd}
dtf
d��Y}||
dd�}dGH|jd�
}d	Gt|�
GHdS(
Ni����i
R8t
Cc
BseZ
d�ZRS(
cSs"|jd
|
|j
j|jj�S(Ni
(RqRgR	RhR�(RR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pytcall_1vs

	
(RR R
(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyR

us
i smaking call...shello, world, s
call returned(R�R�R�R
R�(R�R<R

t
cR�((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyttestcltps






((((ItxdrRGRBRRRRut	AUTH_UNIXt
AUTH_SHORTtAUTH_DESRR,RR/R0R1R2R-R.tAUTH_BADCREDtAUTH_REJECTEDCREDtAUTH_BADVERFtAUTH_REJECTEDVERFtAUTH_TOOWEAKRt	ExceptionR!R"R#R$R9R?RIRJRFRZR}RR�R�RaR�R�R�R�R�R�R�R�t
PMAPPROC_NULLR�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R
R
(((s$/usr/lib64/python2.7/Demo/rpc/rpc.pyt<module>
s�















%

A			
	Q				
	'>







	 
	1c6