| Server IP : 185.216.8.13 / Your IP : 216.73.216.140 Web Server : Apache System : Linux webhost-vie2.sitetide.com 4.18.0-553.156.1.el8_10.x86_64 #1 SMP Mon Aug 17 17:52:57 UTC 2026 x86_64 User : apache ( 48) PHP Version : 8.2.33 Disable Function : syslog MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/usr/lib/python3.6/site-packages/pyzor/engines/__pycache__/ |
Upload File : |
3
�Ugbv � @ sr d Z ddlZddlZddlmZ ddddgZeddd d
d g�ZG d d� de�ZG d
d� de �Z
G dd� de �Z dS )z+Common library shared by different engines.� N)�
namedtuple�DBHandle�
DatabaseError�Record�
BaseEngineZsingle_threadedZmulti_threadedZmulti_processingZpreforkc @ s e Zd ZdS )r N)�__name__�
__module__� __qualname__� r
r
� /usr/lib/python3.6/common.pyr s c @ s: e Zd ZdZddd�Zdd� Zdd � Zd
d � Zd d
� ZdS )r zTPrefix conventions used in this class:
r = report (spam)
wl = whitelist
r Nc C s( || _ || _|| _|| _|| _|| _d S )N)�r_count�wl_count� r_entered� r_updated�
wl_entered�
wl_updated)�selfr r
r r r r r
r
r �__init__ s zRecord.__init__c C s< | j tjk r| j d7 _ | jd kr0tjj� | _| j� d S )N� )r
�sys�maxsizer �datetime�now� wl_update)r r
r
r � wl_increment s
zRecord.wl_incrementc C s< | j tjk r| j d7 _ | jd kr0tjj� | _| j� d S )Nr )r r r r r r �r_update)r r
r
r � r_increment( s
zRecord.r_incrementc C s t j j� | _d S )N)r r r )r r
r
r r 0 s zRecord.r_updatec C s t j j� | _d S )N)r r r )r r
r
r r 3 s zRecord.wl_update)r r NNNN) r r r �__doc__r r r r r r
r
r
r r s
c @ sf e Zd ZdZdZdZdd� Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
eddd��ZdS )r z Base class for Pyzor engines.TFc C s
t � �dS )zIterate over all keysN)�NotImplementedError)r r
r
r �__iter__< s zBaseEngine.__iter__c C s
t � �dS )z$Iterate over pairs of (key, record).N)r )r r
r
r � iteritems@ s zBaseEngine.iteritemsc C s
t � �dS )z Return a list of (key, record).N)r )r r
r
r �itemsD s zBaseEngine.itemsc C s
t � �dS )z*Get the record for this corresponding key.N)r )r �keyr
r
r � __getitem__H s zBaseEngine.__getitem__c C s
t � �dS )zqSet the record for this corresponding key. 'value' should be a
instance of the ``Record`` class.
N)r )r r" �valuer
r
r � __setitem__L s zBaseEngine.__setitem__c C s
t � �dS )z2Remove the corresponding record from the database.N)r )r r" r
r
r � __delitem__R s zBaseEngine.__delitem__c C s
t � �dS )z�Report the corresponding key as spam, incrementing the report count.
Engines that implement don't implement this method should have
handles_one_step set to False.
N)r )r �keysr
r
r �reportV s zBaseEngine.reportc C s
t � �dS )z�Report the corresponding key as ham, incrementing the whitelist
count.
Engines that implement don't implement this method should have
handles_one_step set to False.
N)r )r r' r
r
r � whitelist^ s zBaseEngine.whitelistNc C s
t � �dS )z�Yields an unlimited number of partial functions that return a new
engine instance, suitable for using toghether with the Pre-Fork server.
N)r )�cls�fn�modeZmax_ager
r
r �get_prefork_connectionsh s z"BaseEngine.get_prefork_connections)N)r r r r Zabsolute_sourceZhandles_one_stepr r r! r# r% r& r( r) � classmethodr- r
r
r
r r 7 s
) r r r � collectionsr �__all__r � Exceptionr �objectr r r
r
r
r �<module> s
%