�
��hc@s5dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
l	Z	dd
l
Z
dd
lZdd
lZej
ddkr�ej
ddkr�ddlmZ
ndd
lZiad�Zd�Zd	�Zd
�Zd�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�Zej
ddkr�
d�Zd�Zd�Z nd�Zd�Zd�Z dd#d��YZ!e"dkr1e�
edd�
edd�
ye�
Wn!e#k
r



edd �
�nXedd�
ed!d�
y
e�Z$Wn!e#k
rX


ed!d �
�nXed!d�
ed"d�
yTe�Z%e%d
k	s�t'�
e%\Z(Z)e�
e!e)ej*e$j+�Z,ee(�

Wn!e#k
r�


ed"d �
�nXed"d�
e�
e,j-�
ye
j.e(�

Wq1e/k
r-


q1Xnd
S($i����Niii
i(
tutilc

Cs%tj
j|d
�

tjd�

dS(Ns

i
(tsyststderrtwritetexit(
tmessage((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytabort#s

cCs_y)t|d
��}|j
|
�

WdQXWn/tk
rZ
}
tjd|d|j�

n
XdS(Nt
wsWarning: unable to write to s: (topenRtIOErrortloggingtwarntstrerror(tpathtcontentst
ft
e((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyttry_write_file's





cCs<tj
d
tjdd�
ttd�r8tjt�

ndS(Ntleveltformats2[ pid=%(process)d, time=%(asctime)s ]: %(message)stcaptureWarnings(R
tbasicConfigtWARNINGthasattrRtTrue(((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytinitialize_logging.s

	
	


cCsVtj
d
�
}|dk	s!t�
|d}
t|
d��}tj|�
aWdQXdS(NtPASSENGER_SPAWN_WORK_DIRs
/args.jsont
r(tostgetenvtNonetAssertionErrorRtjsontloadtoptions(twork_dirR
R((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytread_startup_arguments5s





cCsgtj
d
�
}|dk	s!t�
|d|j�}t|d|
�
t|dttj��
�
dS(NRs/response/steps/s/states/begin_time(RRRRtlowerRtstrttime(tsteptstateR#tstep_dir((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytrecord_journey_step_begin>s





cCs�tj
d
�
}|dk	s!t�
|d|j�}t|d|
�
tjj|d�
r�tjj|d�
r�t|dtt	j	��
�
nt|dtt	j	��
�
dS(NRs/response/steps/s/states/begin_times/begin_time_monotonics	/end_time(
RRRRR%RR
texistsR&R'(R(R)R#R*((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytrecord_journey_step_endEs




.
 
cCs�tj
jd
tj��
tjdd�}tjd
dkr�tjddkr�tj	d|�}
|
dk	sut�
tj|
�
}|
j
dk	s�t�
|
j
j|�

|Stjd|�SdS(Nitstartup_filespassenger_wsgi.pyii
itpassenger_wsgi(R
R
tinsertRtgetcwdR"tgettversion_infoRtspec_from_file_locationRRtmodule_from_spectloadertexec_moduletimptload_source(R.tspect
app_module((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytload_appNs

&





cCs�tt
jd
d��
}dt
kr7t
d}
d}ntj�}
d}d}xw|dkr�yt|
||�SWqRtjk
r�
}
|jtj	kr�|d7}|dkr�|�
q�q�|�
qRXqRWdS(	Nt
UNIX_PATH_MAXidt
socket_dirtwsgit
PsgWsgiAppii�i
(
tintR"R2ttempfilet
gettempdirtmake_sockettsocketterrorterrnot
EADDRINUSE(R=R>t
socket_prefixt
iR((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytcreate_server_socket]s 



	









cCs�tjtj
tj�}ttjd
tjd�
�dd�}|d|
d|}|d|!}|j|�

|j	d�

||fS(Nt
Qiit
xt
/t
.i�(
REtAF_UNIXtSOCK_STREAMRtstructtunpackRturandomtbindtlisten(R>RIR=t
st
socket_suffixtfilename((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyRDts

(







c
s/d
���f
d�}tjtj
|�
dS(NcSs�tgt
j�D]}|j|jf^q�
}g}x�tj�j�D]�\}}|jd
|j	|d�|f�

x]t
j|�
D]L\}}}	}
|jd|||	f�

|
r�|jd|
j��

q�q�WqJWdj
|�
GHdS(Ns
# Thread: %s(%d)ts  File: "%s", line %d, in %ss    %ss

(tdictt	threadingt	enumeratetidenttnameR
t_current_framestitemstappendR2t	tracebackt
extract_stacktstriptjoin(tsigtframetthtid2nametcodet	thread_idtstackRYtlinenoR_tline((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytdebug~s
1


#
"


"
cs�||
�
tj
d
�

dS(Ni
(R
R(RgRh(
Rp(sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytdebug_and_exit�s


(tsignaltSIGABRT(
Rq((
RpsL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytinstall_signal_handlers}s
	c
Cs�tj
d
�
}
|
dk	s!t�
|
d}i
idd6d|d6dd6d	d
6td6g
d6}t|d
��}tj||�
WdQXdS(NRs/response/properties.jsontmainR_sunix:taddresstsessiontprotocoli
tconcurrencytaccept_http_requeststsocketsR(RRRRRRR tdump(tsocket_filenameR#R
tdocR((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytadvertise_sockets�s










cCsTtj
d
�
}|dk	s!t�
|d}
t|
d��}|jd�

WdQXdS(NRs/response/finishRt
1(RRRRRR(R#R
R((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytadvertise_readiness�s






c

Cs"|d
j|d|d��
dS(Nii
i(
twith_traceback(
texc_info((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytreraise_exception�s
c

Cs
|jd
�
S(Nslatin-1(
tdecode(
t
b((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytbytes_to_str�s
c

Cs$t|t
�r|S|jd
�
SdS(Nslatin-1(t
isinstancetbytestencode(
RW((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytstr_to_bytes�s

c

Bsd
dUdS(Ns+raise exc_info[0], exc_info[1], exc_info[2]((
R�((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR��s
c


Cs|S(
N((
R�((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR��s
c


Cs|S(
N((
RW((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR��s
tRequestHandlercBsbeZ
d�Zd
�Zd�Zd�Zeed�rEd�Zn	d�Zd�Z	d�Z
RS(	cCs|
|_||_
||_dS(
N(tservert
owner_pipetapp(tselft
server_socketR�R�((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyt__init__�s
	
	
c
Css
t}
yU
xN
|
sY
|j
�\}}|s4t}
Pnt}z�yW|j|�
\}}|r�|d
dkr{|j|�

q�|j|||�}nWn{tk
r�


t}
netk
r�
}
t|dt�s�|j	t	j
kr
tjd�

q
nt
k
r



tjd�

n
XWd|sU
y|jtj�

Wn


n
Xy|j�
WqU



qU
XnXqWWntk
rn



n
XdS(NtREQUEST_METHODtpingt	passengers)WSGI application raised an I/O exception!s%WSGI application raised an exception!(tFalsetaccept_connectionRt
parse_requesttprocess_pingtprocess_requesttKeyboardInterruptR	tgetattrRGtEPIPER
t	exceptiont	ExceptiontshutdownREtSHUT_WRtclose(R�tdonetclientRvtsocket_hijackedtenvtinput_streamR((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyt	main_loop�sB


	













	

%













c
CsUtj|j
|jj�ggg�d
}
|jj�|
krM|jj�SdSdS(Ni(NN(tselectR�R�tfilenotacceptR(R�tresult((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR��s
+


cCs:
d
}xOt|�
dkrW|
j
dt|�
�
}t|�
dkrJdS||7}q	Wtjd|�d}d
}xOt|�
|kr�|
j
|t|�
�
}t|�
dkr�d	S||7}qwW|jd�
}|j�
i}d}xB|t|�
kr/
t||d�
|t||�
<|d7}q�W||
fS(
NRZiis>Is
i
i(NN(NN(tlentrecvRRRRStsplittpopR�(R�R�tbufttmptheader_sizetheadersR�RJ((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR��s*

















"
t_fileobjectcCstj
|
d
d�S(Ntrbi(RER�(R�tsock((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytwrap_input_socket
s
cCstjj
|
d
d�S(NR�i(REtmakefile(R�R�((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR�
s
csc
|j|�
�d
<t
j�d<d�d<t�d<t�d<t�d<�jd	d
�dkrmd�d<n
d�d<g�g�
�ddk��
���fd��d�
��fd�
}t��fd�
}|�d<|j�|�}d�kr
tSz;x!|D]}|r
�|�

q
q
W�
s>
�d�

nWdt|d�r^
|j	�
nXtS(Ns
wsgi.inputswsgi.errorsi
iswsgi.versionswsgi.multithreadswsgi.multiprocesss
wsgi.run_oncetHTTPStofftonR�ttruetyesthttpsswsgi.url_schemethttpR�tHEADc
s�y��
std
�
�
nl�s��
\}
}�(�j
td|
|
f�
�

x%|D]}�j
td|�
�

qSW�j
d�

n�s��j
t|�
�

nWn)tk
r�
}
t|dt�
|�
n
XdS(Nswrite() before start_response()s,HTTP/1.1 %s
Status: %s
Connection: close
s%s: %s
s
R�(RtsendallR�R	tsetattrR(tdatatstatustresponse_headerstheaderR(theaders_senttheaders_settis_headt
output_stream(sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR.
s 




	









csP|r*z�rt|�

nWdd}Xn�
r?td
�
�
n||
g�
(�S(NsHeaders already set!(R�RR(R�R�R�(R�R�R(sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pytstart_responseC
s







c

s|r�
�d
<�
SdS(Nspassenger.hijacked_socket((
tdo_it(R�R�(sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pythijackU
s



spassenger.hijackspassenger.hijacked_socketRZR�(i
i(R�R�R�R�(
R�R
RR�RR2RR�RR�(R�R�R�R�R�R�R�R�((R�R�R�R�R�RsL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR�
s8
























cCs|
jd
�

dS(Ntpong(
R�(R�R�((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR�m
s
(t__name__t
__module__R�R�R�R�RRER�R�R�(((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyR��s
		'		
		Vt__main__tSUBPROCESS_EXEC_WRAPPERtSTEP_PERFORMEDtSUBPROCESS_WRAPPER_PREPARATIONtSTEP_IN_PROGRESStSTEP_ERROREDtSUBPROCESS_APP_LOAD_OR_EXECtSUBPROCESS_LISTEN((0R
RR\RrRcRER�RRR
RGRBR R'R3t	importlibRR8R"RRRR$R+R-R<RKRDRtRR�R�R�R�R�R�R�R;ttupleRRR}R�tstdintapplicationthandlerR�tremovetOSError(((sL/opt/cpanel/ea-ruby27/root/usr/share/passenger/helper-scripts/wsgi-loader.pyt<module>sxx
$
&
															
					�