/usr/lib/python3/dist-packages/fail2ban/server/__pycache__
Edit: /usr/lib/python3/dist-packages/fail2ban/server/__pycache__/observer.cpython-310.pyc (13635B)
o
_E @ s d Z dZdZddlZddlmZ ddlmZ ddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZdd lmZ dd
lmZ dd lmZ eeZG d d
d
eZG dd dZe ZdS )zSerg G. Brester (sebres)z"Copyright (c) 2014 Serg G. BresterGPL N )
JailThread)FailManagerEmpty ) getLogger)MyTime)Utilsc sN e Zd ZdZejd Z fddZdd Zdd Zd d
Z d d Z
d
d Z dd Z dd Z
dd Zdd Zdd Zdd Zdd Zd d Zd d Zd!d" ZdGd$d%Z fd&d'ZdHd*d+Zed,d- ZdGd.d/ZdGd0d1Z ed2d3 Z e j d4d3 Z ed5d6 Z d7d8 Z d9d: Z!d;d< Z"G d=d> d>Z#d?d@ Z$dAdB Z%dCdD Z&dEdF Z' Z(S )IObserverThreada8 Handles observing a database, managing bad ips and ban increment.
Parameters
----------
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.
c sZ t t| jdd d| _t | _g | _t | _ d| _
i | _ d| _ d | _
d| _d| _d S )Nz f2b/observer)nameT< Fi )superr
__init__idle threadingRLock _queue_lock_queueEvent_notify sleeptime_timers_paused_ObserverThread__db"_ObserverThread__db_purge_intervaldaemonself __class__ :/usr/lib/python3/dist-packages/fail2ban/server/observer.pyr ? s
zObserverThread.__init__c C s( z| j | W S ty td| w )NzInvalid event index : %sr KeyErrorr ir! r! r" __getitem__T s
zObserverThread.__getitem__c C s* z| j |= W d S ty td| w )NzInvalid event index: %sr# r% r! r! r" __delitem__Z s
zObserverThread.__delitem__c C
t | jS N)iterr r r! r! r" __iter__`
zObserverThread.__iter__c C r) r* )lenr r r! r! r" __len__c r- zObserverThread.__len__c C dS )NFr! )r otherr! r! r" __eq__f s zObserverThread.__eq__c C s t | S r* )idr r! r! r" __hash__i s zObserverThread.__hash__c G sD | j |d}|dur| t|| j|}|| j |< | dS )zAdd a named timer event to queue will start (and wake) in 'starttime' seconds
Previous timer event with same name will be canceled and trigger self into
queue after new 'starttime' value
N)r getcancelr Timeraddstart)r r starttimeeventtr! r! r" add_named_timerl s
z ObserverThread.add_named_timerc G s^ t jdur!|r!ttj| jt | t | |f}| dS t|| j |}| dS )zJAdd a timer event to queue will start (and wake) in 'starttime' seconds
N)
r myTimer r7 r DEFAULT_SLEEP_INTERVAL
_delayedEventtimer9 r8 )r r: r; r< r! r! r" add_timery s zObserverThread.add_timerc C sR t |ks t |kr| jdg|R d S ttj| j|||f}| d S )Nr ) r rA rB r r7 r r? r@ r9 )r endMyTimeendTimer; r< r! r! r" r@ s z ObserverThread._delayedEventc C s$ | j s| j}|r| dS dS dS )z1Notify wakeup (sets /and resets/ notify event)
N)r r set)r nr! r! r" pulse_notify s zObserverThread.pulse_notifyc G s> | j | j| W d n1 sw Y | dS )z5Add a event to queue and notify thread to wake up.
N)r r appendrG r r; r! r! r" r8 s zObserverThread.addc G s8 | j | j| W d dS 1 sw Y dS )z=Add a event to queue withouth notifying thread to wake up.
N)r r rH rI r! r! r" add_wn s "zObserverThread.add_wnc G s || d S r* r! )r largsr! r! r" call_lambda s zObserverThread.call_lambdac
C s t d | d| jd | j| j| j| j| j| j | j
dd dd d }z| d | j rd | _
| jszDd
}| j t| jrE| jd }W d
n1 sOw Y |d
u rZW n;|d }t|d sn||pmt| |}||d d
W n ty } zt jd
|dd W Y d
}~nd
}~ww | jr3| j}|rd| _
|| j | | jrq*n
t t j | j sn| j s-t dt| j d
| _W n ty } zt jd|dd W Y d
}~nd
}~ww | j g | _W d
n1 sw Y d| _
dS )zMain loop for Threading.
This function is the main loop of the thread.
Returns
-------
bool
True when the thread exits nicely.
zObserver start...DB_PURGEdb_purgec S r0 Nr! r! r! r! r! r"
z$ObserverThread.run..c S r0 rP r! r! r! r! r" rQ rR ) calldb_setrO is_alive is_activer9 stopnopshutdownrU FNr r %sTexc_infoz&Observer stopped, %s events remaining.z Observer stopped after error: %s)!logSysinfor= r rM rT rO isAliveisActiver9 rW r8 activer r r r. r popcallabler5 getattr Exceptionerrorr waitr clearrA sleepr
r? is_full)r _ObserverThread__methevmetherF r! r! r" run sr
$
zObserverThread.runc C r0 )NTr! r r! r! r" r_ s zObserverThread.isAliveNc C | j S r* )ra )r fromStrr! r! r" r` s zObserverThread.isActivec sP | j | jstt| W d d S W d d S 1 s!w Y d S r* )r ra r r
r9 r r r! r" r9 s "zObserverThread.start Tc C s | j rS| jrStd| | j | d | j}| j d | _W d n1 s*w Y | |s6|rD| d| _ d| _ d | _
n|| _| t |doR| j
S dS )Nz-Observer stop ... try to end queue %s secondsrY FTg ?)ra r r] r^ r rJ rE
wait_emptyrh r r wait_idleminrj )r wtime forceQuitrF r! r! r" rW s
zObserverThread.stopc C s< | j t| jr dndW d S 1 sw Y d S )NTF)r r. r r r! r! r" rj # s $zObserverThread.is_fullc C s t tj |durt | }| jdur$| d | jr$| jr$| | jr;|dur2t |kr2n t tj | js'|
d | j S )zWWait observer is running and returns if observer has no more events (queue is empty)
NrX gMbP?) rA ri r
r? r r rJ rj r rG rt r r rn r! r! r" rs ( s
zObserverThread.wait_emptyc C sd t tj | jr dS |durt | }| js/|dur&t |kr& | jS t tj | jr| jS )zJWait observer is running and returns if observer idle (observer sleeps)
TN)rA ri r
r? r r rx r! r! r" rt < s zObserverThread.wait_idlec C rp r* )r r r! r! r" pausedJ s zObserverThread.pausedc C s | j |krd S || _ | d S r* )r rG )r pauser! r! r" ry N s
c C r0 )z/Status of observer to be implemented. [TODO]
) r{ r! r r! r! r" statusW s zObserverThread.statusc C s
|| _ d S r* )r )r dbr! r! r" rT a r- zObserverThread.db_setc C s2 t d | jd ur| j | d| jd d S )Nz Purge database event occurredrN rO )r] debugr purger= r r r! r! r" rO d s
zObserverThread.db_purgec
C s | r |ds dS | }| }td|j| d}d}d}z| } |j}
|
durh|
||D ]\}}} t
|| }d|dk rF|nd> d d } t || }|durh||krhtd|j||| W dS |dkroW dS t
d |j|t||||| krd
nd |||d d }|| || krz ||}|| q ty |t Y W dS w W dS ty } ztjd
| t tjkd W Y d} ~ dS d} ~ ww )z} Notify observer a failure for ip was found
Observer will check ip was known (bad) and possibly increase an retry count
incrementNz [%s] Observer: failure found %sr r r z8[%s] Ignore failure %s before last ban %s < %s, restoredz%[%s] Found %s, bad - %s, %s # -> %s%sz, Banr{ TrZ r[ ) r_ getBanTimeExtragetIPgetTimer] r~ r getMaxRetrydatabasegetBanmax getBanCountru r^ r time2str
addFailure setBanCounttoBan
putFailTicketr cleanuprA re rf getEffectiveLevelloggingDEBUG)
r failManagerjailticketipunixTimebanCount
retryCount timeOfBanmaxRetryr} lastBanTimern r! r! r" failureFoundo sX
(zObserverThread.failureFoundc @ e Zd Zdd ZdS )zObserverThread.BanTimeIncrc C s || _ || _d S r* )TimeCount)r banTimer r! r! r" r s
z#ObserverThread.BanTimeIncr.__init__N__name__
__module__ __qualname__r r! r! r! r" BanTimeIncr r c C s | }|d | ||S )N evformula)r r )r r r r ber! r! r" calcBanTime s zObserverThread.calcBanTimec C sX | r|js |S | }| }|}zx|dkr|ddr|jj|||dddD ]]\}}} || kr=||d t d||| |dkrS|d |
||}| | | |kr|t
d |j||t|tjt|d
tjt|d
f nd |_ W |S W |S W |S W |S ty }
ztjd |
t tjkd
W Y d}
~
|S d}
~
ww )ztCheck for IP address to increment ban time (if was already banned).
Returns
-------
float
new ban time.
r r F overalljails)r r z"IP %s was already banned: %s #, %sr z/[%s] IP %s is bad: %s # last %s - incr %s to %ssecondsTrZ r[ N)r_ r r r r5 r r r r] r~ r
setBanTimer r^ r r r datetime timedeltaintrestoredre rf r r r ) r r r r r r
orgBanTimer r r rn r! r! r" incrBanTime sD
$zObserverThread.incrBanTimec
C s |j rdS z|}| }td|j|| |dkr3| du r3| |||}|dks.||kr3|| |dkr\| | }t j
t |dt
|f}|t k r[td|d W dS nd}||krtjd |j|| g|R td
d |j|||f | td td
|| d
| j|| |jdur|j s|j|| W dS W dS W dS ty } ztjd|t tj kd W Y d}~dS d}~ww ) Notify observer a ban occured for ip
Observer will check ip was known (bad) and possibly increase/prolong a ban time
Secondary we will actualize the bans and bips (bad ip) in database
Nz [%s] Observer: ban found %s, %sr zIgnore old bantime %sr F) permanentinfinitez$[%s] Increase Ban %s (%d # %s -> %s)rr z [%s] Observer: prolong %s in %sr r rZ r[ ) r r r] r~ r
getBanTimer r r r r r r r rA noticer logrB ru r
prolongBanr addBanre rf r r r ) r r r btimeoldbtimer bendtimelogtimern r! r! r" banFound sF
& (zObserverThread.banFoundc
C sv z| }| }td|j|| |j| W dS ty: } ztjd|t t
j kd W Y d}~dS d}~ww )r z [%s] Observer: prolong %s, %srZ r[ N) r r r] r~ r actions _prolongBanre rf r r r )r r r r r rn r! r! r" r s (zObserverThread.prolongBanr* )rr T))r r r __doc__r r? r r' r( r, r/ r2 r4 r= rB r@ rG r8 rJ rM ro r_ r` r9 rW propertyrj rs rt ry setterr| rT rO r r r r r r
__classcell__r! r! r r" r
( sP
P
8)+r
c @ r )
_Observersc C s
d | _ d S r* )Mainr r! r! r" r r- z_Observers.__init__Nr r! r! r! r" r r r )
__author__
__copyright__ __license__r
jailthreadr failmanagerr osr rA r mathjsonrandomsyshelpersr mytimer utilsr r r] r
r Observersr! r! r! r" s$ 8 o