File: //proc/2/cwd/usr/local/ssl/lib/python2.4/Demo/pdist/server.pyo
mò
=5Dc @ s~ d Z d k Z d k Z d k Z d k l Z d k l Z d Z d f d YZ d k l Z d e e f d YZ
d S(
s RPC Server module.N( s fnmatch( s repri t Serverc B s t Z d Z e d Z d Z d Z d Z d Z d Z d d d d
g Z
d Z d Z d
Z
e d Z RS( sD RPC Server class. Derive a class to implement a particular service.c C s t | t d j o d | f } n | | _ | | _ d | _ t i t i t i
| _ | i i | | i i d d | _
d S( Ni t i ( t typet addresst selft _addresst verboset _verboset Nonet _sockett sockett AF_INETt SOCK_STREAMt bindt listent
_listening( R R R ( ( t' /usr/lib/python2.4/Demo/pdist/server.pyt __init__ s c C s
| | _ d S( N( R R R ( R R ( ( R t _setverbose s c C s | i d S( N( R t _close( R ( ( R t __del__ s c C s1 d | _ | i o | i i n d | _ d S( Ni ( R R R t closeR ( R ( ( R R # s
c C s x | i o | i q Wd S( N( R R t _serve( R ( ( R t _serverloop) s
c C så | i o d GHn | i i \ } } | i o d t | GHn | i | | p! d t | GH| i d Sn | i d } | i d } d } xA | o9 | i
| i d j o d GHn | i | | } q Wd S( Ns Wait for connection ...s Accepted connection from %ss *** Connection from %s refusedt rt wi s Wait for next request ...( R R R t acceptt connR t reprt _verifyR t makefilet rft wft okt flusht
_dorequest( R R R! R R R ( ( R R - s$
s 192.16.201.*s 192.16.197.*s 132.151.1.*s
129.6.64.*c C s< | \ } } x) | i D] } t | | o d Sq q Wd S( Ni i ( R t hostt portR t _validt patt fnmatch( R R R R' R$ R% ( ( R R ? s
c C s t i | } y | i } Wn t j
o d Sn X| i d j o d t | GHn y | \ } } }
d | j o d | i | | |
f } nP | d d j o t d t | n( t | | } d t | | |
f } Wn t i t i |
f } n X|
d j o2 | d d
j o! | i d j o d GHn d Sn | i d j o d t | GHn t i | } | i | d S( Ni i s Got request: %st .t _s illegal method name %si s Suppress replys Send reply: %s( NN( t picklet UnpicklerR t rpt loadt requestt EOFErrorR R R t
methodnamet argst idR t _specialt replyt NameErrort getattrt methodt applyt syst exc_typet exc_valuet PicklerR t wpt dump( R R R R> R- R2 R/ R8 R1 R5 R3 ( ( R R# E s4
c C sX | d j o4 t | d p t | i | _ n | i Sn t d t | d S( Ns .methodst _methodss# unrecognized special method name %s( R1 t hasattrR t tuplet _listmethodsR@ R6 R ( R R1 R2 ( ( R R4 _ s
c C s | p
| i } n | i i } t d | } | i xE | i D]: } | i
| } t | d | } | | t | )qI W| S( Nc C s | d d j S( Ni R* ( t x( RD ( ( R t <lambda>i s c C s
| | j S( N( RD t names( RD RF ( ( R RE m s (
t clR t __class__t __dict__t keysRF t filtert sortt __bases__t baseRC t basenamest len( R RG RN RF RO ( ( R RC f s
( t __name__t
__module__t __doc__t VERBOSER R R R R R R& R R# R4 R RC ( ( ( R R s ( s Securityt SecureServerc B s t Z d Z d Z RS( Nc G s( t t i | f | t i | d S( N( R9 R R R R2 t Security( R R2 ( ( R R w s c C s0 d k } | i } | i d | d } xJ d | j o< t | d j o) | i d } | p Pn | | } q/ Wy | i
| i | } Wn= | i j
o. | i
d j o d Gt | GHn d Sn X| i | | p+ | i
d j o d Gt | GHn d Sn | i
d j o d GHn d S(
Ns %d
R s
id i s Invalid response syntaxs Invalid response valuei s& Response matches challenge. Go ahead!( t stringR t _generate_challenget challengeR t sendt responseRP t recvt datat atolt stript
atol_errorR R t _compare_challenge_response( R R R RW RY R] R[ ( ( R R { s. ( RQ RR R R ( ( ( R RU u s ( RS R: R
R+ R( R RT R t securityRV RU ( RT RU R R R: R( RV R+ R
( ( R t ? s
d