✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�M�e�-�@s�dZd
dl
Z
d
dlZd
dlmZmZmZmZmZ
d
dl	Z
d
dlZ
d
dlZ
d
dl
Z
d
dlZ
d
dlZ
d
dlZ
d
dlZ
d
dlZ
Gdd�de
jj�Ze
jjZe
jjZe
jjZe
jjZe
jjZe
jjZGdd�de
jj�ZdS)zDNS Versioned Zones.�N)�Callable�Deque�Optional�Set�Unionc
@seZ
dZd
ZdS)�UseTransactionz-To alter a versioned zone, use a transaction.N)�__name__�
__module__�__qualname__�__doc__�rr�1/usr/lib/python3.9/site-packages/dns/versioned.pyrs
rc	sXeZ
dZgd
�
ZeZejjddfe	e
ejje
fejjee	edege	efd��f
dd�
Zd7e	ee	eed�dd	�Zd8eed�dd
�Zdd�Zdd�Zdd�Ze	edd�dd�Ze	edege	efdd�dd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Z d$d%�Z!d9e
ejje
feej"jd&��f
d'd(�
Z#e
ejje
fdd)�d*d+�Z$ej%j&d
fe
ejje
fe
ej%j'e
fe
ej%j'e
feej(j)d,��f
d-d.�
Z*ej%j&d
fe
ejje
fe
ej%j'e
fe
ej%j'e
fee	ej(j)d,��f
d/d0�
Z+ej%j&f
e
ejje
fe
ej%j'e
fe
ej%j'e
fdd1�d2d3�Z,e
ejje
fej(j)dd4�d5d6�Z-�Z.S):�Zone)�	_versionsZ_versions_lock�
_write_txn�_write_waiters�_write_event�_pruning_policy�_readersTN)�origin�rdclass�
relativize�pruning_policycstt��
|
||�
t��|_t��|_|d
ur6|j|_	n||_	d
|_
d
|_t��|_t
�|_|�d
t|dd�|
�
d
S)a�Initialize a versioned zone object.

        *origin* is the origin of the zone.  It may be a ``dns.name.Name``,
        a ``str``, or ``None``.  If ``None``, then the zone's origin will
        be set by the first ``$ORIGIN`` line in a zone file.

        *rdclass*, an ``int``, the zone's rdata class; the default is class IN.

        *relativize*, a ``bool``, determine's whether domain names are
        relativized to the zone's origin.  The default is ``True``.

        *pruning policy*, a function taking a ``Zone`` and a ``Version`` and returning
        a ``bool``, or ``None``.  Should the version be pruned?  If ``None``,
        the default policy, which retains one version is used.
        NT)
�replacement)�super�__init__�collections�dequer�	threading�Lock�
_version_lock�_default_pruning_policyrrrr�setr�_commit_version_unlocked�WritableVersion)�selfrrrr�
�	__class__rr
r.s













�z
Zone.__init__)�id�serial�returnc	Cs:
|
du
r|du
rtd
�
�
|j
�
�
|
du
rbd}t|j�
D]}|j|
kr8|}
qPq8|dur�td�
�
n�|du
r�|jrztjj	}n|j
du
s�J�
|j
}d}t|j�
D]@}|j�|�
}|r�|�
|jtjj�}|r�|dj|kr�|}
q�q�|dur�td�
�
n
|jd}t|d|�}|j�|�

|Wd�
S1�
s,0


Y
dS)Nz!cannot specify both id and serialzversion not foundr
zserial not found���F)�
ValueErrorr �reversedrr(�KeyErrorr�dns�name�emptyr�nodes�get�get_rdatasetr�	rdatatypeZSOAr)�Transactionr�add)	r%r(r)�version�
vZoname�
nZrds�txnrrr
�readerSs<
































zZone.readerF)rr*cCs�d}|j�\
|j
durD||jkrDt||
d
d�|_
d|_Wd�
q�t��}|j�|�

Wd�
n1sl0


Y
|��
q|j
�	�
|j
S)NT)
Zmake_immutable)
r rrr6r�Eventr�append�waitZ_setup_version)r%rZeventrrr
�writerws

�

*


zZone.writerc

Cs(t|j
�
d
kr$|j
��|_|j��
dS)Nr
)�lenr�popleftrr")
r%rrr
�!_maybe_wakeup_one_waiter_unlocked�s


z&Zone._maybe_wakeup_one_waiter_unlockedc
Csd
S)NTr)r%�zoner8rrr
r!�s
zZone._default_pruning_policyc
Cstt|j
�
d
ksJ�
t|j�
d
kr6tdd�|jD�
�
}
n|j
dj}
|j
d
j|
krp|�||j
d
�rp|j
��
qBdS)Nr
c
ss|]}
|
jj
V
qdS�
N)r8r()�.0r;rrr
�	<genexpr>��z0Zone._prune_versions_unlocked.<locals>.<genexpr>r+)rArr�minr(rrB)r%Z
least_keptrrr
�_prune_versions_unlocked�s




�zZone._prune_versions_unlocked)�max_versionsr*csD�d
u
r�dkrtd�
�
�d
ur*dd�}n�f
dd�}|�
|�

d
S)zYSet a pruning policy that retains up to the specified number
        of versions
        N�
zmax versions must be at least 1c
Ssd
S)NFr�rD�
_rrr
�policy�s
z%Zone.set_max_versions.<locals>.policycst|j
�
�kSrE)rArrM�
rKrr
rO�s
)r,�set_pruning_policy)r%rKrOrrPr
�set_max_versions�s


zZone.set_max_versions)rOr*cCsF|
d
ur|j}
|j
�
|
|_|��
Wd
�
n1s80


Y
d
S)a�
Set the pruning policy for the zone.

        The *policy* function takes a `Version` and returns `True` if
        the version should be pruned, and `False` otherwise.  `None`
        may also be specified for policy, in which case the default policy
        is used.

        Pruning checking proceeds from the least version and the first
        time the function returns `False`, the checking stops.  I.e. the
        retained versions are always a consecutive sequence.
        N)r!r rrJ)r%rOrrr
rQ�s




zZone.set_pruning_policycCs>|j�$
|j
�|
�

|��
Wd�
n1s00


Y
dSrE)r r�removerJ�r%r;rrr
�	_end_read�s


zZone._end_readcCs |j|
ksJ�
d|_|�
�
dSrE)rrCrTrrr
�_end_write_unlocked�s


zZone._end_write_unlockedcCs4|j�
|�
|
�

Wd�
n1s&0


Y
dSrE)r rVrTrrr
�
_end_write�s

zZone._end_writecCsB|j�
|�

|��
|j|_|jdur,||_|
du
r>|�|
�

dSrE)rr>rJr2rrV�r%r;r8rrrr
r#�s






zZone._commit_version_unlockedcCs8|j�
|�
|
||�
Wd�
n1s*0


Y
dSrE)r r#rXrrr
�_commit_version
s

zZone._commit_versionc
Cs(t|j
�
d
kr |j
djd}
nd}
|
S)Nr
r+rL)rArr()r%r(rrr
�_get_next_version_id
s


zZone._get_next_version_id)r0�creater*cs|rt�
t
��|
�
SrE)rr�	find_node)r%r0r[r&rr
r\
s

zZone.find_node)r0r*c
Cst�
dSrE�
r)r%r0rrr
�delete_node
s
zZone.delete_node)r0�rdtype�coversr[r*cs$|rt�
t
��|
||�}tj�|�
SrE)rr�
find_rdatasetr/�rdataset�ImmutableRdataset�r%r0r_r`r[rbr&rr
ra
s


zZone.find_rdatasetcs4|rt�
t
��|
||�}|du
r,tj�|�
SdSdSrE)rrr4r/rbrcrdr&rr
r4$
s



zZone.get_rdataset)r0r_r`r*c
Cst�
dSrEr])r%r0r_r`rrr
�delete_rdataset3
szZone.delete_rdataset)r0rr*c
Cst�
dSrEr])r%r0rrrr
�replace_rdataset;
szZone.replace_rdataset)NN)
F)
F)/rr	r
�	__slots__�NodeZnode_factoryr/Z
rdataclass�INrrr0�Name�strZ
RdataClass�boolr�Versionr�intr6r<r@rCr!rJrRrQrUrVrWr#rYrZZnoder\r^r5ZNONEZ	RdataTyperbZRdatasetrar4rerf�
__classcell__rrr&r
r!s�



�


�&�

�$1
�
�

�
�



�
�




��


�	
�r) rrr�typingrrrrrZ
dns.exceptionr/Z
dns.immutableZdns.nameZdns.nodeZdns.rdataclassZdns.rdatasetZ
dns.rdatatypeZdns.rdtypes.ANY.SOAZdns.zone�	exceptionZDNSExceptionrrDZ
VersionedNoderhZImmutableVersionedNodeZ
ImmutableNodermr$ZImmutableVersionr6rrrrr
�<module>s(