a
=Æ*fÈt ã @ s8 d Z dZdZddlZddlmZmZ ddlZddlZddlZddl Z ddl
Z
ddl m Z m
Z
ddlmZ dd lmZmZmZ dd
lmZ dd lmZmZ d d
lmZ d dlm Z m Z m Z m Z m Z m!Z!m"Z" e e#ƒZ$dZ%dZ&dZ'zddl(m)Z) W n e*y dZ)Y n0 dd„ Z+dd„ Z,G dd„ dƒZ-G dd„ de.ƒZ/dS )z
Cyril Jaquierz Copyright (c) 2004 Cyril JaquierZGPLé N)ÚLockÚRLocké )Ú ObserversÚObserverThread)ÚJails)ÚDNSUtilsÚ
FileFilterÚ
JournalFilter)Ú Transmitter)Ú AsyncServerÚAsyncServerExceptioné )Úversion)Ú getLoggerÚ_as_boolÚextractOptionsÚ str2LogLevelÚgetVerbosityFormatÚ
excepthookÚprctl_set_th_nameÚautoÚINFOÚSTDOUT)Ú
Fail2BanDbc C s t ¡ jjS ©N)Ú threadingÚcurrent_threadÚ __class__Ú__name__© r r ú:/usr/lib/python3.9/site-packages/fail2ban/server/server.pyÚ _thread_name: s r" c
C s` t j | ¡} t j | ¡r\zt | ¡ W n4 ttfyZ } z|jdkrF‚ W Y d}~n
d}~0 0 dS )z0Creates path of file (last level only) on demandé N)ÚosÚpathÚdirnameÚisabsÚmkdirÚOSErrorÚFileExistsErrorÚerrno)ÚnameÚer r r! Ú_make_file_path= s
r. c @ sÜ e Zd Zd°dd„Zdd„ Zdd„ Zdd „ Zdd
i fd d „Zd
d„ Zdd„ Z d±dd„Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd „ Zd d „ Zd d „ Zd!d"„ Zd#d$„ Zd%d&„ Zd'd(„ Zd)d*„ Zd²d+d,„Zd-d.„ Zd/d0„ Zd1d2„ Zd3d4„ Zd5d6„ Z d7d8„ Z d9d:„ Z d;d<„ Z d=d>„ Z d?d@„ Z!dAdB„ Z"dCdD„ Z#dEdF„ Z$dGdH„ Z%dIdJ„ Z&dKdL„ Z'dMdN„ Z(dOdP„ Z)dQdR„ Z*d³dSdT„Z+d´dVdW„Z,dXdY„ Z-dµdZd[„Z.d\d]„ Z/d^d_„ Z0d`da„ Z1dbdc„ Z2ddde„ Z3dfdg„ Z4dhdi„ Z5djdk„ Z6dldm„ Z7dndo„ Z8dpdq„ Z9drds„ Z:dtdu„ Z;dvdw„ Zd|d}„ Z?d¶d~d„Z@d·d€d„ZAd‚dƒ„ ZBd¸d„d…„ZCd†d‡„ ZDdˆd‰„ ZEdŠd‹„ ZFd¹dŒd„ZGdºdd‘„ZHd»d’d“„ZId”d•„ ZJd–d—„ ZKd˜d™„ ZLdšd›„ ZMdœd„ ZNdždŸ„ ZOd d¡„ ZPeQd¢d£„ ƒZRd¤d¥„ ZSd¦d§„ ZTd¨d©„ ZUdªd«„ ZVeQd¬d„ ƒZWd®d¯„ ZXdUS )¼ÚServerFc C sj t ƒ | _tƒ | _tƒ | _d | _|| _t| ƒ| _ i | _
d | _ d | _ d | _
d | _d | _ddddœ| _i | _d S )Nz/var/run/syslogz /var/run/logz/dev/log)ZDarwinZFreeBSDZLinux)r Ú_Server__loggingLockr Ú
_Server__lockr Ú_Server__jailsÚ _Server__dbÚ_Server__daemonr Ú_Server__transmÚ_Server__reload_stateÚ_Server__asyncServerÚ_Server__logLevelÚ_Server__logTargetÚ_Server__verboseÚ_Server__syslogSocketÚ _Server__autoSyslogSocketPathsÚ_Server__prev_signals)ÚselfÚdaemonr r r! Ú__init__L s"
ýzServer.__init__c C s t d|¡ | ¡ d S )NzCaught signal %d. Exiting)ÚlogSysÚdebugÚquit)r> ÚsignumÚframer r r! Z__sigTERMhandlera s zServer.__sigTERMhandlerc C s t d|¡ | ¡ d S )Nz Caught signal %d. Flushing logs)rA rB Ú flushLogs)r> rD Úfnamer r r! Z__sigUSR1handlere s zServer.__sigUSR1handlerc C s t |¡| j|< t ||¡ dS )z>Bind new signal handler while storing old one in _prev_signalsN)ÚsignalÚ getsignalr= )r> ÚsÚnewr r r! Ú
_rebindSignali s zServer._rebindSignalTc
C s² t d¡ | jrXt d¡ | ¡ }|d u r.dS |d sXd|dd … f}t |¡ t|ƒ‚t| dd¡ƒ | d d ¡| _
| | d
| j d ur| j nt
¡¡ | | d | jd ur²| jnt¡¡ | | d | jd urÔ| jnt¡¡ t d
¡ t dtj¡ | jrt d¡ tƒ dkrDtjtjfD ]}| || j¡ q | tj| j ¡ t t _ z ZsockZpidfileÚforceÚobserverZconfÚretÚerrrJ ZpidFiler- r r r! rk n sp
ÿ
ÿ
ÿ
"
" z Server.startc C sÌ dd„ | _ t d¡ | jd ur(| j ¡ tƒ dkrR| j ¡ D ]\}}t ||¡ qÀ ó z Server.quit..zShutdown in progress...rP F)Z forceQuitzExiting Fail2ban)rC rA rT r7 Zstop_communicationr" r= ÚitemsrH r rj ÚstopÚ stopAllJailr3 rh )r> rJ ÚshZobsMainr r r! rC ¾ s,
z Server.quitc C sª d}| j |¡rt| j |¡rt| j| }|j|krLd}t d|¡ d | j |< n(t d||j|¡ | j|dd | j |= |rŠ| j ||| j ¡ | j d ur¦| j
| j| ¡ d S )NTFzReload jail %rz"Restart jail %r (reason: %r != %r)©rt ) r6 rX r2 ÚexistsÚbackendrA rT ÚdelJailÚaddr3 ÚaddJail)r> r, ry ZaddflgÚjailr r r! r| í s
zServer.addJailc C sJ | j | }|s| ¡ r$|j||d |rF| jd ur>| j |¡ | j |= d S )N©rt Újoin)r2 ÚisAlivert r3 rz )r> r, rt r r} r r r! rz s
zServer.delJailc C sp | j V | j| }| ¡ s$| ¡ n || jv rBt d|¡ | j|= |jrNd|_W d ƒ n1 sb0 Y d S )NzJail %r reloadedF)r1 r2 r€ rk r6 rA rT Úidle)r> r, r} r r r! Ú startJail
s
zServer.startJailc C s8 | j | j|dd W d ƒ n1 s*0 Y d S )NTrw )r1 rz ©r> r, r r r! ÚstopJail s zServer.stopJailc C s| t d¡ | jX t| j ¡ ƒD ]}| j|ddd q t| j ¡ ƒD ]}| j|ddd qDW d ƒ n1 sn0 Y d S )NzStopping all jailsTFr~ )rA rT r1 Úlistr2 Úkeysrz rƒ r r r! ru s
zServer.stopAllJailc C s t j ¡ t j ¡ d S r )r ZCACHE_nameToIpÚclearZCACHE_ipToName©r> r r r! Ú clearCaches# s
zServer.clearCachesc C sÜ |r<| j r(|dks | j |¡r(tdƒ‚t d|dkr>d| nd ¡ | jÜ |dkr¢d }d|vsn| j |¡rx| j| }|rÊd|v rŽ| |¡ d|v rÊ| |¡ n(|
¡ d|v rº| ¡ d|v rÊ| ¡ | j ¡ D ]D\}}|dksì||krÔd |_
|| j |< |jjd d
|jjd d
qÔW d ƒ n1 s00 Y nœ| jt g }| j ¡ D ]>\}}|| j v rr| |¡ n |jjd d
|jjd d
qR|D ]}| |¡ q–W d ƒ n1 s¾0 Y i | _ t d ¡ d S )
Nú--allzReload already in progresszReload zjail %sz all jailsz --if-existsz--unbanz --restartT)ÚbeginFzReload finished.)r6 rX Ú
ValueErrorrA rT r1 r2 rx Ú
setUnbanIPr„ r‰ ru rs r ÚfilterÚreloadÚactionsÚappendrz )r> r, Zoptsr‹ r} ZjnZdeljailsr r r! Ú reloadJails( sJ
" .zServer.reloadJailsc C s || j | _dS )NT©r2 r ©r> r, Úvaluer r r! Ú setIdleJail_ s zServer.setIdleJailc C s | j | jS r r“ rƒ r r r! Ú getIdleJailc s zServer.getIdleJailc C s t |ƒ| j| j_d S r )r r2 rŽ Ú
ignoreSelfr” r r r! Ú
setIgnoreSelfg s zServer.setIgnoreSelfc C s | j | jjS r )r2 rŽ r˜ rƒ r r r! Ú
getIgnoreSelfj s zServer.getIgnoreSelfc C s | j | j |¡ d S r )r2 rŽ Ú addIgnoreIP©r> r, Úipr r r! r› m s zServer.addIgnoreIPc C s | j | j |¡ d S r )r2 rŽ Ú delIgnoreIPrœ r r r! rž p s zServer.delIgnoreIPc C s | j | j ¡ S r )r2 rŽ Ú getIgnoreIPrƒ r r r! rŸ s s zServer.getIgnoreIPc C s& | j | j}t|tƒr"| ||¡ d S r )r2 rŽ Ú
isinstancer Ú
addLogPath)r> r, ÚfileNameÚtailÚfilter_r r r! r¡ v s
zServer.addLogPathc C s$ | j | j}t|tƒr | |¡ d S r )r2 rŽ r r Ú
delLogPath)r> r, r¢ r¤ r r r! r¥ { s
zServer.delLogPathc C s4 | j | j}t|tƒr | ¡ S t d| ¡ g S d S )Nz$Jail %s is not a FileFilter instance)r2 rŽ r r Z getLogPathsrA rB ©r> r, r¤ r r r! Ú
getLogPath€ s
zServer.getLogPathc C s$ | j | j}t|tƒr | |¡ d S r )r2 rŽ r r
ÚaddJournalMatch©r> r, Úmatchr¤ r r r! r¨ ˆ s
zServer.addJournalMatchc C s$ | j | j}t|tƒr | |¡ d S r )r2 rŽ r r
ÚdelJournalMatchr© r r r! r« s
zServer.delJournalMatchc C s4 | j | j}t|tƒr | ¡ S t d| ¡ g S d S )Nz'Jail %s is not a JournalFilter instance)r2 rŽ r r
ÚgetJournalMatchrA rB r¦ r r r! r¬ ’ s
zServer.getJournalMatchc C s | j | j}| |¡ d S r )r2 rŽ ÚsetLogEncoding)r> r, Úencodingr¤ r r r! r š s zServer.setLogEncodingc C s | j | j}| ¡ S r )r2 rŽ ÚgetLogEncodingr¦ r r r! r¯ ž s zServer.getLogEncodingc C s | j | j |¡ d S r )r2 rŽ Ú setFindTimer” r r r! r° ¢ s zServer.setFindTimec C s | j | j ¡ S r )r2 rŽ Ú getFindTimerƒ r r r! r± ¥ s zServer.getFindTimec C s | j | j |¡ d S r )r2 rŽ ÚsetDatePattern)r> r, Úpatternr r r! r² ¨ s zServer.setDatePatternc C s | j | j ¡ S r )r2 rŽ ÚgetDatePatternrƒ r r r! r´ « s zServer.getDatePatternc C s | j | j |¡ d S r )r2 rŽ ÚsetLogTimeZone)r> r, Ztzr r r! rµ ® s zServer.setLogTimeZonec C s | j | j ¡ S r )r2 rŽ ÚgetLogTimeZonerƒ r r r! r¶ ± s zServer.getLogTimeZonec C s || j | j_d S r ©r2 rŽ Z
ignoreCommandr” r r r! ÚsetIgnoreCommand´ s zServer.setIgnoreCommandc C s | j | jjS r r· rƒ r r r! ÚgetIgnoreCommand· s zServer.getIgnoreCommandc C s& t d| d ƒ\}}|| j| j_d S )Nzcache[ú])r r2 rŽ Ú ignoreCache)r> r, r• Úoptionsr r r! ÚsetIgnoreCacheº s zServer.setIgnoreCachec C s | j | jjS r )r2 rŽ r» rƒ r r r! ÚgetIgnoreCache¾ s zServer.getIgnoreCachec C s" | j | j}t d|¡ ||_d S )Nz prefregex: %r)r2 rŽ rA rB Ú prefRegex)r> r, r• Úfltr r r! Ú setPrefRegexÁ s zServer.setPrefRegexc C s | j | jjS r )r2 rŽ r¿ rƒ r r r! Ú getPrefRegexÆ s zServer.getPrefRegexc C s: | j | j}|s|f}|D ]}t d|¡ | |¡ qd S )Nz failregex: %r)r2 rŽ rA rB Ú addFailRegex©r> r, r• ZmultiplerÀ r r r! rÃ É s
zServer.addFailRegexNc C s | j | j |¡ d S r )r2 rŽ Ú delFailRegex©r> r, Úindexr r r! rÅ Ð s zServer.delFailRegexc C s | j | j ¡ S r )r2 rŽ Ú getFailRegexrƒ r r r! rÈ Ó s zServer.getFailRegexc C s: | j | j}|s|f}|D ]}t d|¡ | |¡ qd S )Nz ignoreregex: %r)r2 rŽ rA rB ÚaddIgnoreRegexrÄ r r r! rÉ Ö s
zServer.addIgnoreRegexc C s | j | j |¡ d S r )r2 rŽ ÚdelIgnoreRegexrÆ r r r! rÊ Ý s zServer.delIgnoreRegexc C s | j | j ¡ S r )r2 rŽ ÚgetIgnoreRegexrƒ r r r! rË à s zServer.getIgnoreRegexc C s | j | j |¡ d S r )r2 rŽ Ú setUseDnsr” r r r! rÌ ã s zServer.setUseDnsc C s | j | j ¡ S r )r2 rŽ Ú getUseDnsrƒ r r r! rÍ æ s zServer.getUseDnsc C s || j | jj_d S r ©r2 rŽ Z failManagerZ
maxMatchesr” r r r! Ú
setMaxMatchesé s zServer.setMaxMatchesc C s | j | jjjS r rÎ rƒ r r r! Ú
getMaxMatchesì s zServer.getMaxMatchesc C s | j | j |¡ d S r )r2 rŽ Ú setMaxRetryr” r r r! rÑ ï s zServer.setMaxRetryc C s | j | j ¡ S r )r2 rŽ Ú getMaxRetryrƒ r r r! rÒ ò s zServer.getMaxRetryc C s | j | j |¡ d S r )r2 rŽ Ú setMaxLinesr” r r r! rÓ õ s zServer.setMaxLinesc C s | j | j ¡ S r )r2 rŽ Ú getMaxLinesrƒ r r r! rÔ ø s zServer.getMaxLinesc G s* | j | jj|g|¢R d|| jv iŽ d S )Nr )r2 r r{ r6 )r> r, r• Úargsr r r! Ú addActionü s ÿzServer.addActionc C s | j | jS r ©r2 r rƒ r r r! Ú
getActions s zServer.getActionsc C s | j | j|= d S r r× r” r r r! Ú delAction s zServer.delActionc C s | j | j| S r r× r” r r r! Ú getAction s zServer.getActionc C s | j | j |¡ d S r )r2 r Ú
setBanTimer” r r r! rÛ
s zServer.setBanTimec G s | j | jj|Ž S r )r2 rŽ Z
addAttempt)r> r, rÕ r r r! Ú addAttemptIP
s zServer.addAttemptIPc C s | j | j |¡S r )r2 r Z addBannedIPr” r r r! ÚsetBanIP s zServer.setBanIPc C sV |d ur| j | g}nt| j ¡ ƒ}d}||d u O }|D ]}||jj||d7 }q8|S )Nr )Úifexists)r2 r… Úvaluesr ZremoveBannedIP)r> r, r• rÞ ÚjailsZcntr} r r r! r s zServer.setUnbanIPc C s¬ |d ur| j | g}nt| j ¡ ƒ}g }|d u rr|rr|D ]6}g }|D ] }|j |g¡rD| |j¡ qD| |¡ q8n6|D ]0}|j |¡}|d ur–| S | |j|i¡ qv|S r )r2 r… rß r Z getBannedr‘ r, )r> r, Zidsrà Úresr ro r} r r r! Úbanned! s$ z
Server.bannedc C s | j | j ¡ S r )r2 r Ú
getBanTimerƒ r r r! rã ; s zServer.getBanTimec C s | j | j |¡S )zµReturns the list of banned IP addresses for a jail.
Parameters
----------
name : str
The name of a jail.
Returns
-------
list
The list of banned IP addresses.
)r2 r Ú
getBanList)r> r, ZwithTimer r r! rä > s
zServer.getBanListc C s | j | ||¡ d S r )r2 ÚsetBanTimeExtra)r> r, Úoptr• r r r! rå M s zServer.setBanTimeExtrac C s | j | |¡S r )r2 ÚgetBanTimeExtra)r> r, ræ r r r! rç P s zServer.getBanTimeExtrac C s | j d uo| j ¡ S r )r7 ZisActiverˆ r r r! Ú isStartedS s zServer.isStartedc C s@ |d urt | jƒ|krdS t| j ¡ ƒD ]}| ¡ s( dS q(dS )Nr r )Úlenr2 r… rß r€ )r> Zjailnumr} r r r! r€ V s zServer.isAliveÚ Úbasicc C sº z¨| j ¡ t| j ¡ ƒ}|dkrJdd„ |D ƒ}dt|ƒfdd |¡fg}|dkršt|ƒ}|D ]\}}|j|d||< q^|dkr|W | j ¡ S |
|¡ |W | j ¡ S | j ¡ 0 d S ) NZstatsc S s g | ] \}}|‘qS r r )Ú.0ÚnÚjr r r! Ú
d rr z!Server.status..zNumber of jailz Jail listz, rŠ ©Úflavor) r1 ÚacquireÚsortedr2 rs ré r ÚdictÚstatusÚreleaser‘ ) r> r, rñ rà ZjailListro Zjstatrí rî r r r! rõ _ s*
þ
ü
þz
Server.statusc C s | j | j|dS )Nrð )r2 rõ )r> r, rñ r r r! Ú
statusJailt s zServer.statusJailc C s~ | ¡ }| j\ | j|kr*W d ƒ d S t|ƒ}tdƒ tdksL|tjk rP|nt ¡ || _W d ƒ n1 sp0 Y d S )NÚfail2banÚ INHERITED)
Úupperr0 r8 r r ZsetLevelr^ ÚloggingÚDEBUGr\ )r> r• Zllr r r! r[ „ s
ÿzServer.setLogLevelc C s0 | j | jW d ƒ S 1 s"0 Y d S r )r0 r8 rˆ r r r! Ú getLogLevel• s zServer.getLogLevelc
C s˜ t |ƒ\}}| ¡ }| jf | j|kr8W d ƒ dS |dkrV|| _W d ƒ dS | d¡}|dkr‚ddlm} |dd}n†|d kr|| d
d ¡ ¡ }|d u r¨d }zttj j
d
| ƒ}W n. t yì t
d| d
¡¡ tj j
j}Y n0 | jdkrdd l}| j | ¡ ¡| _| jd urZtj | j¡rZt t | j¡j¡rZtj j
| j|d}n t
d| j ¡ W d ƒ dS nŒ|dv r”t tj¡}nt|dkr¬t tj ¡}n\z t |dƒ ¡ tj |¡}W n< t y t
d|¡ t !d| j¡ Y W d ƒ dS 0 t"dƒ} | j d d d… D ] }
| #|
¡ |
$¡ |
¡ q | %¡ tj&krr| j'd u rrtj&| %¡ d | _'| d¡} | d urt(| ƒ} n|dv} |d ur¬t(|ƒ}nd}| d d ¡d krÎ| d ¡} n4d}
| j'd urô| j'd krô| j'd }
t)|
| |d } |dkr | *t +| ¡¡ | ,|¡ | jd urlt !d t-j-¡ t !d!|d krT|n d"|| jf t-j-f ¡ || _W d ƒ dS 1 sŠ0 Y d S )#NTrù ÚpaddingúSYSTEMD-JOURNALr )ÚJournalHandlerrø )ZSYSLOG_IDENTIFIERÚSYSLOGÚfacilityZDAEMONÚ0ZLOG_z)Unable to set facility %r, using 'DAEMON'r )r z9Syslog socket file: %s does not exists or is not a socketF)r ÚSYSOUTÚSTDERRÚazUnable to log to %rz Logging to previous target %réÿÿÿÿr Zdatetime)r r Úformatrê r )Úaddtimerþ zStart Fail2ban v%sz-Changed logging target to %s for Fail2ban v%sz%s (%s)).r rú r0 r9 rX Zsystemd.journalr Úgetattrrû ÚhandlersZ
SysLogHandlerÚAttributeErrorrA rV Z
LOG_DAEMONr; Úplatformr< Úsystemr$ r% rx ÚstatÚS_ISSOCKÚst_modeZ
StreamHandlerrd ÚstdoutÚstderrre rh ZRotatingFileHandlerri rT r Z
removeHandlerÚflushZgetEffectiveLevelrü r: r r Z setFormatterZ FormatterZ
addHandlerr )r> ÚtargetZ
logOptionsZ systargetrþ r Zhdlrr r
ÚloggerÚhandlerr ÚfmtrN r r r! r] Ÿ s¶
ÿ ÿÿþÿÿÿ
ÿÿüÿÿzServer.setLogTargetc C s\ | j 0 | j|kr"W d ƒ dS || _W d ƒ n1 s<0 Y | jdkpZ| | j¡S )NTr )r0 r; r9 r] )r> rO r r r! rY s
$
ÿzServer.setSyslogSocketc C s0 | j | jW d ƒ S 1 s"0 Y d S r )r0 r9 rˆ r r r! Ú getLogTarget s zServer.getLogTargetc C s0 | j | jW d ƒ S 1 s"0 Y d S r )r0 r; rˆ r r r! ÚgetSyslogSocket s zServer.getSyslogSocketc C s– | j dvrftdƒjD ]L}z | ¡ t d| j ¡ W q ty^ | ¡ t d| j ¡ Y q0 qdS tdƒjD ] }| ¡ t d| j ¡ qpdS d S )N)r r r rÿ rø zrollover performed on %szflush performed on %sz rolled overZflushed)r9 r r Z
doRolloverrA rT r r )r> r r r r! rF s
zServer.flushLogsc C s | dkrt | ƒnd } t | ¡S )Nr )r r ÚsetIPv6IsAllowed)r• r r r! r - s zServer.setIPv6IsAllowedc C s> | ¡ D ]0\}}|dkr,t t|ƒd ¡ qtd| ƒ‚qd S )NÚ stacksizeé zunknown option %r)rs r Ú
stack_sizeÚintÚKeyError)r> r• ÚoÚvr r r! ÚsetThreadOptions2 s zServer.setThreadOptionsc C s dt ¡ d iS )Nr r )r r rˆ r r r! ÚgetThreadOptions9 s zServer.getThreadOptionsc C s¢ | j r| j j|krd S | j s,| ¡ dkr,d S t| jƒdkrBtdƒ‚| ¡ dkrVd | _ n0td ur|t|ƒ t|ƒ| _ | j ¡ n
t
d¡ t j d uržt j
| j ¡ d S )NZnoner z3Cannot change database when there are jails presentzEUnable to import fail2ban database module as sqlite is not available.)r3 ÚfilenameÚlowerré r2 Ú RuntimeErrorr r. Z delAllJailsrA rV r rj Zdb_set)r> r% r r r! Ú setDatabase< s& ÿ
ÿ
zServer.setDatabasec C s | j S r )r3 rˆ r r r! Ú getDatabaseS s zServer.getDatabasec s8 dD ]&‰ t j ˆ ¡r‡ fdd„} | ƒ S qtdƒ‚dS )zµGenerate a list of open file descriptors.
This wouldn't work on some platforms, or if proc/fdescfs not mounted, or a chroot environment,
then it'd raise a FileExistsError.
)z
/proc/self/fdz/proc/fdc 3 s& t ˆ ¡D ]} | ¡ r
t| ƒV q
d S r )r$ ÚlistdirÚisdigitr )r, ©r% r r! Úfdlistb s z#Server.__get_fdlist..fdlistzfd-list not foundN)r$ r% rx r* )r- r r, r! Z __get_fdlistV s
zServer.__get_fdlistc C sv | tjtj¡ z t ¡ }W n4 tyP } z d|j|jffW Y d}~S d}~0 0 |dkrÄt ¡ z t ¡ }W n4 ty¢ } z d|j|jffW Y d}~S d}~0 0 |dkr¸t
d¡ qÈt d¡ ndS z:| ¡ }|D ](}zt
|¡ W qÖ t yü Y qÖ0 qÖW nD zt d¡}W n ttfy4 d}Y n0 t d|¡ Y n0 t dtj¡ t dtj¡ t dtj¡ dS ) z¤ Detach a process from the controlling terminal and run it in the
background as a daemon.
http://aspn.activestate.com/ASPN/Cookbook/Python/Recipe/278731
FNr ú/Ú SC_OPEN_MAXé z /dev/null)T)rL rH ÚSIGHUPÚSIG_IGNr$ Úforkr) r+ ÚstrerrorÚsetsidÚchdirÚ_exitÚ_Server__get_fdlistrh Úsysconfr rŒ Ú
closerangere ÚO_RDONLYÚO_RDWR)r> Úpidr- r- ÚfdZmaxfdr r r! Z__createDaemonj s@
& &
zServer.__createDaemon)F)TT)F)F)N)F)NNT)NN)F)N)rê rë )rë )Yr Ú
__module__Ú __qualname__r@ ra rc rL rk rC r| rz r‚ r„ ru r‰ r’ r– r— r™ rš r› rž rŸ r¡ r¥ r§ r¨ r« r¬ r r¯ r° r± r² r´ rµ r¶ r¸ r¹ r½ r¾ rÁ r rà rÅ rÈ rÉ rÊ rË rÌ rÍ rÏ rÐ rÑ rÒ rÓ rÔ rÖ rØ rÙ rÚ rÛ rÜ rÝ r râ rã rä rå rç rè r€ rõ r÷ r[ rý r] rY r r rF Ú staticmethodr r# r$ r( r) r8 rU r r r r! r/ J s®
P/
7
m
r/ c @ s e Zd ZdS )rW N)r r? r@ r r r r! rW ¼ s rW )0Ú
__author__Z
__copyright__Z __license__r r r rû r$ rH r rd rn r r rà r rŽ r r r
Z transmitterr Z asyncserverr r
rê r Zhelpersr r r r r r r r rA rZ r\ r^ Zdatabaser Ú ImportErrorr" r. r/ Ú ExceptionrW r r r r! Ú sD $
x