�
��_c@s@
dZd
Z
dZddlmZmZmZ
ddlZddlZddl	Z	ddl
Z
ddlZddlZddl
Z
ddlZddlZddlmZ
dd	lmZ
dd
lmZmZmZ
ee�
Zdejf
d��YZdedd
�Zdejf
d��YZ de!f
d��YZ"dS(s
Cyril Jaquiers Copyright (c) 2004 Cyril JaquiertGPLi����(tdumpstloadstHIGHEST_PROTOCOLNi
(
tUtilsi(
tCSPROTO(tloggingt	getLoggertformatExceptionInfotRequestHandlercBsTeZ
d�Zd
�Zd�Zd�Zdef
d��YZd�Zd�Z	RS(cCsBtj
j||
�
|
|_||_g|_|jtj�

dS(
N(	tasynchatt
async_chatt__init__t_RequestHandler__connt_RequestHandler__transmittert_RequestHandler__buffertset_terminatorRtEND(tselftconnttransmitter((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyR5s


	
	
	c
CsW|jrS|j}
d|_y|
jtj�

|
j�
WqStjk
rO


qSXndS(
N(R
tNonetshutdowntsockett	SHUT_RDWRtcloseterror(RR((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyt__close=s
	
	
	




c

Cs|j�
t
jj|�

dS(
N(t_RequestHandler__closeR
Rthandle_close(
R((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyRGs


cCs|jj
|
�

dS(
N(Rtappend(Rtdata((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytcollect_incoming_dataKst	LoadErrorc
BseZ
RS((t__name__t
__module__(((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyR!Ps
c
Csd
y�|j}
g|_t
jj|
�
}
|
t
jkrD|j�
dSyt|
�
}
WnGtk
r�
}
tj	d
|dtj
�tjk�

t
j|�
�
n
X|jr�|jj|
�
}
n	dg
}
t|
t�}
|j|
t
j�

Wnttk
r_

}
t|t
j�s5
tj	d|dtj
�tjk
�

ntd|t�}
|j|
t
j�

n
XdS(Ns$PROTO-error: load message failed: %stexc_infotSHUTDOWNsCaught unhandled exception: %rs	ERROR: %s(RRtEMPTYtjointCLOSEtclose_when_doneRt	ExceptiontlogSysRtgetEffectiveLevelRtDEBUGR	R!RtproceedR
RtpushRt
isinstance(Rtmessaget
e((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytfound_terminatorXs0
	
	







	
	




c
Cs�yjt�\}
}t
jd
t|�
�

t
jtj�j��

td|t�}|j	|t
j�

Wntk
r
}
n
X|j
�
dS(Ns"Unexpected communication error: %ss	ERROR: %s(RR+Rtstrt	tracebackt
format_exct
splitlinesR
RR/RRR*R)(Rte1te2R1R2((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pythandle_error~s







(
R"R#RRRR R*R!R3R:(((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyR	3s		
			&cCs�
|si}nd
|d<|
dkr1t
j}
ntj}t|�
rO|}nJ|r�tjr�ttjd�r�t	j
d�

t|
�
d}
tj}nxN
|�r�
y+||
�

|dr�|dcd8<nWq�tk
r�

}
|�s�Pn|dcd7<|ddkr`
|j
d
tjtjfkrG
t	jdt|�
�
q�
t	jdt|�
�
q�
|ddkr�
t	j|�

t	jd	�

q�
|dd
kr�
|j
d
tjks�
t|j��
dkr�
t	jd|�
Pq�
q�
q�Xq�WdS(
s�Custom event loop implementation

	Uses poll instead of loop to respect `active` flag,
	to avoid loop timeout mistake: different in poll and poll2 (sec vs ms),
	and to prevent sporadic errors like EBADF 'Bad file descriptor' etc. (see gh-161)
	itlistentpolls"Server listener (select) uses polli�i
is Server connection was closed: %ss0Too many errors - stop logging connection errorsids+Too many errors - critical count reached %rN(RRtDEFAULT_SLEEP_TIMEtasyncoreR<tcallabletpoll2thasattrtselectR+tdebugtfloatR*targsterrnotENOTCONNtEBADFtinfoR4Rt	exceptiontEMFILEtsumt
itervaluestcritical(tactivettimeouttuse_pollt	err_countR<R2((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytloop�sB	




	

	
!










	










tAsyncServercBsneZ
d�Zd
�Zd�Zd
ed�Zd�Zd�Z	d�Z
d�Zd�Ze
d	��
ZRS(cCsXtj
j|�

|
|_d
|_t|_t|_idd6dd6|_d|_
dS(Ns/var/run/fail2ban/fail2ban.sockitacceptR;(R>t
dispatcherRt_AsyncServer__transmittert_AsyncServer__socktFalset_AsyncServer__initt_AsyncServer__activet_AsyncServer__errCountRtonstart(RR((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyR�s

	
	
	
	

c


CstS(
N(
RY(
R((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytwritable�s
c
CsY
y|j�\}
}Wn�t
k
r

}
|jd
cd7<|jd
dkrttjd|d|jd
dk
�

n�|jd
dkr�tjd�

ny|jd
dkr
t|tj�r�|jdt	j
ks�t|jj��
d	kr
tj
d
|j�
|j�
q
ndSX|jd
r8
|jd
cd8<ntj|
�

t|
|j�
dS(NRUi
isAccept socket error: %sR$s.Too many acceptor errors - stop logging errorsidii�s+Too many errors - critical count reached %r(RUR*R\R+twarningRR0RRERFRKRLRMRNtstopRTt_AsyncServer__markCloseOnExecR	RW(RRtaddrR2((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyt
handle_accept�s&









(







csG
tj
��_|
�_tjj|
�
rftjd
�

|rWtj	d�

�j
�
qftd�
�
n�jt
jt
j�
�j�
y�j|
�

Wn$tk
r�


td�j�
�
n
Xtj�j
�

�jd�

t�_�_�_�jr
�j�
nt�f
d�d|d|d	�j�

t�_�j�
dS(
Ns$Fail2ban seems to be already runningsForcing execution of the serversServer already runningsUnable to bind socket %si
c
s�jS(
N(
t_AsyncServer__loop((
R(s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyt<lambda>
sRPRQRR(t	threadingtcurrent_threadt_AsyncServer__workerRXtostpathtexistsR+RR_t_remove_socktAsyncServerExceptiont
create_socketRtAF_UNIXtSOCK_STREAMtset_reuse_addrtbindR*RTRaR;tTrueRZRdR[R]RSR\RYR`(RtsocktforceRPRQ((
Rs?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytstart�s,

	
















	

(
	c
s�t}
�j
r�t�_�jrRy�jjtj�

WqRtjk
rN


qRXntjj	��

t
j��jkr�t
j�f
d
�d�
nt}
n�jr�tjj�j�
r��j�
tjd�j�

n|
r�tjd�

nt�_
dS(Nc
s�jS(
N(
R[((
R(s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyRe
si
sRemoved socket file sSocket shutdown(RYR[RdRRRRR>RVRRfRgRhRtwait_forRsRZRiRjRkRXRlR+RC(Rtstopflg((
Rs?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyR
s$

	
		





	





c

Cs&|jr"t
jd
�

d|_ndS(NsStop communication, shutdown(RWR+RCR(
R((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytstop_communication,
s
	


c


Cs|j�
|j
�
dS(
N(RyR(
R((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyR`4
s


c


Cs|jS(
N(
R[(
R((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pytisActive9
s
c
CsFytj
|j�

Wn+tk
rA
}

|
jtjkrB�qBn
XdS(
N(RitremoveRXtOSErrorRFtENOENT(RR2((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyRl?
s





c
CsB|j�}
t
j
|
t
j�}t
j
|
t
j|t
jB�
dS(
N(tfilenotfcntltF_GETFDtF_SETFDt
FD_CLOEXEC(Rttfdtflags((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyt__markCloseOnExecL
s

N(R"R#RR^RcRRYRvRRyR`RzRltstaticmethodRa(((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyRT�s								
Rmc
BseZ
RS((R"R#(((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyRmV
s
(#t
__author__t
__copyright__t__license__tpickleR
RRR
R>RFRRiRtsysRfR5tutilsRtprotocolRthelpersRRRR"R+RR	RRYRSRVRTR*Rm(((s?/usr/lib/python2.7/site-packages/fail2ban/server/asyncserver.pyt<module>s(












X6�