/usr/lib/python3/dist-packages/twisted/names/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/names/__pycache__/secondary.cpython-310.pyc (7885B)
o
b @ s d dgZ ddlmZ ddlmZmZ ddlmZmZm Z m
Z
ddl m Z ddl
mZmZ ddlmZ G d d dejZG d
d d e Zd S ) SecondaryAuthoritySecondaryAuthorityService )service)defertask)clientcommondnsresolve)
FileAuthority)failurelog) nativeStringc @ sD e Zd ZdZdZdZdd Zedd Zdd Z d
d Z
d d
Z dS )r a:
A service that keeps one or more authorities up to date by doing hourly
zone transfers from a master.
@ivar primary: IP address of the master.
@type primary: L{str}
@ivar domains: An authority for each domain mirrored from the master.
@type domains: L{list} of L{SecondaryAuthority}
N5 c s" t | _ 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}
c s g | ]}t |qS )r .0dprimaryr 9/usr/lib/python3/dist-packages/twisted/names/secondary.py
+ s z6SecondaryAuthorityService.__init__..N)r r domains)selfr r r r r __init__ s
z"SecondaryAuthorityService.__init__c s0 \}}| |g }||_ fdd|D |_|S )a
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 domains: Domain names for which to perform zone transfers.
@type domains: sequence of L{bytes}
@return: A new instance of L{SecondaryAuthorityService}.
c s g | ]}t |qS r )r fromServerAddressAndDomainr
serverAddressr r r A s
zISecondaryAuthorityService.fromServerAddressAndDomains..)_portr )clsr r r portr r r r fromServerAddressAndDomains- s
z5SecondaryAuthorityService.fromServerAddressAndDomainsc C s t | jS )z_
Get a resolver for the transferred domains.
@rtype: L{ResolverChain}
)r
ResolverChainr r r r r getAuthorityG s z&SecondaryAuthorityService.getAuthorityc C sV t j| dd | jD | _d}ddlm} | jD ]}|||jd |d7 }qd S )Nc S s g | ]}t |jqS r )r LoopingCalltransferr r r r r Q s z:SecondaryAuthorityService.startService..r reactori ) r Service startServicer callstwisted.internetr( callLaterstart)r ir( cr r r r+ O s
z&SecondaryAuthorityService.startServicec C s$ t j| | jD ]}| q d S N)r r* stopServicer, stop)r r1 r r r r3 Z s
z%SecondaryAuthorityService.stopService) __name__
__module__ __qualname____doc__r, r r classmethodr! r$ r+ r3 r r r r r s
c @ sr e Zd ZdZdZd ZZdZdZdd Z e
dd Z d d
Z dd d Z
d
d Zdd Zdd Zdd Zdd ZdS )r a
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: L{str}
@ivar _port: The port number of the server from which zone transfers will
be attempted.
@type _port: L{int}
@ivar domain: The domain for which this is the secondary authority.
@type domain: L{bytes}
@ivar _reactor: The reactor to use to perform the zone transfers, or
L{None} to use the global reactor.
FNr c C s& t j| t|| _t|| _dS )z
@param domain: The domain for which this will be the secondary
authority.
@type domain: L{bytes} or L{str}
N)r ResolverBaser r r r domainStringdomain)r primaryIPr< r r r r x s
zSecondaryAuthority.__init__c C s |\}}| ||}||_ |S )af
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.
@type domain: L{bytes}
@return: A new instance of L{SecondaryAuthority}.
)r )r r r< r r secondaryr r r r s
z-SecondaryAuthority.fromServerAddressAndDomainc C s^ | j rdS d| _| j}|du rddlm} tj| j| jfg|d}| | j
| j
| jS )z
Attempt a zone transfer.
@returns: A L{Deferred} that fires with L{None} when attempted zone
transfer has completed.
NTr r' )serversr( ) transferring transfering_reactorr- r( r Resolverr r
lookupZoner< addCallback_cbZone
addErrback_ebZone)r r( resolverr r r r& s
zSecondaryAuthority.transferc C s4 | j r| jsttt|S t | ||||S r2 )
soarecordsr failr Failurer DomainErrorr _lookup)r namer typetimeoutr r r rO s zSecondaryAuthority._lookupc C sf |\}}}i | _ }|D ]$}| js"|jtjkr"|jj |jf| _q ||jj g |j q d S r2 )
rK rJ rQ r SOArP lowerpayload
setdefaultappend)r zoneans_rrecr r r rF s
zSecondaryAuthority._cbZonec C s$ t d| j| jf t | d S )Nz/Updating %s from %s failed during zone transfer)r
msgr< r errr r r r r rH s
zSecondaryAuthority._ebZonec C s | | j| j d S r2 )r& addCallbacks_cbTransferred_ebTransferredr# r r r update s zSecondaryAuthority.updatec C s
d| _ d S )NF)r@ )r resultr r r ra s
z!SecondaryAuthority._cbTransferredc C s* d| _ td| j| jf t| d S )NFz2Transferring %s from %s failed after zone transfer) transferredr
r] r< r r^ r_ r r r rb s
z!SecondaryAuthority._ebTransferredr2 )r5 r6 r7 r8 r@ rJ rK r rB r r9 r r& rO rF rH rc ra rb r r r r r ` s
N)__all__twisted.applicationr r- r r
twisted.namesr r r r
twisted.names.authorityr twisted.pythonr r
twisted.python.compatr r* r r r r r r s P