���ѧۧݧ�ӧ�� �ާ֧ߧ֧էا֧� - ���֧էѧܧ�ڧ��ӧѧ�� - /home/ukubnwwtacc0unt/chapelbellstudios.com/uploads/cover/rpc.zip
���ѧ٧ѧ�
PK �"�\��:� � T.pycnu �[��� � ��^c @ s: d d l Z d d l Z d d l Z d � Z d � Z d S( i����Nc C s9 t j � \ } } } } | | | | t j � f a d S( N( t ost timest timet t0( t ut st cut cs( ( s" /usr/lib64/python2.7/Demo/rpc/T.pyt TSTART s c G s� t j � \ } } } } | | | | t j � f a g } x- t d � D] } | j t | t | � qH W| \ } } } d } x | D] } | | d } q� W| d | | | f } t j j | � d S( Ni t t s %r user, %r sys, %r real ( R R R t t1t ranget appendR t syst stderrt write( t labelR R R R t ttt it rt msgt x( ( s" /usr/lib64/python2.7/Demo/rpc/T.pyt TSTOP s ( R R R R R ( ( ( s" /usr/lib64/python2.7/Demo/rpc/T.pyt <module> s $ PK �"�\���� � xdr.pyonu �[��� � ��^c @ s` y d d l Z Wn e k r) d Z n Xe d � Z d d d � � YZ d d d � � YZ d S( i����Nl t Packerc B s� e Z d � Z d � Z d � Z d � Z e rT e j d d � d k rT d � Z n e Z e Z d � Z d � Z e Z d � Z d � Z d � Z e Z d � Z e Z d � Z d � Z d � Z RS( c C s | j � d S( N( t reset( t self( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt __init__ s c C s d | _ d S( Nt ( t buf( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR s c C s | j S( N( R ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt get_buf s c C sl | j t t | d ?d @� � t t | d ?d @� � t t | d ?d @� � t t | d @� � | _ d S( Ni i� i i ( R t chrt int( R t x( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_uint s t li s c C sM t | � t k r- t | d d d � } n | j t j d | � | _ d S( Nl l R ( t typet LongR R t structt pack( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR s c C s- | r | j d | _ n | j d | _ d S( Ns s ( R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_bool' s c C s6 | j t | d ?d @� � | j t | d @� � d S( Ni I���� ( R R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_uhyper+ s c C s | j t j d | � | _ d S( Nt f( R R R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_float1 s c C s | j t j d | � | _ d S( Nt d( R R R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_double5 s c C s` | d k r t d � n | d d d } | | } | | t | � d } | j | | _ d S( Ni s fstring size must be nonnegativei i s ( t ValueErrort lenR ( R t nt st data( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_fstring9 s c C s- t | � } | j | � | j | | � d S( N( R R R ( R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_stringC s c C s9 x% | D] } | j d � | | � q W| j d � d S( Ni i ( R ( R t listt pack_itemt item( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_listJ s c C s= t | � | k r t d � n x | D] } | | � q% Wd S( Ns wrong array size( R R ( R R R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_farrayP s c C s0 t | � } | j | � | j | | | � d S( N( R R R! ( R R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_arrayV s ( t __name__t __module__R R R R R R t pack_intt pack_enumR R t pack_hyperR R R t pack_fopaqueR t pack_opaqueR R! R" ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR s( t Unpackerc B s� e Z d � Z d � Z d � Z d � Z e rT e j d d � d k rT d � Z n d � Z e Z e Z d � Z d � Z d � Z d � Z d � Z e Z d � Z e Z d � Z d � Z d � Z RS( c C s | j | � d S( N( R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR ^ s c C s | | _ d | _ d S( Ni ( R t pos( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR a s c C s( | j t | j � k r$ t d � n d S( Ns unextracted data remains( R+ R R t RuntimeError( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt donee s c C s� | j } | d | _ } | j | | !} t | � d k rE t � n t t | d � � d >t | d � d >Bt | d � d >Bt | d � B} | d k r� t | � } n | S( Ni i i i i i i i l ( R+ R R t EOFErrort longt ordR ( R t it jR R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_uinti s L R s i c C sU | j } | d | _ } | j | | !} t | � d k rE t � n t j d | � S( Ni R ( R+ R R R. R t unpack( R R1 R2 R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR3 v s c C s/ | j � } | d k r% | d } n t | � S( Nl l ( R3 R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_int~ s c C s* | j � } | j � } t | � d >| BS( Ni ( R3 R/ ( R t hit lo( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_uhyper� s c C s) | j � } | d k r% | d } n | S( Nl l ( R8 ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_hyper� s c C sY | j } | d | _ } | j | | !} t | � d k rE t � n t j d | � d S( Ni R i ( R+ R R R. R R4 ( R R1 R2 R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_float� s c C sY | j } | d | _ } | j | | !} t | � d k rE t � n t j d | � d S( Ni R i ( R+ R R R. R R4 ( R R1 R2 R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_double� s c C sp | d k r t d � n | j } | | d d d } | t | j � k rU t � n | | _ | j | | | !S( Ni s fstring size must be nonnegativei i ( R R+ R R R. ( R R R1 R2 ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_fstring� s c C s | j � } | j | � S( N( R3 R< ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_string� s c C sb g } xU | j � } | d k r% Pn | d k rD t d | f � n | � } | j | � q W| S( Ni i s 0 or 1 expected, got %r( R3 R, t append( R t unpack_itemR R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_list� s c C s1 g } x$ t | � D] } | j | � � q W| S( N( t rangeR> ( R R R? R R1 ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_farray� s c C s | j � } | j | | � S( N( R3 RB ( R R? R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_array� s ( R# R$ R R R- R3 R R4 R5 t unpack_enumt unpack_boolR8 R9 R: R; R< t unpack_fopaqueR= t unpack_opaqueR@ RB RC ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR* \ s( ( ( ( R t ImportErrort NoneR R R R* ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt <module> s OPK �"�\�r�� � nfsclient.pyonu �[��� � ��^c @ s� d d l Z d d l m Z m Z d d l m Z m Z m Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d � Z d S( i����N( t UDPClientt TCPClient( t FHSIZEt MountPackert MountUnpackeri�� i i i i i i t NFSPackerc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s* | \ } } | j | � | j | � d S( N( t pack_fhandlet pack_sattr( t selft sat filet attributes( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt pack_sattrargs s c C sj | \ } } } } } } | j | � | j | � | j | � | j | � | j | � | j | � d S( N( t pack_uintt pack_timeval( R R t modet uidt gidt sizet atimet mtime( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR $ s c C s* | \ } } | j | � | j | � d S( N( R t pack_string( R t dat dirt name( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt pack_diropargs- s c C s: | \ } } } | j | � | j | � | j | � d S( N( R R ( R t raR t cookiet count( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt pack_readdirargs2 s c C s* | \ } } | j | � | j | � d S( N( R ( R t tvt secst usecs( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR 8 s ( t __name__t __module__R R R R R ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR s t NFSUnpackerc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sU | j � } | t k rE | j | j � } | j � } | | f } n d } | | f S( N( t unpack_enumt NFS_OKt unpack_listt unpack_entryt unpack_boolt None( R t statust entriest eoft rest( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt unpack_readdirres@ s c C s1 | j � } | j � } | j � } | | | f S( N( t unpack_uintt unpack_string( R t fileidR R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR' J s c C sO | j � } | t k r? | j � } | j � } | | f } n d } | | f S( N( R$ R% t unpack_fhandlet unpack_fattrR) ( R R* t fht faR- ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt unpack_diropresP s c C s7 | j � } | t k r' | j � } n d } | | f S( N( R$ R% R3 R) ( R R* R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt unpack_attrstatZ s c C s� | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | | | | | | | | | | | | | | f S( N( R$ R/ t unpack_timeval( R t typeR t nlinkR R R t blocksizet rdevt blockst fsidR1 R R t ctime( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR3 b s c C s" | j � } | j � } | | f S( N( R/ ( R R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR8 t s ( R! R" R. R' R6 R7 R3 R8 ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR# > s t NFSClientc B sP e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s t j | | t t � d S( N( R t __init__t NFS_PROGRAMt NFS_VERSION( R t host( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyRA | s c C s t � | _ t d � | _ d S( Nt ( R t packerR# t unpacker( R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt addpackers s c C s1 | j d k r* t j t j � f | _ n | j S( N( t credR) t rpct AUTH_UNIXt make_auth_unix_default( R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt mkcred� s c C s" | j d | | j j | j j � S( Ni ( t make_callRF R RG R7 ( R R4 ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Getattr� s c C s" | j d | | j j | j j � S( Ni ( RN RF R RG R7 ( R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Setattr� s c C s" | j d | | j j | j j � S( Ni ( RN RF R RG R6 ( R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Lookup� s c C s" | j d | | j j | j j � S( Ni ( RN RF R RG R. ( R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Readdir� s c C s� g } | d d f } x� | j | � \ } } | t k r= Pn | \ } } d } x0 | D]( \ } } } | j | | f � | } qV W| s� | d k r� Pn | d | | d f } q W| S( Ni i� i ( RR R% R) t append( R R t listR R* R- R+ R, t last_cookieR1 R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Listdir� s ( R! R" RA RH RM RO RP RQ RR RV ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR@ z s c C s# d d l } | j d r) | j d } n d } | j d rL | j d } n d } d d l m } m } | | � } | d k r� | j � } x | D] } | GHq� Wd S| j | � } | GH| d } | r t | � } | j | � } | GH| j | � } x | D] } | GHq W| j | � n d S( Ni����i RE i ( t UDPMountClientt TCPMountClient( t syst argvR) t mountclientRW RX t Exportt MntR@ RO RV t Umnt( RY RD t filesysRW RX t mclRT t itemt sfR4 t nclt attrstat( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt test� s2 ( RJ R R R[ R R R RB RC R% t NFNONt NFREGt NFDIRt NFBLKt NFCHRt NFLNKR R# R@ Re ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt <module> s !<9PK �"�\X���P P mountclient.pycnu �[��� � ��^c @ s� d d l Z d d l m Z m Z m Z m Z d Z d Z d Z d e f d � � YZ d e f d � � YZ d d d � � YZ d e e f d � � YZ d e e f d � � YZ d � Z d S( i����N( t Packert Unpackert TCPClientt UDPClienti�� i i t MountPackerc B s e Z d � Z RS( c C s | j t | � d S( N( t pack_fopaquet FHSIZE( t selft fhandle( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt pack_fhandle s ( t __name__t __module__R ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR s t MountUnpackerc B sG e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s | j t � S( N( t unpack_fopaqueR ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_fhandle* s c C s7 | j � } | d k r' | j � } n d } | | f S( Ni ( t unpack_uintR t None( R t statust fh( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_fhstatus- s c C s | j | j � S( N( t unpack_listt unpack_mountstruct( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_mountlist5 s c C s" | j � } | j � } | | f S( N( t unpack_string( R t hostnamet directory( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR 8 s c C s | j | j � S( N( R t unpack_exportstruct( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_exportlist= s c C s" | j � } | j � } | | f S( N( R t unpack_groups( R t filesyst groups( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR @ s c C s | j | j � S( N( R R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR E s ( R R R R R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR ( s t PartialMountClientc B sP e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s t � | _ t d � | _ d S( Nt ( R t packerR t unpacker( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt addpackersP s c C sn d d l } y | j � } Wn t k r5 d } n X| d k rZ t j | j d � } n | j j d � d S( Ni����i i R ( R i ( t ost getuidt AttributeErrort rpct bindresvportt sockt bind( R R$ t uidt port( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt bindsocketX s c C s1 | j d k r* t j t j � f | _ n | j S( N( t credR R' t AUTH_UNIXt make_auth_unix_default( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt mkcredf s c C s" | j d | | j j | j j � S( Ni ( t make_callR! t pack_stringR" R ( R R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Mnt� s c C s | j d d d | j j � S( Ni ( R2 R R" R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Dump� s c C s | j d | | j j d � S( Ni ( R2 R! R3 R ( R R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Umnt� s c C s | j d d d d � S( Ni ( R2 R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Umntall� s c C s | j d d d | j j � S( Ni ( R2 R R" R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Export� s ( R R R# R- R1 R4 R5 R6 R7 R8 ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR L s # t TCPMountClientc B s e Z d � Z RS( c C s t j | | t t � d S( N( R t __init__t MOUNTPROGt MOUNTVERS( R t host( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR: � s ( R R R: ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR9 � s t UDPMountClientc B s e Z d � Z RS( c C s t j | | t t � d S( N( R R: R; R< ( R R= ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR: � s ( R R R: ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR> � s c C s d d l } | j d r? | j d d k r? t } | j d =n9 | j d rr | j d d k rr t } | j d =n t } | j d r� | j d } n d } | | � } | j � } xK | D]C } | GHy | j | d � Wn d GHq� n X| j | d � q� Wd S( Ni����i s -ts -uR i t Sorry( t syst argvR9 R> R8 R4 R6 ( R@ t CR= t mclt listt item( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt test� s* ( ( R' R R R R R; R< R R R R R9 R> RF ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt <module> s " $W PK �"�\� � � mountclient.pynu �[��� # Mount RPC client -- RFC 1094 (NFS), Appendix A # This module demonstrates how to write your own RPC client in Python. # When this example was written, there was no RPC compiler for # Python. Without such a compiler, you must first create classes # derived from Packer and Unpacker to handle the data types for the # server you want to interface to. You then write the client class. # If you want to support both the TCP and the UDP version of a # protocol, use multiple inheritance as shown below. import rpc from rpc import Packer, Unpacker, TCPClient, UDPClient # Program number and version for the mount protocol MOUNTPROG = 100005 MOUNTVERS = 1 # Size of the 'fhandle' opaque structure FHSIZE = 32 # Packer derived class for Mount protocol clients. # The only thing we need to pack beyond basic types is an 'fhandle' class MountPacker(Packer): def pack_fhandle(self, fhandle): self.pack_fopaque(FHSIZE, fhandle) # Unpacker derived class for Mount protocol clients. # The important types we need to unpack are fhandle, fhstatus, # mountlist and exportlist; mountstruct, exportstruct and groups are # used to unpack components of mountlist and exportlist and the # corresponding functions are passed as function argument to the # generic unpack_list function. class MountUnpacker(Unpacker): def unpack_fhandle(self): return self.unpack_fopaque(FHSIZE) def unpack_fhstatus(self): status = self.unpack_uint() if status == 0: fh = self.unpack_fhandle() else: fh = None return status, fh def unpack_mountlist(self): return self.unpack_list(self.unpack_mountstruct) def unpack_mountstruct(self): hostname = self.unpack_string() directory = self.unpack_string() return (hostname, directory) def unpack_exportlist(self): return self.unpack_list(self.unpack_exportstruct) def unpack_exportstruct(self): filesys = self.unpack_string() groups = self.unpack_groups() return (filesys, groups) def unpack_groups(self): return self.unpack_list(self.unpack_string) # These are the procedures specific to the Mount client class. # Think of this as a derived class of either TCPClient or UDPClient. class PartialMountClient: # This method is called by Client.__init__ to initialize # self.packer and self.unpacker def addpackers(self): self.packer = MountPacker() self.unpacker = MountUnpacker('') # This method is called by Client.__init__ to bind the socket # to a particular network interface and port. We use the # default network interface, but if we're running as root, # we want to bind to a reserved port def bindsocket(self): import os try: uid = os.getuid() except AttributeError: uid = 1 if uid == 0: port = rpc.bindresvport(self.sock, '') # 'port' is not used else: self.sock.bind(('', 0)) # This function is called to cough up a suitable # authentication object for a call to procedure 'proc'. def mkcred(self): if self.cred is None: self.cred = rpc.AUTH_UNIX, rpc.make_auth_unix_default() return self.cred # The methods Mnt, Dump etc. each implement one Remote # Procedure Call. This is done by calling self.make_call() # with as arguments: # # - the procedure number # - the arguments (or None) # - the "packer" function for the arguments (or None) # - the "unpacker" function for the return value (or None) # # The packer and unpacker function, if not None, *must* be # methods of self.packer and self.unpacker, respectively. # A value of None means that there are no arguments or is no # return value, respectively. # # The return value from make_call() is the return value from # the remote procedure call, as unpacked by the "unpacker" # function, or None if the unpacker function is None. # # (Even if you expect a result of None, you should still # return the return value from make_call(), since this may be # needed by a broadcasting version of the class.) # # If the call fails, make_call() raises an exception # (this includes time-outs and invalid results). # # Note that (at least with the UDP protocol) there is no # guarantee that a call is executed at most once. When you do # get a reply, you know it has been executed at least once; # when you don't get a reply, you know nothing. def Mnt(self, directory): return self.make_call(1, directory, \ self.packer.pack_string, \ self.unpacker.unpack_fhstatus) def Dump(self): return self.make_call(2, None, \ None, self.unpacker.unpack_mountlist) def Umnt(self, directory): return self.make_call(3, directory, \ self.packer.pack_string, None) def Umntall(self): return self.make_call(4, None, None, None) def Export(self): return self.make_call(5, None, \ None, self.unpacker.unpack_exportlist) # We turn the partial Mount client into a full one for either protocol # by use of multiple inheritance. (In general, when class C has base # classes B1...Bn, if x is an instance of class C, methods of x are # searched first in C, then in B1, then in B2, ..., finally in Bn.) class TCPMountClient(PartialMountClient, TCPClient): def __init__(self, host): TCPClient.__init__(self, host, MOUNTPROG, MOUNTVERS) class UDPMountClient(PartialMountClient, UDPClient): def __init__(self, host): UDPClient.__init__(self, host, MOUNTPROG, MOUNTVERS) # A little test program for the Mount client. This takes a host as # command line argument (default the local machine), prints its export # list, and attempts to mount and unmount each exported files system. # An optional first argument of -t or -u specifies the protocol to use # (TCP or UDP), default is UDP. def test(): import sys if sys.argv[1:] and sys.argv[1] == '-t': C = TCPMountClient del sys.argv[1] elif sys.argv[1:] and sys.argv[1] == '-u': C = UDPMountClient del sys.argv[1] else: C = UDPMountClient if sys.argv[1:]: host = sys.argv[1] else: host = '' mcl = C(host) list = mcl.Export() for item in list: print item try: mcl.Mnt(item[0]) except: print 'Sorry' continue mcl.Umnt(item[0]) PK �"�\X���P P mountclient.pyonu �[��� � ��^c @ s� d d l Z d d l m Z m Z m Z m Z d Z d Z d Z d e f d � � YZ d e f d � � YZ d d d � � YZ d e e f d � � YZ d e e f d � � YZ d � Z d S( i����N( t Packert Unpackert TCPClientt UDPClienti�� i i t MountPackerc B s e Z d � Z RS( c C s | j t | � d S( N( t pack_fopaquet FHSIZE( t selft fhandle( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt pack_fhandle s ( t __name__t __module__R ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR s t MountUnpackerc B sG e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s | j t � S( N( t unpack_fopaqueR ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_fhandle* s c C s7 | j � } | d k r' | j � } n d } | | f S( Ni ( t unpack_uintR t None( R t statust fh( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_fhstatus- s c C s | j | j � S( N( t unpack_listt unpack_mountstruct( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_mountlist5 s c C s" | j � } | j � } | | f S( N( t unpack_string( R t hostnamet directory( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR 8 s c C s | j | j � S( N( R t unpack_exportstruct( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt unpack_exportlist= s c C s" | j � } | j � } | | f S( N( R t unpack_groups( R t filesyst groups( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR @ s c C s | j | j � S( N( R R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR E s ( R R R R R R R R R ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR ( s t PartialMountClientc B sP e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s t � | _ t d � | _ d S( Nt ( R t packerR t unpacker( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt addpackersP s c C sn d d l } y | j � } Wn t k r5 d } n X| d k rZ t j | j d � } n | j j d � d S( Ni����i i R ( R i ( t ost getuidt AttributeErrort rpct bindresvportt sockt bind( R R$ t uidt port( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt bindsocketX s c C s1 | j d k r* t j t j � f | _ n | j S( N( t credR R' t AUTH_UNIXt make_auth_unix_default( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt mkcredf s c C s" | j d | | j j | j j � S( Ni ( t make_callR! t pack_stringR" R ( R R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Mnt� s c C s | j d d d | j j � S( Ni ( R2 R R" R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Dump� s c C s | j d | | j j d � S( Ni ( R2 R! R3 R ( R R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Umnt� s c C s | j d d d d � S( Ni ( R2 R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Umntall� s c C s | j d d d | j j � S( Ni ( R2 R R" R ( R ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt Export� s ( R R R# R- R1 R4 R5 R6 R7 R8 ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR L s # t TCPMountClientc B s e Z d � Z RS( c C s t j | | t t � d S( N( R t __init__t MOUNTPROGt MOUNTVERS( R t host( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR: � s ( R R R: ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR9 � s t UDPMountClientc B s e Z d � Z RS( c C s t j | | t t � d S( N( R R: R; R< ( R R= ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR: � s ( R R R: ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyR> � s c C s d d l } | j d r? | j d d k r? t } | j d =n9 | j d rr | j d d k rr t } | j d =n t } | j d r� | j d } n d } | | � } | j � } xK | D]C } | GHy | j | d � Wn d GHq� n X| j | d � q� Wd S( Ni����i s -ts -uR i t Sorry( t syst argvR9 R> R8 R4 R6 ( R@ t CR= t mclt listt item( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt test� s* ( ( R' R R R R R; R< R R R R R9 R> RF ( ( ( s, /usr/lib64/python2.7/Demo/rpc/mountclient.pyt <module> s " $W PK �"�\ x�}�v �v rpc.pycnu �[��� � ��^c @ s= d d l Z d d l Z d d l 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 j f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e j f d � � YZ d � Z d � Z d � Z d a! d � Z" d dC 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$ Z0 d Z1 d Z2 d Z3 d Z4 d Z5 d Z6 d% Z7 d& Z8 d' e f d( � � YZ9 d) e f d* � � YZ: d+ dD d, � � YZ; d- e; e+ f d. � � YZ< d/ e; e, f d0 � � YZ= d1 e; e- f d2 � � YZ> d3 e+ f d4 � � YZ? d5 e, f d6 � � YZ@ d7 e# f d8 � � YZA d9 dE d: � � YZB d; eB f d< � � YZC d= eB f d> � � YZD d? � ZE d@ � ZF dA � ZG dB � ZH d S(F i����Ni i i i i i t Packerc B s, e Z d � Z d � Z d � Z d � Z RS( c C s* | \ } } | j | � | j | � d S( N( t pack_enumt pack_opaque( t selft autht flavort stuff( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_auth0 s c C si | j | � | j | � | j | � | j | � | j t | � � x | D] } | j | � qN Wd S( N( t pack_uintt pack_stringt len( R t stampt machinenamet uidt gidt gidst i( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_auth_unix5 s c C sl | j | � | j t � | j t � | j | � | j | � | j | � | j | � | j | � d S( N( R R t CALLt RPCVERSIONR ( R t xidt progt verst proct credt verf( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_callheader> s c C sE | j | � | j t � | j t � | j | � | j t � d S( N( R R t REPLYt MSG_ACCEPTEDR t SUCCESS( R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_replyheaderI s ( t __name__t __module__R R R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR . s t BadRPCFormatc B s e Z RS( ( R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR! S s t BadRPCVersionc B s e Z RS( ( R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR" T s t GarbageArgsc B s e Z RS( ( R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR# U s t Unpackerc B s# e Z d � Z d � Z d � Z RS( c C s" | j � } | j � } | | f S( N( t unpack_enumt unpack_opaque( R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_authY s c C s� | j � } | j � } | t k r7 t d | f � n | j � } | t k rb t d | f � n | j � } | j � } | j � } | j � } | j � } | | | | | | f S( Ns no CALL but %rs bad RPC version %r( t unpack_uintR% R R! R R" R' ( R R t tempR R R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_callheader^ s c C s� | j � } | j � } | t k r7 t d | f � n | j � } | t k r� | j � } | t k r� | j � } | j � } t d | | f f � n | t k r� | j � } t d | f � n t d | f � n | t k r� t d | f � n | j � } | j � } | t k r%t d � n | t k rb| j � } | j � } t d | | f f � n | t k rzt d � n | t k r�t d � n | t k r�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 t RuntimeErrort MSG_DENIEDt RPC_MISMATCHt AUTH_ERRORR R' t PROG_UNAVAILt PROG_MISMATCHt PROC_UNAVAILt GARBAGE_ARGSR ( R R t mtypet statt lowt highR ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_replyheadern sH ( R R R' R* R7 ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR$ W s c C s d S( Nt ( ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_auth_null� s c C s, t � } | j | | | | | � | j � S( N( R R t get_buf( t seedt hostR R t groupst p( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_auth_unix� s c C s� y, d d l m } m } | � } | � } Wn t k rI d } } n Xd d l } t t | j � t � � t j � | | g � S( Ni����( t getuidt getgidi ( t osR@ RA t ImportErrort timeR? t intt unix_epocht sockett gethostname( R@ RA R R RD ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_auth_unix_default� s c C s t d k r t Sd d l } | j � } | j | � } | j | � } | j | � | j | � } d \ } } } } } } t | | d � \ } } t | | d � \ } } t | | d � \ } } | | } | j | | | | | | d d d f � a d G| j 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 i����Ni� i i< i s Unix epoch:( i� i i i i i ( t _unix_epochRD t localtimet gmtimet mktimet divmodt ctime( RD t nowt localtt gmtt offsett yt mt dt hht mmt ss( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRF � s *t Clientc B st e 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( c C sk | | _ | | _ | | _ | | _ | j � | j � | j � d | _ | j � d | _ d | _ d S( Ni ( R< R R t portt makesockett bindsockett connsockett lastxidt addpackerst NoneR R ( R R< R R R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt __init__� s c C s | j j � d S( N( t sockt close( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRd � s c C s t d � d S( Ns makesocket not defined( R+ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ � s c C s | j j | j | j f � d S( N( Rc t connectR< R[ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR^ � s c C s | j j d � d S( NR8 i ( R8 i ( Rc t bind( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR] � s c C s t � | _ t d � | _ d S( NR8 ( R t packerR$ t unpacker( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR` � s c C sw | d k r$ | d k r$ t d � n | j | � | rD | | � n | j � | r` | � } n d } | j j � | S( Ns! non-null args with null pack_func( Ra t TypeErrort start_callt do_callRh t done( R R t argst pack_funct unpack_funct result( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_call� s c C se | j d | _ } | j � } | j � } | j } | j � | j | | j | j | | | � d S( Ni ( R_ t mkcredt mkverfRg t resetR R R ( R R R R R R> ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRj � s c C s t d � d S( Ns do_call not defined( R+ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRk s c C s+ | j d k r$ t t � f | _ n | j S( N( R Ra t AUTH_NULLR9 ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRr s c C s+ | j d k r$ t t � f | _ n | j S( N( R Ra Ru R9 ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRs s c C s | j d d d d � S( Ni ( Rq Ra ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt call_0 s ( R R Rb Rd R\ R^ R] R` Rq Rj Rk Rr Rs Rv ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRZ � s c C s� t | � } | r | d B} n t t | d ?d @� � t t | d ?d @� � t t | d ?d @� � t t | d @� � } | j | | � d S( Nl i i� i i ( R t chrRE t send( Rc t lastt fragt xt header( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt sendfrag s ^c C s t | d | � d S( Ni ( R} ( Rc t record( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt sendrecord" s c C s� | j d � } t | � d k r* t � n t t | d � � d >t | d � d >Bt | d � d >Bt | d � B} | d @d k } t | d @� } d } xH | d k r� | j | � } | s� t � n | t | � } | | } q� W| | f S( Ni i i i i i i i I � i���R8 ( t recvR t EOFErrort longt ordRE ( Rc R| R{ Ry t nRz t buf( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt recvfrag% s L c C s9 d } d } x& | s4 t | � \ } } | | } q W| S( NR8 i ( R� ( Rc R~ Ry Rz ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt recvrecord5 s c C s� d \ } } t d k r? d d l } | | j � | | a n x� t t | � t | t � D]g } | a y | j | | f � t SWq\ t j k r� \ } } | d k r� t j | | f � q� q\ Xq\ Wt d � d S( NiX i i����ir s can't assign reserved port( iX i ( t last_resv_port_triedRa RB t getpidt rangeRf RG t errorR+ ( Rc R< t FIRSTt LASTRB R t errnot msg( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt bindresvportA s t RawTCPClientc B s e Z d � Z d � Z RS( c C s t j t j t j � | _ d S( N( RG t AF_INETt SOCK_STREAMRc ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ W s c C s� | j j � } t | j | � t | j � } | j } | j | � | j � \ } } | | j k r~ t d | | j f � n d S( Ns# wrong xid in reply %r instead of %r( Rg R: R Rc R� Rh Rt R7 R_ R+ ( R t callt replyt uR R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRk Z s ( R R R\ Rk ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� U s t RawUDPClientc B s e Z d � Z d � Z RS( c C s t j t j t j � | _ d S( N( RG R� t SOCK_DGRAMRc ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ k s c C s` | j j � } | j j | � y d d l m } Wn t k rQ d GHd } n Xd } d } d } x� | j g g g } } } | r� | | | | | � \ } } } n | j | k r| d } | d k r� t d � n | d k r� | d } n | j j | � qg n | j j | � } | j } | j | � | j � \ } } | | j k rWqg n Pqg Wd S( Ni����( t selects' WARNING: select not found, RPC may hangi i i i t timeouti i ( Rg R: Rc Rx R� RC Ra R+ R� Rh Rt R7 R_ ( R R� R� t BUFSIZER� t countt rt wR{ R� R� R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRk n s: ! ( R R R\ Rk ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� i s t RawBroadcastUDPClientc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s/ t j | | | | | � d | _ d | _ d S( Ni ( R� Rb Ra t reply_handlerR� ( R t bcastaddrR R R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb � s c C s | j j t j t j d � d S( Ni ( Rc t setsockoptRG t SOL_SOCKETt SO_BROADCAST( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR^ � s c C s | | _ d S( N( R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt set_reply_handler� s c C s | | _ d S( N( R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt set_timeout� s c C s� | d k r$ | d k r$ t d � n | j | � | rD | | � n | j j � } | j j | | j | j f � y d d l m } Wn t k r� d GHd } n Xd } g } | d k r� d � } | } n x"| j g g g } } } | rC| j d k r | | | | � \ } } } qC| | | | | j � \ } } } n | j | k rVPn | j j | � \ } } | j } | j | � | j � \ } } | | j k r�q� n | � } | j j � | j | | f � | j r� | j | | � q� q� W| S( Ns! non-null args with null pack_funci����( R� s. WARNING: select not found, broadcast will hangi c S s d S( N( ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt dummy� R8 ( Ra Ri Rj Rg R: Rc t sendtoR< R[ R� RC R� t recvfromRh Rt R7 R_ Rl t appendR� ( R R Rm Rn Ro R� R� R� t repliesR� R� R� R{ R� t fromaddrR� R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRq � sJ $ ( R R Rb R^ R� R� Rq ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s i�� io i i t PortMapperPackerc B s# e Z d � Z d � Z d � Z RS( c C sJ | \ } } } } | j | � | j | � | j | � | j | � d S( N( R ( R t mappingR R t protR[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_mapping� s c C s | j | | j � d S( N( t pack_listR� ( R t list( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_pmaplist� s c C sJ | \ } } } } | j | � | j | � | j | � | j | � d S( N( R R ( R t caR R R Rm ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_call_args� s ( R R R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s t PortMapperUnpackerc B s# e Z d � Z d � Z d � Z RS( c C s@ | j � } | j � } | j � } | j � } | | | | f S( N( R( ( R R R R� R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_mapping� s c C s | j | j � S( N( t unpack_listR� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_pmaplist s c C s" | j � } | j � } | | f S( N( R( R& ( R R[ t res( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_call_result s ( R R R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s t PartialPortMapperClientc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s t � | _ t d � | _ d S( NR8 ( R� Rg R� Rh ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR` s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_SETRg R� Rh R( ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Set s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_UNSETRg R� Rh R( ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Unset s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_GETPORTRg R� Rh R( ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Getport s c C s | j t d d | j j � S( N( Rq t PMAPPROC_DUMPRa Rh R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Dump! s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_CALLITRg R� Rh R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Callit& s ( R R R` R� R� R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� s t TCPPortMapperClientc B s e Z d � Z RS( c C s t j | | t t t � d S( N( R� Rb t PMAP_PROGt PMAP_VERSt PMAP_PORT( R R< ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb . s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� , s t UDPPortMapperClientc B s e Z d � Z RS( c C s t j | | t t t � d S( N( R� Rb R� R� R� ( R R< ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb 5 s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� 3 s t BroadcastUDPPortMapperClientc B s e Z d � Z RS( c C s t j | | t t t � d S( N( R� Rb R� R� R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb = s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� : s t TCPClientc B s e Z d � Z RS( c C sf t | � } | j | | t d f � } | j � | d k rI t d � n t j | | | | | � d S( Ni s program not registered( R� R� t IPPROTO_TCPRd R+ R� Rb ( R R< R R t pmapR[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb F s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� D s t UDPClientc B s e Z d � Z RS( c C sf t | � } | j | | t d f � } | j � | d k rI t d � n t j | | | | | � d S( Ni s program not registered( R� R� t IPPROTO_UDPRd R+ R� Rb ( R R< R R R� R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb Q s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� O s t BroadcastUDPClientc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sK t | � | _ | j j | j � | | _ | | _ d | _ | j � d S( N( R� R� R� t my_reply_handlerR R Ra t user_reply_handlerR` ( R R� R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb \ s c C s | j j � d S( N( R� Rd ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRd d s c C s | | _ d S( N( R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� g s c C s | j j | � d S( N( R� R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� j s c C sq | \ } } | j j | � | j � } | j j � | j j | | f � | j d k rm | j | | � n d S( N( Rh Rt Ro Rl R� R� R� Ra ( R R� R� R[ R� Rp ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� m s c C s� | j j � | r | | � n | d k rA d � } | | _ n | | _ g | _ | j j � } | j j | j | j | | f � } | j S( Nc S s d S( N( ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� { R8 ( Rg Rt Ra Ro R� R: R� R� R R ( R R Rm Rn Ro R� t packed_argst dummy_replies( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRq v s ( R R Rb Rd R� R� R� Rq ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� Z s t Serverc B sY e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sa | | _ | | _ | | _ | | _ | j � | j � | j j � \ | _ | _ | j � d S( N( R< R R R[ R\ R] Rc t getsocknameR` ( R R< R R R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb � s c C sL | j | j | j | j f } t | j � } | j | � sH t d � n d S( Ns register failed( R R R� R[ R� R< R� R+ ( R R� R> ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt register� s c C sL | j | j | j | j f } t | j � } | j | � sH t d � n d S( Ns unregister failed( R R R� R[ R� R< R� R+ ( R R� R> ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unregister� s c C s� | j j | � | j j � | j j � } | j j | � | j j � } | t k r[ d S| j j t � | j j � } | t k r� | j j t � | j j t � | j j t � | j j t � | j j � S| j j t � | j j t t � f � | j j � } | | j k r7| j j t � | j j � S| j j � } | | j k r�| j j t � | j j | j � | j j | j � | j j � S| j j � } d t | � } y t | | � } Wn+ t k r�| j j t � | j j � SX| j j � } | j j � } y | � Wn} t t f k r�| j j � | j j | � | j j t � | j j t � | j j t t � f � | j j t � n X| j j � S( Nt handle_( Rh Rt Rg R( R R% R Ra R R R, R- R: R R Ru R9 R R/ R R0 t reprt getattrt AttributeErrorR1 R' R� R# R2 ( R R� R R) R R R t methnamet methR R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt handle� s\ c C s? y | j j � Wn t k r* t � n X| j j t � d S( N( Rh Rl R+ R# Rg R R ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt turn_around� s c C s | j � d S( N( R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt handle_0� s c C s t d � d S( Ns makesocket not defined( R+ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ � s c C s | j j | j | j f � d S( N( Rc Rf R< R[ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR] � s c C s t � | _ t d � | _ d S( NR8 ( R Rg R$ Rh ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR` � s ( R R Rb R� R� R� R� R� R\ R] R` ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s 3 t TCPServerc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s( t j t j t j � | _ t | _ d S( N( RG R� R� Rc R� R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ � s c C s1 | j j d � x | j | j j � � q Wd S( Ni ( Rc t listent sessiont accept( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt loop� s c C s� | \ } \ } } xs y t | � } Wn1 t k r9 Pn t j k rX } d G| GHPn X| j | � } | d k r t | | � q q Wd S( Ns socket error:( R� R� RG R� R� Ra R ( R t connectionRc R< R[ R� R� R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s c C s1 | j j d � x | j | j j � � q Wd S( Ni ( Rc R� t forksessionR� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt forkingloop s c C s� d d l } y# x | j d d � \ } } q WWn | j k rE n Xd } z5 | j � } | rs | d j � d S| j | � Wd | d k r� | j d � n Xd S( Ni����i i ( RB t waitpidR� Ra t forkRd R� t _exit( R R� RB t pidt sts( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� s ( R R R\ R� R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s t UDPServerc B s# e Z d � Z d � Z d � Z RS( c C s( t j t j t j � | _ t | _ d S( N( RG R� R� Rc R� R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ & s c C s x | j � q Wd S( N( R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� * s c C sM | j j d � \ } } | j | � } | d k rI | j j | | � n d S( Ni ( Rc R� R� Ra R� ( R R� t host_portR� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� . s ( R R R\ R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� $ s c C sz t d � } | j � } | j � xQ | D]I \ } } } } | G| G| t k rV d Gn | t k ri d Gn | G| GHq) Wd S( NR8 t tcpt udp( R� R� t sortR� R� ( R� R� R R R� R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt test7 s c C s} d d l } | j d r) | j d } n d } d � } t | � } | j | � | j d � | j d d t d f � } d S( Ni����i s <broadcast>c S s# | \ } } | d t | � GHd S( Ns ( R� ( R� R� R< R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt rhK s i i�� i ( t syst argvR� R� R� R� R� ( R� R� R� R� R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt testbcastE s c C s� d t f d � � Y} | d d d d � } y | j � Wn t k r[ } d G| Gd GHn X| j � d GHz | j � Wd | j � d GHXd S( Nt Sc B s e Z d � Z RS( c S s@ | j j � } | j � d Gt | � GH| j j | | � d S( Ns RPC function 1 called, arg( Rh t unpack_stringR� R� Rg R ( R t arg( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt handle_1\ s ( R R R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� [ s R8 i i i s RuntimeError:s (ignored)s Service started...s Service interrupted.( R� R� R+ R� R� ( R� t sR� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt testsvrY s c C s~ d d l } | j d r) | j d } n d } d t f d � � Y} | | d d � } d GH| j d � } d Gt | � GHd S( Ni����i R8 t Cc B s e Z d � Z RS( c S s" | j d | | j j | j j � S( Ni ( Rq Rg R Rh R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt call_1v s ( R R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR u s i s making call...s hello, world, s call returned( R� R� R� R R� ( R� R< R t cR� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt testcltp s ( ( ( (I t xdrRG RB R R R Ru t AUTH_UNIXt AUTH_SHORTt AUTH_DESR R, R R/ R0 R1 R2 R- R. t AUTH_BADCREDt AUTH_REJECTEDCREDt AUTH_BADVERFt AUTH_REJECTEDVERFt AUTH_TOOWEAKR t ExceptionR! 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 ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt <module> s� %A Q '> 1c6 PK �"�\"��z� � nfsclient.pynu �[��� # NFS RPC client -- RFC 1094 # XXX This is not yet complete. # XXX Only GETATTR, SETTTR, LOOKUP and READDIR are supported. # (See mountclient.py for some hints on how to write RPC clients in # Python in general) import rpc from rpc import UDPClient, TCPClient from mountclient import FHSIZE, MountPacker, MountUnpacker NFS_PROGRAM = 100003 NFS_VERSION = 2 # enum stat NFS_OK = 0 # (...many error values...) # enum ftype NFNON = 0 NFREG = 1 NFDIR = 2 NFBLK = 3 NFCHR = 4 NFLNK = 5 class NFSPacker(MountPacker): def pack_sattrargs(self, sa): file, attributes = sa self.pack_fhandle(file) self.pack_sattr(attributes) def pack_sattr(self, sa): mode, uid, gid, size, atime, mtime = sa self.pack_uint(mode) self.pack_uint(uid) self.pack_uint(gid) self.pack_uint(size) self.pack_timeval(atime) self.pack_timeval(mtime) def pack_diropargs(self, da): dir, name = da self.pack_fhandle(dir) self.pack_string(name) def pack_readdirargs(self, ra): dir, cookie, count = ra self.pack_fhandle(dir) self.pack_uint(cookie) self.pack_uint(count) def pack_timeval(self, tv): secs, usecs = tv self.pack_uint(secs) self.pack_uint(usecs) class NFSUnpacker(MountUnpacker): def unpack_readdirres(self): status = self.unpack_enum() if status == NFS_OK: entries = self.unpack_list(self.unpack_entry) eof = self.unpack_bool() rest = (entries, eof) else: rest = None return (status, rest) def unpack_entry(self): fileid = self.unpack_uint() name = self.unpack_string() cookie = self.unpack_uint() return (fileid, name, cookie) def unpack_diropres(self): status = self.unpack_enum() if status == NFS_OK: fh = self.unpack_fhandle() fa = self.unpack_fattr() rest = (fh, fa) else: rest = None return (status, rest) def unpack_attrstat(self): status = self.unpack_enum() if status == NFS_OK: attributes = self.unpack_fattr() else: attributes = None return status, attributes def unpack_fattr(self): type = self.unpack_enum() mode = self.unpack_uint() nlink = self.unpack_uint() uid = self.unpack_uint() gid = self.unpack_uint() size = self.unpack_uint() blocksize = self.unpack_uint() rdev = self.unpack_uint() blocks = self.unpack_uint() fsid = self.unpack_uint() fileid = self.unpack_uint() atime = self.unpack_timeval() mtime = self.unpack_timeval() ctime = self.unpack_timeval() return (type, mode, nlink, uid, gid, size, blocksize, \ rdev, blocks, fsid, fileid, atime, mtime, ctime) def unpack_timeval(self): secs = self.unpack_uint() usecs = self.unpack_uint() return (secs, usecs) class NFSClient(UDPClient): def __init__(self, host): UDPClient.__init__(self, host, NFS_PROGRAM, NFS_VERSION) def addpackers(self): self.packer = NFSPacker() self.unpacker = NFSUnpacker('') def mkcred(self): if self.cred is None: self.cred = rpc.AUTH_UNIX, rpc.make_auth_unix_default() return self.cred def Getattr(self, fh): return self.make_call(1, fh, \ self.packer.pack_fhandle, \ self.unpacker.unpack_attrstat) def Setattr(self, sa): return self.make_call(2, sa, \ self.packer.pack_sattrargs, \ self.unpacker.unpack_attrstat) # Root() is obsolete def Lookup(self, da): return self.make_call(4, da, \ self.packer.pack_diropargs, \ self.unpacker.unpack_diropres) # ... def Readdir(self, ra): return self.make_call(16, ra, \ self.packer.pack_readdirargs, \ self.unpacker.unpack_readdirres) # Shorthand to get the entire contents of a directory def Listdir(self, dir): list = [] ra = (dir, 0, 2000) while 1: (status, rest) = self.Readdir(ra) if status <> NFS_OK: break entries, eof = rest last_cookie = None for fileid, name, cookie in entries: list.append((fileid, name)) last_cookie = cookie if eof or last_cookie is None: break ra = (ra[0], last_cookie, ra[2]) return list def test(): import sys if sys.argv[1:]: host = sys.argv[1] else: host = '' if sys.argv[2:]: filesys = sys.argv[2] else: filesys = None from mountclient import UDPMountClient, TCPMountClient mcl = TCPMountClient(host) if filesys is None: list = mcl.Export() for item in list: print item return sf = mcl.Mnt(filesys) print sf fh = sf[1] if fh: ncl = NFSClient(host) attrstat = ncl.Getattr(fh) print attrstat list = ncl.Listdir(fh) for item in list: print item mcl.Umnt(filesys) PK �"�\ 6O< rnusersclient.pyonu �[��� � ��^c @ s� d d l Z d d l m Z m Z m Z m Z d e f d � � YZ d e f d � � YZ d d d � � YZ d e e f d � � YZ d e e f d � � YZ d � Z d � Z d � Z e � d S( i����N( t Packert Unpackert UDPClientt BroadcastUDPClientt RnusersPackerc B s# e Z d � Z d � Z d � Z RS( c C sJ t \ } } } } | j | � | j | � | j | � | j | � d S( N( t utmpt pack_stringt pack_int( t selft uit ut_linet ut_namet ut_hostt ut_time( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt pack_utmp s c C s* | \ } } | j t � | j | � d S( N( R t ui_utmpt pack_uint( R R t ui_itmpt ui_idle( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt pack_utmpidle s c C s | j | | j � d S( N( t pack_arrayt pack_itmpidle( R t list( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt pack_utmpidlearr s ( t __name__t __module__R R R ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR s t RnusersUnpackerc B s# e Z d � Z d � Z d � Z RS( c C s@ | j � } | j � } | j � } | j � } | | | | f S( N( t unpack_stringt unpack_int( R R R R R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt unpack_utmp s c C s" | j � } | j � } | | f S( N( R t unpack_uint( R R R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt unpack_utmpidle s c C s | j | j � S( N( t unpack_arrayR ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt unpack_utmpidlearr! s ( R R R R R! ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR s t PartialRnusersClientc B s, e Z d � Z d � Z d � Z d � Z RS( c C s t � | _ t d � | _ d S( Nt ( R t packerR t unpacker( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt addpackers' s c C s | j d d d | j j � S( Ni ( t make_callt NoneR% R ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt Num+ s c C s | j d d d | j j � S( Ni ( R' R( R% R! ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt Names. s c C s | j d d d | j j � S( Ni ( R' R( R% R! ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt Allnames2 s ( R R R& R) R* R+ ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR" % s t RnusersClientc B s e Z d � Z RS( c C s t j | | d d � d S( Ni�� i ( R t __init__( R t host( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR- 9 s ( R R R- ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR, 7 s t BroadcastRnusersClientc B s e Z d � Z RS( c C s t j | | d d � d S( Ni�� i ( R R- ( R t bcastaddr( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR- ? s ( R R R- ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR/ = s c C s� d d l } | j d s$ t � d S| j d } t | � } | j � } x\ | D]T \ \ } } } } } t | � } t | � } t | � } d | | | | | f GHqP Wd S( Ni����i s %r %r %r %s %s( t syst argvt testbcastR, R* t strip0( R1 R. t cR t linet namet timet idle( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt testC s c C sA t d � } d � } | j | � | j � } d Gt | � GHd S( Ns <broadcast>c S sF | \ } } | d Gx* | D]" \ \ } } } } } t | � Gq WHd S( Ns :( R4 ( R t fromaddrR. t portR6 R7 R8 R9 ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt listitT s s Total Count:( R/ t set_reply_handlerR* t len( R5 R= t all( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR3 R s c C s+ x$ | r& | d d k r& | d } q W| S( Ni����s ( ( t s( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR4 ^ s ( ( t rpcR R R R R R R" R, R/ R: R3 R4 ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt <module> s " PK �"�\W��j� � READMEnu �[��� This is a Python interface to Sun RPC, designed and implemented mostly by reading the Internet RFCs about the subject. *** NOTE: xdr.py has evolved into the standard module xdrlib.py *** There are two library modules, xdr.py and rpc.py, and several example clients: mountclient.py, nfsclient.py, and rnusersclient.py, implementing the NFS Mount protocol, (part of) the NFS protocol, and the "rnusers" protocol (used by rusers(1)), respectively. The latter demonstrates the use of broadcast via the Port mapper's CALLIT procedure. There is also a way to create servers in Python. To test the nfs client, run it from the shell with something like this: python -c 'import nfsclient; nfsclient.test()' [hostname [filesystemname]] When called without a filesystemname, it lists the filesystems at the host; default host is the local machine. Other clients are tested similarly. For hostname, use e.g. wuarchive.wustl.edu or gatekeeper.dec.com (two hosts that are known to export NFS filesystems with little restrictions). There are now two different RPC compilers: 1) Wim Lewis rpcgen.py found on http://www.omnigroup.com/~wiml/soft/stale-index.html#python. 2) Peter �strands rpcgen.py, which is part of "pynfs" (http://www.cendio.se/~peter/pynfs/). PK �"�\ x�}�v �v rpc.pyonu �[��� � ��^c @ s= d d l Z d d l Z d d l 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 j f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e j f d � � YZ d � Z d � Z d � Z d a! d � Z" d dC 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$ Z0 d Z1 d Z2 d Z3 d Z4 d Z5 d Z6 d% Z7 d& Z8 d' e f d( � � YZ9 d) e f d* � � YZ: d+ dD d, � � YZ; d- e; e+ f d. � � YZ< d/ e; e, f d0 � � YZ= d1 e; e- f d2 � � YZ> d3 e+ f d4 � � YZ? d5 e, f d6 � � YZ@ d7 e# f d8 � � YZA d9 dE d: � � YZB d; eB f d< � � YZC d= eB f d> � � YZD d? � ZE d@ � ZF dA � ZG dB � ZH d S(F i����Ni i i i i i t Packerc B s, e Z d � Z d � Z d � Z d � Z RS( c C s* | \ } } | j | � | j | � d S( N( t pack_enumt pack_opaque( t selft autht flavort stuff( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_auth0 s c C si | j | � | j | � | j | � | j | � | j t | � � x | D] } | j | � qN Wd S( N( t pack_uintt pack_stringt len( R t stampt machinenamet uidt gidt gidst i( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_auth_unix5 s c C sl | j | � | j t � | j t � | j | � | j | � | j | � | j | � | j | � d S( N( R R t CALLt RPCVERSIONR ( R t xidt progt verst proct credt verf( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_callheader> s c C sE | j | � | j t � | j t � | j | � | j t � d S( N( R R t REPLYt MSG_ACCEPTEDR t SUCCESS( R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_replyheaderI s ( t __name__t __module__R R R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR . s t BadRPCFormatc B s e Z RS( ( R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR! S s t BadRPCVersionc B s e Z RS( ( R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR" T s t GarbageArgsc B s e Z RS( ( R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR# U s t Unpackerc B s# e Z d � Z d � Z d � Z RS( c C s" | j � } | j � } | | f S( N( t unpack_enumt unpack_opaque( R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_authY s c C s� | j � } | j � } | t k r7 t d | f � n | j � } | t k rb t d | f � n | j � } | j � } | j � } | j � } | j � } | | | | | | f S( Ns no CALL but %rs bad RPC version %r( t unpack_uintR% R R! R R" R' ( R R t tempR R R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_callheader^ s c C s� | j � } | j � } | t k r7 t d | f � n | j � } | t k r� | j � } | t k r� | j � } | j � } t d | | f f � n | t k r� | j � } t d | f � n t d | f � n | t k r� t d | f � n | j � } | j � } | t k r%t d � n | t k rb| j � } | j � } t d | | f f � n | t k rzt d � n | t k r�t d � n | t k r�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 t RuntimeErrort MSG_DENIEDt RPC_MISMATCHt AUTH_ERRORR R' t PROG_UNAVAILt PROG_MISMATCHt PROC_UNAVAILt GARBAGE_ARGSR ( R R t mtypet statt lowt highR ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_replyheadern sH ( R R R' R* R7 ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR$ W s c C s d S( Nt ( ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_auth_null� s c C s, t � } | j | | | | | � | j � S( N( R R t get_buf( t seedt hostR R t groupst p( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_auth_unix� s c C s� y, d d l m } m } | � } | � } Wn t k rI d } } n Xd d l } t t | j � t � � t j � | | g � S( Ni����( t getuidt getgidi ( t osR@ RA t ImportErrort timeR? t intt unix_epocht sockett gethostname( R@ RA R R RD ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_auth_unix_default� s c C s t d k r t Sd d l } | j � } | j | � } | j | � } | j | � | j | � } d \ } } } } } } t | | d � \ } } t | | d � \ } } t | | d � \ } } | | } | j | | | | | | d d d f � a d G| j 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 i����Ni� i i< i s Unix epoch:( i� i i i i i ( t _unix_epochRD t localtimet gmtimet mktimet divmodt ctime( RD t nowt localtt gmtt offsett yt mt dt hht mmt ss( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRF � s *t Clientc B st e 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( c C sk | | _ | | _ | | _ | | _ | j � | j � | j � d | _ | j � d | _ d | _ d S( Ni ( R< R R t portt makesockett bindsockett connsockett lastxidt addpackerst NoneR R ( R R< R R R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt __init__� s c C s | j j � d S( N( t sockt close( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRd � s c C s t d � d S( Ns makesocket not defined( R+ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ � s c C s | j j | j | j f � d S( N( Rc t connectR< R[ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR^ � s c C s | j j d � d S( NR8 i ( R8 i ( Rc t bind( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR] � s c C s t � | _ t d � | _ d S( NR8 ( R t packerR$ t unpacker( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR` � s c C sw | d k r$ | d k r$ t d � n | j | � | rD | | � n | j � | r` | � } n d } | j j � | S( Ns! non-null args with null pack_func( Ra t TypeErrort start_callt do_callRh t done( R R t argst pack_funct unpack_funct result( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt make_call� s c C se | j d | _ } | j � } | j � } | j } | j � | j | | j | j | | | � d S( Ni ( R_ t mkcredt mkverfRg t resetR R R ( R R R R R R> ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRj � s c C s t d � d S( Ns do_call not defined( R+ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRk s c C s+ | j d k r$ t t � f | _ n | j S( N( R Ra t AUTH_NULLR9 ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRr s c C s+ | j d k r$ t t � f | _ n | j S( N( R Ra Ru R9 ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRs s c C s | j d d d d � S( Ni ( Rq Ra ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt call_0 s ( R R Rb Rd R\ R^ R] R` Rq Rj Rk Rr Rs Rv ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRZ � s c C s� t | � } | r | d B} n t t | d ?d @� � t t | d ?d @� � t t | d ?d @� � t t | d @� � } | j | | � d S( Nl i i� i i ( R t chrRE t send( Rc t lastt fragt xt header( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt sendfrag s ^c C s t | d | � d S( Ni ( R} ( Rc t record( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt sendrecord" s c C s� | j d � } t | � d k r* t � n t t | d � � d >t | d � d >Bt | d � d >Bt | d � B} | d @d k } t | d @� } d } xH | d k r� | j | � } | s� t � n | t | � } | | } q� W| | f S( Ni i i i i i i i I � i���R8 ( t recvR t EOFErrort longt ordRE ( Rc R| R{ Ry t nRz t buf( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt recvfrag% s L c C s9 d } d } x& | s4 t | � \ } } | | } q W| S( NR8 i ( R� ( Rc R~ Ry Rz ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt recvrecord5 s c C s� d \ } } t d k r? d d l } | | j � | | a n x� t t | � t | t � D]g } | a y | j | | f � t SWq\ t j k r� \ } } | d k r� t j | | f � q� q\ Xq\ Wt d � d S( NiX i i����ir s can't assign reserved port( iX i ( t last_resv_port_triedRa RB t getpidt rangeRf RG t errorR+ ( Rc R< t FIRSTt LASTRB R t errnot msg( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt bindresvportA s t RawTCPClientc B s e Z d � Z d � Z RS( c C s t j t j t j � | _ d S( N( RG t AF_INETt SOCK_STREAMRc ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ W s c C s� | j j � } t | j | � t | j � } | j } | j | � | j � \ } } | | j k r~ t d | | j f � n d S( Ns# wrong xid in reply %r instead of %r( Rg R: R Rc R� Rh Rt R7 R_ R+ ( R t callt replyt uR R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRk Z s ( R R R\ Rk ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� U s t RawUDPClientc B s e Z d � Z d � Z RS( c C s t j t j t j � | _ d S( N( RG R� t SOCK_DGRAMRc ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ k s c C s` | j j � } | j j | � y d d l m } Wn t k rQ d GHd } n Xd } d } d } x� | j g g g } } } | r� | | | | | � \ } } } n | j | k r| d } | d k r� t d � n | d k r� | d } n | j j | � qg n | j j | � } | j } | j | � | j � \ } } | | j k rWqg n Pqg Wd S( Ni����( t selects' WARNING: select not found, RPC may hangi i i i t timeouti i ( Rg R: Rc Rx R� RC Ra R+ R� Rh Rt R7 R_ ( R R� R� t BUFSIZER� t countt rt wR{ R� R� R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRk n s: ! ( R R R\ Rk ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� i s t RawBroadcastUDPClientc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s/ t j | | | | | � d | _ d | _ d S( Ni ( R� Rb Ra t reply_handlerR� ( R t bcastaddrR R R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb � s c C s | j j t j t j d � d S( Ni ( Rc t setsockoptRG t SOL_SOCKETt SO_BROADCAST( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR^ � s c C s | | _ d S( N( R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt set_reply_handler� s c C s | | _ d S( N( R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt set_timeout� s c C s� | d k r$ | d k r$ t d � n | j | � | rD | | � n | j j � } | j j | | j | j f � y d d l m } Wn t k r� d GHd } n Xd } g } | d k r� d � } | } n x"| j g g g } } } | rC| j d k r | | | | � \ } } } qC| | | | | j � \ } } } n | j | k rVPn | j j | � \ } } | j } | j | � | j � \ } } | | j k r�q� n | � } | j j � | j | | f � | j r� | j | | � q� q� W| S( Ns! non-null args with null pack_funci����( R� s. WARNING: select not found, broadcast will hangi c S s d S( N( ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt dummy� R8 ( Ra Ri Rj Rg R: Rc t sendtoR< R[ R� RC R� t recvfromRh Rt R7 R_ Rl t appendR� ( R R Rm Rn Ro R� R� R� t repliesR� R� R� R{ R� t fromaddrR� R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRq � sJ $ ( R R Rb R^ R� R� Rq ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s i�� io i i t PortMapperPackerc B s# e Z d � Z d � Z d � Z RS( c C sJ | \ } } } } | j | � | j | � | j | � | j | � d S( N( R ( R t mappingR R t protR[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_mapping� s c C s | j | | j � d S( N( t pack_listR� ( R t list( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_pmaplist� s c C sJ | \ } } } } | j | � | j | � | j | � | j | � d S( N( R R ( R t caR R R Rm ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt pack_call_args� s ( R R R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s t PortMapperUnpackerc B s# e Z d � Z d � Z d � Z RS( c C s@ | j � } | j � } | j � } | j � } | | | | f S( N( R( ( R R R R� R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_mapping� s c C s | j | j � S( N( t unpack_listR� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_pmaplist s c C s" | j � } | j � } | | f S( N( R( R& ( R R[ t res( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unpack_call_result s ( R R R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s t PartialPortMapperClientc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s t � | _ t d � | _ d S( NR8 ( R� Rg R� Rh ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR` s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_SETRg R� Rh R( ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Set s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_UNSETRg R� Rh R( ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Unset s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_GETPORTRg R� Rh R( ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Getport s c C s | j t d d | j j � S( N( Rq t PMAPPROC_DUMPRa Rh R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Dump! s c C s" | j t | | j j | j j � S( N( Rq t PMAPPROC_CALLITRg R� Rh R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt Callit& s ( R R R` R� R� R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� s t TCPPortMapperClientc B s e Z d � Z RS( c C s t j | | t t t � d S( N( R� Rb t PMAP_PROGt PMAP_VERSt PMAP_PORT( R R< ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb . s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� , s t UDPPortMapperClientc B s e Z d � Z RS( c C s t j | | t t t � d S( N( R� Rb R� R� R� ( R R< ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb 5 s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� 3 s t BroadcastUDPPortMapperClientc B s e Z d � Z RS( c C s t j | | t t t � d S( N( R� Rb R� R� R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb = s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� : s t TCPClientc B s e Z d � Z RS( c C sf t | � } | j | | t d f � } | j � | d k rI t d � n t j | | | | | � d S( Ni s program not registered( R� R� t IPPROTO_TCPRd R+ R� Rb ( R R< R R t pmapR[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb F s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� D s t UDPClientc B s e Z d � Z RS( c C sf t | � } | j | | t d f � } | j � | d k rI t d � n t j | | | | | � d S( Ni s program not registered( R� R� t IPPROTO_UDPRd R+ R� Rb ( R R< R R R� R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb Q s ( R R Rb ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� O s t BroadcastUDPClientc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sK t | � | _ | j j | j � | | _ | | _ d | _ | j � d S( N( R� R� R� t my_reply_handlerR R Ra t user_reply_handlerR` ( R R� R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb \ s c C s | j j � d S( N( R� Rd ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRd d s c C s | | _ d S( N( R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� g s c C s | j j | � d S( N( R� R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� j s c C sq | \ } } | j j | � | j � } | j j � | j j | | f � | j d k rm | j | | � n d S( N( Rh Rt Ro Rl R� R� R� Ra ( R R� R� R[ R� Rp ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� m s c C s� | j j � | r | | � n | d k rA d � } | | _ n | | _ g | _ | j j � } | j j | j | j | | f � } | j S( Nc S s d S( N( ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� { R8 ( Rg Rt Ra Ro R� R: R� R� R R ( R R Rm Rn Ro R� t packed_argst dummy_replies( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRq v s ( R R Rb Rd R� R� R� Rq ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� Z s t Serverc B sY e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sa | | _ | | _ | | _ | | _ | j � | j � | j j � \ | _ | _ | j � d S( N( R< R R R[ R\ R] Rc t getsocknameR` ( R R< R R R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyRb � s c C sL | j | j | j | j f } t | j � } | j | � sH t d � n d S( Ns register failed( R R R� R[ R� R< R� R+ ( R R� R> ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt register� s c C sL | j | j | j | j f } t | j � } | j | � sH t d � n d S( Ns unregister failed( R R R� R[ R� R< R� R+ ( R R� R> ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt unregister� s c C s� | j j | � | j j � | j j � } | j j | � | j j � } | t k r[ d S| j j t � | j j � } | t k r� | j j t � | j j t � | j j t � | j j t � | j j � S| j j t � | j j t t � f � | j j � } | | j k r7| j j t � | j j � S| j j � } | | j k r�| j j t � | j j | j � | j j | j � | j j � S| j j � } d t | � } y t | | � } Wn+ t k r�| j j t � | j j � SX| j j � } | j j � } y | � Wn} t t f k r�| j j � | j j | � | j j t � | j j t � | j j t t � f � | j j t � n X| j j � S( Nt handle_( Rh Rt Rg R( R R% R Ra R R R, R- R: R R Ru R9 R R/ R R0 t reprt getattrt AttributeErrorR1 R' R� R# R2 ( R R� R R) R R R t methnamet methR R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt handle� s\ c C s? y | j j � Wn t k r* t � n X| j j t � d S( N( Rh Rl R+ R# Rg R R ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt turn_around� s c C s | j � d S( N( R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt handle_0� s c C s t d � d S( Ns makesocket not defined( R+ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ � s c C s | j j | j | j f � d S( N( Rc Rf R< R[ ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR] � s c C s t � | _ t d � | _ d S( NR8 ( R Rg R$ Rh ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR` � s ( R R Rb R� R� R� R� R� R\ R] R` ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s 3 t TCPServerc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s( t j t j t j � | _ t | _ d S( N( RG R� R� Rc R� R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ � s c C s1 | j j d � x | j | j j � � q Wd S( Ni ( Rc t listent sessiont accept( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt loop� s c C s� | \ } \ } } xs y t | � } Wn1 t k r9 Pn t j k rX } d G| GHPn X| j | � } | d k r t | | � q q Wd S( Ns socket error:( R� R� RG R� R� Ra R ( R t connectionRc R< R[ R� R� R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s c C s1 | j j d � x | j | j j � � q Wd S( Ni ( Rc R� t forksessionR� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt forkingloop s c C s� d d l } y# x | j d d � \ } } q WWn | j k rE n Xd } z5 | j � } | rs | d j � d S| j | � Wd | d k r� | j d � n Xd S( Ni����i i ( RB t waitpidR� Ra t forkRd R� t _exit( R R� RB t pidt sts( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� s ( R R R\ R� R� R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� � s t UDPServerc B s# e Z d � Z d � Z d � Z RS( c C s( t j t j t j � | _ t | _ d S( N( RG R� R� Rc R� R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR\ & s c C s x | j � q Wd S( N( R� ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� * s c C sM | j j d � \ } } | j | � } | d k rI | j j | | � n d S( Ni ( Rc R� R� Ra R� ( R R� t host_portR� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� . s ( R R R\ R� R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� $ s c C sz t d � } | j � } | j � xQ | D]I \ } } } } | G| G| t k rV d Gn | t k ri d Gn | G| GHq) Wd S( NR8 t tcpt udp( R� R� t sortR� R� ( R� R� R R R� R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt test7 s c C s} d d l } | j d r) | j d } n d } d � } t | � } | j | � | j d � | j d d t d f � } d S( Ni����i s <broadcast>c S s# | \ } } | d t | � GHd S( Ns ( R� ( R� R� R< R[ ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt rhK s i i�� i ( t syst argvR� R� R� R� R� ( R� R� R� R� R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt testbcastE s c C s� d t f d � � Y} | d d d d � } y | j � Wn t k r[ } d G| Gd GHn X| j � d GHz | j � Wd | j � d GHXd S( Nt Sc B s e Z d � Z RS( c S s@ | j j � } | j � d Gt | � GH| j j | | � d S( Ns RPC function 1 called, arg( Rh t unpack_stringR� R� Rg R ( R t arg( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt handle_1\ s ( R R R� ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR� [ s R8 i i i s RuntimeError:s (ignored)s Service started...s Service interrupted.( R� R� R+ R� R� ( R� t sR� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt testsvrY s c C s~ d d l } | j d r) | j d } n d } d t f d � � Y} | | d d � } d GH| j d � } d Gt | � GHd S( Ni����i R8 t Cc B s e Z d � Z RS( c S s" | j d | | j j | j j � S( Ni ( Rq Rg R Rh R� ( R R� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt call_1v s ( R R R ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyR u s i s making call...s hello, world, s call returned( R� R� R� R R� ( R� R< R t cR� ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt testcltp s ( ( ( (I t xdrRG RB R R R Ru t AUTH_UNIXt AUTH_SHORTt AUTH_DESR R, R R/ R0 R1 R2 R- R. t AUTH_BADCREDt AUTH_REJECTEDCREDt AUTH_BADVERFt AUTH_REJECTEDVERFt AUTH_TOOWEAKR t ExceptionR! 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 ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/rpc.pyt <module> s� %A Q '> 1c6 PK �"�\},�� � xdr.pynu �[��� # Implement (a subset of) Sun XDR -- RFC1014. try: import struct except ImportError: struct = None Long = type(0L) class Packer: def __init__(self): self.reset() def reset(self): self.buf = '' def get_buf(self): return self.buf def pack_uint(self, x): self.buf = self.buf + \ (chr(int(x>>24 & 0xff)) + chr(int(x>>16 & 0xff)) + \ chr(int(x>>8 & 0xff)) + chr(int(x & 0xff))) if struct and struct.pack('l', 1) == '\0\0\0\1': def pack_uint(self, x): if type(x) == Long: x = int((x + 0x80000000L) % 0x100000000L \ - 0x80000000L) self.buf = self.buf + struct.pack('l', x) pack_int = pack_uint pack_enum = pack_int def pack_bool(self, x): if x: self.buf = self.buf + '\0\0\0\1' else: self.buf = self.buf + '\0\0\0\0' def pack_uhyper(self, x): self.pack_uint(int(x>>32 & 0xffffffff)) self.pack_uint(int(x & 0xffffffff)) pack_hyper = pack_uhyper def pack_float(self, x): # XXX self.buf = self.buf + struct.pack('f', x) def pack_double(self, x): # XXX self.buf = self.buf + struct.pack('d', x) def pack_fstring(self, n, s): if n < 0: raise ValueError, 'fstring size must be nonnegative' n = ((n + 3)//4)*4 data = s[:n] data = data + (n - len(data)) * '\0' self.buf = self.buf + data pack_fopaque = pack_fstring def pack_string(self, s): n = len(s) self.pack_uint(n) self.pack_fstring(n, s) pack_opaque = pack_string def pack_list(self, list, pack_item): for item in list: self.pack_uint(1) pack_item(item) self.pack_uint(0) def pack_farray(self, n, list, pack_item): if len(list) <> n: raise ValueError, 'wrong array size' for item in list: pack_item(item) def pack_array(self, list, pack_item): n = len(list) self.pack_uint(n) self.pack_farray(n, list, pack_item) class Unpacker: def __init__(self, data): self.reset(data) def reset(self, data): self.buf = data self.pos = 0 def done(self): if self.pos < len(self.buf): raise RuntimeError, 'unextracted data remains' def unpack_uint(self): i = self.pos self.pos = j = i+4 data = self.buf[i:j] if len(data) < 4: raise EOFError x = long(ord(data[0]))<<24 | ord(data[1])<<16 | \ ord(data[2])<<8 | ord(data[3]) # Return a Python long only if the value is not representable # as a nonnegative Python int if x < 0x80000000L: x = int(x) return x if struct and struct.unpack('l', '\0\0\0\1') == 1: def unpack_uint(self): i = self.pos self.pos = j = i+4 data = self.buf[i:j] if len(data) < 4: raise EOFError return struct.unpack('l', data) def unpack_int(self): x = self.unpack_uint() if x >= 0x80000000L: x = x - 0x100000000L return int(x) unpack_enum = unpack_int unpack_bool = unpack_int def unpack_uhyper(self): hi = self.unpack_uint() lo = self.unpack_uint() return long(hi)<<32 | lo def unpack_hyper(self): x = self.unpack_uhyper() if x >= 0x8000000000000000L: x = x - 0x10000000000000000L return x def unpack_float(self): # XXX i = self.pos self.pos = j = i+4 data = self.buf[i:j] if len(data) < 4: raise EOFError return struct.unpack('f', data)[0] def unpack_double(self): # XXX i = self.pos self.pos = j = i+8 data = self.buf[i:j] if len(data) < 8: raise EOFError return struct.unpack('d', data)[0] def unpack_fstring(self, n): if n < 0: raise ValueError, 'fstring size must be nonnegative' i = self.pos j = i + (n+3)//4*4 if j > len(self.buf): raise EOFError self.pos = j return self.buf[i:i+n] unpack_fopaque = unpack_fstring def unpack_string(self): n = self.unpack_uint() return self.unpack_fstring(n) unpack_opaque = unpack_string def unpack_list(self, unpack_item): list = [] while 1: x = self.unpack_uint() if x == 0: break if x <> 1: raise RuntimeError, '0 or 1 expected, got %r' % (x, ) item = unpack_item() list.append(item) return list def unpack_farray(self, n, unpack_item): list = [] for i in range(n): list.append(unpack_item()) return list def unpack_array(self, unpack_item): n = self.unpack_uint() return self.unpack_farray(n, unpack_item) PK �"�\?��� � testnu �[��� : ${PYTHON=python} : ${SERVER=charon.cwi.nl} set -xe $PYTHON -c 'from rpc import test; test()' $PYTHON -c 'from rpc import test; test()' ${SERVER} $PYTHON -c 'from rpc import testsvr; testsvr()' & PID=$! sleep 2 $PYTHON -c 'from rpc import testclt; testclt()' kill -2 $PID $PYTHON -c 'from mountclient import test; test()' $PYTHON -c 'from mountclient import test; test()' gatekeeper.dec.com $PYTHON -c 'from nfsclient import test; test()' $PYTHON -c 'from nfsclient import test; test()' gatekeeper.dec.com $PYTHON -c 'from nfsclient import test; test()' gatekeeper.dec.com /archive $PYTHON -c 'from rnusersclient import test; test()' '' $PYTHON -c 'from rpc import testbcast; testbcast()' PK �"�\��A)E E rnusersclient.pynu �[��� # Remote nusers client interface import rpc from rpc import Packer, Unpacker, UDPClient, BroadcastUDPClient class RnusersPacker(Packer): def pack_utmp(self, ui): ut_line, ut_name, ut_host, ut_time = utmp self.pack_string(ut_line) self.pack_string(ut_name) self.pack_string(ut_host) self.pack_int(ut_time) def pack_utmpidle(self, ui): ui_itmp, ui_idle = ui self.pack_utmp(ui_utmp) self.pack_uint(ui_idle) def pack_utmpidlearr(self, list): self.pack_array(list, self.pack_itmpidle) class RnusersUnpacker(Unpacker): def unpack_utmp(self): ut_line = self.unpack_string() ut_name = self.unpack_string() ut_host = self.unpack_string() ut_time = self.unpack_int() return ut_line, ut_name, ut_host, ut_time def unpack_utmpidle(self): ui_utmp = self.unpack_utmp() ui_idle = self.unpack_uint() return ui_utmp, ui_idle def unpack_utmpidlearr(self): return self.unpack_array(self.unpack_utmpidle) class PartialRnusersClient: def addpackers(self): self.packer = RnusersPacker() self.unpacker = RnusersUnpacker('') def Num(self): return self.make_call(1, None, None, self.unpacker.unpack_int) def Names(self): return self.make_call(2, None, \ None, self.unpacker.unpack_utmpidlearr) def Allnames(self): return self.make_call(3, None, \ None, self.unpacker.unpack_utmpidlearr) class RnusersClient(PartialRnusersClient, UDPClient): def __init__(self, host): UDPClient.__init__(self, host, 100002, 2) class BroadcastRnusersClient(PartialRnusersClient, BroadcastUDPClient): def __init__(self, bcastaddr): BroadcastUDPClient.__init__(self, bcastaddr, 100002, 2) def test(): import sys if not sys.argv[1:]: testbcast() return else: host = sys.argv[1] c = RnusersClient(host) list = c.Names() for (line, name, host, time), idle in list: line = strip0(line) name = strip0(name) host = strip0(host) print "%r %r %r %s %s" % (name, host, line, time, idle) def testbcast(): c = BroadcastRnusersClient('<broadcast>') def listit(list, fromaddr): host, port = fromaddr print host + '\t:', for (line, name, host, time), idle in list: print strip0(name), print c.set_reply_handler(listit) all = c.Names() print 'Total Count:', len(all) def strip0(s): while s and s[-1] == '\0': s = s[:-1] return s test() PK �"�\��:� � T.pyonu �[��� � ��^c @ s: d d l Z d d l Z d d l Z d � Z d � Z d S( i����Nc C s9 t j � \ } } } } | | | | t j � f a d S( N( t ost timest timet t0( t ut st cut cs( ( s" /usr/lib64/python2.7/Demo/rpc/T.pyt TSTART s c G s� t j � \ } } } } | | | | t j � f a g } x- t d � D] } | j t | t | � qH W| \ } } } d } x | D] } | | d } q� W| d | | | f } t j j | � d S( Ni t t s %r user, %r sys, %r real ( R R R t t1t ranget appendR t syst stderrt write( t labelR R R R t ttt it rt msgt x( ( s" /usr/lib64/python2.7/Demo/rpc/T.pyt TSTOP s ( R R R R R ( ( ( s" /usr/lib64/python2.7/Demo/rpc/T.pyt <module> s $ PK �"�\�yOGi i MANIFESTnu �[��� File Name Archive # Description ----------------------------------------------------------- MANIFEST 1 This shipping list README 1 T.py 1 mountclient.py 1 nfsclient.py 1 rpc.py 1 test 1 xdr.py 1 PK �"�\���� � xdr.pycnu �[��� � ��^c @ s` y d d l Z Wn e k r) d Z n Xe d � Z d d d � � YZ d d d � � YZ d S( i����Nl t Packerc B s� e Z d � Z d � Z d � Z d � Z e rT e j d d � d k rT d � Z n e Z e Z d � Z d � Z e Z d � Z d � Z d � Z e Z d � Z e Z d � Z d � Z d � Z RS( c C s | j � d S( N( t reset( t self( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt __init__ s c C s d | _ d S( Nt ( t buf( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR s c C s | j S( N( R ( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt get_buf s c C sl | j t t | d ?d @� � t t | d ?d @� � t t | d ?d @� � t t | d @� � | _ d S( Ni i� i i ( R t chrt int( R t x( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_uint s t li s c C sM t | � t k r- t | d d d � } n | j t j d | � | _ d S( Nl l R ( t typet LongR R t structt pack( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR s c C s- | r | j d | _ n | j d | _ d S( Ns s ( R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_bool' s c C s6 | j t | d ?d @� � | j t | d @� � d S( Ni I���� ( R R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_uhyper+ s c C s | j t j d | � | _ d S( Nt f( R R R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_float1 s c C s | j t j d | � | _ d S( Nt d( R R R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_double5 s c C s` | d k r t d � n | d d d } | | } | | t | � d } | j | | _ d S( Ni s fstring size must be nonnegativei i s ( t ValueErrort lenR ( R t nt st data( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_fstring9 s c C s- t | � } | j | � | j | | � d S( N( R R R ( R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_stringC s c C s9 x% | D] } | j d � | | � q W| j d � d S( Ni i ( R ( R t listt pack_itemt item( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_listJ s c C s= t | � | k r t d � n x | D] } | | � q% Wd S( Ns wrong array size( R R ( R R R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_farrayP s c C s0 t | � } | j | � | j | | | � d S( N( R R R! ( R R R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt pack_arrayV s ( t __name__t __module__R R R R R R t pack_intt pack_enumR R t pack_hyperR R R t pack_fopaqueR t pack_opaqueR R! R" ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR s( t Unpackerc B s� e Z d � Z d � Z d � Z d � Z e rT e j d d � d k rT d � Z n d � Z e Z e Z d � Z d � Z d � Z d � Z d � Z e Z d � Z e Z d � Z d � Z d � Z RS( c C s | j | � d S( N( R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR ^ s c C s | | _ d | _ d S( Ni ( R t pos( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR a s c C s( | j t | j � k r$ t d � n d S( Ns unextracted data remains( R+ R R t RuntimeError( R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt donee s c C s� | j } | d | _ } | j | | !} t | � d k rE t � n t t | d � � d >t | d � d >Bt | d � d >Bt | d � B} | d k r� t | � } n | S( Ni i i i i i i i l ( R+ R R t EOFErrort longt ordR ( R t it jR R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_uinti s L R s i c C sU | j } | d | _ } | j | | !} t | � d k rE t � n t j d | � S( Ni R ( R+ R R R. R t unpack( R R1 R2 R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR3 v s c C s/ | j � } | d k r% | d } n t | � S( Nl l ( R3 R ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_int~ s c C s* | j � } | j � } t | � d >| BS( Ni ( R3 R/ ( R t hit lo( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_uhyper� s c C s) | j � } | d k r% | d } n | S( Nl l ( R8 ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_hyper� s c C sY | j } | d | _ } | j | | !} t | � d k rE t � n t j d | � d S( Ni R i ( R+ R R R. R R4 ( R R1 R2 R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_float� s c C sY | j } | d | _ } | j | | !} t | � d k rE t � n t j d | � d S( Ni R i ( R+ R R R. R R4 ( R R1 R2 R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_double� s c C sp | d k r t d � n | j } | | d d d } | t | j � k rU t � n | | _ | j | | | !S( Ni s fstring size must be nonnegativei i ( R R+ R R R. ( R R R1 R2 ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_fstring� s c C s | j � } | j | � S( N( R3 R< ( R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_string� s c C sb g } xU | j � } | d k r% Pn | d k rD t d | f � n | � } | j | � q W| S( Ni i s 0 or 1 expected, got %r( R3 R, t append( R t unpack_itemR R R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_list� s c C s1 g } x$ t | � D] } | j | � � q W| S( N( t rangeR> ( R R R? R R1 ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_farray� s c C s | j � } | j | | � S( N( R3 RB ( R R? R ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt unpack_array� s ( R# R$ R R R- R3 R R4 R5 t unpack_enumt unpack_boolR8 R9 R: R; R< t unpack_fopaqueR= t unpack_opaqueR@ RB RC ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyR* \ s( ( ( ( R t ImportErrort NoneR R R R* ( ( ( s$ /usr/lib64/python2.7/Demo/rpc/xdr.pyt <module> s OPK �"�\�r�� � nfsclient.pycnu �[��� � ��^c @ s� d d l Z d d l m Z m Z d d l m Z m Z m Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d � Z d S( i����N( t UDPClientt TCPClient( t FHSIZEt MountPackert MountUnpackeri�� i i i i i i t NFSPackerc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s* | \ } } | j | � | j | � d S( N( t pack_fhandlet pack_sattr( t selft sat filet attributes( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt pack_sattrargs s c C sj | \ } } } } } } | j | � | j | � | j | � | j | � | j | � | j | � d S( N( t pack_uintt pack_timeval( R R t modet uidt gidt sizet atimet mtime( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR $ s c C s* | \ } } | j | � | j | � d S( N( R t pack_string( R t dat dirt name( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt pack_diropargs- s c C s: | \ } } } | j | � | j | � | j | � d S( N( R R ( R t raR t cookiet count( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt pack_readdirargs2 s c C s* | \ } } | j | � | j | � d S( N( R ( R t tvt secst usecs( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR 8 s ( t __name__t __module__R R R R R ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR s t NFSUnpackerc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sU | j � } | t k rE | j | j � } | j � } | | f } n d } | | f S( N( t unpack_enumt NFS_OKt unpack_listt unpack_entryt unpack_boolt None( R t statust entriest eoft rest( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt unpack_readdirres@ s c C s1 | j � } | j � } | j � } | | | f S( N( t unpack_uintt unpack_string( R t fileidR R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR' J s c C sO | j � } | t k r? | j � } | j � } | | f } n d } | | f S( N( R$ R% t unpack_fhandlet unpack_fattrR) ( R R* t fht faR- ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt unpack_diropresP s c C s7 | j � } | t k r' | j � } n d } | | f S( N( R$ R% R3 R) ( R R* R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt unpack_attrstatZ s c C s� | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | j � } | | | | | | | | | | | | | | f S( N( R$ R/ t unpack_timeval( R t typeR t nlinkR R R t blocksizet rdevt blockst fsidR1 R R t ctime( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR3 b s c C s" | j � } | j � } | | f S( N( R/ ( R R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR8 t s ( R! R" R. R' R6 R7 R3 R8 ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR# > s t NFSClientc B sP e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s t j | | t t � d S( N( R t __init__t NFS_PROGRAMt NFS_VERSION( R t host( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyRA | s c C s t � | _ t d � | _ d S( Nt ( R t packerR# t unpacker( R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt addpackers s c C s1 | j d k r* t j t j � f | _ n | j S( N( t credR) t rpct AUTH_UNIXt make_auth_unix_default( R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt mkcred� s c C s" | j d | | j j | j j � S( Ni ( t make_callRF R RG R7 ( R R4 ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Getattr� s c C s" | j d | | j j | j j � S( Ni ( RN RF R RG R7 ( R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Setattr� s c C s" | j d | | j j | j j � S( Ni ( RN RF R RG R6 ( R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Lookup� s c C s" | j d | | j j | j j � S( Ni ( RN RF R RG R. ( R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Readdir� s c C s� g } | d d f } x� | j | � \ } } | t k r= Pn | \ } } d } x0 | D]( \ } } } | j | | f � | } qV W| s� | d k r� Pn | d | | d f } q W| S( Ni i� i ( RR R% R) t append( R R t listR R* R- R+ R, t last_cookieR1 R R ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt Listdir� s ( R! R" RA RH RM RO RP RQ RR RV ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyR@ z s c C s# d d l } | j d r) | j d } n d } | j d rL | j d } n d } d d l m } m } | | � } | d k r� | j � } x | D] } | GHq� Wd S| j | � } | GH| d } | r t | � } | j | � } | GH| j | � } x | D] } | GHq W| j | � n d S( Ni����i RE i ( t UDPMountClientt TCPMountClient( t syst argvR) t mountclientRW RX t Exportt MntR@ RO RV t Umnt( RY RD t filesysRW RX t mclRT t itemt sfR4 t nclt attrstat( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt test� s2 ( RJ R R R[ R R R RB RC R% t NFNONt NFREGt NFDIRt NFBLKt NFCHRt NFLNKR R# R@ Re ( ( ( s* /usr/lib64/python2.7/Demo/rpc/nfsclient.pyt <module> s !<9PK �"�\ 6O< rnusersclient.pycnu �[��� � ��^c @ s� d d l Z d d l m Z m Z m Z m Z d e f d � � YZ d e f d � � YZ d d d � � YZ d e e f d � � YZ d e e f d � � YZ d � Z d � Z d � Z e � d S( i����N( t Packert Unpackert UDPClientt BroadcastUDPClientt RnusersPackerc B s# e Z d � Z d � Z d � Z RS( c C sJ t \ } } } } | j | � | j | � | j | � | j | � d S( N( t utmpt pack_stringt pack_int( t selft uit ut_linet ut_namet ut_hostt ut_time( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt pack_utmp s c C s* | \ } } | j t � | j | � d S( N( R t ui_utmpt pack_uint( R R t ui_itmpt ui_idle( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt pack_utmpidle s c C s | j | | j � d S( N( t pack_arrayt pack_itmpidle( R t list( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt pack_utmpidlearr s ( t __name__t __module__R R R ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR s t RnusersUnpackerc B s# e Z d � Z d � Z d � Z RS( c C s@ | j � } | j � } | j � } | j � } | | | | f S( N( t unpack_stringt unpack_int( R R R R R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt unpack_utmp s c C s" | j � } | j � } | | f S( N( R t unpack_uint( R R R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt unpack_utmpidle s c C s | j | j � S( N( t unpack_arrayR ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt unpack_utmpidlearr! s ( R R R R R! ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR s t PartialRnusersClientc B s, e Z d � Z d � Z d � Z d � Z RS( c C s t � | _ t d � | _ d S( Nt ( R t packerR t unpacker( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt addpackers' s c C s | j d d d | j j � S( Ni ( t make_callt NoneR% R ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt Num+ s c C s | j d d d | j j � S( Ni ( R' R( R% R! ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt Names. s c C s | j d d d | j j � S( Ni ( R' R( R% R! ( R ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt Allnames2 s ( R R R& R) R* R+ ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR" % s t RnusersClientc B s e Z d � Z RS( c C s t j | | d d � d S( Ni�� i ( R t __init__( R t host( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR- 9 s ( R R R- ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR, 7 s t BroadcastRnusersClientc B s e Z d � Z RS( c C s t j | | d d � d S( Ni�� i ( R R- ( R t bcastaddr( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR- ? s ( R R R- ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR/ = s c C s� d d l } | j d s$ t � d S| j d } t | � } | j � } x\ | D]T \ \ } } } } } t | � } t | � } t | � } d | | | | | f GHqP Wd S( Ni����i s %r %r %r %s %s( t syst argvt testbcastR, R* t strip0( R1 R. t cR t linet namet timet idle( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt testC s c C sA t d � } d � } | j | � | j � } d Gt | � GHd S( Ns <broadcast>c S sF | \ } } | d Gx* | D]" \ \ } } } } } t | � Gq WHd S( Ns :( R4 ( R t fromaddrR. t portR6 R7 R8 R9 ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt listitT s s Total Count:( R/ t set_reply_handlerR* t len( R5 R= t all( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR3 R s c C s+ x$ | r& | d d k r& | d } q W| S( Ni����s ( ( t s( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyR4 ^ s ( ( t rpcR R R R R R R" R, R/ R: R3 R4 ( ( ( s. /usr/lib64/python2.7/Demo/rpc/rnusersclient.pyt <module> s " PK �"�\�'Cj? ? T.pynu �[��� # Simple interface to report execution times of program fragments. # Call TSTART() to reset the timer, TSTOP(...) to report times. import sys, os, time def TSTART(): global t0, t1 u, s, cu, cs = os.times() t0 = u+cu, s+cs, time.time() def TSTOP(*label): global t0, t1 u, s, cu, cs = os.times() t1 = u+cu, s+cs, time.time() tt = [] for i in range(3): tt.append(t1[i] - t0[i]) [u, s, r] = tt msg = '' for x in label: msg = msg + (x + ' ') msg = msg + '%r user, %r sys, %r real\n' % (u, s, r) sys.stderr.write(msg) PK �"�\�Ĩ��k �k rpc.pynu �[��� # Sun RPC version 2 -- RFC1057. # XXX There should be separate exceptions for the various reasons why # XXX an RPC can fail, rather than using RuntimeError for everything # XXX Need to use class based exceptions rather than string exceptions # XXX The UDP version of the protocol resends requests when it does # XXX not receive a timely reply -- use only for idempotent calls! # XXX There is no provision for call timeout on TCP connections import xdr import socket import os RPCVERSION = 2 CALL = 0 REPLY = 1 AUTH_NULL = 0 AUTH_UNIX = 1 AUTH_SHORT = 2 AUTH_DES = 3 MSG_ACCEPTED = 0 MSG_DENIED = 1 SUCCESS = 0 # RPC executed successfully PROG_UNAVAIL = 1 # remote hasn't exported program PROG_MISMATCH = 2 # remote can't support version # PROC_UNAVAIL = 3 # program can't support procedure GARBAGE_ARGS = 4 # procedure can't decode params RPC_MISMATCH = 0 # RPC version number != 2 AUTH_ERROR = 1 # remote can't authenticate caller AUTH_BADCRED = 1 # bad credentials (seal broken) AUTH_REJECTEDCRED = 2 # client must begin new session AUTH_BADVERF = 3 # bad verifier (seal broken) AUTH_REJECTEDVERF = 4 # verifier expired or replayed AUTH_TOOWEAK = 5 # rejected for security reasons class Packer(xdr.Packer): def pack_auth(self, auth): flavor, stuff = auth self.pack_enum(flavor) self.pack_opaque(stuff) def pack_auth_unix(self, stamp, machinename, uid, gid, gids): self.pack_uint(stamp) self.pack_string(machinename) self.pack_uint(uid) self.pack_uint(gid) self.pack_uint(len(gids)) for i in gids: self.pack_uint(i) def pack_callheader(self, xid, prog, vers, proc, cred, verf): self.pack_uint(xid) self.pack_enum(CALL) self.pack_uint(RPCVERSION) self.pack_uint(prog) self.pack_uint(vers) self.pack_uint(proc) self.pack_auth(cred) self.pack_auth(verf) # Caller must add procedure-specific part of call def pack_replyheader(self, xid, verf): self.pack_uint(xid) self.pack_enum(REPLY) self.pack_uint(MSG_ACCEPTED) self.pack_auth(verf) self.pack_enum(SUCCESS) # Caller must add procedure-specific part of reply # Exceptions class BadRPCFormat(Exception): pass class BadRPCVersion(Exception): pass class GarbageArgs(Exception): pass class Unpacker(xdr.Unpacker): def unpack_auth(self): flavor = self.unpack_enum() stuff = self.unpack_opaque() return (flavor, stuff) def unpack_callheader(self): xid = self.unpack_uint() temp = self.unpack_enum() if temp != CALL: raise BadRPCFormat, 'no CALL but %r' % (temp,) temp = self.unpack_uint() if temp != RPCVERSION: raise BadRPCVersion, 'bad RPC version %r' % (temp,) prog = self.unpack_uint() vers = self.unpack_uint() proc = self.unpack_uint() cred = self.unpack_auth() verf = self.unpack_auth() return xid, prog, vers, proc, cred, verf # Caller must add procedure-specific part of call def unpack_replyheader(self): xid = self.unpack_uint() mtype = self.unpack_enum() if mtype != REPLY: raise RuntimeError, 'no REPLY but %r' % (mtype,) stat = self.unpack_enum() if stat == MSG_DENIED: stat = self.unpack_enum() if stat == RPC_MISMATCH: low = self.unpack_uint() high = self.unpack_uint() raise RuntimeError, \ 'MSG_DENIED: RPC_MISMATCH: %r' % ((low, high),) if stat == AUTH_ERROR: stat = self.unpack_uint() raise RuntimeError, \ 'MSG_DENIED: AUTH_ERROR: %r' % (stat,) raise RuntimeError, 'MSG_DENIED: %r' % (stat,) if stat != MSG_ACCEPTED: raise RuntimeError, \ 'Neither MSG_DENIED nor MSG_ACCEPTED: %r' % (stat,) verf = self.unpack_auth() stat = self.unpack_enum() if stat == PROG_UNAVAIL: raise RuntimeError, 'call failed: PROG_UNAVAIL' if stat == PROG_MISMATCH: low = self.unpack_uint() high = self.unpack_uint() raise RuntimeError, \ 'call failed: PROG_MISMATCH: %r' % ((low, high),) if stat == PROC_UNAVAIL: raise RuntimeError, 'call failed: PROC_UNAVAIL' if stat == GARBAGE_ARGS: raise RuntimeError, 'call failed: GARBAGE_ARGS' if stat != SUCCESS: raise RuntimeError, 'call failed: %r' % (stat,) return xid, verf # Caller must get procedure-specific part of reply # Subroutines to create opaque authentication objects def make_auth_null(): return '' def make_auth_unix(seed, host, uid, gid, groups): p = Packer() p.pack_auth_unix(seed, host, uid, gid, groups) return p.get_buf() def make_auth_unix_default(): try: from os import getuid, getgid uid = getuid() gid = getgid() except ImportError: uid = gid = 0 import time return make_auth_unix(int(time.time()-unix_epoch()), \ socket.gethostname(), uid, gid, []) _unix_epoch = -1 def unix_epoch(): """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. """ global _unix_epoch if _unix_epoch >= 0: return _unix_epoch import time now = time.time() localt = time.localtime(now) # (y, m, d, hh, mm, ss, ..., ..., ...) gmt = time.gmtime(now) offset = time.mktime(localt) - time.mktime(gmt) y, m, d, hh, mm, ss = 1970, 1, 1, 0, 0, 0 offset, ss = divmod(ss + offset, 60) offset, mm = divmod(mm + offset, 60) offset, hh = divmod(hh + offset, 24) d = d + offset _unix_epoch = time.mktime((y, m, d, hh, mm, ss, 0, 0, 0)) print "Unix epoch:", time.ctime(_unix_epoch) return _unix_epoch # Common base class for clients class Client: def __init__(self, host, prog, vers, port): self.host = host self.prog = prog self.vers = vers self.port = port self.makesocket() # Assigns to self.sock self.bindsocket() self.connsocket() self.lastxid = 0 # XXX should be more random? self.addpackers() self.cred = None self.verf = None def close(self): self.sock.close() def makesocket(self): # This MUST be overridden raise RuntimeError, 'makesocket not defined' def connsocket(self): # Override this if you don't want/need a connection self.sock.connect((self.host, self.port)) def bindsocket(self): # Override this to bind to a different port (e.g. reserved) self.sock.bind(('', 0)) def addpackers(self): # Override this to use derived classes from Packer/Unpacker self.packer = Packer() self.unpacker = Unpacker('') def make_call(self, proc, args, pack_func, unpack_func): # Don't normally override this (but see Broadcast) if pack_func is None and args is not None: raise TypeError, 'non-null args with null pack_func' self.start_call(proc) if pack_func: pack_func(args) self.do_call() if unpack_func: result = unpack_func() else: result = None self.unpacker.done() return result def start_call(self, proc): # Don't override this self.lastxid = xid = self.lastxid + 1 cred = self.mkcred() verf = self.mkverf() p = self.packer p.reset() p.pack_callheader(xid, self.prog, self.vers, proc, cred, verf) def do_call(self): # This MUST be overridden raise RuntimeError, 'do_call not defined' def mkcred(self): # Override this to use more powerful credentials if self.cred is None: self.cred = (AUTH_NULL, make_auth_null()) return self.cred def mkverf(self): # Override this to use a more powerful verifier if self.verf is None: self.verf = (AUTH_NULL, make_auth_null()) return self.verf def call_0(self): # Procedure 0 is always like this return self.make_call(0, None, None, None) # Record-Marking standard support def sendfrag(sock, last, frag): x = len(frag) if last: x = x | 0x80000000L header = (chr(int(x>>24 & 0xff)) + chr(int(x>>16 & 0xff)) + \ chr(int(x>>8 & 0xff)) + chr(int(x & 0xff))) sock.send(header + frag) def sendrecord(sock, record): sendfrag(sock, 1, record) def recvfrag(sock): header = sock.recv(4) if len(header) < 4: raise EOFError x = long(ord(header[0]))<<24 | ord(header[1])<<16 | \ ord(header[2])<<8 | ord(header[3]) last = ((x & 0x80000000) != 0) n = int(x & 0x7fffffff) frag = '' while n > 0: buf = sock.recv(n) if not buf: raise EOFError n = n - len(buf) frag = frag + buf return last, frag def recvrecord(sock): record = '' last = 0 while not last: last, frag = recvfrag(sock) record = record + frag return record # Try to bind to a reserved port (must be root) last_resv_port_tried = None def bindresvport(sock, host): global last_resv_port_tried FIRST, LAST = 600, 1024 # Range of ports to try if last_resv_port_tried is None: import os last_resv_port_tried = FIRST + os.getpid() % (LAST-FIRST) for i in range(last_resv_port_tried, LAST) + \ range(FIRST, last_resv_port_tried): last_resv_port_tried = i try: sock.bind((host, i)) return last_resv_port_tried except socket.error, (errno, msg): if errno != 114: raise socket.error, (errno, msg) raise RuntimeError, 'can\'t assign reserved port' # Client using TCP to a specific port class RawTCPClient(Client): def makesocket(self): self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) def do_call(self): call = self.packer.get_buf() sendrecord(self.sock, call) reply = recvrecord(self.sock) u = self.unpacker u.reset(reply) xid, verf = u.unpack_replyheader() if xid != self.lastxid: # Can't really happen since this is TCP... raise RuntimeError, 'wrong xid in reply %r instead of %r' % ( xid, self.lastxid) # Client using UDP to a specific port class RawUDPClient(Client): def makesocket(self): self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) def do_call(self): call = self.packer.get_buf() self.sock.send(call) try: from select import select except ImportError: print 'WARNING: select not found, RPC may hang' select = None BUFSIZE = 8192 # Max UDP buffer size timeout = 1 count = 5 while 1: r, w, x = [self.sock], [], [] if select: r, w, x = select(r, w, x, timeout) if self.sock not in r: count = count - 1 if count < 0: raise RuntimeError, 'timeout' if timeout < 25: timeout = timeout *2 ## print 'RESEND', timeout, count self.sock.send(call) continue reply = self.sock.recv(BUFSIZE) u = self.unpacker u.reset(reply) xid, verf = u.unpack_replyheader() if xid != self.lastxid: ## print 'BAD xid' continue break # Client using UDP broadcast to a specific port class RawBroadcastUDPClient(RawUDPClient): def __init__(self, bcastaddr, prog, vers, port): RawUDPClient.__init__(self, bcastaddr, prog, vers, port) self.reply_handler = None self.timeout = 30 def connsocket(self): # Don't connect -- use sendto self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) def set_reply_handler(self, reply_handler): self.reply_handler = reply_handler def set_timeout(self, timeout): self.timeout = timeout # Use None for infinite timeout def make_call(self, proc, args, pack_func, unpack_func): if pack_func is None and args is not None: raise TypeError, 'non-null args with null pack_func' self.start_call(proc) if pack_func: pack_func(args) call = self.packer.get_buf() self.sock.sendto(call, (self.host, self.port)) try: from select import select except ImportError: print 'WARNING: select not found, broadcast will hang' select = None BUFSIZE = 8192 # Max UDP buffer size (for reply) replies = [] if unpack_func is None: def dummy(): pass unpack_func = dummy while 1: r, w, x = [self.sock], [], [] if select: if self.timeout is None: r, w, x = select(r, w, x) else: r, w, x = select(r, w, x, self.timeout) if self.sock not in r: break reply, fromaddr = self.sock.recvfrom(BUFSIZE) u = self.unpacker u.reset(reply) xid, verf = u.unpack_replyheader() if xid != self.lastxid: ## print 'BAD xid' continue reply = unpack_func() self.unpacker.done() replies.append((reply, fromaddr)) if self.reply_handler: self.reply_handler(reply, fromaddr) return replies # Port mapper interface # Program number, version and (fixed!) port number PMAP_PROG = 100000 PMAP_VERS = 2 PMAP_PORT = 111 # Procedure numbers PMAPPROC_NULL = 0 # (void) -> void PMAPPROC_SET = 1 # (mapping) -> bool PMAPPROC_UNSET = 2 # (mapping) -> bool PMAPPROC_GETPORT = 3 # (mapping) -> unsigned int PMAPPROC_DUMP = 4 # (void) -> pmaplist PMAPPROC_CALLIT = 5 # (call_args) -> call_result # A mapping is (prog, vers, prot, port) and prot is one of: IPPROTO_TCP = 6 IPPROTO_UDP = 17 # A pmaplist is a variable-length list of mappings, as follows: # either (1, mapping, pmaplist) or (0). # A call_args is (prog, vers, proc, args) where args is opaque; # a call_result is (port, res) where res is opaque. class PortMapperPacker(Packer): def pack_mapping(self, mapping): prog, vers, prot, port = mapping self.pack_uint(prog) self.pack_uint(vers) self.pack_uint(prot) self.pack_uint(port) def pack_pmaplist(self, list): self.pack_list(list, self.pack_mapping) def pack_call_args(self, ca): prog, vers, proc, args = ca self.pack_uint(prog) self.pack_uint(vers) self.pack_uint(proc) self.pack_opaque(args) class PortMapperUnpacker(Unpacker): def unpack_mapping(self): prog = self.unpack_uint() vers = self.unpack_uint() prot = self.unpack_uint() port = self.unpack_uint() return prog, vers, prot, port def unpack_pmaplist(self): return self.unpack_list(self.unpack_mapping) def unpack_call_result(self): port = self.unpack_uint() res = self.unpack_opaque() return port, res class PartialPortMapperClient: def addpackers(self): self.packer = PortMapperPacker() self.unpacker = PortMapperUnpacker('') def Set(self, mapping): return self.make_call(PMAPPROC_SET, mapping, \ self.packer.pack_mapping, \ self.unpacker.unpack_uint) def Unset(self, mapping): return self.make_call(PMAPPROC_UNSET, mapping, \ self.packer.pack_mapping, \ self.unpacker.unpack_uint) def Getport(self, mapping): return self.make_call(PMAPPROC_GETPORT, mapping, \ self.packer.pack_mapping, \ self.unpacker.unpack_uint) def Dump(self): return self.make_call(PMAPPROC_DUMP, None, \ None, \ self.unpacker.unpack_pmaplist) def Callit(self, ca): return self.make_call(PMAPPROC_CALLIT, ca, \ self.packer.pack_call_args, \ self.unpacker.unpack_call_result) class TCPPortMapperClient(PartialPortMapperClient, RawTCPClient): def __init__(self, host): RawTCPClient.__init__(self, \ host, PMAP_PROG, PMAP_VERS, PMAP_PORT) class UDPPortMapperClient(PartialPortMapperClient, RawUDPClient): def __init__(self, host): RawUDPClient.__init__(self, \ host, PMAP_PROG, PMAP_VERS, PMAP_PORT) class BroadcastUDPPortMapperClient(PartialPortMapperClient, \ RawBroadcastUDPClient): def __init__(self, bcastaddr): RawBroadcastUDPClient.__init__(self, \ bcastaddr, PMAP_PROG, PMAP_VERS, PMAP_PORT) # Generic clients that find their server through the Port mapper class TCPClient(RawTCPClient): def __init__(self, host, prog, vers): pmap = TCPPortMapperClient(host) port = pmap.Getport((prog, vers, IPPROTO_TCP, 0)) pmap.close() if port == 0: raise RuntimeError, 'program not registered' RawTCPClient.__init__(self, host, prog, vers, port) class UDPClient(RawUDPClient): def __init__(self, host, prog, vers): pmap = UDPPortMapperClient(host) port = pmap.Getport((prog, vers, IPPROTO_UDP, 0)) pmap.close() if port == 0: raise RuntimeError, 'program not registered' RawUDPClient.__init__(self, host, prog, vers, port) class BroadcastUDPClient(Client): def __init__(self, bcastaddr, prog, vers): self.pmap = BroadcastUDPPortMapperClient(bcastaddr) self.pmap.set_reply_handler(self.my_reply_handler) self.prog = prog self.vers = vers self.user_reply_handler = None self.addpackers() def close(self): self.pmap.close() def set_reply_handler(self, reply_handler): self.user_reply_handler = reply_handler def set_timeout(self, timeout): self.pmap.set_timeout(timeout) def my_reply_handler(self, reply, fromaddr): port, res = reply self.unpacker.reset(res) result = self.unpack_func() self.unpacker.done() self.replies.append((result, fromaddr)) if self.user_reply_handler is not None: self.user_reply_handler(result, fromaddr) def make_call(self, proc, args, pack_func, unpack_func): self.packer.reset() if pack_func: pack_func(args) if unpack_func is None: def dummy(): pass self.unpack_func = dummy else: self.unpack_func = unpack_func self.replies = [] packed_args = self.packer.get_buf() dummy_replies = self.pmap.Callit( \ (self.prog, self.vers, proc, packed_args)) return self.replies # Server classes # These are not symmetric to the Client classes # XXX No attempt is made to provide authorization hooks yet class Server: def __init__(self, host, prog, vers, port): self.host = host # Should normally be '' for default interface self.prog = prog self.vers = vers self.port = port # Should normally be 0 for random port self.makesocket() # Assigns to self.sock and self.prot self.bindsocket() self.host, self.port = self.sock.getsockname() self.addpackers() def register(self): mapping = self.prog, self.vers, self.prot, self.port p = TCPPortMapperClient(self.host) if not p.Set(mapping): raise RuntimeError, 'register failed' def unregister(self): mapping = self.prog, self.vers, self.prot, self.port p = TCPPortMapperClient(self.host) if not p.Unset(mapping): raise RuntimeError, 'unregister failed' def handle(self, call): # Don't use unpack_header but parse the header piecewise # XXX I have no idea if I am using the right error responses! self.unpacker.reset(call) self.packer.reset() xid = self.unpacker.unpack_uint() self.packer.pack_uint(xid) temp = self.unpacker.unpack_enum() if temp != CALL: return None # Not worthy of a reply self.packer.pack_uint(REPLY) temp = self.unpacker.unpack_uint() if temp != RPCVERSION: self.packer.pack_uint(MSG_DENIED) self.packer.pack_uint(RPC_MISMATCH) self.packer.pack_uint(RPCVERSION) self.packer.pack_uint(RPCVERSION) return self.packer.get_buf() self.packer.pack_uint(MSG_ACCEPTED) self.packer.pack_auth((AUTH_NULL, make_auth_null())) prog = self.unpacker.unpack_uint() if prog != self.prog: self.packer.pack_uint(PROG_UNAVAIL) return self.packer.get_buf() vers = self.unpacker.unpack_uint() if vers != self.vers: self.packer.pack_uint(PROG_MISMATCH) self.packer.pack_uint(self.vers) self.packer.pack_uint(self.vers) return self.packer.get_buf() proc = self.unpacker.unpack_uint() methname = 'handle_' + repr(proc) try: meth = getattr(self, methname) except AttributeError: self.packer.pack_uint(PROC_UNAVAIL) return self.packer.get_buf() cred = self.unpacker.unpack_auth() verf = self.unpacker.unpack_auth() try: meth() # Unpack args, call turn_around(), pack reply except (EOFError, GarbageArgs): # Too few or too many arguments self.packer.reset() self.packer.pack_uint(xid) self.packer.pack_uint(REPLY) self.packer.pack_uint(MSG_ACCEPTED) self.packer.pack_auth((AUTH_NULL, make_auth_null())) self.packer.pack_uint(GARBAGE_ARGS) return self.packer.get_buf() def turn_around(self): try: self.unpacker.done() except RuntimeError: raise GarbageArgs self.packer.pack_uint(SUCCESS) def handle_0(self): # Handle NULL message self.turn_around() def makesocket(self): # This MUST be overridden raise RuntimeError, 'makesocket not defined' def bindsocket(self): # Override this to bind to a different port (e.g. reserved) self.sock.bind((self.host, self.port)) def addpackers(self): # Override this to use derived classes from Packer/Unpacker self.packer = Packer() self.unpacker = Unpacker('') class TCPServer(Server): def makesocket(self): self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.prot = IPPROTO_TCP def loop(self): self.sock.listen(0) while 1: self.session(self.sock.accept()) def session(self, connection): sock, (host, port) = connection while 1: try: call = recvrecord(sock) except EOFError: break except socket.error, msg: print 'socket error:', msg break reply = self.handle(call) if reply is not None: sendrecord(sock, reply) def forkingloop(self): # Like loop but uses forksession() self.sock.listen(0) while 1: self.forksession(self.sock.accept()) def forksession(self, connection): # Like session but forks off a subprocess import os # Wait for deceased children try: while 1: pid, sts = os.waitpid(0, 1) except os.error: pass pid = None try: pid = os.fork() if pid: # Parent connection[0].close() return # Child self.session(connection) finally: # Make sure we don't fall through in the parent if pid == 0: os._exit(0) class UDPServer(Server): def makesocket(self): self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) self.prot = IPPROTO_UDP def loop(self): while 1: self.session() def session(self): call, host_port = self.sock.recvfrom(8192) reply = self.handle(call) if reply is not None: self.sock.sendto(reply, host_port) # Simple test program -- dump local portmapper status def test(): pmap = UDPPortMapperClient('') list = pmap.Dump() list.sort() for prog, vers, prot, port in list: print prog, vers, if prot == IPPROTO_TCP: print 'tcp', elif prot == IPPROTO_UDP: print 'udp', else: print prot, print port # Test program for broadcast operation -- dump everybody's portmapper status def testbcast(): import sys if sys.argv[1:]: bcastaddr = sys.argv[1] else: bcastaddr = '<broadcast>' def rh(reply, fromaddr): host, port = fromaddr print host + '\t' + repr(reply) pmap = BroadcastUDPPortMapperClient(bcastaddr) pmap.set_reply_handler(rh) pmap.set_timeout(5) replies = pmap.Getport((100002, 1, IPPROTO_UDP, 0)) # Test program for server, with corresponding client # On machine A: python -c 'import rpc; rpc.testsvr()' # On machine B: python -c 'import rpc; rpc.testclt()' A # (A may be == B) def testsvr(): # Simple test class -- proc 1 doubles its string argument as reply class S(UDPServer): def handle_1(self): arg = self.unpacker.unpack_string() self.turn_around() print 'RPC function 1 called, arg', repr(arg) self.packer.pack_string(arg + arg) # s = S('', 0x20000000, 1, 0) try: s.unregister() except RuntimeError, msg: print 'RuntimeError:', msg, '(ignored)' s.register() print 'Service started...' try: s.loop() finally: s.unregister() print 'Service interrupted.' def testclt(): import sys if sys.argv[1:]: host = sys.argv[1] else: host = '' # Client for above server class C(UDPClient): def call_1(self, arg): return self.make_call(1, arg, \ self.packer.pack_string, \ self.unpacker.unpack_string) c = C(host, 0x20000000, 1) print 'making call...' reply = c.call_1('hello, world, ') print 'call returned', repr(reply) PK �"�\��:� � T.pycnu �[��� PK �"�\���� � � xdr.pyonu �[��� PK �"�\�r�� � # nfsclient.pyonu �[��� PK �"�\X���P P => mountclient.pycnu �[��� PK �"�\� � � �T mountclient.pynu �[��� PK �"�\X���P P �n mountclient.pyonu �[��� PK �"�\ x�}�v �v �� rpc.pycnu �[��� PK �"�\"��z� � �� nfsclient.pynu �[��� PK �"�\ 6O< � rnusersclient.pyonu �[��� PK �"�\W��j� � �% READMEnu �[��� PK �"�\ x�}�v �v + rpc.pyonu �[��� PK �"�\},�� � 1� xdr.pynu �[��� PK �"�\?��� � � testnu �[��� PK �"�\��A)E E � rnusersclient.pynu �[��� PK �"�\��:� � �� T.pyonu �[��� PK �"�\�yOGi i }� MANIFESTnu �[��� PK �"�\���� � � xdr.pycnu �[��� PK �"�\�r�� � :� nfsclient.pycnu �[��� PK �"�\ 6O< n rnusersclient.pycnu �[��� PK �"�\�'Cj? ? � T.pynu �[��� PK �"�\�Ĩ��k �k - rpc.pynu �[��� PK R�
| ver. 1.4 |
Github
|
.
| PHP 8.1.34 | ���֧ߧ֧�ѧ�ڧ� ����ѧߧڧ��: 0.1 |
proxy
|
phpinfo
|
���ѧ����ۧܧ�