U  W[@sddlmZmZddgZddlmZmZddlmZddlm Z ddlm Z ddlm Z dd l m Z dd lmZmZdd lmZGd ddejZGd dde ZdS))absolute_importdivisionSecondaryAuthoritySecondaryAuthorityService)taskdefer)dns)common)client)resolve) FileAuthority)logfailure)servicec@s@eZdZdZdZddZeddZddZd d Z d d Z dS) rN5cs|_fdd|D|_dS)a @param primary: The IP address of the server from which to perform zone transfers. @type primary: L{str} @param domains: A sequence of domain names for which to perform zone transfers. @type domains: L{list} of L{bytes} csg|]}t|qS)r.0dprimaryr9/usr/lib/python3/dist-packages/twisted/names/secondary.py #sz6SecondaryAuthorityService.__init__..N)rdomains)selfrrrrr__init__s z"SecondaryAuthorityService.__init__cs6|dg}d|_d|_fdd|D|_|S)aS Construct a new L{SecondaryAuthorityService} from a tuple giving a server address and a C{str} giving the name of a domain for which this is an authority. @param serverAddress: A two-tuple, the first element of which is a C{str} giving an IP address and the second element of which is a C{int} giving a port number. Together, these define where zone transfers will be attempted from. @param domain: A C{bytes} giving the domain to transfer. @return: A new instance of L{SecondaryAuthorityService}. Nrcsg|]}t|qSr)rfromServerAddressAndDomainr serverAddressrrr9szISecondaryAuthorityService.fromServerAddressAndDomains..)r_portr)clsrrrrrrfromServerAddressAndDomains&s    z5SecondaryAuthorityService.fromServerAddressAndDomainscCs t|jSN)r Z ResolverChainrrrrr getAuthority?sz&SecondaryAuthorityService.getAuthoritycCsVtj|dd|jD|_d}ddlm}|jD]}|||jd|d7}q4dS)NcSsg|]}t|jqSr)rZ LoopingCalltransferrrrrrDsz:SecondaryAuthorityService.startService..rreactorir) rService startServicercallstwisted.internetr(Z callLaterstart)rir(crrrr*Bs   z&SecondaryAuthorityService.startServicecCs$tj||jD] }|qdSr#)rr) stopServicer+stop)rr/rrrr0Ls  z%SecondaryAuthorityService.stopService) __name__ __module__ __qualname__r+r r classmethodr"r%r*r0rrrrrs  c@sreZdZdZdZdZZdZdZddZ e ddZ d d Z dd d Z d dZddZddZddZddZdS)ra An Authority that keeps itself updated by performing zone transfers. @ivar primary: The IP address of the server from which zone transfers will be attempted. @type primary: C{str} @ivar _port: The port number of the server from which zone transfers will be attempted. @type: C{int} @ivar _reactor: The reactor to use to perform the zone transfers, or L{None} to use the global reactor. FNrcCstj|||_||_dS)z @param domain: The domain for which this will be the secondary authority. @type domain: L{bytes} N)r Z ResolverBaserrdomain)rZ primaryIPr6rrrrhs zSecondaryAuthority.__init__cCs(|dd}|d|_|d|_||_|S)aG Construct a new L{SecondaryAuthority} from a tuple giving a server address and a C{bytes} giving the name of a domain for which this is an authority. @param serverAddress: A two-tuple, the first element of which is a C{str} giving an IP address and the second element of which is a C{int} giving a port number. Together, these define where zone transfers will be attempted from. @param domain: A C{bytes} giving the domain to transfer. @return: A new instance of L{SecondaryAuthority}. Nrr)rr r6)r!rr6Z secondaryrrrrvs    z-SecondaryAuthority.fromServerAddressAndDomaincCs^|jr dSd|_|j}|dkr*ddlm}tj|j|jfg|d}| |j  |j  |jS)NTrr')Zserversr() transferringZ transfering_reactorr,r(r ZResolverrr Z lookupZoner6Z addCallback_cbZoneZ addErrback_ebZone)rr(Zresolverrrrr&s   zSecondaryAuthority.transfercCs4|jr |js"ttt|St |||||Sr#) soarecordsrZfailrZFailurerZ DomainErrorr _lookup)rnamer!typeZtimeoutrrrr=s zSecondaryAuthority._lookupcCsj|\}}}i|_}|D]L}|jsF|jtjkrFt|j|jf|_q| t|jg |jqdSr#) r<r;r?rZSOAstrr>lowerZpayload setdefaultappend)rZzoneZans_rZrecrrrr9s   zSecondaryAuthority._cbZonecCs$td|j|jft|dS)Nz/Updating %s from %s failed during zone transfer)r msgr6rerrrrrrrr:szSecondaryAuthority._ebZonecCs||j|jdSr#)r&Z addCallbacks_cbTransferred_ebTransferredr$rrrupdateszSecondaryAuthority.updatecCs d|_dS)NF)r7)rresultrrrrIsz!SecondaryAuthority._cbTransferredcCs*d|_td|j|jft|dS)NFz2Transferring %s from %s failed after zone transfer)Z transferredr rFr6rrGrHrrrrJsz!SecondaryAuthority._ebTransferred)N)r2r3r4__doc__r7r;r<r r8rr5rr&r=r9r:rKrIrJrrrrrSs   N)Z __future__rr__all__r,rrZ twisted.namesrr r r Ztwisted.names.authorityr Ztwisted.pythonr rZtwisted.applicationrr)rrrrrrs      @