|
Server : LiteSpeed System : Linux host 5.15.0-161-generic #171-Ubuntu SMP Sat Oct 11 08:17:01 UTC 2025 x86_64 User : idnco5810 ( 1093) PHP Version : 8.2.29 Disable Function : NONE Directory : /lib/python3/dist-packages/twisted/names/__pycache__/ |
Upload File : |
o
�b� � @ s� d dgZ ddlmZ ddlmZmZ ddlmZmZm Z m
Z
ddl m Z ddl
mZmZ ddlmZ G d d� dej�ZG d
d � d e �Zd S ) �SecondaryAuthority�SecondaryAuthorityService� )�service)�defer�task)�client�common�dns�resolve)�
FileAuthority)�failure�log)� 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}
N�5 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 ��.0�d��primaryr �9/usr/lib/python3/dist-packages/twisted/names/secondary.py�
<listcomp>+ s z6SecondaryAuthorityService.__init__.<locals>.<listcomp>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.<locals>.<listcomp>)�_portr )�clsr r r �portr r r r �fromServerAddressAndDomains- s
�z5SecondaryAuthorityService.fromServerAddressAndDomainsc C s t �| j�S )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 �|j��qS r )r � LoopingCall�transferr r r r r Q s z:SecondaryAuthorityService.startService.<locals>.<listcomp>r ��reactori � ) r �Service� startServicer �calls�twisted.internetr( � callLater�start)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 � domainString�domain)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 ��
| j�S )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| jst�t�t�|���S t� | ||||�S r2 )
�soa�recordsr �failr �Failurer � DomainErrorr �_lookup)r �namer �type�timeoutr 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 �lower�payload�
setdefault�append)r �zone�ans�_�r�recr 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 �err�r 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| _ t�d| 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 �<module> s P