Bd..dZdZdZddlZddlZddlZddlZddlZddlZddl m Z ddl Z ddl m Z mZmZddlmZejd krddlZnddlZe eZd d iZed ejDZGd dZdS)z2Serg G. Brester (sebres) and Fail2Ban ContributorszYCopyright (c) 2004 Cyril Jaquier, 2011-2012 Yaroslav Halchenko, 2012-2015 Serg G. BresterGPLN)Lock) getLogger _merge_dicts uni_decode) OrderedDictr 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#NK|] \}}|d||fV!dS)SIGN) startswith).0namenums 7/usr/lib/python3/dist-packages/fail2ban/server/utils.py r7sWEET3T__U-C-CET{EEEEEEceZdZdZdZdZdZedz ZGddeZ e dZ e d Z e ddZ e ddZejdkr e dZn e dZe dZdS)UtilszPUtilities provide diverse static methods like executes OS shell commands, etc. rg?gMbP?dc@eZdZdZdZd dZdZd dZd Zd Z d Z dS) Utils.Cachez.A simple cache with a TTL and limit on size cl|j|i|t|_t|_dSN) setOptionsr _cacher _Cache__lock)selfargskwargss r__init__zUtils.Cache.__init__Hs34?D#F###4;4;;;r<c"||_||_dSr)maxCountmaxTime)r r'r(s rrzUtils.Cache.setOptionsMs4=4<<>!611$+'!* .rr%TFrNc * dx}}d} dx} |r8|rt|nttj|} t fd} t jt jt j|| tj  } | 5fd} t | |tj } | r| d} | !| r| tjd} td|fztjj} tj| t(jt-jtj } | |rStj| t(jt-jtj|  } | &t| s t(j} nb#t6$rU}| r| tjd} d|}t|s|sdnd||| fcYd}~SYd}~nd}~wwxYw| |vr tjn tj}|tkr.| r,| |tjkr|dz n tjd} |s|tkrĉjr | | d kr tjdj }n2#tB$r%}td |Yd}~nd}~wwxYw|d|d kr^|tkrA|"D],}t#|d tI|-j%r | | d kr tj%dj% }n2#tB$r%}td |Yd}~nd}~wwxYw|d|d kr^|tkrA|"D],}t#|dtI|-jrj&j%rj%&d}| |vrt'd| d}n| "tdjn| d ks| dkrH| d kr| n| dz }tdtP)|d|z| ndtT)| d}td| |r+t+d| |tYz|r|||| fSt[|dkr|n|| fS)aExecutes 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>t|dS)Nz%x -- exec: %s)logSyslog)levelrY realCmdIds rz"Utils.executeCmd..sE+;YPPr)stdoutstderrshellenv preexec_fnc<}|d|fndS)NT)poll)retcodepopens r_popen_wait_endz)Utils.executeCmd.._popen_wait_ends#zz||W&2T7OO$>Yq[[GMRRR]aTZ JyF446666 l J97Q;; %,...l!!VV 999 \\4a888888889 fllyF::: + 667 ** &&!++'71CCsRF'H I%AI I% I%7AL99 M(M##M(AP Q %QQ c"d} |}|r|S|r1dx}}t|stj|zfd}n|}|rn>t||p tjztj}tj||S)a5Wait 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.Trc2tjkSr)r0)time0srrez Utils.wait_for..<sDIKK%/r)callabler0minrrDEFAULT_SLEEP_TIMEr)condrintervaliniretstm timeout_exprrs @rrwzUtils.wait_fors, # 3  J MC# G   Y[[7 "U////\\\lnn  SH< < =u?W X X3:c??? *rposixcddl}|dkrdS tj|ddS#t$r}|j|jkcYd}~Sd}~wwxYw)z6Check whether pid exists in the current process table.rNFT)errnorJkillrEPERM)r}rrs rrzUtils.pid_existsHsu<<< Agg 5GCOOO 4 """ 7ek !!!!!!!"s% A AA A cddl}|jj}d}||d|}|dkr||dSdS)NriTF)ctypeswindllkernel32 OpenProcess CloseHandle)r}rr SYNCHRONIZEprocesss rrzUtils.pid_existsUsX===m$8;  ! !+q# 6 67 ll !!! 4 5rc:tjtj|d}tjdkr3t j|| }ntj ||}|S)Nrr ) rJpathsplitextbasenamesys version_info importlib machinerySourceFileLoader load_moduleimp load_source) pythonModulepythonModuleNamemods rload_python_modulezUtils.load_python_modulebsW%%7L!!###$&   - -l $ $$/KMM3 l $ $3 *r)r%TFTr^Nr)rArBrCrDrrDEFAULT_SHORT_INTERVALrxobjectrF staticmethodrPr]rrwrJrrrrErrrr:sQ3c9.....V...b,,,NR#DDDDDD,DDL% % % ,% RGw  <    <    ,    rr) __author__ __copyright__ __license__rHryrJrrsr threadingrr0helpersrrr collectionsr rimportlib.machineryrrrArardict__dict__rWrrrErrrsd(B k     9999999999######v  8  D $EE/''))EEE E Er r r r r r r r r r r