Shadowsocks-For-WHMCS/Server/shadowsocks/tcprelay.pyc

<EFBFBD><EFBFBD>
T#zUc@s8
dd
kZdd
k
Z
dd
kZdd
kZdd
kZdd
kZdd
kZdd
kZdd
kZdd
k	Z	ddk
lZ
dZdZ
dZdZdZdZd	ZdZdZdZdZd
ZdZd	ZdZd	ZdZdZeeBZddZd
e f
d<00><00>YZ!de f
d<00><00>YZ"d
S(i<><69><EFBFBD><EFBFBD>N(
tparse_headeriii i
iiiii itTCPRelayHandlercBs<>eZ
d<00>Zd
<00>Zed<00><00>
Zd<00>Zd<00>Zd<00>Zd<00>Z	d<00>Z
d<00>Zd	<00>Zd
<00>Z
d<00>Zd<00>Zd
<00>Zd<00>Zd<00>Zd<00>Zd<00>Zd<00>ZRS(cCs%
|
|_||_
||_||_d|_||_||_||_t	|_
ti|d
|d<19>|_
t|_g|_g|_t|_t|_d|_|o
|i<00>|_n

|||i<00><|it<00>

|ititid<00>
|i|t i!t i"B<>
d|_#|i$<00>
dS(Ntpasswordtmethodi
i(%t_servert_fd_to_handlerst_loopt_local_socktNonet_remote_sockt_configt
_dns_resolvert	_is_localt
STAGE_INITt_stagetencryptt	Encryptort
_encryptortFalset_fastopen_connectedt_data_to_write_to_localt_data_to_write_to_remotetWAIT_STATUS_READINGt_upstream_statustWAIT_STATUS_INITt_downstream_statust_remote_addresst
_get_a_servert_chosen_servertfilenotsetblockingt
setsockopttsockettSOL_TCPtTCP_NODELAYtaddt	eventlooptPOLL_INtPOLL_ERRt
last_activityt_update_activity(tselftservertfd_to_handlerstloopt
local_socktconfigtdns_resolvertis_local((s%/home/wwwroot/shadowsocks/tcprelay.pyt__init__Rs2	
	
	
	
	
	
	
	
	



	
	
	
	
	
	







	
c

Cs
t|<00>
S(
N(
tid(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pyt__hash__nsc


Cs|iS(
N(
R(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pytremote_addressssc
Cs]|id
}
|id}t
|<00>
tjo
ti|<00>
}n

tid|
|<00>
|
|fS(NR*tserver_portschosen server: %s:%d(R
ttypetlisttrandomtchoicetloggingtdebug(R)R*R5((s%/home/wwwroot/shadowsocks/tcprelay.pyRws






c

Cs|ii
|<00>

dS(
N(Rtupdate_activity(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pyR(<00>s
cCsS
t}|
t
jo'
|i|jo
||_t}qn
n5
|
tjo'
|i|jo
||_t}qn
n

|o<>
|ioa
ti}|it	@o
|ti
O}n

|it@o
|tiO}n

|i
i|i|<00>
n

|ioa
ti}|it@o
|tiO}n

|it	@o
|ti
O}n

|i
i|i|<00>
qO

n

dS(
N(RtSTREAM_DOWNRtTruet	STREAM_UPRRR$R&tWAIT_STATUS_WRITINGtPOLL_OUTRR%RtmodifyR	(R)tstreamtstatustdirtytevent((s%/home/wwwroot/shadowsocks/tcprelay.pyt_update_stream<61>s0




	




	




	







	




cCs<>
|
p
|o
tS
t}y@t
|
<00>
}|i|
<00>
}||jo
|
|}
t}n

Wn<57>ttfj
ox

}
ti|<00>
}|ti	ti
tifjo

t}q<>
ti
|<00>

|id
o
ti<00>
n

|i<00>
tSn
X|oy
||ijo$
|ii|
<00>

|itt<00>
q<>

||ijo$
|ii|
<00>

|itt<00>
q<>

ti
d<00>

nV
||ijo
|itt<00>
n2
||ijo
|itt<00>
n
ti
d<00>

tS(Ntverboses write_all_to_sock:unknown socket(RtlentsendR>tOSErrortIOErrorR$terrno_from_exceptionterrnotEAGAINtEINPROGRESStEWOULDBLOCKR:terrorR
t	tracebackt	print_exctdestroyRRtappendRGR=R@R	RR?R(R)tdatatsockt
uncompletet
lt
st
eterror_no((s%/home/wwwroot/shadowsocks/tcprelay.pyt_write_to_sock<63>sB






















	











cCs<>
|io
|i
i|
<00>
}
n

|ii|
<00>

|io<>

|io<>

|id
o<>

y<>t|_|i|i	d|i	d<19>}|i
i|ti
<00>
di|i<00>
}
t|
<00>
}|i|
t|i	<00>}||jo*
|
|}
|
g
|_|itt<00>
n#
g|_|itt<00>
t|_Wq<57>
ttfj
o<>

}
ti|<00>
tijo
|itt<00>
q<>

ti|<00>
tijo(
ti d<00>

t!|id
<|i"<00>
q<>

ti |<00>

|ido
t#i$<00>
n

|i"<00>
q<>

Xn

dS(Nt	fast_openii
ts"fast open not supported on this OSRH(%RRRRRVRR
R>t_create_remote_socketRRR#R$R&tjoinRRItsendtotMSG_FASTOPENRGR?tWAIT_STATUS_READWRITINGRtSTAGE_STREAMRRKRLRMRNRPtENOTCONNR:RRRRURSRT(R)RWtremote_sockRZR[R\((s%/home/wwwroot/shadowsocks/tcprelay.pyt_handle_stage_reply<6C>s>







	










	















cCsxy)|io<>
t
|
d
<19>
}|tjo<>
tid<00>

|iitijo

d}n
d}|ii	<00>\}}ti
|ii|<00>}tid|<00>}|i
||||i<00>
t|_dS
|tjo
|
d}
q

tid|<00>
|i<00>
dSn

t|
<00>
}|djo
td|id	<16>
<00>
n

|\}	}
}}tid
|
|f<16>

|
|f|_|itt<00>
t|_|ioV
|i
d|i<00>
|ii|
<00>
}
|ii |
<00>

|i!i"|i#d|i$<00>
nB
t%|
<00>
|jo
|ii |
|<1F>

n

|i!i"|
|i$<00>
WnHtj
o<

}
ti|<00>

|id
o
t&i'<00>
n

|i<00>
n
XdS(Ni
s
UDP associatess
s>Hisunknown command %ds[%s]can not parse headerR5sconnecting %s:%ds

iRH((RtordtCMD_UDP_ASSOCIATER:R;RtfamilyR tAF_INET6tgetsocknamet	inet_ptontstructtpackR^tSTAGE_UDP_ASSOCRtCMD_CONNECTRRRURRt	ExceptionR
tinfoRRGR?R@t	STAGE_DNSRRRRVRtresolveRt_handle_dns_resolvedRIRSRT(R)RWtcmdtheadertaddrtporttaddr_to_sendtport_to_sendt
header_resulttaddrtypetremote_addrtremote_portt
header_lengthtdata_to_sendR\((s%/home/wwwroot/shadowsocks/tcprelay.pyt_handle_stage_hello<6C>sZ













	




	












	

	











c
Cs<>ti
|
|d
titi<00>}t|<00>
d
jo
td|
|f<16>
<00>
n

|d
\}}}}}ti|||<00>}	|	|_||i|	i<00><|	i	t
<00>

|	ititid<00>
|	S(Nisgetaddrinfo failed for %s:%di
(
R tgetaddrinfotSOCK_STREAMR!RIRtR	RRRRRR"(
R)tipR|taddrstaftsocktypetprotot	canonnametsaRh((s%/home/wwwroot/shadowsocks/tcprelay.pyRa!
s






	




c
Cs<>
|o
ti
|<00>

|i<00>
dS
|
o~

|
d
}|oi

y
t|_|}|io
|id
}n
|id
}|io+
|ido
t|_|i	t
t<00>
n<>
|i||<00>}y|i
||f<00>

Wn8ttfj
o&

}
ti|<00>
tijo
q

n
X|ii|titiB<>
t|_|i	t
t<00>
|i	tt<00>
dSWq<57>
ttfj
o2

}
ti
|<00>

|ido
ti<00>
q<>

q<>

Xq<58>

n

|i<00>
dS(Ni
R_RH(R:RRRUtSTAGE_REPLYRRRRR
RGR?RRatconnectRKRLR$RMRNRPRR#R&RAReR=RSRT(R)tresultRRR<>R<>R<>RhR\((s%/home/wwwroot/shadowsocks/tcprelay.pyRx.
sF











	




	
	
	






	


	








c
Cs<>
|i<00>
|i
p
dS
|i}
d}y|i
it<00>
}WnHttfj
o6

}
ti	|<00>
t
it
it
i
fjo
dS
n
X|p
|i<00>
dS
|iit|<00>
7_|
p"
|ii|<00>
}|p
dS
n

|itjo8
|io
|ii|<00>
}n

|i||i<00>
dS
|
o1
|itjo!
|id
|i
<00>
t|_dS
|itjo
|i|<00>

nA
|
o
|itjp
|
o!
|itjo
|i|<00>

n

dS(Ns(R(RRRtrecvtBUF_SIZERKRLR$RMRNt	ETIMEDOUTRORQRURtserver_transfer_ulRIRtdecryptRRfRR^R	R
tSTAGE_HELLOR<4F>RiR<>(R)R0RWR\((s%/home/wwwroot/shadowsocks/tcprelay.pyt_on_local_readX
sB





	
















	







	





c
	Cs7
|i<00>
d}
y|iit<00>
}
WnHttfj
o6

}
ti|<00>
t	i
t	it	ifjo
dS
n
X|
p
|i
<00>
dS
|iit|
<00>
7_|io
|ii|
<00>
}
n
|ii|
<00>
}
y|i|
|i<00>
WnHtj
o<

}
ti|<00>

|id
o
ti<00>
n

|i
<00>
n
XdS(NRH(R(RR	R<>R<>RKRLR$RMRNR<>RORQRURtserver_transfer_dlRIRRR<>RR^RRtR:RRR
RSRT(R)RWR\((s%/home/wwwroot/shadowsocks/tcprelay.pyt_on_remote_read|
s,
























c
CsP|io2
d
i
|i<00>
}
g|_|i|
|i<00>
n
|itt<00>
dS(NR`(RRbR^RRGR=R(R)RW((s%/home/wwwroot/shadowsocks/tcprelay.pyt_on_local_write<74>
s




	
c
CsYt|_
|io2
d
i|i<00>
}
g|_|i|
|i<00>
n
|itt<00>
dS(NR`(	RfRRRbR^R	RGR?R(R)RW((s%/home/wwwroot/shadowsocks/tcprelay.pyt_on_remote_write<74>
s
	



	
c

CsBti
d
<00>

|io
titi|i<00>
<00>

n

|i<00>
dS(Nsgot local error(R:R;RRRR$tget_sock_errorRU(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pyt_on_local_error<6F>
s





c

CsBti
d
<00>

|io
titi|i<00>
<00>

n

|i<00>
dS(Nsgot remote error(R:R;R	RRR$R<>RU(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pyt_on_remote_error<6F>
s





cCse
|it
jo
tid
<00>

dS
|
|ijo<>
|ti@o#
|i<00>
|it
jo
dS
n

|titi	B@o#
|i
<00>
|it
jo
dS
n

|ti@o
|i<00>
qa

n<>
|
|i
jo<>
|ti@o#
|i<00>
|it
jo
dS
n

|titi	B@o#
|i<00>
|it
jo
dS
n

|ti@o
|i<00>
qa

n
tid<00>

dS(Nsignore handle_event: destroyedsunknown socket(RtSTAGE_DESTROYEDR:R;R	R$R&R<>R%tPOLL_HUPR<50>RAR<>RR<>R<>R<>twarn(R)RXRF((s%/home/wwwroot/shadowsocks/tcprelay.pythandle_event<6E>
s4








	




	







	




	

c

Cs
|it
jo
tid
<00>

dS
t
|_|io[
yMtid<00>

|ii|i<00>

|i|ii<00>=|ii	<00>
d|_Wq<57>


q<>Xn

|io[
yMtid<00>

|ii|i<00>

|i|ii<00>=|ii	<00>
d|_Wq<57>


q<>Xn

|ii
|i<00>

|ii|<00>

dS(Nsalready destroyedsdestroying remotesdestroying local(RR<>R:R;R	RtremoveRRtcloseRRRtremove_callbackRxRtremove_handler(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pyRU<00>
s0




	



























(t__name__t
__module__R1R3tpropertyR4RR(RGR^RiR<>RaRxR<>R<>R<>R<>R<>R<>R<>RU(((s%/home/wwwroot/shadowsocks/tcprelay.pyR
Qs&
							'	$	9	
	*	$							tTCPRelayc
BsYeZ
d<00>Zd
<00>Zd<00>Zd<00>Zd<00>Zd<00>Zd<00>Zd<00>Z	d<00>Z
RS(	c
Cs<>
|
|_||_
||_t|_d|_h|_ti<00>|_	d
|_
d
|_|
d|_g|_
d|_h|_|o
|
d}|
d}n
|
d}|
d}ti||dtiti<00>}t|<00>
djo
td||f<16>
<00>
n

|d\}}}	}
}ti|||	<00>}|ititid	<00>
|i|<00>

|it<00>

|
d
oQ
y|itidd<00>
Wq<57>
tij
o!



tid
<00>

t|id
<q<>

Xn

|id<00>

||_dS(Nlttimeoutit
local_addresst
local_portR*R5scan't get addrinfo for %s:%di
R_iis#warning: fast open is not availablei(R
RRRt_closedRt
_eventloopRttimet
_last_timeR<65>R<>t_timeoutt	_timeoutst_timeout_offsett_handler_to_timeoutsR R<>R<>R!RIRtRt
SOL_SOCKETtSO_REUSEADDRtbindRRRR:tlistent_server_socket(
R)R.R/R0tlisten_addrtlisten_portR<74>R<>R<>R<>R<>R<>t
server_socket((s%/home/wwwroot/shadowsocks/tcprelay.pyR1<00>
sH
	
	
	
	
	
	

	
	

		
	


























cCsq|io
t
d
<00>
<00>
n

|io
t
d<00>
<00>
n

|
|_|
i|i<00>

|ii|ititi	B<>
dS(Nsalready add to loopsalready closed(
R<>RtR<>tadd_handlert_handle_eventsR#R<>R$R%R&(R)R,((s%/home/wwwroot/shadowsocks/tcprelay.pytadd_to_loops






	

c

Cs*|ii
|i<00>

|ii|i<00>

dS(
N(R<>R<>R<>R<>R<>(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pytremove_to_loop#s

c
Cs_|i<00>
xD|i
i<00>D]3}
y|i
|
i<00>
Wqtj
o	

}
q
XqW|i<00>
dS(
N(R<>RtkeysRURtR<>(R)tfdR\((s%/home/wwwroot/shadowsocks/tcprelay.pyRU's




	
cCsM|ii
t|
<00>
d
<00>}|djo!
d|i|<|it|
<00>
=n

dS(Ni<4E><69><EFBFBD><EFBFBD>i(R<>tgetthashRR<>(R)thandlertindex((s%/home/wwwroot/shadowsocks/tcprelay.pyR<79>2s




cCs<>tt
i
<00><00>
}||
itjo
d
S
||
_|iit|
<00>
d<00>}|djo
d
|i|<n

t	|i<00>
}|ii
|
<00>

||it|
<00>
<d
S(s set handler to active Ni<4E><69><EFBFBD><EFBFBD>i(tintR<74>R'tTIMEOUT_PRECISIONR<4E>R<>R<>RR<>RIRV(R)R<>tnowR<77>tlength((s%/home/wwwroot/shadowsocks/tcprelay.pyR<9s

	





c
CsT
|ioF

t
itid
<00>
ti<00>}
t|i<00>
}|i}x<>||jo<>
|i|}|op
|
|i|i	jo
Pq<50>
|i
o
t
id|i
<16>

n
t
id<00>

|i<00>
d|i|<|d7}qD
|d7}qD
W|tjoR
||d?joA
|i||_x$|iD]}|i|c|8<q
Wd}n

||_n

dS(Nssweeping timeoutsstimed out: %s:%ds	timed outi
i(R<>R:tlogtutilst
VERBOSE_LEVELR<4C>RIR<>R'R<>R4R<>RURtTIMEOUTS_CLEAN_SIZER<45>(R)R<>R<>tposR<73>tkey((s%/home/wwwroot/shadowsocks/tcprelay.pyt_sweep_timeoutHs4




	








	













c
Cs<>
x<>
|
D]<5D>
\}}}|o,
ti
tid
|tii||<00><00>
n

||ijo<>
|ti@o
t	d<00>
<00>
n

yOti
d<00>

|ii<00>}t||i
|i|d|i|i|i<00>
Wq<57>
ttfj
og

}
ti|<00>
}|tititifjo
qqB

ti|<00>

|ido
ti<00>
qB

q<>

Xq
|o4
|i
i|d<00>}|o
|i||<00>
q<>

q
tid<00>

qWti<00>}	|	|i t!jo
|i"<00>
|	|_ n

dS(Nsfd %d %ssserver_socket errortacceptiRHspoll removed fd(#R:R<>R<>R<>R$tEVENT_NAMESR<53>R<>R&RtR;R<>R
RR<>R
RRRKRLRMRNRORPRQRRRSRTRR<>R<>R<>R<>R<>R<>(
R)teventsRXR<>RFtconnR\R]R<>R<>((s%/home/wwwroot/shadowsocks/tcprelay.pyR<79>js>



























c

Cst|_
|ii<00>
dS(
N(R>R<>R<>R<>(
R)((s%/home/wwwroot/shadowsocks/tcprelay.pyR<79><00>s
	
(R<>R<>R1R<>R<>RUR<>R<R<>R<>R<>(((s%/home/wwwroot/shadowsocks/tcprelay.pyR<79><00>
s
	+						"	%(#R<>R RNRpR:RSR8RR$R<>tcommonRR<>R<>RdRstCMD_BINDRkR
R<>RrRvR<>RfR<>R?R=RRR@ReR<>tobjectR
R<>(((s%/home/wwwroot/shadowsocks/tcprelay.pyt<module>sB
























<16><00>