=*f=.SrSrSrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK r SSK J r JrJr SSKJr SSKr\ "\5rS S 0r\"S \R0R3555r"S S 5rg)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) OrderedDictam"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#\# UH"upURS5(dMX!4v M$ g7f)SIGN) startswith).0namenums 7/usr/lib/python3/dist-packages/fail2ban/server/utils.py r4s)E)YTT__U-C{)s, ,c\rSrSrSrSrSrSr\S- r"SS\ 5r \ S 5r \ S 5r \ SS j5r\ SS j5r\R"S:Xa \ S5rO\ S5r\ S5rSrg )Utils7zWUtilities provide diverse static methods like executes OS shell commands, etc. rg?gMbP?dcJ\rSrSrSrSrS SjrSrS SjrSr S r S r S r g) Utils.CacheAzr2rD__static_attributes__r$rCacherAs* % r$rOc[R"U[R5nU(dU[R-nOU[R)-n[R"U[RU5 U$r)fcntlF_GETFLos O_NONBLOCKF_SETFL)fhandlevalueflagss r setFBlockModeUtils.setFBlockModersP ++gu}} -% BMM5R]]N5++gu}}e, ,r$cSn[U[5(dU/n[U5S- nUR5H'upEX$<SU<S3- nUR U5 US- nM) US-US-US'U$)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=$  r) isinstancelistr*itemsappend)realCmdvarsDictvarsStatir3r5s r buildShellCmdUtils.buildShellCmd|s~( GT " "Y7 'l1n!nnda Aq!!8 >>!61$+'!* .r$Nc  ^^^S=pxSn S=mn U(a8U(a[RTU5mO[[RU5n [ T5mUU4Sjn [ R"T[ R[ RX*[RS9mTR5n U c6U4Sjn [RX[R5n U (aU Sn U GcEU (aU "[R5 Sn [R!STU4-5 [R""TR$5n [R&"U [(R*5 [,R."[R05 TR5n U bU(a\[R&"U [(R25 [,R."[R05 U cTR5n U c*[R5U 5(d[(R2n X;a[R8O[RnU[R;5:a8U (a1U "U[R8:XaUS- O[R5 Sn U(dU[R;5:Ga\TR<(aU bU S :a [R?TR<S5 TR<RA5nUbVUS :waPU[R;5:a8URE5H$n[RGUS T[IU55 M& TRJ(aU bU S :a [R?TRJS5 TRJRA5nUbVUS :waPU[R;5:a8URE5H$n[RGUST[IU55 M& TR<(aTR<RM5 TRJ(aTRJRM5 SnX;a[ROSTU 5 SnOU c"[R!STTR$5 OU S :dU S:a>U S :aU *OU S- n[R!ST[PRSUSU-5U 5 OV[TRSU S5n[R!STU 5 U(a"[RWSU U[Y5-5 U(aUXxU 4$[[U5S:XaU$UU 4$![6abnU (aU "[R5 Sn T<SU<3n[R!U5 T(dU(dSOSXxU 4sSnA$SnAGNSnAff=f![Ba!n[R!S U5 SnAGNSnAff=f![Ba!n[R!S U5 SnAGNySnAff=f)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. Nc4>[RUSTT5$)Nz%x -- exec: %s)logSyslog)levelrc realCmdIds r"Utils.executeCmd..sE+;YPr$)stdoutstderrshellenv preexec_fnc6>TR5nUbSU4$S$)NT)poll)retcodepopens r_popen_wait_end)Utils.executeCmd.._popen_wait_ends"zz|W&2T7O<Yq[GMMR]aTZ yF4466 ll97Q; %,,.ll!VflyF: 67 ** &!+C'71CCq E fW]]#dV&-q 16 << 5UFG$DD  E& 9 \\4a889 9 \\4a889sRGVAW0AX W- AW(W-(W-0 X:XX Y (YY cV^SnU"5nU(aU$U(a4S=p5[U5(d[R"5U-mU4SjnOUnW"5(aU$[WU=(d [R-[R 5n[R "U5 M)aFWait 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/rc4>[R"5T:$r)r1)time0srro Utils.wait_for..9sDIIK%/r$)callabler1minrrDEFAULT_SLEEP_TIMEr)condrintervaliniretstm timeout_exprrs @rrUtils.wait_fors, # 3 J MC G   YY[7 "U/\\nn  * SH< < < =u?W?W X3::c? r$posixcSSKnUS:ag[R"US5 g![a#nURUR:HsSnA$SnAff=f)z6Check whether pid exists in the current process table.rNFT)errnorSkillrEPERM)rrrs rrUtils.pid_existsEsM Ag GGCO  " 77ekk !!"s% AA A AcSSKnURRnSnURUSU5nUS:waUR U5 gg)NriTF)ctypeswindllkernel32 OpenProcess CloseHandle)rrr SYNCHRONIZEprocesss rrrRsHmm$$8;  ! !+q# 67 l !  r$c[RR[RRU55Sn[R R X5R5nU$)Nr)rSpathsplitextbasename importlib machinerySourceFileLoader load_module) pythonModulepythonModuleNamemods rload_python_moduleUtils.load_python_module_sYWW%%77L!##$&,, ##.;= *r$rN)rGTFT)rNr)rHrIrJrKrLrrDEFAULT_SHORT_INTERVALrobjectrO staticmethodrYrgrrrSrrrrMrNr$rrr7s3c9.V.b,NR#DDDDL% % RGGw      r$r) __author__ __copyright__ __license__rQrrSrrsys threadingrr1helpersrrr collectionsr importlib.machineryrrHrkrdict__dict__rarrrNr$rrs(B k     99# 8 D E//'')E En n r$