File: //usr/local/ssl/lib/python2.4/site-packages/dns/query.pyc
mò
…|Rc @ sÅ d Z d k l Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z
d k Z
d k Z
d k
Z
d k Z
d k Z
d e
i i f d „ ƒ YZ d e
i i f d „ ƒ YZ d „ Z d „ Z d „ Z d
„ Z d „ Z e e d ƒ o
e a n e a d
„ Z d „ Z d „ Z d „ Z d d d d d e! e! d „ Z" d „ Z# d „ Z$ d „ Z% d d d d d e! d „ Z& e
i' i( e
i) i* d d d d e+ d d d d d e! e
i, i- d „ Z. d S( s Talk to a DNS server.( s
generatorsNt UnexpectedSourcec B s t Z d Z RS( sD Raised if a query response comes from an unexpected address or port.( t __name__t
__module__t __doc__( ( ( t- /usr/lib/python2.4/site-packages/dns/query.pyR " s t BadResponsec B s t Z d Z RS( sB Raised if a query response does not respond to the question asked.( R R R ( ( ( R R & s c C s' | d j o d Sn t i ƒ | Sd S( N( t timeoutt Nonet time( R ( ( R t _compute_expiration* s
c C s¤ d } | o | t i O} n | o | t i O} n | o | t i O} n t i ƒ } | i
| | ƒ | o | i t
| d ƒ ƒ } n
| i ƒ } t | ƒ S( sq Poll polling backend.
@param fd: File descriptor
@type fd: int
@param readable: Whether to wait for readability
@type readable: bool
@param writable: Whether to wait for writability
@type writable: bool
@param timeout: Deadline timeout (expiration time, in seconds)
@type timeout: float
@return True on success, False on timeout
i iè N( t
event_maskt readablet selectt POLLINt writablet POLLOUTt errort POLLERRt pollt pollablet registert fdR t longt
event_listt bool( R R R R R R R
R ( ( R t _poll_for0 s c C s¸ g g g } } } | o
| g } n | o
| g } n | o
| g } n | d j o" t i | | | ƒ \ }
} } n" t i | | | | ƒ \ }
} } t
|
p | p | ƒ S( ss Select polling backend.
@param fd: File descriptor
@type fd: int
@param readable: Whether to wait for readability
@type readable: bool
@param writable: Whether to wait for writability
@type writable: bool
@param timeout: Deadline timeout (expiration time, in seconds)
@type timeout: float
@return True on success, False on timeout
N( t rsett wsett xsetR R R R R R R t rcountt wcountt xcountR ( R R R R R R R R R R R ( ( R t _select_forN s
"!c C sÌ t } x¿ | p· | d j o
d } n. | t i ƒ } | d j o t i i ‚ n y- t | | | | | ƒ p t i i ‚ n Wn9 t i
j
o* } | i d t i j o
| ‚ q½ n Xt } q Wd S( Nf0.0i ( t Falset donet
expirationR R R t dnst exceptiont Timeoutt _polling_backendR R R R R t et argst errnot EINTRt True( R R R R R# R R" R( ( ( R t _wait_forj s
c C s
| a d S( s#
Internal API. Do not use.
N( t fnR' ( R. ( ( R t _set_polling_backend{ s R c C s t | t t t | ƒ d S( N( R- t sR, R! R# ( R0 R# ( ( R t _wait_for_readable‹ s c C s t | t t t | ƒ d S( N( R- R0 R! R, R# ( R0 R# ( ( R t _wait_for_writableŽ s c C sQ t i i | | d ƒ } t i i | | d ƒ } | | j o | d | d j S( Ni i ( R$ t inett inet_ptont aft a1t n1t a2t n2( R5 R6 R8 R7 R9 ( ( R t _addresses_equal‘ s c C s | d j o0 y t i i | ƒ } Wq= t i i } q= Xn | t i i j oQ | | f } | d j p
| d j o' | d j o
d } n | | f } qnq | t i i j o] | | d d f } | d j p
| d j o- | d j o
d } n | | d d f } qn | | | f S( Ni s 0.0.0.0s ::( R5 R R$ R3 t af_for_addresst wheret AF_INETt portt destinationt sourcet source_portt AF_INET6( R5 R< R> R@ RA R? ( ( R t _destination_and_source™ s$
i5 i c C s~ | i ƒ }
t | | | | | ƒ \ } } } t
i
| t
i d ƒ } zã t
| ƒ } | i d ƒ | d j o | i | ƒ n t | | ƒ | i |
| ƒ xˆ t | | ƒ | i d ƒ \ }
} t | | | ƒ p( t i i | ƒ o | d | d j o Pn | p t d | | f ƒ ‚ qŸ qŸ WWd | i ƒ Xt i i |
d | i! d | i" d | ƒ}
| i% |
ƒ p
t& ‚ n |
S( s’ Return the response obtained after sending a query via UDP.
@param q: the query
@type q: dns.message.Message
@param where: where to send the message
@type where: string containing an IPv4 or IPv6 address
@param timeout: The number of seconds to wait before the query times out.
If None, the default, wait forever.
@type timeout: float
@param port: The port to which to send the message. The default is 53.
@type port: int
@param af: the address family to use. The default is None, which
causes the address family to use to be inferred from the form of of where.
If the inference attempt fails, AF_INET is used.
@type af: int
@rtype: dns.message.Message object
@param source: source address. The default is the wildcard address.
@type source: string
@param source_port: The port from which to send the message.
The default is 0.
@type source_port: int
@param ignore_unexpected: If True, ignore responses from unexpected
sources. The default is False.
@type ignore_unexpected: bool
@param one_rr_per_rrset: Put each RR into its own RRset
@type one_rr_per_rrset: bool
i i iÿÿ s$ got a response from %s instead of %sNt keyringt request_mact one_rr_per_rrset(' t qt to_wiret wireRC R5 R< R> R@ RA R? t sockett
SOCK_DGRAMR0 R R R# t setblockingR t bindR2 t sendtoR1 t recvfromt from_addressR: R$ R3 t is_multicastt ignore_unexpectedR t closet messaget from_wireRD t macRF t rt is_responseR ( RG R< R R> R5 R@ RA RR RF RP RI R? R0 RW R# ( ( R t udp¯ s6
;#
c C sl d } x_ | d j oQ t | | ƒ | i | ƒ } | d j o
t ‚ n | t | ƒ } | | } q W| S( sß Read the specified number of bytes from sock. Keep trying until we
either get the desired amount, or we hit EOF.
A Timeout exception will be raised if the operation is not completed
by the expiration time.
t i N( R0 t countR1 t sockR# t recvt nt EOFErrort len( R\ R[ R# R^ R0 ( ( R t _net_readë s
c C sO d } t | ƒ } x6 | | j o( t | | ƒ | | i | | ƒ 7} q Wd S( s‘ Write the specified data to the socket.
A Timeout exception will be raised if the operation is not completed
by the expiration time.
i N( t currentR` t datat lR2 R\ R# t send( R\ Rc R# Rd Rb ( ( R t
_net_writeû s
c C sŠ y | i | ƒ Wnr t i j
oc t i ƒ d \ } } | d t i
j o2 | d t i j o | d t i j o
| ‚ q† n Xd S( Ni i (
R0 t connectt addressRJ R t syst exc_infot tyt vR* t EINPROGRESSt EWOULDBLOCKt EALREADY( R0 Rh Rk Rl ( ( R t _connect s <c C sN | i ƒ } t | | | | | ƒ \ } }
} t
i
| t
i d ƒ }
z³ t
| ƒ } |
i d ƒ | d j o |
i | ƒ n t |
|
ƒ t | ƒ } t i d | ƒ | } t |
| | ƒ t |
d | ƒ } t i d | ƒ \ } t |
| | ƒ } Wd |
i ƒ Xt i i | d | i! d | i" d | ƒ} | i% | ƒ p
t& ‚ n | S( s Return the response obtained after sending a query via TCP.
@param q: the query
@type q: dns.message.Message object
@param where: where to send the message
@type where: string containing an IPv4 or IPv6 address
@param timeout: The number of seconds to wait before the query times out.
If None, the default, wait forever.
@type timeout: float
@param port: The port to which to send the message. The default is 53.
@type port: int
@param af: the address family to use. The default is None, which
causes the address family to use to be inferred from the form of of where.
If the inference attempt fails, AF_INET is used.
@type af: int
@rtype: dns.message.Message object
@param source: source address. The default is the wildcard address.
@type source: string
@param source_port: The port from which to send the message.
The default is 0.
@type source_port: int
@param one_rr_per_rrset: Put each RR into its own RRset
@type one_rr_per_rrset: bool
i s !Hi NRD RE RF (' RG RH RI RC R5 R< R> R@ RA R? RJ t SOCK_STREAMR0 R R R# RL R RM Rp R` Rd t structt packt tcpmsgRf Ra t ldatat unpackRS R$ RT RU RD RV RF RW RX R ( RG R< R R> R5 R@ RA RF Ru RI R? Rt Rd R0 RW R# ( ( R t tcp s0
c & c sh t | t t f ƒ o t i i | ƒ } n t | t t f ƒ o t i i | ƒ } n t i i
| | | ƒ }! | t i i
j o6 t i i | d d d d |
ƒ } |! i i | ƒ n | d j o |! i | | d | ƒn |! i ƒ } t | | | | | ƒ \ } } } | o? | t i i
j o t! d ƒ ‚ n t" i" | t" i# d ƒ }" n t" i" | t" i% d ƒ }" |" i& d ƒ | d j o |" i' | ƒ n t( |
ƒ }# t+ |" | ƒ t, | ƒ } | o t. |" |# ƒ |" i/ | ƒ n' t0 i1 d | ƒ | } t3 |" | |# ƒ t4 } d } d } | o | } t i i: }% n
d } | }% d } t= }$ x
| pt( | ƒ } | d j p
| |# j o
|# } n | o& tA |" |# ƒ |" iB d ƒ \ } } n: tD |" d | ƒ } t0 iF d | ƒ \ } tD |" | | ƒ } t i iG | d
|! i d |! iH d t= d
| d | d t= d |$ d | t i i
j ƒ} | i< } t4 }$ d } t4 } t4 } | d j o¼ | iM p | iM d i |% j o t iN iO ‚ n | iM d } | i t i iP j o t iN iO d ƒ ‚ n d } | iQ ƒ } | t i i
j o( | d i |
j o
t= } q't= } q+n xñ | iM | D]â } | o t iN iO d ƒ ‚ n | i t i iP j oŒ | i |% j o| | o4 | d i |
j o t iN iO d ƒ ‚ n t4 } n | t i i
j o | } n | | j o | o
t= } qq9| o t i iR } t4 } q9q9W| o+ |! i o! | iS o t iN iO d ƒ ‚ n | VqPW|" iT ƒ d S( s† Return a generator for the responses to a zone transfer.
@param where: where to send the message
@type where: string containing an IPv4 or IPv6 address
@param zone: The name of the zone to transfer
@type zone: dns.name.Name object or string
@param rdtype: The type of zone transfer. The default is
dns.rdatatype.AXFR.
@type rdtype: int or string
@param rdclass: The class of the zone transfer. The default is
dns.rdataclass.IN.
@type rdclass: int or string
@param timeout: The number of seconds to wait for each response message.
If None, the default, wait forever.
@type timeout: float
@param port: The port to which to send the message. The default is 53.
@type port: int
@param keyring: The TSIG keyring to use
@type keyring: dict
@param keyname: The name of the TSIG key to use
@type keyname: dns.name.Name object or string
@param relativize: If True, all names in the zone will be relativized to
the zone origin. It is essential that the relativize setting matches
the one specified to dns.zone.from_xfr().
@type relativize: bool
@param af: the address family to use. The default is None, which
causes the address family to use to be inferred from the form of of where.
If the inference attempt fails, AF_INET is used.
@type af: int
@param lifetime: The total number of seconds to spend doing the transfer.
If None, the default, then there is no limit on the time the transfer may
take.
@type lifetime: float
@rtype: generator of dns.message.Message objects.
@param source: source address. The default is the wildcard address.
@type source: string
@param source_port: The port from which to send the message.
The default is 0.
@type source_port: int
@param serial: The SOA serial number to use as the base for an IXFR diff
sequence (only meaningful if rdtype == dns.rdatatype.IXFR).
@type serial: int
@param use_udp: Use UDP (only meaningful for IXFR)
@type use_udp: bool
@param keyalgorithm: The TSIG algorithm to use; defaults to
dns.tsig.default_algorithm
@type keyalgorithm: string
i t INt SOAs . . %u 0 0 0 0t algorithms cannot do a UDP AXFRs !Hiÿÿ i RD RE t xfrt origint tsig_ctxt multit firstRF s first RRset is not an SOAi s answers after final SOAs IXFR base serial mismatchs missing TSIGN(U t
isinstancet zonet strt unicodeR$ t namet from_textt rdtypet rdatatypeRT t
make_queryt rdclassRG t IXFRt rrsett serialt authorityt appendRD R t use_tsigt keynamet keyalgorithmRH RI RC R5 R< R> R@ RA R? t use_udpt
ValueErrorRJ RK R0 Rq RL RM R t lifetimeR# Rp R` Rd R2 Re Rr Rs Rt Rf R! R" t soa_rrsett soa_countt
relativizeR| t emptyt onameR} R, R R t mexpirationR1 RO RP Ra Ru Rv RU RV RW t answer_indext delete_modet
expecting_SOAt answerR% t FormErrorRy t copyt AXFRt had_tsigRS (& R< R R† R‰ R R> RD R R— R5 R” R@ RA RŒ R’ R‘ R| Ru R" R‹ Rœ RP RI R? R• R R› R} RW Rš Rt R– Rd RG R0 R# R R™ ( ( R R{ H sº 3
"
&
(/ R t
__future__t
generatorsR* R RJ Rr Ri R t
dns.exceptionR$ t dns.inett dns.namet dns.messaget dns.rdataclasst
dns.rdatatypeR% t DNSExceptionR RŸ R R R R R- R/ t hasattrR' R1 R2 R: RC R R! RY Ra Rf Rp Rw R‡ R¡ t
rdataclassRx R, t tsigt default_algorithmR{ ( Rw Rf R1 R Rr Ra R* RC R2 R¤ R$ R R RY R R Ri R{ Rp RJ R/ R R R- R: ( ( R t ? sB
<
8