�
�c@s
dd
kZdd
k
Z
dd
kZdd
kZdd
kZdd
kZdd
kZdd
kZddkl	Z	l
Z
lZ
ddkl
Z

ddklZ
ddklZ
d�Zdef
d��YZd	eif
d
��YZdef
d��YZd
�Zd
S(i�N(thgtutilterror(
thgweb(
thgwebdir(
t
_c
CsId
|jo
|id
d�\}
}n
|d}
}t
i|
�|fS(sx Return path and query splited from uri

    Just like CGI environment, the path is unquoted, the query is
    not.
    t
?i
t(tsplitturllibtunquote(turitpathtquery((s)/sys/lib/python/mercurial/hgweb/server.pyt	_splitURIs



t
_error_loggerc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(cCs
|
|_dS(
N(
thandler(tselfR((s)/sys/lib/python/mercurial/hgweb/server.pyt__init__s
c


CsdS(
N((
R((s)/sys/lib/python/mercurial/hgweb/server.pytflushs
cCs|i|
i
d
��
dS(Ns

(t
writelinesR(Rtstr((s)/sys/lib/python/mercurial/hgweb/server.pytwrite s
cCs(x!|
D]}|ii
d
|�
qWdS(Ns
HG error:  %s(Rt	log_error(Rtseqtmsg((s)/sys/lib/python/mercurial/hgweb/server.pyR"s

(t__name__t
__module__RRRR(((s)/sys/lib/python/mercurial/hgweb/server.pyRs
			t
_hgwebhandlercBsteZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zdd
�Z
d�ZRS(
thttpc
Os#d
|_t
ii||
|�
dS(NsHTTP/1.1(tprotocol_versiontBaseHTTPServertBaseHTTPRequestHandlerR(Rtargstkargs((s)/sys/lib/python/mercurial/hgweb/server.pyR*s
	
cGs9|
id
|i
d|i�||f�
|
i�
dS(Ns%s - - [%s] %s
i(Rtclient_addresstlog_date_time_stringR(RtfptformatR!((s)/sys/lib/python/mercurial/hgweb/server.pyt_log_any.s

	

cGs|i|i
i|
|�
dS(
N(R'tserverterrorlog(RR&R!((s)/sys/lib/python/mercurial/hgweb/server.pyR4s
cGs|i|i
i|
|�
dS(
N(R'R(t	accesslog(RR&R!((s)/sys/lib/python/mercurial/hgweb/server.pytlog_message7s
c
CsHy|i�
Wn3t
ij
o$

}

|
d
tijo
�qD
n
XdS(Ni(tdo_hgwebtsocketRterrnotEPIPE(Rtinst((s)/sys/lib/python/mercurial/hgweb/server.pytdo_write:s





c
Csyy|i�
Wndt
j
oX



|id
g�
|id�
dititi���}
|i	d|i
|
�
n
XdS(Ns500 Internal Server ErrorsInternal Server ErrorRs5Exception happened during processing request '%s':
%s(R1t
StandardErrort_start_responset_writetjoint	tracebacktformat_exceptiontsystexc_infoRR(Rttb((s)/sys/lib/python/mercurial/hgweb/server.pytdo_POSTAs







	
c


Cs|i�
dS(
N(
R;(
R((s)/sys/lib/python/mercurial/hgweb/server.pytdo_GETKs
c
Cs�t|i
�\}
}h}d
|d<|i|d<|ii|d<t|ii�|d<|i
|d<|ii|d<|
t|ii�|d<|i	d	|d
<|i	d	|d<|o
||d<n

|i
idjo
|i
i
|d
<n
|i
i|d
<|i
id�}|o
||d<n

x�g}|i
i�D]}|djo
||q;

q;
~D]a}d|idd�i�}|i
i|�}	|	idd�i�}	|	o
|	||<q`

q`
W|i|d<d |d<|i|d<|i|d<t|�|d<t|iti�|d<t|iti�|d<d	|d<t|_d|_g|_t|_ d|_!x-|ii"||i#�D]}
|i$|
�
q�WdS(!NsCGI/1.1tGATEWAY_INTERFACEtREQUEST_METHODtSERVER_NAMEtSERVER_PORTtREQUEST_URItSCRIPT_NAMEt	PATH_INFOitREMOTE_HOSTtREMOTE_ADDRtQUERY_STRINGtCONTENT_TYPEscontent-lengthtCONTENT_LENGTHscontent-typetHTTP_t
-Rs

RtSERVER_PROTOCOLi
swsgi.versionswsgi.url_schemes
wsgi.inputswsgi.errorsswsgi.multithreadswsgi.multiprocesss
wsgi.run_once(scontent-typescontent-length(i
i(%RRtcommandR(tserver_nameRtserver_porttprefixtlenR#theaderst
typeheadertNonettypet	getheadertkeystreplacetuppertstriptrequest_versiont
url_schemetrfileRt
isinstancetSocketServertThreadingMixIntForkingMixIntTruetclose_connectiontsaved_statust
saved_headerstFalsetsent_headerstlengthtapplicationR3R4(RRR
tenvRgt_[1]t
htheaderthkeythvaltchunk((s)/sys/lib/python/mercurial/hgweb/server.pyR,NsZ



































	

	


	
	
	
	
	

c
Cs<
|ip
t
d
��n

|iidd�}
t|
d�|
d<|i|
�
t}xR|iD]G}|i|�
|di	�djo
t
}t|d�|_q`
q`Wdg}|ii
dd�id�D]}||i�i	�q�~jo

t}n

|o
|id	d�
n

||_|i�
t|_dS(
Ns.Sending headers before start_response() calledi
iscontent-lengthtcloset
connectionRt
,t
Connection(RctAssertionErrorRRStintt
send_responseRaRdtsend_headertlowerReRgRQtgetRYRbtend_headersRf(RRctshould_closeRkRjttoken((s)/sys/lib/python/mercurial/hgweb/server.pytsend_headerss(















B




	


c	Csy|
idd
�\}}t|�}|
|_d}g}|D](}|di�|jo
||q>
q>~|_|iS(Ni
Rqstransfer-encodingi(s
connectionstransfer-encoding(RRSRuRcRxRdR4(	Rthttp_statusRQR9tcodeRtbad_headersRjRk((s)/sys/lib/python/mercurial/hgweb/server.pyR3�s


	


.
cCs�|ip
t
d
��n
|ip
|i�
n

|idj	o@
t|
�|ijo
t
d��n

|it|
�|_n

|ii|
�
|ii	�
dS(Ns+data written before start_response() calledsLContent-length header sent, but more bytes than specified are being written.(
RcRtRfR}RgRSRPtwfileRR(Rtdata((s)/sys/lib/python/mercurial/hgweb/server.pyR4�s










N(RRR[RR'RR+R1R;R<R,R}RSR3R4(((s)/sys/lib/python/mercurial/hgweb/server.pyR&s						
		1		t_shgwebhandlerc
Bs)eZ
dZd
�Zd�Zd�ZRS(thttpsc

CsL|i|_
ti|id
|i�|_ti|id|i�|_dS(Ntrbtwb(trequestRqR-t_fileobjecttrbufsizeR\twbufsizeR�(
R((s)/sys/lib/python/mercurial/hgweb/server.pytsetup�s


c
Csad
dkl
}

ytt|�i�
Wn3|
j
o'

}
|idtijo
�q]
n
XdS(Ni�(
tSysCallErrori(tOpenSSL.SSLR�tsuperR�R1R!R.R/(RR�R0((s)/sys/lib/python/mercurial/hgweb/server.pyR1�s





c
CsVd
dkl
}
l}
ytt|�i�
Wn"|
|fj
o



t|_n
XdS(Ni�(R�tZeroReturnError(R�R�R�R�R�thandle_one_requestRaRb(RR�R�((s)/sys/lib/python/mercurial/hgweb/server.pyR��s




	
(RRR[R�R1R�(((s)/sys/lib/python/mercurial/hgweb/server.pyR��s		c
s�t}d
�}�djo

�}n

�i}|iddd��t|iddd��}|iddd���o
d�id��n

|idd	�}|idd
��|idd��||iddd
�ti��||iddd
�ti	��|o4
yddk
l}
WqE
tj
o




t
}qE

Xn

|o

ti}n1
ttd�o

ti}n
ddd��Y}dt|tif��������fd��Y}	d|	f
�f
d��Y��o

t}
n
t}
ddk}|i�
y5|o
��|f|
�Sn
|	�|f|
�SWnAtij
o2

}
titd��||idf��n
XdS(NcSs)|o
|d
jo
t|d�Sn

|
S(NRJt
a(
topen(topttdefault((s)/sys/lib/python/mercurial/hgweb/server.pytopenlog�s


twebtaddressRtporti@ROt
/tipv6twebdir_conftcertificateR*RJR)i�(
tactiveCounttforkt_mixinc
BseZ
RS((RR(((s)/sys/lib/python/mercurial/hgweb/server.pyR��s
tMercurialHTTPServercsFeZ
eidjo

d
Zn

��������fd�ZRS(tntic
	sJ
ti
i||
|�
�|_�|_t|_���fd
�}|�|_�o�
y&ddkl	}
|i
|i�}Wn(tj
o



t
itd���n
X|i��
|i��
ti|i|i�}|i||�|_|i�
|i�
n

|ii�dd!\|_|_�|_ti��|_dS(Nc
sb�o
t���}nE
�dj	o"
tti�i�i��}n
tit	d
���|S(Ns5There is no Mercurial repository here (.hg not found)(
RRSRRt
repositorytuitrootRt	RepoErrorR(
thgwebobj(R�trepoR�(s)/sys/lib/python/mercurial/hgweb/server.pytmake_handler�s




"i�(
tSSLsSSL support is unavailableii(Rt
HTTPServerRR*R)Ratdaemon_threadsRhtOpenSSLR�tContextt
SSLv23_METHODtImportErrorR
tAbortRtuse_privatekey_filetuse_certificate_fileR-taddress_familytsocket_typeRstserver_bindtserver_activatetgetsocknametaddrR�ROtgetfqdntfqaddr(RR!R"R�R�tctxtsock(R*tssl_certR)ROR�R�R�R�(s)/sys/lib/python/mercurial/hgweb/server.pyR�s*

	
	
	
	













"
	
(RRtostnametallow_reuse_addressR((R*R�R�R)R�ROR�R�(s)/sys/lib/python/mercurial/hgweb/server.pyR��s

tIPv6HTTPServercs)eZ
eedd�Z�f
d
�ZRS(tAF_INET6c
sF|idjo
titd
���n

t�|�i|
|�
dS(Ns$IPv6 is not available on this system(R�RSRR�RR�R(RR!tkwargs(
R�(s)/sys/lib/python/mercurial/hgweb/server.pyR
s


N(RRtgetattrR-RSR�R((
R�(s)/sys/lib/python/mercurial/hgweb/server.pyR�
s
s"cannot start server at '%s:%d': %si
(( RaRSR�tconfigRuRYt
configboolR8tstdouttstderrt	threadingR�R�ReR^R_thasattrR�R`tobjectRR�R�Rt	mimetypestinitR-RR
R�RR!(
R�R�tuse_threadsR�tmyuiR�tuse_ipv6R�R�R�RR�R0((	R�ROR*R�R�R�R�R)R�s)/sys/lib/python/mercurial/hgweb/server.pyt
create_server�sL
	


	








!
!







:'






(R�R8R.R	RR-R^R6t	mercurialRR
Rt	hgweb_modRthgwebdir_modRtmercurial.i18nRRR�RR RR�R�(((s)/sys/lib/python/mercurial/hgweb/server.pys<module>	s`



	�