/usr/lib/python3/dist-packages/fail2ban/server/__pycache__
Edit: /usr/lib/python3/dist-packages/fail2ban/server/__pycache__/utils.cpython-310.pyc (10271B)
o
;s*b0 @ s d Z dZdZddlZddlZddlZddlZddlZddlZddl m
Z
ddl Z ddl m
Z
mZmZ zddlmZ W n eyE eZY nw ejd krPddlZnddlZe
eZd
d iZed d
ej D Z G dd dZ dS )z2Serg G. Brester (sebres) and Fail2Ban ContributorszYCopyright (c) 2004 Cyril Jaquier, 2011-2012 Yaroslav Halchenko, 2012-2015 Serg G. BresterGPL N)Lock ) getLogger _merge_dicts
uni_decode) OrderedDict r
am "Command not found". Make sure that all commands in %(realCmd)r are in the PATH of fail2ban-server process (grep -a PATH= /proc/`pidof -x fail2ban-server`/environ). You may want to start "fail2ban-server -f" separately, initiate it with "fail2ban-client reload" in another shell session and observe if additional informative error messages appear in the terminals.c c s& | ]\}}| d r||fV qdS )SIGN)
startswith).0namenum r 7/usr/lib/python3/dist-packages/fail2ban/server/utils.py
; s r c @ s e Zd ZdZdZdZdZed ZG dd deZ e
dd Z e
d
d Z e
dddZ
e
d ddZejdkr@e
dd Zne
dd Ze
dd ZdS ) UtilszPUtilities provide diverse static methods like executes OS shell commands, etc.
r g?gMbP?d c @ sL e Zd ZdZdd ZdddZdd Zdd d Zd
d Zdd Z dd Z
d
S )z Utils.Cachez.A simple cache with a TTL and limit on size
c O s$ | j |i | t | _t | _d S N)
setOptionsr _cacher _Cache__lock)selfargskwargsr r r __init__L s zUtils.Cache.__init__ < c C s || _ || _d S r )maxCountmaxTime)r r r! r r r r Q s
zUtils.Cache.setOptionsc C s
t | jS r )lenr r r r r __len__U s
zUtils.Cache.__len__Nc C s6 | j |}|r|d t kr|d S | | |S )N r )r gettimeunset)r kdefvvr r r r& X s
zUtils.Cache.getc C s t }| j}| jp t|| jkrittur1|r0|jdd\}}|d |kr.t|| jk r.n|sn8g }| D ]\}}|d |krF| | q7|D ] }| j
|d qI|rit|| jkri| |rit|| jks\||| j f||< W d d S 1 s}w Y d S )NF)lastr% ) r' r r r" r r dictpopitemitemsappendpopr! )r r) r+ tcacheckcvremlstr r r set` s.
"zUtils.Cache.setc C s: | j | j|d W d d S 1 sw Y d S r )r r r1 )r r) r r r r( | s "zUtils.Cache.unsetc C s6 | j | j W d d S 1 sw Y d S r )r r clearr# r r r r8 s "zUtils.Cache.clear)r r r ) __name__
__module__ __qualname____doc__r r r$ r& r7 r( r8 r r r r CacheH s
r= c C s> t | t j}|s|tjO }n|tj M }t | t j| |S r )fcntlF_GETFLos
O_NONBLOCKF_SETFL)fhandlevalueflagsr r r
setFBlockMode s zUtils.setFBlockModec C sl d}t | ts
| g} t| d }| D ]\}}|d||f 7 }| | |d7 }q|d | d | d< | S )a Generates new shell command as array, contains map as variables to
arguments statement (varsStat), the command (realCmd) used this variables and
the list of the arguments, mapped from varsDict
Example:
buildShellCmd('echo "V2: $v2, V1: $v1"', {"v1": "val 1", "v2": "val 2", "vUnused": "unused var"})
returns:
['v1=$0 v2=$1 vUnused=$2
echo "V2: $v2, V1: $v1"', 'val 1', 'val 2', 'unused var']
r% z%s=$%s
r )
isinstancelistr" r/ r0 )realCmdvarsDictvarsStatir) r+ r r r
buildShellCmd s
zUtils.buildShellCmdr TFr Nc
s d }}d} d }
|r|rt |nttj|}
tfdd} ztjtjtj||
tj d
} | du rQ fdd} t | |t j } | rQ| d } | du r| r^| t
j d} td|f t j}
t|
tj tt j
} | du s|rt|
tj tt j | du r
} | du rt |
stj} W n8 ty } z,| r| t
j d} d |f }t| s|sd
nd
||| fW Y d}~S W Y d}~nd}~ww | |v rt
j nt
j}|t kr| r| |t
j kr|d nt
j d} |s
|t kr j rfz| du s | d k r#t j d
j }W n t!yB } z td | W Y d}~nd}~ww |durf|d
krf|t krf|" D ]
}t#|dt$| qX j%rz| du su| d k r|t j%d
j% }W n t!y } z td| W Y d}~nd}~ww |dur|d
kr|t kr|" D ]
}t#|dt$| q j rȈ j & j%rш j%& d
}| |v rt'd| d}nM| du rtd j n?| d k s| dkr| d k r| n| d }tdt()|d| | nt*)| d}td| |r/t+d| |t, |r8|||| fS t-|dkrA|S || fS )a Executes a command.
Parameters
----------
realCmd : str
The command to execute.
timeout : int
The time out in seconds for the command.
shell : bool
If shell is True (default), the specified command (may be a string) will be
executed through the shell.
output : bool
If output is True, the function returns tuple (success, stdoutdata, stderrdata, returncode).
If False, just indication of success is returned
varsDict: dict
variables supplied to the command (or to the shell script)
Returns
-------
bool or (bool, str, str, int)
True if the command succeeded and with stdout, stderr, returncode if output was set to True
Raises
------
OSError
If command fails to be executed.
RuntimeError
If command execution times out.
Nc s t | d S )Nz%x -- exec: %s)logSyslog)level)rK realCmdIdr r s z"Utils.executeCmd..)stdoutstderrshellenv
preexec_fnc s } | d ur d| fS d S )NT)poll)retcode)popenr r _popen_wait_end s z)Utils.executeCmd.._popen_wait_endr% z!%x -- timed out after %s seconds.z%s -- failed with %sFr z ... -- failed to read stdout %srG z%x -- stdout: %rz ... -- failed to read stderr %sz%x -- stderr: %rz %x -- returned successfully %iTz%x -- unable to kill PID %i z&%x -- killed with %s (return code: %s)z signal %iz%x -- returned %izHINT on %i: %s).r rO r r@ environid
subprocessPopenPIPEsetsidr[ wait_forDEFAULT_SHORTEST_INTERVALloggingERRORrQ errorgetpgidpidkillpgsignalSIGTERMr' sleepDEFAULT_SLEEP_INTERVALSIGKILL
pid_existsOSErrorDEBUGgetEffectiveLevelrV rF readIOError
splitlinesrR r rW closedebugsignamer& _RETCODE_HINTSinfolocalsr" )rK timeoutrX outputtout_kill_tree
success_codesrL rV rW r\ rY logCmdr^ pgide std_levellsuccesssigcodemsgr )r] rK rT r
executeCmd s
&" "
zUtils.executeCmdc sx d} | }|r
|S |r(d }}t |s!t | fdd}n|}|s(tj}| r. |S t|| tj}t| q)a5 Wait until condition expression `cond` is True, up to `timeout` sec
Parameters
----------
cond : callable
The expression to check condition
(should return equivalent to bool True if wait successful).
timeout : float or callable
The time out for end of wait
(in seconds or callable that returns True if timeout occurred).
interval : float (optional)
Polling start interval for wait cycle in seconds.
Returns
-------
variable
The return value of the last call of `cond`,
logical False (or None, 0, etc) if timeout occurred.
r% Tr c s t kS r )r' r time0r r rU L s z Utils.wait_for..)callabler' r rq minDEFAULT_SLEEP_TIMErp )condr intervaliniretstm timeout_exprr r r rf - s&
zUtils.wait_forposixc
C sX ddl }| dk r
dS z t| d W dS ty+ } z |j |jkW Y d}~S d}~ww )z6Check whether pid exists in the current process table.r NFT)errnor@ killrt EPERM)rl r r r r r rs Z s zUtils.pid_existsc C s< dd l }|jj}d}||d| }|dkr || dS dS )Nr i TF)ctypeswindllkernel32 OpenProcess CloseHandle)rl r r SYNCHRONIZEprocessr r r rs g s
c C sH t jt j| d }tjdkr tj|| }|S t
|| }|S )Nr r ) r@ pathsplitextbasenamesys version_info importlib machinerySourceFileLoader load_moduleimp load_source) pythonModulepythonModuleNamemodr r r load_python_modulet s
zUtils.load_python_module)r TFTrP Nr )r9 r: r; r< r rq DEFAULT_SHORT_INTERVALrg objectr= staticmethodrF rO r rf r@ r rs r r r r r r > s2 =
+
r )
__author__
__copyright__ __license__r> rh r@ rn rb r threadingr r' helpersr r r collectionsr ImportErrorr- r importlib.machineryr r r9 rQ r} __dict__r/ r| r r r r r s6