��Qc@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZddlm	Z	m
Z

ddlmZ
ddl
mZ
d�Zdef
d��YZdejf
d	��YZd
ef
d��YZdef
d
��YZy$ddlmZ
e�
ejZWnEek
re



e	jed�rL
ejZqf
def
d��YZn
Xd�Zdeeejfd��YZdef
d��YZ d�Z!d
S(i�N(tutilterror(
tcommon(
t
_c
CsGd
|kr'|jd
d�\}
}n
|d}
}t
j|
�|fS(s�Return path and query that has been split from uri

    Just like CGI environment, the path is unquoted, the query is
    not.
    t
?i
t(tsplitturllibtunquote(turitpathtquery((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyt	_splitURIs


t
_error_loggerc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(cCs
|
|_dS(
N(
thandler(tselfR((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyt__init__s
c


CsdS(
N((
R((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytflushs
cCs|j|
j
d
��
dS(Ns

(t
writelinesR(Rtstr((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytwrites
cCs(x!|
D]}|jj
d
|�
qWdS(Ns
HG error:  %s(Rt	log_error(Rtseqtmsg((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR!s


(t__name__t
__module__RRRR(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR
s
			t_httprequesthandlercBs�eZ
dZed
��Zd�Zd�Zd�Zd�Zddd�Z	d�Z
d	�Zd
�Zd�Z
d�Zdd
�Zd�Zd�ZRS(thttpc
Csd
S(s*Prepare .socket of new HTTPServer instanceN((t
httpservertssl_cert((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytpreparehttpserver)sc
Os#d
|_t
jj||
|�
dS(NsHTTP/1.1(tprotocol_versiontBaseHTTPServertBaseHTTPRequestHandlerR(Rtargstkargs((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR.s
	
cGs9|
jd
|j
d|j�||f�
|
j�
dS(Ns%s - - [%s] %s
i(Rtclient_addresstlog_date_time_stringR(RtfptformatR"((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyt_log_any2s

	

cGs|j|j
j|
|�
dS(
N(R(tserverterrorlog(RR'R"((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR8s
cGs|j|j
j|
|�
dS(
N(R(R)t	accesslog(RR'R"((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytlog_message;s
t
-c
Cs�g|jj
�D]}|d
jd�r|^q}|jd|jt|
�t|�djgt|�D]}d|^qi��
dS(Nisx-s"%s" %s %s%sRs %s:%s(theaderstitemst
startswithR,trequestlineRtjointsorted(Rtcodetsizet
htxheaders((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytlog_request>s
5
	

c
CsDy|j�
Wn/t
jk
r?
}

|
d
tjkr@�q@n
XdS(Ni(tdo_hgwebtsocketR
terrnotEPIPE(Rtinst((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytdo_writeDs





c
Cswy|j�
Wnbt
k
rr


|jd
g�
|jd�
djtjtj���}
|j	d|j
|
�
n
XdS(Ns500 Internal Server ErrorsInternal Server ErrorRs5Exception happened during processing request '%s':
%s(R>t	Exceptiont_start_responset_writeR2t	tracebacktformat_exceptiontsystexc_infoRR
(Rttb((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytdo_POSTKs








	
c


Cs|j�
dS(
N(
RG(
R((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytdo_GETUs
c

Cs�t|j
�\}
}i}d
|d<|j|d<|jj|d<t|jj�|d<|j
|d<|jj|d<|
t|jj�|d<|j	d	|d
<|j	d	|d<|r�||d<n|j
jdkr�j
j
|d
<n|j
j|d
<|j
jd�}|r
||d<nx�g|j
j�D]}|d!kr1
|^q1
D]_}d|jdd�j�}|j
j|�}|jdd�j�}|rM
|||<qM
qM
W|j|d<d"|d<|j|d<|jdd�j�dkrtj|j|jj�|_n|j|d<t|�|d<t|jtj�|d<t|jtj �|d<d	|d <d|_!g|_"t#|_$d|_%d|_&x-|jj'||j(�D]}	|j)|	�
q�W|j$s�|j*�
n|j+�
dS(#NsCGI/1.1tGATEWAY_INTERFACEtREQUEST_METHODtSERVER_NAMEtSERVER_PORTtREQUEST_URItSCRIPT_NAMEt	PATH_INFOitREMOTE_HOSTtREMOTE_ADDRtQUERY_STRINGtCONTENT_TYPEscontent-lengthtCONTENT_LENGTHscontent-typetHTTP_R-Rs

RtSERVER_PROTOCOLi
swsgi.versionswsgi.url_schemetHTTP_EXPECTs100-continues
wsgi.inputswsgi.errorsswsgi.multithreadswsgi.multiprocesss
wsgi.run_once(scontent-typescontent-length(i
i(,RR
tcommandR)tserver_nameRtserver_porttprefixtlenR$R.t
typeheadertNonettypet	getheadertkeystreplacetuppertstriptrequest_versiont
url_schemetgettlowerRtcontinuereadertrfiletwfileRR
t
isinstancetSocketServertThreadingMixIntForkingMixIntsaved_statust
saved_headerstFalsetsent_headerstlengtht_chunkedtapplicationR@RAtsend_headerst_done(
RR
RtenvRtR6theaderthkeythvaltchunk((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR9Xs`



































!


	

	


	
	
	
	
	


	


c
Cs1
|jst
d
��n|jjdd�}
t|
d�|
d<|j|
�
d|_t|_xJ|j	D]?}|j
|�
|dj�dkrjt|d�|_qjqjW|jdkr
|
dtj
kr
|jo�jdk|_|jr
|j
dd�
q
|j
dd	�
n|j�
t|_dS(
Ns.Sending headers before start_response() calledi
iscontent-lengthsHTTP/1.1sTransfer-Encodingtchunkedt
Connectiontclose(RptAssertionErrorRR^tintt
send_responseRtRrRuRqtsend_headerRhRtHTTP_NOT_MODIFIEDtclose_connectionRetend_headerstTrueRs(RRpR6((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyRw�s(
	




	
	










	



cCsl|
jdd
�\}}t|�}|
|_d}g|D]"}|dj�|kr:|^q:|_|jS(Ni
t
connectionstransfer-encodingi(s
connectionstransfer-encoding(RR^R�RpRhRqRA(Rthttp_statusR.RER4Rtbad_headersR6((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR@�s


	



%
cCs�|jst
d
��n|js.|j�
n|jdk	rzt|
�|jkrat
d��n|jt|
�|_n(|jr�|
r�dt|
�|
f}
n|jj	|
�
|jj
�
dS(Ns+data written before start_response() calledsLContent-length header sent, but more bytes than specified are being written.s%x
%s
(RpR�RsRwRtR^R\RuRkRR(Rtdata((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyRA�s
	

	








c

Cs-|jr)|j
jd
�
|j
j�
ndS(Ns0

(RuRkRR(
R((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyRx�s
	

N(RRRftstaticmethodRRR(RR,R8R>RGRHR9RwR^R@RARx(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR%s						
		7			t_httprequesthandleropensslcBs>eZ
dZd
Zed��Zd�Zd�Zd�ZRS(s HTTPS handler based on pyOpenSSLthttpscCs�yd
dl}|j
j
Wn&tk
rB


tjtd���n
X|j
j|j
j�}|j|
�
|j	|
�
t
j
|j|j�}|j
j
||�|_
|j�
|j�
dS(Ni�sSSL support is unavailable(tOpenSSLtSSLtContexttImportErrorRtAbortRt
SSLv23_METHODtuse_privatekey_filetuse_certificate_fileR:taddress_familytsocket_typeRtserver_bindtserver_activate(RRR�tctxtsock((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR�s














c

CsL|j|_
tj|jd
|j�|_tj|jd|j�|_dS(Ntrbtwb(trequestR�R:t_fileobjecttrbufsizeRjtwbufsizeRk(
R((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytsetup�s


c
CsYd
dl}
yt
j|�
Wn5|
jjk
rT
}
|jdtjkrU�qUn
XdS(Ni�i(R�RR>R�tSysCallErrorR"R;R<(RR�R=((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR>�s





c
CsPd
dl}
yt
j|�
Wn,|
jj|
jjfk
rK


t|_n
XdS(Ni�(R�Rthandle_one_requestR�R�tZeroReturnErrorR�R�(RR�((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR��s




	
(	RRt__doc__RfR�RR�R>R�(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR��s
		t_httprequesthandlersslcBs,eZ
dZd
Zed��Zd�ZRS(s=HTTPS handler based on Pythons ssl module (introduced in 2.6)R�cCsnyd
dl}|j

Wn&tk
r?


tjtd���n
X|j
|jdtd|
d|j�|_dS(Ni�sSSL support is unavailabletserver_sidetcertfiletssl_version(	tssltwrap_socketR�RR�RR:R�tPROTOCOL_SSLv23(RRR�((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR�s






c

CsL|j|_
tj|jd
|j�|_tj|jd|j�|_dS(NR�R�(R�R�R:R�R�RjR�Rk(
R((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR��s


(RRR�RfR�RR�(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR��s

(
tactiveCounttforkt_mixinc
BseZ
RS((RR(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR�	
s
cCs#|r|d
krt|d�S|
S(NR-t
a(
topen(topttdefault((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pytopenlog
s



tMercurialHTTPServercBs)eZ
ejdkrd
Znd�ZRS(tntic	Ks
tj
j||||�
t|_||_|j||
jd
d��
|
jd
dd�}|rxd|jd�}n||_	t
|
jd
dd�tj�}t
|
jd
dd�tj
�}||_||_|jj�d	d
!\|_|_tj|d	�|_dS(NtwebtcertificateR[Rt
/R+R-R*ii(R t
HTTPServerRR�tdaemon_threadsRvRtconfigRdR[R�RDtstdouttstderrR+R*R:tgetsocknametaddrtporttgetfqdntfqaddr(	RtuitappR�RtkwargsR[talogtelog((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR
s

	
	


	!
!
	
	"
(RRtostnametallow_reuse_addressR(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR�
s
	tIPv6HTTPServercBs#eZ
eedd�Zd
�ZRS(tAF_INET6c
OsD|jdkr'tjtd
���ntt|�j|
|�
dS(Ns$IPv6 is not available on this system(R�R^R
t	RepoErrorRtsuperR�R(RR"R�((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR-
s


N(RRtgetattrR:R^R�R(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyR�+
s

cCs
|jd
d�r3t
jd
kr*t}q9t}nt}|jd
d�rTt}nt}ddl	}|j
�
|jd
dd�}tj|jd
d	d
��}y|||
||f|�SWn?t
jk
r


}
tjtd�|||jdf��n
XdS(NR�R�iitipv6i�taddressRR�i@s"cannot start server at '%s:%d': %si
(ii(R�RDtversion_infoR�R�Rt
configboolR�R�t	mimetypestinitRtgetportR:R
R�RR"(R�R�RtclsR�R�R�R=((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyt
create_server2
s"

		
	






("R�RDR;RR R:RmRBt	mercurialRR
tmercurial.hgwebRtmercurial.i18nRRtobjectR
R!RR�R�t	threadingR�RnR�R�tsafehasattrRoR�R�R�R�R�(((s:/sys/lib/python2.7/site-packages/mercurial/hgweb/server.pyt<module>	s(`


	�)