File: //usr/lib/python3/dist-packages/twisted/names/__pycache__/secondary.cpython-38.pyc
U
W[� � @ s� d dl mZmZ ddgZd dlmZmZ d dlmZ d dlm Z d dlm
Z
d dlm Z d d l m
Z
d d
lmZmZ d d lmZ G d d� dej�ZG d
d� de
�ZdS )� )�absolute_import�division�SecondaryAuthority�SecondaryAuthorityService)�task�defer)�dns)�common)�client)�resolve)�
FileAuthority)�log�failure)�servicec @ s@ e Zd ZdZdZdd� Zedd� �Zdd� Zd d
� Z d d � Z
dS )
r N�5 c s � | _ � 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 �domains)�selfr r r r r �__init__ s
z"SecondaryAuthorityService.__init__c s6 | 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}.
Nr � c s g | ]}t �� |��qS r )r �fromServerAddressAndDomainr ��
serverAddressr r r 9 s �zISecondaryAuthorityService.fromServerAddressAndDomains.<locals>.<listcomp>)r �_portr )�clsr r r r r r �fromServerAddressAndDomains& s
�z5SecondaryAuthorityService.fromServerAddressAndDomainsc C s t �| j�S �N)r Z
ResolverChainr �r r r r � getAuthority? s z&SecondaryAuthorityService.getAuthorityc C sV t j�| � dd� | jD �| _d}ddlm} | jD ] }|�||jd� |d7 }q4d S )Nc S s g | ]}t �|j��qS r )r Z LoopingCall�transferr r r r r D s z:SecondaryAuthorityService.startService.<locals>.<listcomp>r ��reactori r ) r �Service� startServicer �calls�twisted.internetr( Z callLater�start)r �ir( �cr r r r* B s
z&SecondaryAuthorityService.startServicec C s$ t j�| � | jD ] }|�� qd S r# )r r) � stopServicer+ �stop)r r/ r r r r0 L s
z%SecondaryAuthorityService.stopService) �__name__�
__module__� __qualname__r+ r r � classmethodr" r% r* r0 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: 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.
FNr c C s t j�| � || _|| _dS )z�
@param domain: The domain for which this will be the secondary
authority.
@type domain: L{bytes}
N)r Z ResolverBaser r �domain)r Z primaryIPr6 r r r r h s zSecondaryAuthority.__init__c C s( | 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}.
Nr r )r r r6 )r! r r6 Z secondaryr r r r v s
z-SecondaryAuthority.fromServerAddressAndDomainc C s^ | j r
d S d| _| j}|d kr*ddlm} tj| j| jfg|d�}|� | j
�� | j ��
| j�S )NTr r' )Zserversr( )� transferringZ transfering�_reactorr, r( r
ZResolverr r Z
lookupZoner6 Z addCallback�_cbZoneZ
addErrback�_ebZone)r r( Zresolverr r r r& � s � ��zSecondaryAuthority.transferc C s4 | j r | js"t�t�t�|���S t� | ||||�S r# )
�soa�recordsr Zfailr ZFailurer Z DomainErrorr �_lookup)r �namer! �typeZtimeoutr r r r= � s zSecondaryAuthority._lookupc C sj |\}}}i | _ }|D ]L}| jsF|jtjkrFt|j��� |jf| _q|� t|j��� g ��
|j� qd S r# ) r< r; r? r ZSOA�strr> �lowerZpayload�
setdefault�append)r ZzoneZans�_�rZrecr r r r9 � s
zSecondaryAuthority._cbZonec C s$ t �d| j| jf � t �|� d S )Nz/Updating %s from %s failed during zone transfer)r
�msgr6 r �err�r r r r r r: � s zSecondaryAuthority._ebZonec C s | � � �| j| j� d S r# )r& Z addCallbacks�_cbTransferred�_ebTransferredr$ r r r �update� s zSecondaryAuthority.updatec C s
d| _ d S )NF)r7 )r �resultr r r rI � s z!SecondaryAuthority._cbTransferredc C s* d| _ t�d| j| jf � t�|� d S )NFz2Transferring %s from %s failed after zone transfer)Z transferredr
rF r6 r rG rH r r r rJ � s z!SecondaryAuthority._ebTransferred)N)r2 r3 r4 �__doc__r7 r; r< r r8 r r5 r r& r= r9 r: rK rI rJ r r r r r S s
N)Z
__future__r r �__all__r, r r Z
twisted.namesr r r
r Ztwisted.names.authorityr Ztwisted.pythonr
r Ztwisted.applicationr r) r r r r r r �<module> s @