File: //usr/lib/python3/dist-packages/fail2ban/server/__pycache__/jailthread.cpython-310.pyc
o
� �_ � @ s� d Z dZdZddlZddlmZ ddlmZ ddlm Z d d
l
m Z m Z G d d � d e�Z
ejd
k r7e
je
_dS ee
d�sBe
je
_dS dS )z
Cyril Jaquierz Copyright (c) 2004 Cyril Jaquier�GPL� N)�Thread)�abstractmethod� )�Utils� )�
excepthook�prctl_set_th_namec s| e Zd ZdZd� fdd� Zejdkr� fdd�Zndd � Ze dd d ��Z
� fd
d�Z dd� Z e dd� �Z
� fdd�Z� ZS )�
JailThreada Abstract class for threading elements in Fail2Ban.
Attributes
----------
daemon
ident
name
status
active : bool
Control the state of the thread.
idle : bool
Control the idle state of the thread.
sleeptime : int
The time the thread sleeps for in the loop.
Nc sH t t| �j|d� d| _d | _d| _tj| _| j � � fdd�}|| _ d S )N)�nameTFc
sh z
� | i |�� W d S t y3 } z td ur tt�� � n t|� W Y d }~d S W Y d }~d S d }~ww �N)� Exception�sysr �exc_info�print)�args�kwargs�e��run� �</usr/lib/python3/dist-packages/fail2ban/server/jailthread.py�run_with_except_hookC s ���z1JailThread.__init__.<locals>.run_with_except_hook)
�superr
�__init__�daemon�active�idler �DEFAULT_SLEEP_TIME� sleeptimer )�selfr r �� __class__r r r 4 s
zJailThread.__init__�� c s t | j� tt| ��� S r )r r r r
�
_bootstrap�r r! r r r% P s
zJailThread._bootstrapc C s t | j� t�| �S r )r r r �_Thread__bootstrapr& r r r � __bootstrapT s
zJailThread.__bootstrap�basicc C � dS )z0Abstract - Should provide status information.
Nr )r �flavorr r r �statusX � zJailThread.statusc s d| _ tt| ��� dS )z&Sets active flag and starts thread.
TN)r r r
�startr& r! r r r. ^ s zJailThread.startc C s
d| _ dS )zASets `active` property to False, to flag run method to return.
FN)r r& r r r �stopd s
zJailThread.stopc C r* )zCAbstract - Called when thread starts, thread stops when returns.
Nr r& r r r r i r- zJailThread.runc s | j durtt| ��� dS dS )z` Safer join, that could be called also for not started (or ended) threads (used for cleanup).
N)r r r
�joinr& r! r r r0 o s
�zJailThread.joinr )r) )�__name__�
__module__� __qualname__�__doc__r r � version_infor% �_JailThread__bootstrapr r, r. r/ r r0 �
__classcell__r r r! r r
# s
r
r# �isAlive)�
__author__�
__copyright__� __license__r � threadingr �abcr �utilsr �helpersr r r
r5 r6 r' �hasattr�is_aliver8 r r r r �<module> s
V
�