File: //proc/2/cwd/usr/local/ssl/lib/python2.4/Demo/rpc/rpc.pyc
m
=5Dc @ s d k Z d k Z d k Z d Z d Z d Z d Z d Z d Z d Z d Z
d Z d Z d Z
d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d e i f d YZ d Z d
Z d Z d e i f d
YZ d Z d Z d Z d a d Z! d f d YZ" d Z# d Z$ d Z% d Z& d a( d Z) d e" f d YZ* d e" f d YZ+ d e+ f d YZ, d Z- d Z. d! Z/ d Z0 d Z1 d Z2 d Z3 d Z4 d Z5 d" Z6 d# Z7 d$ e f d% YZ8 d& e f d' YZ9 d( f d) YZ: d* e: e* f d+ YZ; d, e: e+ f d- YZ< d. e: e, f d/ YZ= d0 e* f d1 YZ> d2 e+ f d3 YZ? d4 e" f d5 YZ@ d6 f d7 YZA d8 eA f d9 YZB d: eA f d; YZC d< ZD d= ZE d> ZF d? ZG d S(@ Ni i i i i i t Packerc B s, t Z d Z d Z d Z d Z RS( Nc C s* | \ } } | i | | i | d S( N( t autht flavort stufft selft pack_enumt pack_opaque( R R R R ( ( t" /usr/lib/python2.4/Demo/rpc/rpc.pyt pack_auth0 s
c C si | i | | i | | i | | i | | i t | x | D] } | i | qN Wd S( N(
R t pack_uintt stampt pack_stringt machinenamet uidt gidt lent gidst i( R R
R R
R R R ( ( R t pack_auth_unix5 s
c C sl | i | | i t | i t | i | | i | | i | | i | | i | d S( N( R R t xidR t CALLt
RPCVERSIONt progt verst procR t credt verf( R R R R R R R ( ( R t pack_callheader> s
c C sE | i | | i t | i t | i | | i t d S( N( R R R R t REPLYt MSG_ACCEPTEDR R t SUCCESS( R R R ( ( R t pack_replyheaderI s
( t __name__t
__module__R R R R ( ( ( R R . s s rpc.BadRPCFormats rpc.BadRPCVersions rpc.GarbageArgst Unpackerc B s# t Z d Z d Z d Z RS( Nc C s" | i } | i } | | f S( N( R t unpack_enumR t
unpack_opaqueR ( R R R ( ( R t unpack_authY s c C s | i } | i } | t j o t d | f n | i } | t j o t d | f n | i } | i } | i } | i } | i } | | | | | | f S( Ns no CALL but %rs bad RPC version %r( R t unpack_uintR R# t tempR t BadRPCFormatR t
BadRPCVersionR R R R% R R ( R R R R' R R R R ( ( R t unpack_callheader^ s
c C s | i } | i } | t j o t d | f n | i } | t j o | i } | t j o2 | i } | i } t d | | f f n | t j o | i } t d | f n t d | f n | t
j o t d | f n | i } | i } | t j o
t d n | t j o2 | i } | i } t d | | f f n | t j o
t d n | t j o
t d n | t j o t d
| f n | | f S( Ns no REPLY but %rs MSG_DENIED: RPC_MISMATCH: %rs MSG_DENIED: AUTH_ERROR: %rs MSG_DENIED: %rs' Neither MSG_DENIED nor MSG_ACCEPTED: %rs call failed: PROG_UNAVAILs call failed: PROG_MISMATCH: %rs call failed: PROC_UNAVAILs call failed: GARBAGE_ARGSs call failed: %r( R R& R R# t mtypeR t RuntimeErrort statt
MSG_DENIEDt RPC_MISMATCHt lowt hight
AUTH_ERRORR R% R t PROG_UNAVAILt
PROG_MISMATCHt PROC_UNAVAILt GARBAGE_ARGSR ( R R- R R+ R1 R0 R ( ( R t unpack_replyheadern s@
( R R! R% R* R7 ( ( ( R R" W s c C s d S( Nt ( ( ( ( R t make_auth_null s c C s, t } | i | | | | | | i S( N( R t pR t seedt hostR
R t groupst get_buf( R; R< R
R R= R: ( ( R t make_auth_unix s c C s y) d k l } l } | } | } Wn t j
o d } } n Xd k } t t | i t t
i | | g S( N( s getuids getgidi ( t ost getuidt getgidR
R t ImportErrort timeR? t intt
unix_epocht sockett gethostname( RA R
R RD RB ( ( R t make_auth_unix_default s
ic
C s t d j o t Sn d k } | i } | i | } | i | }
| i | | i |
} d \ } } } } } } t | | d \ } } t | | d \ } } t | | d \ } } | | } | i | | | | | | d d d f a d G| i t GHt S( 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.
i Ni i i< i s Unix epoch:( i i i i i i ( t _unix_epochRD t nowt localtimet localtt gmtimet gmtt mktimet offsett yt mt dt hht mmt sst divmodt ctime( RT RD RS RV RU RQ RR RM RK RW RO ( ( R RF s"
*t Clientc B st t Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
d
Z d Z d Z
RS(
Nc C sk | | _ | | _ | | _ | | _ | i | i | i d | _ | i d | _ d | _ d S( Ni (
R< R R R t portt
makesockett
bindsockett
connsockett lastxidt
addpackerst NoneR R ( R R< R R R[ ( ( R t __init__ s
c C s | i i d S( N( R t sockt close( R ( ( R Rd s c C s
t d d S( Ns makesocket not defined( R, ( R ( ( R R\ s c C s | i i | i | i f d S( N( R Rc t connectR< R[ ( R ( ( R R^ s c C s | i i d d S( NR8 i ( R8 i ( R Rc t bind( R ( ( R R] s c C s t | _ t d | _ d S( NR8 ( R R t packerR" t unpacker( R ( ( R R` s c C s~ | d j o | d j o
t d n | i | | o | | n | i | o
| } n d } | i
i | S( Ns! non-null args with null pack_func( t pack_funcRa t argst TypeErrorR t
start_callR t do_callt unpack_funct resultRh t done( R R Rj Ri Rn Ro ( ( R t make_call s
c C se | i d | _ } | i } | i } | i } | i | i
| | i | i | | | d S( Ni ( R R_ R t mkcredR t mkverfR Rg R: t resetR R R R ( R R R R R: R ( ( R Rl s
c C s
t d d S( Ns do_call not defined( R, ( R ( ( R Rm s c C s- | i d j o t t f | _ n | i S( N( R R Ra t AUTH_NULLR9 ( R ( ( R Rr s c C s- | i d j o t t f | _ n | i S( N( R R Ra Ru R9 ( R ( ( R Rs s c C s | i d d d d S( Ni ( R Rq Ra ( R ( ( R t call_0 s ( R R! Rb Rd R\ R^ R] R` Rq Rl Rm Rr Rs Rv ( ( ( R RZ s
c C s t | } | o | d B} n t t | d ?d @ t t | d ?d @ t t | d ?d @ t t | d @ } | i | | d S( Nl i i i i ( R t fragt xt lastt chrRE t headerRc t send( Rc Ry Rw R{ Rx ( ( R t sendfrag s
^c C s t | d | d S( Ni ( R} Rc t record( Rc R~ ( ( R t
sendrecord" s c C s | i d } t | d j o
t n t t | d d >t | d d >Bt | d d >Bt | d B} | d @d j } t | d
@ } d } xL | d j o> | i | } | p
t n | t | } | | } q W| | f S( Ni i i i i i i i l iR8 (
Rc t recvR{ R t EOFErrort longt ordRx Ry RE t nRw t buf( Rc Rw Ry R R{ Rx R ( ( R t recvfrag% s
L
c C s; d } d } x( | p t | \ } } | | } q W| S( NR8 i ( R~ Ry R Rc Rw ( Rc Rw R~ Ry ( ( R t
recvrecord5 s c C s d \ } } t d j o% d k } | | i | | a n x t t | t | t D]k } | a y | i | | f t SWq[ t i j
o2 \ } } | d j o t i | | f q q[ Xq[ Wt d d S( NiX i ir s can't assign reserved port( iX i ( t FIRSTt LASTt last_resv_port_triedRa R@ t getpidt rangeR Rc Rf R< RG t errort errnot msgR, ( Rc R< R R R R R@ R ( ( R t bindresvportA s
t RawTCPClientc B s t Z d Z d Z RS( Nc C s t i t i t i | _ d S( N( RG t AF_INETt SOCK_STREAMR Rc ( R ( ( R R\ W s c C s | i i } t | i | t | i } | i } | i
| | i \ } } | | i j o t d | | i f n d S( Ns# wrong xid in reply %r instead of %r( R Rg R> t callR Rc R t replyRh t uRt R7 R R R_ R, ( R R R R R R ( ( R Rm Z s
( R R! R\ Rm ( ( ( R R U s t RawUDPClientc B s t Z d Z d Z RS( Nc C s t i t i t i | _ d S( N( RG R t
SOCK_DGRAMR Rc ( R ( ( R R\ k s c
C sj | i i } | i i | y d k l } Wn t j
o d GHd } n Xd } d } d } x | i g g g } } }
| o" | | | |
| \ } } }
n | i | j oV | d } | d j o
t d n | d j o | d } n | i i | qf n | i i | } | i } | i | | i \ } } | | i j o qf n Pqf Wd S(
N( s selects' WARNING: select not found, RPC may hangi i i i t timeouti i ( R Rg R> R Rc R| t selectRC Ra t BUFSIZER t countt rt wRx R, R R Rh R Rt R7 R R R_ (
R R R R R R R R R R Rx R R ( ( R Rm n s< "
( R R! R\ Rm ( ( ( R R i s t RawBroadcastUDPClientc B s5 t Z d Z d Z d Z d Z d Z RS( Nc C s/ t i | | | | | d | _ d | _ d S( Ni (
R Rb R t bcastaddrR R R[ Ra t
reply_handlerR ( R R R R R[ ( ( R Rb s c C s | i i t i t i d d S( Ni ( R Rc t
setsockoptRG t
SOL_SOCKETt SO_BROADCAST( R ( ( R R^ s c C s
| | _ d S( N( R R ( R R ( ( R t set_reply_handler s c C s
| | _ d S( N( R R ( R R ( ( R t set_timeout s c C s | d j o | d j o
t d n | i | | o | | n | i i } | i
i | | i | i
f y d k l } Wn t j
o d GHd } n Xd } g }
| d j o d } | } n x-| i
g g g }
} } | oT | i d j o | |
| | \ }
} } qM| |
| | | i \ }
} } n | i
|
j o Pn | i
i | \ } } | i } | i | | i \ } } | | i! j o q n | } | i i" |
i# | | f | i$ o | i$ | | q q W|
S( Ns! non-null args with null pack_func( s selects. WARNING: select not found, broadcast will hangi c C s d S( N( ( ( ( R t dummy s i (% Ri Ra Rj Rk R Rl R Rg R> R Rc t sendtoR< R[ R RC R t repliesRn R R R Rx R t recvfromR t fromaddrRh R Rt R7 R R R_ Rp t appendR ( R R Rj Ri Rn R R R R R R R R R Rx R R R ( ( R Rq sL
%
( R R! Rb R^ R R Rq ( ( ( R R s
i io i i t PortMapperPackerc B s# t Z d Z d Z d Z RS( Nc C sJ | \ } } } } | i | | i | | i | | i | d S( N( t mappingR R t protR[ R R ( R R R R R R[ ( ( R t pack_mapping s
c C s | i | | i d S( N( R t pack_listt listR ( R R ( ( R t
pack_pmaplist s c C sJ | \ } } } } | i | | i | | i | | i | d S( N( t caR R R Rj R R R ( R R R Rj R R ( ( R t pack_call_args s
( R R! R R R ( ( ( R R s t PortMapperUnpackerc B s# t Z d Z d Z d Z RS( Nc C s@ | i } | i } | i } | i } | | | | f S( N( R R& R R R R[ ( R R R R R[ ( ( R t unpack_mapping s
c C s | i | i S( N( R t unpack_listR ( R ( ( R t unpack_pmaplist s c C s" | i } | i } | | f S( N( R R& R[ R$ t res( R R R[ ( ( R t unpack_call_result s ( R R! R R R ( ( ( R R s t PartialPortMapperClientc B s> t Z d Z d Z d Z d Z d Z d Z RS( Nc C s t | _ t d | _ d S( NR8 ( R R Rg R Rh ( R ( ( R R` s c C s" | i t | | i i | i i S( N( R Rq t PMAPPROC_SETR Rg R Rh R& ( R R ( ( R t Set s c C s" | i t | | i i | i i S( N( R Rq t PMAPPROC_UNSETR Rg R Rh R& ( R R ( ( R t Unset s c C s" | i t | | i i | i i S( N( R Rq t PMAPPROC_GETPORTR Rg R Rh R& ( R R ( ( R t Getport s c C s | i t d d | i i S( N( R Rq t
PMAPPROC_DUMPRa Rh R ( R ( ( R t Dump! s c C s" | i t | | i i | i i S( N( R Rq t PMAPPROC_CALLITR Rg R Rh R ( R R ( ( R t Callit& s ( R R! R` R R R R R ( ( ( R R s t TCPPortMapperClientc B s t Z d Z RS( Nc C s t i | | t t t d S( N( R Rb R R< t PMAP_PROGt PMAP_VERSt PMAP_PORT( R R< ( ( R Rb . s ( R R! Rb ( ( ( R R , s t UDPPortMapperClientc B s t Z d Z RS( Nc C s t i | | t t t d S( N( R Rb R R< R R R ( R R< ( ( R Rb 5 s ( R R! Rb ( ( ( R R 3 s t BroadcastUDPPortMapperClientc B s t Z d Z RS( Nc C s t i | | t t t d S( N( R Rb R R R R R ( R R ( ( R Rb = s ( R R! Rb ( ( ( R R : s t TCPClientc B s t Z d Z RS( Nc C sh t | } | i | | t d f } | i | d j o
t d n t
i | | | | | d S( Ni s program not registered(
R R< t pmapR R R t IPPROTO_TCPR[ Rd R, R Rb R ( R R< R R R R[ ( ( R Rb F s
( R R! Rb ( ( ( R R D s t UDPClientc B s t Z d Z RS( Nc C sh t | } | i | | t d f } | i | d j o
t d n t
i | | | | | d S( Ni s program not registered(
R R< R R R R t IPPROTO_UDPR[ Rd R, R Rb R ( R R< R R R R[ ( ( R Rb Q s
( R R! Rb ( ( ( R R O s t BroadcastUDPClientc B s> t Z d Z d Z d Z d Z d Z d Z RS( Nc C sK t | | _ | i i | i | | _ | | _ d | _ | i
d S( N( R R R R R t my_reply_handlerR R Ra t user_reply_handlerR` ( R R R R ( ( R Rb \ s c C s | i i d S( N( R R Rd ( R ( ( R Rd d s c C s
| | _ d S( N( R R R ( R R ( ( R R g s c C s | i i | d S( N( R R R R ( R R ( ( R R j s c C ss | \ } } | i i | | i } | i i | i i
| | f | i d j o | i | | n d S( N( R R[ R R Rh Rt Rn Ro Rp R R R R Ra ( R R R R Ro R[ ( ( R R m s
c C s | i i | o | | n | d j o d } | | _ n
| | _ g | _ | i i } | i i | i
| i | | f } | i S( Nc C s d S( N( ( ( ( R R { s ( R Rg Rt Ri Rj Rn Ra R R R> t packed_argsR R R R R t
dummy_replies( R R Rj Ri Rn R R R ( ( R Rq v s
$( R R! Rb Rd R R R Rq ( ( ( R R Z s t Serverc B sY t Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
RS(
Nc C sa | | _ | | _ | | _ | | _ | i | i | i i \ | _ | _ | i d S( N(
R< R R R R[ R\ R] Rc t getsocknameR` ( R R< R R R[ ( ( R Rb s
c C sN | i | i | i | i f } t | i } | i | p
t
d n d S( Ns register failed( R R R R R[ R R R< R: R R, ( R R: R ( ( R t register s c C sN | i | i | i | i f } t | i } | i | p
t
d n d S( Ns unregister failed( R R R R R[ R R R< R: R R, ( R R: R ( ( R t
unregister s c C s | i i | | i i | i i } | i i | | i i } | t
j o d Sn | i i t | i i } | t
j oQ | i i t | i i t | i i t
| i i t
| i i Sn | i i t | i i t t f | i i } | | i j o! | i i t | i i Sn | i i } | | i j oG | i i t | i i | i | i i | i | i i Sn | i i } d t | } y t | | } Wn0 t j
o$ | i i t | i i Sn X| i i }
| i i } y | Wn t# t$ f j
om | i i | i i | | i i t | i i t | i i t t f | i i t% n X| i i S( Nt handle_(& R Rh Rt R Rg R& R R R# R' R Ra R R R. R/ R> R R Ru R9 R R3 R R4 R t reprt methnamet getattrt metht AttributeErrorR5 R% R R R t GarbageArgsR6 ( R R R R R R R R R R' R ( ( R t handle s\
c C sA y | i i Wn t j
o
t n X| i i t d S( N( R Rh Rp R, R Rg R R ( R ( ( R t turn_around s
c C s | i d S( N( R R ( R ( ( R t handle_0 s c C s
t d d S( Ns makesocket not defined( R, ( R ( ( R R\ s c C s | i i | i | i f d S( N( R Rc Rf R< R[ ( R ( ( R R] s c C s t | _ t d | _ d S( NR8 ( R R Rg R" Rh ( R ( ( R R` s ( R R! Rb R R R R R R\ R] R` ( ( ( R R s
3 t TCPServerc B s5 t Z d Z d Z d Z d Z d Z RS( Nc C s( t i t i t i | _ t | _ d S( N( RG R R R Rc R R ( R ( ( R R\ s c C s2 | i i d x | i | i i q Wd S( Ni i ( R Rc t listent sessiont accept( R ( ( R t loop s c C s | \ } \ } } xz y t | } Wn5 t j
o Pn# t i j
o } d G| GHPn X| i | } | d j o t | | q q Wd S( Ni s
socket error:( t
connectionRc R< R[ R R R RG R R R R R Ra R ( R R Rc R< R R R R[ ( ( R R s
c C s2 | i i d x | i | i i q Wd S( Ni i ( R Rc R t forksessionR ( R ( ( R t forkingloop s c C s d k } y$ x | i d d \ } } q WWn | i j
o n Xd } z: | i } | o | d i d Sn | i
| Wd | d j o | i d n Xd S( Ni i ( R@ t waitpidt pidt stsR Ra t forkR Rd R R t _exit( R R R R R@ ( ( R R
s" !
( R R! R\ R R R R ( ( ( R R s
t UDPServerc B s# t Z d Z d Z d Z RS( Nc C s( t i t i t i | _ t | _ d S( N( RG R R R Rc R R ( R ( ( R R\ & s c C s x | i q Wd S( Ni ( R R ( R ( ( R R * s c C sO | i i d \ } } | i | } | d j o | i i | | n d S( Ni ( R Rc R R t host_portR R Ra R ( R R R R ( ( R R . s
( R R! R\ R R ( ( ( R R $ s c C s~ t d } | i } | i xU | D]M \ } } } } | G| G| t j o d Gn | t
j o d Gn | G| GHq) Wd S( NR8 t tcpt udp( R R R R t sortR R R R[ R R ( R R R R R R[ ( ( R t test7 s
c C s| d k } | i d o | i d } n d } d } t | } | i | | i d | i d d t d f } d S( Ni s <broadcast>c C s# | \ } } | d t | GHd S( Ns ( R R< R[ R R ( R R R< R[ ( ( R t rhK s i i i ( t syst argvR R R R R R R R R ( R R R R R ( ( R t testbcastE s
c C s d t f d Y} | d d d d } y | i Wn" t j
o } d G| Gd GHn X| i d GHz | i Wd | i d
GHXd S( Nt Sc B s t Z d Z RS( Nc C s@ | i i } | i d Gt | GH| i i | | d S( Ns RPC function 1 called, arg( R Rh t
unpack_stringt argR R Rg R ( R R ( ( R t handle_1\ s
( R R! R ( ( ( R R [ s R8 i i i s
RuntimeError:s (ignored)s Service started...s Service interrupted.( R R t sR R, R R R ( R R R ( ( R t testsvrY s
c C s} d k } | i d o | i d } n d } d t f d Y} | | d d } d GH| i d } d Gt | GHd S( Ni R8 t Cc B s t Z d Z RS( Nc C s" | i d | | i i | i i S( Ni ( R Rq R Rg R Rh R ( R R ( ( R t call_1v s ( R R! R ( ( ( R R u s i s making call...s hello, world, s
call returned( R R R< R R t cR R R ( R R R R< R ( ( R t testcltp s (H t xdrRG R@ R R R Ru t AUTH_UNIXt
AUTH_SHORTt AUTH_DESR R. R R3 R4 R5 R6 R/ R2 t AUTH_BADCREDt AUTH_REJECTEDCREDt AUTH_BADVERFt AUTH_REJECTEDVERFt AUTH_TOOWEAKR R( R) R R" R9 R? RI RJ RF RZ R} R R R Ra R 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 (E R R RI R R R
R R R R RZ R R R R9 R R R" R R R4 R R R? R( R R R R R
R6 R R R} R R/ R R Ru R R R RG R R R R) R R5 R. R R3 R R R R R R R R2 R RF R R R R@ R R R ( ( R t ?
s %A Q '>
1c6