KGRKJGETMRETU895U-589TY5MIGM5JGB5SDFESFREWTGR54TY
Server : Apache/2.2.17 (Unix) mod_ssl/2.2.17 OpenSSL/0.9.8e-fips-rhel5 DAV/2 PHP/5.2.17
System : Linux localhost 2.6.18-419.el5 #1 SMP Fri Feb 24 22:47:42 UTC 2017 x86_64
User : nobody ( 99)
PHP Version : 5.2.17
Disable Function : NONE
Directory :  /proc/22697/root/usr/lib64/python2.4/test/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //proc/22697/root/usr/lib64/python2.4/test/test_socket.pyo
m
=5Dc@sPdkZdklZdkZdkZdkZdkZdkZdkZdk	Z	dk
lZdZdZ
dZdeifdYZdeifd	YZd
fdYZdeefd
YZdeefdYZdefdYZdeiefdYZdeifdYZdefdYZdefdYZdefdYZdefdYZdefdYZd efd!YZd"efd#YZd$efd%YZd&efd'YZ d(efd)YZ!d*eifd+YZ"d,Z#e$d-joe#ndS(.N(stest_support(sproxyiWt	localhostsMichael Gilfix was here
t
SocketTCPTestcBstZdZdZRS(NcCsatititi|_|iititid|iit	t
f|iiddS(Ni(tsockettAF_INETtSOCK_STREAMtselftservt
setsockoptt
SOL_SOCKETtSO_REUSEADDRtbindtHOSTtPORTtlisten(R((t(/usr/lib64/python2.4/test/test_socket.pytsetUpscCs|iid|_dS(N(RRtclosetNone(R((RttearDowns
(t__name__t
__module__RR(((RRs	t
SocketUDPTestcBstZdZdZRS(NcCsQtititi|_|iititid|iit	t
fdS(Ni(RRt
SOCK_DGRAMRRRRR	R
RR(R((RR scCs|iid|_dS(N(RRRR(R((RR%s
(RRRR(((RRs	tThreadableTestcBsMtZdZdZdZdZdZdZdZdZ	RS(sThreadable Test class

    The ThreadableTest class makes it easy to create a threaded
    client/server pair from an existing unit test. To create a
    new threaded class from an existing unit test, use multiple
    inheritance:

        class NewClass (OldClass, ThreadableTest):
            pass

    This class defines two new fixture functions with obvious
    purposes for overriding:

        clientSetUp ()
        clientTearDown ()

    Any new test functions within the class must then define
    tests in pairs, where the test name is preceeded with a
    '_' to indicate the client portion of the test. Ex:

        def testFoo(self):
            # Server portion

        def _testFoo(self):
            # Client portion

    Any exceptions raised by the clients during their tests
    are caught and transferred to the main thread to alert
    the testing framework.

    Note, the server setup function cannot call any blocking
    functions that rely on the client thread during setup,
    unless serverExplicityReady() is called just before
    the blocking call (such as in setting up a client/server
    connection and performing the accept() in setUp().
    cCs4|i|_|i|_|i|_|i|_dS(N(RRt_ThreadableTest__setUpRt_ThreadableTest__tearDownt_setUpt	_tearDown(R((Rt__init__OscCs|iidS(sThis method allows the server to explicitly indicate that
        it wants the client thread to proceed. This is useful if the
        server is about to execute a blocking routine that is
        dependent upon the client thread during its setup routine.N(Rtserver_readytset(R((RtserverExplicitReadyVscCsti|_ti|_ti|_tid|_|i}|i
d}||d}t|d|}ti|i|f|_|i|iip|iin|iidS(Nit.t_(t	threadingtEventRRtclient_readytdonetQueuetqueuetidt
methodnametrfindtitgetattrttest_methodtthreadtstart_new_threadt	clientRunt
client_threadRtisSetRtwait(RR)R+R-((RR]s
cCsK|i|ii|iip |ii}|i|ndS(N(	RRR%R3R'temptytgettmsgtfail(RR6((RRps


cCs|ii|ii|it|p
tdny|Wn%t	j
o}|ii|nX|i
dS(Ns%test_func must be a callable function(RRR3R$RtclientSetUptcallablet	test_funct	TypeErrort	ExceptiontstrerrorR'tputtclientTearDown(RR:R=((RR0xs




cCs
tddS(Ns clientSetUp must be implemented.(tNotImplementedError(R((RR8scCs|iitidS(N(RR%RR.texit(R((RR?s
(
RRt__doc__RRRRR0R8R?(((RR)s$						tThreadedTCPSocketTestcBs&tZddZdZdZRS(NtrunTestcCs$ti|d|ti|dS(Nt
methodName(RRRRER(RRE((RRscCstititi|_dS(N(RRRRtcli(R((RR8scCs'|iid|_ti|dS(N(RRFRRRR?(R((RR?s
	(RRRR8R?(((RRCs	tThreadedUDPSocketTestcBstZddZdZRS(NRDcCs$ti|d|ti|dS(NRE(RRRRER(RRE((RRscCstititi|_dS(N(RRRRRF(R((RR8s(RRRR8(((RRGstSocketConnectedTestcBs8tZddZdZdZdZdZRS(NRDcCsti|d|dS(NRE(RCRRRE(RRE((RRscCs9ti||i|ii\}}||_dS(N(	RCRRRRtaccepttconntaddrtcli_conn(RRJRK((RRs

cCs'|iid|_ti|dS(N(RRLRRRCR(R((RRs
	cCs3ti||iittf|i|_dS(N(RCR8RRFtconnectRRt	serv_conn(R((RR8s
cCs'|iid|_ti|dS(N(RRNRRRCR?(R((RR?s
	(RRRRRR8R?(((RRHs
			tSocketPairTestcBs8tZddZdZdZdZdZRS(NRDcCs'tii|d|ti|dS(NRE(tunittesttTestCaseRRRER(RRE((RRscCsti\|_|_dS(N(Rt
socketpairRRRF(R((RRscCs|iid|_dS(N(RRRR(R((RRs
cCsdS(N((R((RR8scCs'|iid|_ti|dS(N(RRFRRRR?(R((RR?s
	(RRRRRR8R?(((RROs
			tGeneralModuleTestscBstZdZdZdZdZdZdZdZdZ	d	Z
d
ZdZdZ
d
ZdZdZdZdZRS(NcCstititi}t|}|i|i|i|i	d}y|iWntj
onX|iddS(NsSocket proxy still exists(
RRRtstproxytpRtassertEqualtfilenoRRtReferenceErrorR7(RRVRT((Rttest_weakrefs
cCsad}d}d}|iti|d|iti|d|iti|ddS(NcOs
tidS(N(Rterror(targstkwargs((Rtraise_errorscOs
tidS(N(Rtherror(R\R]((Rtraise_herrorscOs
tidS(N(Rtgaierror(R\R]((Rtraise_gaierrorssError raising socket exception.(R^R`RbRtfailUnlessRaisesRR[(RR^R`Rb((RttestSocketErrors			cCs<titititititititidS(N(	RRRRtSOCK_RAWtSOCK_RDMtSOCK_SEQPACKETRR	(R((RttestCrucialConstantsscCsti}yti|}Wntij
odSnX|i|iddjdyti	|\}}}Wntij
odSnX||g|}ti}||jo|idndS(NR isError resolving host to ip.s)Error testing host resolution mechanisms.(Rtgethostnamethostnamet
gethostbynametipR[Rtassert_tfindt
gethostbyaddrthnametaliasestipaddrstall_host_namestgetfqdntfqhnR7(RRlRjRpRsRuRrRq((RttestHostnameRess		
cCsdk}t|dody#|it}titdWq}tj
o.|it|jo|i	dqyq}XndS(Ntgetrefcountis$socket.getnameinfo loses a reference(
tsysthasattrRwRtorigRtgetnameinfotSystemErrorRR7(RRxRz((RttestRefCountGetNameInfos	cCs1ytiddWntij
onXdS(Ntxi(R~iii(RR{R[(R((RttestInterpreterCrashscCshtid<tid<tid<tid<}x|iD]\}}d|>d}x6dD].}|i||@||||@|@qdW||}|i||@||it|dd>qCWdS(
Ni iliiiiiigE#i2Tvi"(iiiiiigE#i2Tv(RthtonltntohlthtonstntohstsizestitemstfunctsizetmaskR+RRWtswappedtassertRaisest
OverflowError(RRR+RRRR((RttestNtoH's6
,cCs.|i}tidjo
d
}nd}xG|D]6}yti|d
}PWq0ti
j
oq0Xq0Wti
ti|}|||yti|d}Wnti
j
o
d}nX||||ti|||ti|d
||dj	o|ti|d|ndS(Ntlinux2tfreebsd4tfreebsd5tfreebsd6tdarwintdaytimetqotdtdomaintechottcptudp(RRRRsdarwin(RRR(RRR(RRWteqRxtplatformtservicestserviceRt
getservbynametportR[tport2tudpportRt
getservbyport(RRRRRRR((Rt
testGetServBy5s.	
		


cCs|itidti}|i|id|itid|itidti}|i|id|itid|itidti}|i|id|i|i	t
tid|i	ttiddS(Ni
itspam(RRWRtgetdefaulttimeoutRRTt
gettimeoutRtsetdefaulttimeoutRt
ValueErrorR;(RRT((RttestDefaultTimeoutYs 




cs
ttdpdSndkl}lld}|id|d|id|d|id|d	|id
|d|id|d
|id|d|id|d|id|d	|id|d
dS(Nt	inet_pton(s	inet_atons	inet_ptonsAF_INETcs
|S(N(RRta(R(RR(Rt<lambda>ysts0.0.0.0ss255.0.255.0ss170.170.170.170ss1.2.3.4ss255.255.255.255(	RyRt	inet_atontfRRtgRtassertEquals(RRRRR((RRRttestIPv4toStringuscsttdpdSny,dklll}|pdSnWntj
odSnXd}|idd|d|idd|d|iddd	|d
|id|ddS(
NR(s	inet_ptonsAF_INET6shas_ipv6cs
|S(N(RtAF_INET6R(R(RR(RRstis::s0::0tis1::sEvV$s$45ef:76cb:1a:56ef:afeb:bac:1924:aeae(	RyRRRthas_ipv6tImportErrorRRR(RRRRR((RRRttestIPv6toStrings		csttdpdSndkl}lld}|id|d|id|d|id|d	|id
|d|id|d|id|d|id|d	dS(Nt	inet_ntop(s	inet_ntoas	inet_ntopsAF_INETcs
|S(N(RRR(R(RR(RRss1.0.1.0ss
170.85.170.85sUUs255.255.255.255ss1.2.3.4s(	RyRt	inet_ntoaRRRRRR(RRRRR((RRRttestStringToIPv4scsttdpdSny,dklll}|pdSnWntj
odSnXd}|id|dd|id|ddd	|id
|ddS(NR(s	inet_ntopsAF_INET6shas_ipv6cs
|S(N(RRR(R(RR(RRss::Ris::1iss!aef:b01:506:1001:ffff:9997:55:170s
Up(	RyRRRRRRRR(RRRRR((RRRttestStringToIPv6s		cCsYtititi}|idtdf|i}|i	|dtdfdS(Ns0.0.0.0i(
RRRtsockR
RtgetsocknametnameRRW(RRR((RttestSockNamescCsJtititi}|ititi}|i	|djddS(Nisinitial mode is reuse(
RRRRt
getsockoptRR	treuseRtfailIf(RRR((RttestGetSockOptscCsctititi}|ititid|ititi}|i
|djddS(Niisfailed to set reuse mode(RRRRRRR	RRRR(RRR((RttestSetSockOptscCsLtititi}|id|i|iti|i	ddS(NiR(
RRRRt
settimeoutRRRR[tsend(RR((RttestSendAfterCloses

(RRRZRdRhRvR}RRRRRRRRRRRR(((RRSs"	
							$								tBasicTCPTestcBstZddZdZdZdZdZdZdZd	Z	d
Z
dZdZd
Z
dZdZdZRS(NRDcCsti|d|dS(NRE(RHRRRE(RRE((RRscCs&|iid}|i|tdS(Ni(RRLtrecvR6RWtMSG(RR6((RttestRecvscCs|iitdS(N(RRNRR(R((Rt	_testRecvscCsL|iittd}|iid}||}|i|tdS(Nii(	RRLRtlenRtseg1tseg2R6RW(RRRR6((RttestOverFlowRecvs
cCs|iitdS(N(RRNRR(R((Rt_testOverFlowRecvscCs,|iid\}}|i|tdS(Ni(RRLtrecvfromR6RKRWR(RR6RK((RttestRecvFromscCs|iitdS(N(RRNRR(R((Rt
_testRecvFromscCsX|iittd\}}|iid\}}||}|i	|tdS(Nii(
RRLRRRRRKRR6RW(RRKRRR6((RttestOverFlowRecvFroms"
cCs|iitdS(N(RRNRR(R((Rt_testOverFlowRecvFromscCsNd}x-|iid}|pPn||7}q	W|i|dddS(NtiiRi(R6RRLRtreadRW(RR6R((RttestSendAllscCsdd}|ii|dS(NRi(t	big_chunkRRNtsendall(RR((Rt_testSendAlls
cCsettdpdSn|ii}ti|titi}|i
d}|i|t
dS(Ntfromfdi(RyRRRLRXtfdRRRRRR6RWR(RRRR6((Rt
testFromFdscCs|iitdS(N(RRNRR(R((Rt_testFromFdscCs&|iid}|i|tdS(Ni(RRLRR6RWR(RR6((RttestShutdownscCs$|iit|iiddS(Ni(RRNRRtshutdown(R((Rt
_testShutdown s(RRRRRRRRRRRRRRRRR(((RRs									
					tBasicUDPTestcBs8tZddZdZdZdZdZRS(NRDcCsti|d|dS(NRE(RGRRRE(RRE((RR&scCs,|iitt}|i|tdS(N(RRRRRR6RW(RR6((RttestSendtoAndRecv)scCs |iitdttfdS(Ni(RRFtsendtoRRR(R((Rt_testSendtoAndRecv.scCs2|iitt\}}|i|tdS(N(RRRRRR6RKRW(RR6RK((RR1scCs |iitdttfdS(Ni(RRFRRRR(R((RR6s(RRRRRRR(((RR$s
			tBasicSocketPairTestcBs8tZddZdZdZdZdZRS(NRDcCsti|d|dS(NRE(RORRRE(RRE((RR;scCs&|iid}|i|tdS(Ni(RRRR6RWR(RR6((RR>scCs|iitdS(N(RRFRR(R((RRBscCs|iitdS(N(RRRR(R((RttestSendEscCs&|iid}|i|tdS(Ni(RRFRR6RWR(RR6((Rt	_testSendHs(RRRRRRR(((RR9s
			tNonBlockingTCPTestscBs\tZddZdZdZdZdZdZdZd	Z	d
Z
RS(NRDcCsti|d|dS(NRE(RCRRRE(RRE((RRNscCsp|iidti}y|iiWntij
onXti}|i	||djddS(Nif1.0s Error setting non-blocking mode.(
RRtsetblockingttimetstartRIRR[tendRm(RRR((RttestSetBlockingQscCsdS(N((R((Rt_testSetBlocking\scCs|iidy|ii\}}Wntij
onX|idt	i	|iggg\}}}|i|jo|ii\}}n|iddS(Nis'Error trying to do non-blocking accept.s'Error trying to do accept after select.(
RRRRIRJRKRR[R7tselectRtwriteterr(RRKRRRRJ((Rt
testAccept_s
$cCs'tid|iittfdS(Nf0.10000000000000001(RtsleepRRFRMRR(R((Rt_testAcceptns
cCs|ii\}}dS(N(RRRIRJRK(RRKRJ((RttestConnectrscCs*|iid|iittfdS(Ni
(RRFRRMRR(R((Rt_testConnectvscCs|ii\}}|idy|itt}Wnt
ij
onX|idt
i
|ggg\}}}||jo)|itt}|i|tn|iddS(Nis%Error trying to do non-blocking recv.s0Error during select call to non-blocking socket.(RRRIRJRKRRRRR6RR[R7RRRRRW(RRKRRRR6RJ((RRzs

!
cCs7|iittftid|iitdS(Nf0.10000000000000001(	RRFRMRRRRRR(R((RRs
(RRRRRRRRRRR(((RRLs							tFileObjectClassTestCasecBstZdZddZdZdZdZdZdZd	Z	d
Z
dZdZd
Z
dZdZdZdZRS(NiRDcCsti|d|dS(NRE(RHRRRE(RRE((RRscCs,ti||iid|i|_dS(Ntrb(RHRRRLtmakefiletbufsizet	serv_file(R((RRs
cCs:|ii|i|iid|_ti|dS(N(RRRRmtclosedRRHR(R((RRs
	cCs&ti||iid|_dS(Ntwb(RHR8RRNRtcli_file(R((RR8s
cCs:|ii|i|iid|_ti|dS(N(RRRRmRRRHR?(R((RR?s
	cCsL|iittd}|iid}||}|i|tdS(Ni(	RRRRRt	first_segt
second_segR6RW(RRRR6((Rt
testSmallReads
cCs!|iit|iidS(N(RRRRtflush(R((Rt_testSmallReadscCs#|ii}|i|tdS(N(RRRR6RWR(RR6((RttestFullReadscCs!|iit|iidS(N(RRRRR(R((Rt
_testFullReadscCsJd}x-|iid}|pPn||7}q	W|i|tdS(NRi(tbufRRRtcharRWR(RR	R((RttestUnbufferedReadscCs!|iit|iidS(N(RRRRR(R((Rt_testUnbufferedReadscCs#|ii}|i|tdS(N(RRtreadlinetlineRWR(RR
((RttestReadlinescCs!|iit|iidS(N(RRRRR(R((Rt
_testReadlinescCs|i|iidS(N(RRmRR(R((RttestClosedAttrscCs|i|iidS(N(RRmRR(R((Rt_testClosedAttrs(RRRRRRR8R?RRRRR
RRRRR(((RRs 									
				t!UnbufferedFileObjectClassTestCasecBs&tZdZdZdZdZRS(sRepeat the tests from FileObjectClassTestCase with bufsize==0.

    In this case (and in this case only), it should be possible to
    create a file object, read a line from it, create another file
    object, read another line from it, without loss of data in the
    first file object's buffer.  Note that httplib relies on this
    when reading multiple requests from the same socket.icCsb|ii}|i|dt|iidd|_|ii}|i|dtdS(NsA. RisB. (RRRR
RWRRLR(RR
((RttestUnbufferedReadlines
cCs9|iidt|iidt|iidS(NsA. sB. (RRRRR(R((Rt_testUnbufferedReadlines(RRRBRRR(((RRs	t#LineBufferedFileObjectClassTestCasecBstZdZRS(Ni(RRR(((RRst$SmallBufferedFileObjectClassTestCasecBstZdZRS(Ni(RRR(((RRstTCPTimeoutTestcBstZdZdZRS(Ncs&d}iti|ddS(Ncs!iidiidS(Nf1.0(RRRRI(R\R](R(Rt
raise_timeoutss*Error generating a timeout exception (TCP)(RRRcRttimeout(RR((RRttestTCPTimeoutscCst}y#|iid|ii}WnQtij
o|i	dn0ti
j
o
t}n|i	dnX|p|i	dndS(Nf0.0s%caught timeout instead of error (TCP)s!caught unexpected exception (TCP)s3accept() returned success when we did not expect it(tFalsetokRRRRItfooRRR7R[tTrue(RRR((RttestTimeoutZeros
(RRRR(((RRs	tUDPTimeoutTestcBstZdZdZRS(Ncs&d}iti|ddS(Ncs$iidiiddS(Nf1.0i(RRRR(R\R](R(RRss*Error generating a timeout exception (UDP)(RRRcRR(RR((RRttestUDPTimeoutscCst}y&|iid|iid}WnQtij
o|i	dn0ti
j
o
t}n|i	dnX|p|i	dndS(Nf0.0is%caught timeout instead of error (UDP)s!caught unexpected exception (UDP)s1recv() returned success when we did not expect it(RRRRRRRRRR7R[R(RRR((RRs
(RRR!R(((RR s	tTestExceptionscBstZdZRS(NcCsq|ittit|ittiti|ittiti|ittitidS(N(	RRmt
issubclassRR[R<R_RaR(R((RttestExceptionTree.s(RRR$(((RR",scCsttttg}tidjo|itt	gn|it
ttt
tgttdo|itnti|dS(NtmacRR(RSRRR"ttestsRxRtextendRR RRRRRRyRtappendRttest_supporttrun_unittest(R&((Rt	test_main5st__main__(%RPttestR)RRRR.R"R&RxtweakrefRURRRRQRRRRCRGRHRORSRRRRRRRRRR R"R+R(!R)RRORRRHRR RRRR"RRGR+RPRxRRURRR&RR.RRRRRRR"RCRS((Rt?sD	
					
b	LDL		


Anon7 - 2021