o g0!@sdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z mZmZmZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddZddZ ej!"dZ#e#rddl$Z%ddl&Z&e%j'Z(e%j)j*j+Z,Gd d d e(Z-Gd d d e&j.Z/nGd d d Z/e#Z0zddl1Z1Wne2yGdddZ1YnwejZ3Gdddej4j5Z6Gdddej4j7Z8Gdddej4j5Z9Gdddej4j5Z:ej;jddZ?e@edrejAaBnejCaBdd ZDd!d"ZEd#d$ZFd%d&ZG 'dd(d)ZHdd*d+ZIdd,ddd-d-dd.d'dd'dejJf d/ejKjLd0eMd1eeNd2eOd3eeMd4eOd5ePd6ePd7ee d8eMd9ePd:eeMd;eePeMfdeeOd?ejKjLf d@dAZQdBdCZRdDdEZS ddFe dGeejKjLeTfdHe dIeeNd?eeOeNff dJdKZU   - -  L - - - ddFe dHee dIeeNdMePd5ePdNee ejVjWejXjYfdOeeTd6ePdPePdQePdReejKjLd?e fdSdTZZ  U   - - - -  -dd/ejKjLd0eMd1eeNd2eOd3eeMd4eOdMePd5ePd6ePdPePdFee dQePd?ejKjLfdVdWZ[  U   - - -   -dd/ejKjLd0eMd1eeNd2eOd3eeMd4eOdMePd5ePd6ePdXee dYee dQePd?eejKjLePffdZd[Z\d\d]Z]d^d_Z^ ddFe dGeejKjLeTfdIeeNd?eeOeNffd`daZ_  -  L -ddFe dIeeNd5ePdNee ejVjWejXjYfdOeeTd6ePd?eejKjLeNffdbdcZ`dddeZa  U   - - dd/ejKjLd0eMd1eeNd2eOd3eeMd4eOd5ePd6ePdFee d?ejKjLfdfdgZbdhdiZcdjeeMd;eePeMfd?e1jdfdkdlZe  m   - -    'dd/ejKjLd0eMd1eeNd2eOd3eeMd4eOd5ePd6ePdFee1jfdnee1jddjeeMd;eePeMfd?ejKjLfdodpZg  m   - -  ' dd/ejKjLd0eMd1eeNd2eOd3eeMd4eOd5ePd6ePdqeejhjid;eePeMfdjeeMd?ejKjLfdrdsZhejjjkejljmddUddd'ddddd-ejXjnf d0eMdteejVjWeMfdueejjjoeMfdveejljpeMfd1eeNd2eOdNee ejVjWejXjYfdweeejVjWeMfdxePdyeeNd3eeMd4eOdzeOd{ePd|eejVjWeMfd?e f d}d~Z;GdddejqZrddUdddderjsfd0eMdejtjudReejKjLd2eOd1eeNdyeeNd3eeMd4eOderd?dfddZvdS)zTalk to a DNS server.N)AnyDictOptionalTupleUnioncCs,|durdS|t}|dkrtjj|S)N)timedns exceptionTimeout) expirationtimeoutrV/var/www/html/portale_awareness/portale-venv/lib/python3.10/site-packages/dns/query.py _remaining/s  rcCs|durdStt||SN)minr)r r rrr_expiration_for_this_attempt8srdohcs4eZdZfddZ dddZ dddZZS) _NetworkBackendcs&t||_||_||_||_dSr)super__init__ _local_port _resolver_bootstrap_address_family)selfresolver local_portbootstrap_addressfamily __class__rrrGs  z_NetworkBackend.__init__Nc Csg}t|\}}tj|r||n(|jdur ||jnt|}|j} |r/tj|} |j j || |d} | }|D]G} tj| } |dusO|j dkrZtj ||j f| } nd} t| tj| }td|}zt|tj | |f| |t|WStyYq>wtj)N)r lifetimerg@)_compute_timesr inet is_addressappendrrraf_for_addressr resolve_name addressesrlow_level_address_tuple _make_socketsocket SOCK_STREAMr_connect_CoreSyncStream Exceptionhttpcore ConnectError)rhostportr local_addresssocket_optionsr*_r r answersaddressafsourcesockattempt_expirationrrr connect_tcpNsD         z_NetworkBackend.connect_tcpcCtrNotImplementedError)rpathr r7rrrconnect_unix_socketusz#_NetworkBackend.connect_unix_socketr)__name__ __module__ __qualname__rr?rD __classcell__rrr!rrFs   (rcs*eZdZdddejdfdd ZZS)_HTTPTransportrN)rrrr csB|dur ddl}|j}tj|i|t|||||j_dSNr) dns.resolverrResolverrrr_pool_network_backend)rrrrr argskwargsr r!rrr{s   z_HTTPTransport.__init__)rErFrGr- AF_UNSPECrrHrrr!rrIzs rIc@seZdZddZdS)rIcCr@rrA)rr4r5r r6rrrr?sz_HTTPTransport.connect_tcpN)rErFrGr?rrrrrIs c@sXeZdZdZGdddeZGdddeZGdddZGdd d Ze d d Z d S) sslrc@ eZdZdS)zssl.WantReadExceptionNrErFrGrrrrWantReadExceptionrUc@rS)zssl.WantWriteExceptionNrTrrrrWantWriteExceptionrVrWc@rS)zssl.SSLContextNrTrrrr SSLContextrVrXc@rS)z ssl.SSLSocketNrTrrrr SSLSocketrVrYcOstd)Nzno ssl support)r1)clsrOrPrrrcreate_default_contextszssl.create_default_contextN) rErFrG CERT_NONEr1rUrWrXrY classmethodr[rrrrrRsrRc@eZdZdZdS)UnexpectedSourcez=A DNS query response came from an unexpected address or port.NrErFrG__doc__rrrrr_r_c@r^) BadResponsez:/. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, a ``int``, the port to send the query to. The default is 443. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *session*, an ``httpx.Client``. If provided, the client session to use to send the queries. *path*, a ``str``. If *where* is an IP address, then *path* will be used to construct the URL to send the DNS query to. *post*, a ``bool``. If ``True``, the default, POST method will be used. *bootstrap_address*, a ``str``, the IP address to use to bypass resolution. *verify*, a ``bool`` or ``str``. If a ``True``, then TLS certificate verification of the server is done using the default CA bundle; if ``False``, then no verification is done; if a `str` then it specifies the path to a certificate file or directory which will be used for verification. *resolver*, a ``dns.resolver.Resolver`` or ``None``, the resolver to use for resolution of hostnames in URLs. If not specified, a new resolver with a default configuration will be used; note this is *not* the default resolver as that resolver might have been configured to use DoH causing a chicken-and-egg problem. This parameter only has an effect if the HTTP library is httpx. *family*, an ``int``, the address family. If socket.AF_UNSPEC (the default), both A and AAAA records will be retrieved. Returns a ``dns.message.Message``. z)session parameter must be an httpx.ClientFNacceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}rr~T)r6http1http2rrrrr )rrr transport)z content-typezcontent-length)headerscontentr =r )rr paramsi+z2{} responded with status code {} Response body: {}keyring request_macrr)&have_dohrdrghttpxClientrto_wirerr r%r&r-AF_INETformatAF_INET6rI contextlib nullcontextupdatestrlenrbase64urlsafe_b64encoderstripdecodeget status_codermessage from_wirerrelapsed total_secondsr is_responserc)rrr r5r<rrrrrCrrrrr wirer;r8 the_sourcerrurlr6rcmresponsetwirerrrrhttpsfsD         rcCs. z||WStyt||Ynwq)zReads a datagram from the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )recvfromBlockingIOErrorr{)r=max_sizer rrr _udp_recvs  rcCs@ z|r |||WS||WStyt||Ynwq)zSends the specified datagram to destination over the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )sendtosendrr})r=datarr rrr _udp_sends  rr=whatrr cCs4t|tjjr |}t}t||||}||fS)aSend a DNS message to the specified UDP socket. *sock*, a ``socket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *destination*, a destination tuple appropriate for the address family of the socket, specifying where to send the query. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. Returns an ``(int, float)`` tuple of bytes sent and the sent time. )rgr rMessagerrr)r=rrr sent_timenrrrsend_udps rrrrraise_on_truncation ignore_errorsqueryc  Csd} t|d|\} } t|j| ||sqt} ztjj| |||||d}Wn-tjjyH}z| rC| durC| |sCWYd}~qd}~wt yS| rRYqw| r`| dur`| |s`q|rf|| fS|| | fS)aRead a DNS message from a UDP socket. *sock*, a ``socket``. *destination*, a destination tuple appropriate for the address family of the socket, specifying where the message is expected to arrive from. When receiving a response, this would be where the associated query was sent. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *keyring*, a ``dict``, the keyring to use for TSIG. *request_mac*, a ``bytes`` or ``None``, the MAC of the request (for TSIG). *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. Raises if the message is malformed, if network errors occur, of if there is a timeout. If *destination* is not ``None``, returns a ``(dns.message.Message, float)`` tuple of the received message and the received time. If *destination* is ``None``, returns a ``(dns.message.Message, float, tuple)`` tuple of the received message, the received time, and the address where the message arrived from. *ignore_errors*, a ``bool``. If various format errors or response mismatches occur, ignore them and keep listening for a valid response. The default is ``False``. *query*, a ``dns.message.Message`` or ``None``. If not ``None`` and *ignore_errors* is ``True``, check that the received message is a response to this query, and if not keep listening for a valid response. rT)rrrrrN) rrr rr rr Truncatedrr1)r=rr rrrrrrrrrr received_timererrr receive_udp2sH>      r5c  Cs|} t||||\} }}t|\}}| rt| }nt| tj|}|1}t|| ||t ||||||j |j || | | \}}|||_ | sM| |sMt|WdS1sYwY J)aReturn the response obtained after sending a query via UDP. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. *sock*, a ``socket.socket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the *source* and *source_port* are ignored. *ignore_errors*, a ``bool``. If various format errors or response mismatches occur, ignore them and keep listening for a valid response. The default is ``False``. Returns a ``dns.message.Message``. N)rrr$rrr,r- SOCK_DGRAMrrrmacrrrc)rrr r5r<rrrrrr=rrr;r begin_timer rrzrrrrrudps<8    rudp_socktcp_sockc Cs`zt|||||||||d| | } | dfWStjjy/t||||||||| } | dfYSw)a|Return the response to the query, trying UDP first and falling back to TCP if UDP results in a truncated response. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *udp_sock*, a ``socket.socket``, or ``None``, the socket to use for the UDP query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the *source* and *source_port* are ignored for the UDP query. *tcp_sock*, a ``socket.socket``, or ``None``, the connected socket to use for the TCP query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected stream socket, and *where*, *source* and *source_port* are ignored for the TCP query. *ignore_errors*, a ``bool``. If various format errors or response mismatches occur while listening for UDP, ignore them and keep listening for a valid response. The default is ``False``. Returns a (``dns.message.Message``, tcp) tuple where tcp is ``True`` if and only if TCP was used. TF)rr rrtcp) rrr r5r<rrrrrrrrrrrudp_with_fallbacks<9  rc Csd}|dkrAz||}|dkrt|t|8}||7}Wnttjfy.t||Yntjy<t||Ynw|dks|S)zRead 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. rr) recvEOFErrorrrrRSSLWantReadErrorr{SSLWantWriteErrorr})r=countr rzrrrr _net_readOs    rc Cs~d}t|}||kr=z ||||d7}Wnttjfy(t||Yntjy6t||Ynw||ks dSdS)zWrite the specified data to the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. rN)rrrrRrr}rr{)r=rr currentlrrr _net_writedsrcCsPt|tjjr|jdd}n t|dd|}t}t|||t||fS)a{Send a DNS message to the specified TCP socket. *sock*, a ``socket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. Returns an ``(int, float)`` tuple of bytes sent and the sent time. T)prepend_lengthbig) rgr rrrrto_bytesrr)r=rr tcpmsgrrrrsend_tcpts   rc CsLt|d|}td|\}t|||}t} tjj|||||d} | | fS)aRead a DNS message from a TCP socket. *sock*, a ``socket``. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *keyring*, a ``dict``, the keyring to use for TSIG. *request_mac*, a ``bytes`` or ``None``, the MAC of the request (for TSIG). *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. Raises if the message is malformed, if network errors occur, of if there is a timeout. Returns a ``(dns.message.Message, float)`` tuple of the received message and the received time. r!Hr)rstructunpackrr rr) r=r rrrrldatarrrrrrr receive_tcps ! rcCs`||}|dkr dS|tjtjtjfvr"t|||tjtj }|dkr.t |t |dSrJ) connect_exerrno EINPROGRESS EWOULDBLOCKEALREADYr} getsockoptr- SOL_SOCKETSO_ERROROSErrorosstrerror)rzr:r errrrrr/s  r/c Cs|} t|\} } |rt|} nt||||\} }}t| tj|} | 1}|s.t||| t || | t || ||j |j |\}}|| |_ ||sMt|WdS1sYwY J)aReturn the response obtained after sending a query via TCP. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *sock*, a ``socket.socket``, or ``None``, the connected socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected stream socket, and *where*, *port*, *source* and *source_port* are ignored. Returns a ``dns.message.Message``. N)rr$rrrr,r-r.r/rrrrrrrc)rrr r5r<rrrr=rrr rr;rrzrrrrrrs,+         rcCsN z|WdStjyt||Yntjy%t||Ynwqr) do_handshakerRrr{rr}ryrrr_tls_handshakesr rcCsd}d}t|trtj|r|}n tj|r|}ntdtj||d}tj j |_ |dur2d|_ | dg|dur@tj|_|S)Nzinvalid verify string)cafilecapathFdot)rgrr rCisfileisdirrrRr[ TLSVersionTLSv1_2minimum_versioncheck_hostnameset_alpn_protocolsr\ verify_mode)rrrrrrrr_make_dot_ssl_contexts      rUrc  Cs|rt||||||||| S|} t|\} }t||||\}}}| dur-|s-t| | } t|tj|| | d4}t|||t ||t || |t ||||j |j |\}}|| |_||sbt|WdS1snwY J)akReturn the response obtained after sending a query via TLS. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 853. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *sock*, an ``ssl.SSLSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected SSL stream socket, and *where*, *port*, *source*, *source_port*, and *ssl_context* are ignored. *ssl_context*, an ``ssl.SSLContext``, the context to use when establishing a TLS connection. If ``None``, the default, creates one with the default configuration. *server_hostname*, a ``str`` containing the server's hostname. The default is ``None``, which means that no hostname is known, and if an SSL context is created, hostname checking will be disabled. *verify*, a ``bool`` or ``str``. If a ``True``, then TLS certificate verification of the server is done using the default CA bundle; if ``False``, then no verification is done; if a `str` then it specifies the path to a certificate file or directory which will be used for verification. Returns a ``dns.message.Message``. N)rr)rrr$rrr,r-r.r/r rrrrrrrc)rrr r5r<rrrr=rrrrrr r;rrzrrrrrtls1sP=         r connectionc  Cstjjstdd|_|} |rtd} |} n tjj| | d} | }| >|s0| ||||} t |\}}| |}| | d| t|} Wdn1sSwYt}Wdn1sfwYtjj| |j|j||d}t||d|_||st|S)aReturn the response obtained after sending a query via DNS-over-QUIC. *q*, a ``dns.message.Message``, the query to send. *where*, a ``str``, the nameserver IP address. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, a ``int``, the port to send the query to. The default is 853. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *connection*, a ``dns.quic.SyncQuicConnection``. If provided, the connection to use to send the query. *verify*, a ``bool`` or ``str``. If a ``True``, then TLS certificate verification of the server is done using the default CA bundle; if ``False``, then no verification is done; if a `str` then it specifies the path to a certificate file or directory which will be used for verification. *server_hostname*, a ``str`` containing the server's hostname. The default is ``None``, which means that no hostname is known, and if an SSL context is created, hostname checking will be disabled. Returns a ``dns.message.Message``. zDNS-over-QUIC is not available.rN)r server_nameTrr)r quic have_quicreidrrrSyncQuicManagerconnectr$ make_streamrreceiverrrrrrmaxrrc)rrr r5r<rrrrrrrmanagerthe_connection the_managerstartr streamfinishrrrrrs@2      rzonerdtyperdclasskeyname relativizer#serialuse_udp keyalgorithmc' cst|tr tj|}tjj|}tj |||}|tjj kr3tj |dddd| }|j ||dur?|j|||d|}t||| | \}}} | rY|tjj krYtd| r^tjntj}t||| q}t| \}}t|||t|}| rt||d|ntd||}t|||d }d }d }d}|r|}tjj}nd}|}d} |st|\}}!|!dus|dur|!|kr|}!| rt|d |!\}}nt|d |!}"t d|"\}t|||!}|tjj k}#tjj!||j"|j#d || d |#d }$|$$}%|%tj$j%krt&|%|$j'} d}&|durP|$j(r|$j(dj|krtj)*d|$j(d}|j+tjj,kr2tj)*dd}&|-}|tjj krPtj./|dj.| krNd }nd }|$j(|&dD][}|rbtj)*d|j+tjj,kr|j|kr|r|dj.| krtj)*dd }n |tjj kr| }||kr|tjj0ks|tjj kr|rd }qW|rtjj0}d }qW|r|j"r|$j1stj)*d|$V|rWddSWddS1swYdS)aReturn a generator for the responses to a zone transfer. *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *zone*, a ``dns.name.Name`` or ``str``, the name of the zone to transfer. *rdtype*, an ``int`` or ``str``, the type of zone transfer. The default is ``dns.rdatatype.AXFR``. ``dns.rdatatype.IXFR`` can be used to do an incremental transfer instead. *rdclass*, an ``int`` or ``str``, the class of the zone transfer. The default is ``dns.rdataclass.IN``. *timeout*, a ``float``, the number of seconds to wait for each response message. If None, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *keyring*, a ``dict``, the keyring to use for TSIG. *keyname*, a ``dns.name.Name`` or ``str``, the name of the TSIG key to use. *relativize*, a ``bool``. 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()`` if using this generator to make a zone. *lifetime*, a ``float``, 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. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *serial*, an ``int``, the SOA serial number to use as the base for an IXFR diff sequence (only meaningful if *rdtype* is ``dns.rdatatype.IXFR``). *use_udp*, a ``bool``. If ``True``, use UDP (only meaningful for IXFR). *keyalgorithm*, a ``dns.name.Name`` or ``str``, the TSIG algorithm to use. Raises on errors, and so does the generator. Returns a generator of ``dns.message.Message`` objects. rINSOAz. . %u 0 0 0 0N) algorithmzcannot do a UDP AXFRrFTrrrrxfrorigintsig_ctxmultirz No answer or RRset not for qnamezfirst RRset is not an SOAr~zanswers after final SOAzIXFR base serial mismatch missing TSIG)2rgrr name from_text rdatatype RdataTypemaker make_queryIXFRrrset authorityr'use_tsigrrrr-rr.r,r$r/rrrpackremptyrrrrrrrcodeNOERROR TransferErrorr:answerr FormErrorr-r5copyr1SerialAXFRhad_tsig)'rr,r-r.r r5rr/r0r#r<rr1r2r3rrDrr;r sock_typerzr8r rrdone delete_mode expecting_SOA soa_rrsetr9onamer: mexpirationris_ixfrrrI answer_indexrrrr8s E                     $r8c@seZdZdZdZdZdZdS)UDPModeaHow should UDP be used in an IXFR from :py:func:`inbound_xfr()`? NEVER means "never use UDP; always use TCP" TRY_FIRST means "try to use UDP but fall back to TCP if needed" ONLY means "raise ``dns.xfr.UseTCP`` if trying UDP does not succeed" rr~rN)rErFrGraNEVER TRY_FIRSTONLYrrrrr[s r[ txn_managerudp_modec  CsT|dur tj|\}} ntj|} |jdj} | tjjk} |} | } t ||||\}}}t |\}}d}|r(d}| rK|t j krKtj}d}ntj}d}t|||}t||||rgt|| d|ntdt| | }t|||tj|| | |}d}d}|st |\}}|dus|dur||kr|}|rt|d|\}}nt|d|}td|\}t|||}tjj||j|jd| || | d}z| |}Wntjj!y|sJ|t j"krd}d}t j }Yqw|j#}|r|s|jr|j$stj%&d Wdn 1swYWdn 1swY|ss~  4     ,             m     ^     X    /  D        n    Z      ;