File: //usr/lib/python3/dist-packages/twisted/names/__pycache__/cache.cpython-38.pyc
U
W[� � @ sV d Z ddlmZmZ ddlmZmZ ddlmZm Z ddl
m Z G dd� dej �Z
dS ) z
An in-memory caching resolver.
� )�division�absolute_import)�dns�common)�failure�log)�deferc @ sR e Zd ZdZdZddd�Zdd� Zdd � Zd
d � Zdd d
�Z ddd�Z
dd� Z dS )�
CacheResolverz�
A resolver that serves records from a local, memory cache.
@ivar _reactor: A provider of L{interfaces.IReactorTime}.
Nr c C sd t j�| � i | _|| _i | _|d kr2ddlm} || _|r`|� � D ]\}\}}| �
|||� qDd S )Nr )�reactor) r � ResolverBase�__init__�cache�verbose�cancel�twisted.internetr
�_reactor�items� cacheResult)�selfr
r r
�query�seconds�payload� r �5/usr/lib/python3/dist-packages/twisted/names/cache.pyr s zCacheResolver.__init__c
C sb || _ | j�� }| j�� D ]B\}\}\}}}|| }|| | D ]} | j|k r@| j|= qq@qd S �N)�__dict__r r r
r �ttl)
r �state�now�k�when�ans�add�ns�diffZrecr r r � __setstate__( s
zCacheResolver.__setstate__c C s( | j �� D ] }|� � q
| j �� | jS r )r �values�clearr )r �cr r r � __getstate__4 s
zCacheResolver.__getstate__c
s | j �� }t�|||�}z| j| \}\}} }
W nF tk
rv | jdkr\t�dt |� � t
� t �
t�|��� Y S X | jr�t�dt |� � || � z8� fdd�|D �� fdd�| D �� fdd�|
D �f} W n, tk
� r� t
� t �
t�|��� Y S X t
�| �S d S )N� zCache miss for zCache hit for c s. g | ]&}t �|jj|j|j|j� |j��qS r �r ZRRHeader�name�type�clsr r ��.0�r�r$ r r �
<listcomp>K s ��z)CacheResolver._lookup.<locals>.<listcomp>c s. g | ]&}t �|jj|j|j|j� |j��qS r r+ r/ r2 r r r3 M s ��c s. g | ]&}t �|jj|j|j|j� |j��qS r r+ r/ r2 r r r3 O s ��)r r r ZQueryr
�KeyErrorr r �msg�reprr �failr �Failure� DomainError�
ValueErrorZsucceed) r r, r. r- �timeoutr �qr r! Zauthr" �resultr r2 r �_lookup; s2
�
�
�� zCacheResolver._lookupc C s t �t�t�|���S r )r r7 r r8 r r9 )r r, r; r r r �lookupAllRecordsW s z CacheResolver.lookupAllRecordsc C s� | j dkrt�d| � |p$| j�� |f| j|< || jkrH| j| �� t|d �t|d � t|d � }|r�|d j}|D ]}t ||j�}q~nd}| j�
|| j |�| j|< dS )a�
Cache a DNS entry.
@param query: a L{dns.Query} instance.
@param payload: a 3-tuple of lists of L{dns.RRHeader} records, the
matching result of the query (answers, authority and additional).
@param cacheTime: The time (seconds since epoch) at which the entry is
considered to have been added to the cache. If L{None} is given,
the current time is used.
r* zAdding %r to cacher � N) r r r5 r r r
r �listr �minZ callLater�
clearEntry)r r r Z cacheTime�s�mr1 r r r r [ s
$
zCacheResolver.cacheResultc C s | j |= | j|= d S r )r
r )r r r r r rC { s zCacheResolver.clearEntry)Nr N)N)N) �__name__�
__module__� __qualname__�__doc__r
r r% r) r> r? r rC r r r r r s
r N)rI Z
__future__r r Z
twisted.namesr r Ztwisted.pythonr r r r r r r r r r �<module> s