File: //usr/lib/python2.7/site-packages/dns/query.pyo
�
�b�Wc @ s* d Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z
d d l Z
d d l Z
d d l
Z
d d l Z
d d l Z
d d l m Z m Z e j d k r� e Z n e j Z e j Z d e
j j f d � � YZ d e
j j f d
� � YZ d � Z d � Z d
� Z d � Z d � Z! e" e d � rce 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
j/ j0 e
j1 j2 d d d d e3 d d d d d e) e
j4 j5 d � Z6 d S( s Talk to a DNS server.i����( t
generatorsNi ( t longt string_typesi t UnexpectedSourcec B s e Z d Z RS( s= A DNS query response came from an unexpected address or port.( t __name__t
__module__t __doc__( ( ( s- /usr/lib/python2.7/site-packages/dns/query.pyR , s t BadResponsec B s e Z d Z RS( s< A DNS query response does not respond to the question asked.( R R R ( ( ( s- /usr/lib/python2.7/site-packages/dns/query.pyR 1 s c C s" | d k r d St j � | Sd S( N( t Nonet time( t timeout( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _compute_expiration6 s c C s� d } | r | t j O} n | r2 | t j O} n | rH | t j O} n t j � } | j | | � | r� | j t | d � � } n | j � } 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� ( t selectt POLLINt POLLOUTt POLLERRt pollt registerR t bool( t fdt readablet writablet errorR
t
event_maskt pollablet
event_list( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _poll_for= s c C s� g g g } } } | r& | g } n | r8 | g } n | rJ | g } n | d k rw t j | | | � \ } } }
n! t j | | | | � \ } } }
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( R R R ( R R R R R
t rsett wsett xsett rcountt wcountt xcount( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _select_for\ s !!c C s� t } x� | s� | d k r$ d } n+ | t j � } | d k rO t j j � n y+ t | | | | | � sy t j j � n Wn2 t k
r� } | j d t j
k r� | � q� n Xt } q Wd S( Ng i ( t FalseR R t dnst exceptiont Timeoutt _polling_backendt select_errort argst errnot EINTRt True( R R R R t
expirationt doneR
t e( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _wait_fory s
c C s
| a d S( s#
Internal API. Do not use.
N( R& ( t fn( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _set_polling_backend� s R c C s t | t t t | � d S( N( R/ R+ R" ( t sR, ( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _wait_for_readable� s c C s t | t t t | � d S( N( R/ R" R+ ( R2 R, ( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _wait_for_writable� s c C sP t j j | | d � } t j j | | d � } | | k oO | d | d k S( Ni i ( R# t inett inet_pton( t aft a1t a2t n1t n2( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _addresses_equal� s c C s | d k rE y t j j | � } WqE t k
rA t j j } qE Xn | t j j k r� | | f } | d k s{ | d k r | d k r� d } n | | f } q ni | t j j k r | | d d f } | d k s� | d k r | d k r� d } n | | d d f } q n | | | f S( Ni s 0.0.0.0s ::( R R# R5 t af_for_addresst Exceptiont AF_INETt AF_INET6( R7 t wheret portt sourcet source_portt destination( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _destination_and_source� s$
i5 i c C s� | j � } t | | | | | � \ } }
} t | t j d � } d } z� t | � }
| j d � | d k r� | j | � n t | |
� t
j
� } | j | |
� x� t | |
� | j
d � \ } } t | | |
� st j j | � r
| d |
d k r
Pn | s� t d | |
f � � q� q� WWd | d k rFd } n t
j
� | } | j � Xt j j | d | j d | j d | �} | | _
| j | � s�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 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 to_wireRF t socket_factoryt sockett
SOCK_DGRAMR R t setblockingt bindR4 R t sendtoR3 t recvfromR< R# R5 t is_multicastR t closet messaget from_wireRG t mact is_responseR ( t qRA R
RB R7 RC RD t ignore_unexpectedRI t wireRE R2 t
begin_timeR, t from_addresst
response_timet r( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt udp� sD
! c C sh d } x[ | d k rc t | | � | j | � } | d k rF 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 ( R3 t recvt EOFErrort len( t sockt countR, R2 t n( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _net_read s
c C sM d } t | � } x4 | | k rH t | | � | | j | | � 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( Rc R4 t send( Rd t dataR, t currentt l( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt
_net_write s
c C s� y | j | � Wnv t j k
r� t j � d \ } } t | d � rU | j } n
| d } | t j t j t j g k r� | � q� n Xd S( Ni R) i (
t connectRL R t syst exc_infot hasattrR) t EINPROGRESSt EWOULDBLOCKt EALREADY( R2 t addresst tyt vt v_err( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt _connect% s
c C s� | j � } t | | | | | � \ } } } t | t j d � }
d } z� t | � } |
j d � t j � } | d k r� |
j | � n t
|
| � t | � }
t j
d |
� | } t |
| | � t |
d | � } t j d | � \ }
t |
|
| � } Wd | d k r d } n t j � | } |
j � Xt j j | d | j d | j d | �} | | _ | j | � s�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 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 NRG RH RI ( RJ RF RK RL t SOCK_STREAMR R RN R RO Rx Rc t structt packRl Rg t unpackRS R# RT RU RG RV RW R ( RX RA R
RB R7 RC RD RI RZ RE R2 R[ R, Rk t tcpmsgt ldataR] R^ ( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt tcp3 s8
! c & c sH t | t � r$ t j j | � } n t | t � rH t j j | � } n t j j | | | � } | t j j k r� t j j | d d d d |
� } | j
j | � n | d k r� | j
| | d | �n | j � } t | | | | | � \ } } } | r8| t j j k r t d � � n t | t j d � } n t | t j d � } | j d � | d k rv| j | � n t |
� } t | | � t | � } | r�t | | � | j | � n& t j d | � | } t | | | � t } t } t } d } | r| } t j j! } n d } | } d } t } x| s9t | � } | d k s\| | k re| } n | r�t" | | � | j# d � \ } }! n9 t$ | d | � }" t j% d |" � \ } t$ | | | � } | t j j k }# t j j& | d
| j' d | j( d t d
| d | d t d | d |# �}$ |$ j) } t } d }% | d k r�|$ j* sd|$ j* d j | k ryt j+ j, d � � n |$ j* d } | j- t j j. k r�t j+ j, d � � n d }% | j/ � } | t j j k r�| d j0 |
k r�t } q�t } q�n x|$ j* |% D]� } | r+t j+ j, d � � n | j- t j j. k r�| j | k r�| r�| d j0 |
k r}t j+ j, d � � n t } n | t j j k r�| } n | | k r�| t j j1 k s�| t j j k r�| r�t } q�q
| r
t j j1 } t } q
q
W| r1| j' r1|$ j2 r1t j+ j, d � � n |$ Vq2W| j3 � 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 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 RG RH t xfrt origint tsig_ctxt multit firstRI s No answer or RRset not for qnames first RRset is not an SOAi s answers after final SOAs IXFR base serial mismatchs missing TSIGN(4 t
isinstanceR R# t namet from_textt rdatatypeRT t
make_queryt IXFRt rrsett authorityt appendR t use_tsigRJ RF t
ValueErrorRK RL RM Ry RN RO R Rx Rc R4 Rh Rz R{ Rl R" R+ t emptyR3 RQ Rg R| RU RG RV R� t answerR$ t FormErrort rdtypeR� t copyt serialt AXFRt had_tsigRS (& RA t zoneR� t rdclassR
RB RG t keynamet
relativizeR7 t lifetimeRC RD R� t use_udpt keyalgorithmRX R� RZ RE R2 R, Rk R} R- t delete_modet
expecting_SOAt soa_rrsetR� t onameR� R� t mexpirationR\ R~ t is_ixfrR^ t answer_index( ( s- /usr/lib/python2.7/site-packages/dns/query.pyR� s s� 5
!
$
( i (7 R t
__future__R R) R RL Rz Rn R t
dns.exceptionR# t dns.inett dns.namet dns.messaget dns.rdataclasst
dns.rdatatypet _compatR R t version_infot OSErrorR' R RK R$ t DNSExceptionR R� R R R R! R/ R1 Rp R& R3 R4 R< RF R R" R_ Rg Rl Rx R R� R� t
rdataclassR� R+ t tsigt default_algorithmR� ( ( ( s- /usr/lib/python2.7/site-packages/dns/query.pyt <module> sV C ?