/usr/lib/python2.6/site-packages/supervisor/medusa
Edit: /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyo (12401B)
Ñò
FATc @ sÖ d Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z e i e ƒ d Z d d „ Z d d „ Z
d „ Z d „ Z d
„ Z
d „ Z d „ Z d
e i f d „ ƒ YZ d e f d „ ƒ YZ d d d „ ƒ YZ d e f d „ ƒ YZ e d j oÃe e i ƒ d j o! d e i d GHe i d ƒ nO d e i j o8 e i i d ƒ Z e i e d Z e i e e d 5n d Z d e i j o& d Z e i i d ƒ Z e i e =n d Z d e i j o d Z e i i d ƒ n d Z e o e e ƒ Z n
e e ƒ Z e e i ƒ d a d „ Z! x[ e i d D]L Z" e o e i# e" e! ƒ qMe o e i$ e" e! ƒ qMe i% e" e! ƒ qMWx2 e i& o# e i' d ƒ d e e i( ƒ GHq Wn d S( s; $Id: resolver.py,v 1.1.1.1 2006/06/26 06:36:05 chrism Exp $iÿÿÿÿN( t counteri i c C sR d t | d ?d @ƒ t | d @ƒ f d t i t d „ t i | d ƒ ƒ d ƒ S( Ns %c%ci iÿ s %s c S s d t t | ƒ ƒ | f S( s %c%s( t chrt len( t part( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt
> s t .t ( R t stringt joint mapt split( t hostt id( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt fast_address_request8 s %c C sR d t | d ?d @ƒ t | d @ƒ f d t i t d „ t i | d ƒ ƒ d ƒ S( Ns %c%ci iÿ s %s c S s d t t | ƒ ƒ | f S( s %c%s( R R ( R ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR K s R R ( R R R R R
( R R ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt fast_ptr_requestE s %c C s• g } x| t | | ƒ } | d @o | d @t | | d ƒ } q | d j o Pq | d } | i | | | | !ƒ | | } q t i | d ƒ S( NiÀ i? i i i R i ? ( t ordt appendR R ( t rt post nt ll( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt unpack_nameR s
c C s^ | } xQ t | | ƒ } | d @o | d S| d j o | d } Pq | | d } q | S( NiÀ i i i ( R ( R R t sR ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt skip_namea s
c C s$ t d „ t t | | | d !ƒ ƒ S( Nc S s | d >| BS( i ( ( t xt y( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR q s i ( t reduceR R ( R R ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt
unpack_ttlo s c C sÿ t | d ƒ d >t | d ƒ } t | d ƒ d } | o» x³ t | ƒ D]¥ } t | | ƒ } | | | d !d j o: t | | d ƒ d t t t | | d | d !ƒ ƒ f S| d } t | | ƒ d >t | | d
ƒ } | d | } qI Wd
Sd Sd S( Ni i i i i t s %d.%d.%d.%di
i i i i ( i N( i N( R R t rangeR t tupleR t None( R t ancountR t ant rdlength( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt unpack_address_reply‹ s "
*
&c C sê t | d ƒ d >t | d ƒ } t | d ƒ d } | o¦ xž t | ƒ D] } t | | ƒ } | | | d !d j o% t | | d ƒ t | | d ƒ f S| d } t | | ƒ d >t | | d ƒ } | d | } qI Wd Sd Sd S(
Ni i i i i t i
i i i ( i N( i N( R R R R R R ( R R R R! R" ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt unpack_ptr_reply¢ s "
&t resolverc B sn e Z e ƒ Z d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z
RS( s 127.0.0.1c C sQ t i i | ƒ | i t i t i ƒ | | _ h | _ t t
i
ƒ ƒ | _ d S( N( t asyncoret
dispatchert __init__t
create_sockett sockett AF_INETt
SOCK_DGRAMt servert request_mapt intt timet last_reap_time( t selfR. ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR) É s
c C s d S( Ni ( ( R3 ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt writableÐ s c G s d S( N( ( R3 t args( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt logÓ s c C s | i d ƒ | i ƒ d S( Ns closing!( t log_infot close( R3 ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt handle_closeÖ s
c C sB t i ƒ \ \ } } } } } } | i d | | | f d ƒ d S( Ns" Problem with DNS lookup (%s:%s %s)t error( R' t compact_tracebackR7 ( R3 t filet funt linet tt vt tbinfo( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt handle_errorÚ s !c C s | i i ƒ d S( Ni i i ( R t as_long( R3 ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt get_idà s c
C sÞ t t i ƒ ƒ } | | i d j o´ | | _ x¨ | i i ƒ D]“ \ } \ } } } } | | d j oj | i | =y | | d d ƒ WqÒ t i ƒ \ \ } } } }
} } | i d |
| | f d ƒ qÒ Xq? q? Wn d S( Ni´ i s %s %s %sR: ( R0 R1 R2 R/ t itemsR R' R; R7 (
R3 t nowt kR t unpackt callbackt whenR< R= R> R? R@ RA ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt reapã s
!c C sq | i ƒ | i i t | | i ƒ ƒ | i d f ƒ | t | t t i ƒ ƒ f | i | i ƒ <| i
i ƒ d S( Ni5 ( RK R+ t sendtoR
RD R. R# R0 R1 R/ R t increment( R3 R RI ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt resolveð s
+c C s£ | i ƒ t i | d ƒ } | i ƒ t i | d ƒ d } | i i t | | i ƒ ƒ | i d f ƒ | t
| t t i ƒ ƒ f | i
| i ƒ <| i i ƒ d S( NR s
.in-addr.arpai5 ( RK R R
t reverseR R+ RL R RD R. R% R0 R1 R/ R RM ( R3 R RI t ip( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt resolve_ptrú s
+c C sæ | i i d ƒ \ } } t | d ƒ d >t | d ƒ } | i i | ƒ o• | i | \ } } } } | i | =| | ƒ \ } } y | | | | ƒ Wqâ t i ƒ \ \ }
} } }
} } | i d |
| | f d ƒ qâ Xn d S( Ni i i i s %s %s %sR: ( R+ t recvfromR R/ t has_keyR' R; R7 ( R3 t replyt whenceR R RH RI RJ t ttlt answerR< R= R> R? R@ RA ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt handle_read s "
!( t __name__t
__module__R R R) R4 R6 R9 RB RD RK RN RQ RX ( ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR& Ç s
t rblc B s e Z d „ Z d „ Z RS( c C s t i | d ƒ } | i ƒ t i | d ƒ d } | i i t | | i ƒ ƒ | i d f ƒ | | i | f | i
| i ƒ <| i i ƒ d S( NR s .rbl.maps.vix.comi5 (
R R
RO R R+ RL R RD R. t check_replyR/ R RM ( R3 R RI RP ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt resolve_maps s
c C s; t | d ƒ d @} | i d | t | ƒ f ƒ d | f S( Ni i s MAPS RBL; RCODE =%02x
%si ( R R7 t repr( R3 R t rcode( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR\ # s ( RY RZ R] R\ ( ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR[ s t hooked_callbackc B s e Z d „ Z d „ Z RS( c C s | | | _ | _ d S( N( t hookRI ( R3 Ra RI ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR) + s c G s$ t | i | ƒ t | i | ƒ d S( N( t applyRa RI ( R3 R5 ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt __call__. s ( RY RZ R) Rc ( ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR` * s t caching_resolverc B sE e Z d Z d „ Z d „ Z d „ Z d „ Z d e Z d „ Z RS( sC Cache DNS queries. Will need to honor the TTL value in the repliesc G sK t t i | ƒ | d } h | _ t ƒ | _ t ƒ | _ t ƒ | _ d S( Ni ( Rb R& R) t cacheR t forward_requestst reverse_requestst
cache_hits( R5 R3 ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyR) 5 s
c C sz | i i ƒ | i i | ƒ o7 | i | \ } } } | | | | ƒ | i i ƒ n t i | | t | i | ƒ ƒ d S( N( Rf RM Re RS Rh R& RN R` t
callback_hook( R3 R RI RJ RV RW ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyRN = s
c C sz | i i ƒ | i i | ƒ o7 | i | \ } } } | | | | ƒ | i i ƒ n t i | | t | i | ƒ ƒ d S( N( Rg RM Re RS Rh R& RQ R` Ri ( R3 R RI RJ RV RW ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyRQ N s
c C s t i ƒ | | f | i | /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyRi _ s s Caching DNS Resolver (V%s)c C sn d d k } | i d | i d | i d t | i ƒ d t | i ƒ d | i d | i d | i ƒ S( Niÿÿÿÿs %s
s
Server: %ss
Cache Entries: %ds
Outstanding Requests: %ds
Forward Requests: %ss
Reverse Requests: %ss
Cache Hits: %s(
t producerst simple_producert SERVER_IDENTR. R Re R/ Rf Rg Rh ( R3 Rj ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt statusd s (
RY RZ t __doc__R) RN RQ Ri t VERSIONRl Rm ( ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyRd 2 s
t __main__i s/ usage: %s [-r] [-s ] host [host ...]s -ss 127.0.0.1s -rs -mc C s2 d | | f GHt d a t p t i ƒ n d S( Ns %s: %si ( t countR R8 ( R RV RW ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt print_it¦ s
g >@s requests outstanding: %d( () t RCS_IDR R' R+ t sysR1 R R
Ro R
R R R R R# R% R( R& R[ R` Rd RY R t argvt exitt indext iR. RO t mapst removeR Rq Rr R RQ R] RN t
socket_mapt pollR/ ( ( ( s> /usr/lib/python2.6/site-packages/supervisor/medusa/resolver.pyt sh "
%OU