"Ic@sddkZddklZddkZddkZddkZddkZddkZddkZddk Z ddk Z ddk Z ddk Z ddk Z ddklZddkZeiZdZdeifdYZdeifdYZd fd YZd eefd YZd eefdYZdefdYZdeiefdYZdeifdYZdefdYZdefdYZdefdYZdefdYZdefdYZ defd YZ!d!e!fd"YZ"d#e!fd$YZ#d%e!fd&YZ$d'e%fd(YZ&d)e&efd*YZ'd+eifd,YZ(d-eefd.YZ)d/eefd0YZ*d1eifd2YZ+d3efd4YZ,d5efd6YZ-d7eifd8YZ.d9eifd:YZ/d;efd<YZ0d=Z1d>Z2d?Z3d@Z4dAeifdBYZ5dCeiefdDYZ6dEZ7e8dFjo e7ndS(GiN(t test_support(tproxysMichael Gilfix was here t SocketTCPTestcBseZdZdZRS(cCsDtititi|_ti|i|_|iiddS(Ni(tsockettAF_INETt SOCK_STREAMtservRt bind_porttporttlisten(tself((s-/mit/python/lib/python2.6/test/test_socket.pytsetUpscCs|iid|_dS(N(RtclosetNone(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttearDowns (t__name__t __module__R R(((s-/mit/python/lib/python2.6/test/test_socket.pyRs t SocketUDPTestcBseZdZdZRS(cCs4tititi|_ti|i|_dS(N(RRt SOCK_DGRAMRRRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR #scCs|iid|_dS(N(RR R (R ((s-/mit/python/lib/python2.6/test/test_socket.pyR's (RRR R(((s-/mit/python/lib/python2.6/test/test_socket.pyR!s tThreadableTestcBsMeZdZdZdZdZdZdZdZdZ 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 serverExplicitReady() 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(R t_ThreadableTest__setUpRt_ThreadableTest__tearDownt_setUpt _tearDown(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt__init__Qs   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(t server_readytset(R ((s-/mit/python/lib/python2.6/test/test_socket.pytserverExplicitReadyXscCsti|_ti|_ti|_tid|_|i}|id}||d}t |d|}t i |i |f|_ |i|iip|iin|iidS(Nit.t_(t threadingtEventRt client_readytdonetQueuetqueuetidtrfindtgetattrtthreadtstart_new_threadt clientRunt client_threadRtis_setRtwait(R t methodnametit test_method((s-/mit/python/lib/python2.6/test/test_socket.pyR_s  cCsK|i|ii|iip |ii}|i|ndS(N(RR!R,R#temptytgettfail(R tmsg((s-/mit/python/lib/python2.6/test/test_socket.pyRrs   cCs|ii|ii|it|p tdny |Wn%tj o}|ii |nX|i dS(Ns%test_func must be a callable function( RR,R Rt clientSetUptcallablet TypeErrort ExceptionR#tputtclientTearDown(R t test_functstrerror((s-/mit/python/lib/python2.6/test/test_socket.pyR)zs      cCs tddS(Ns clientSetUp must be implemented.(tNotImplementedError(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4scCs|iitidS(N(R!RR'texit(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9s ( RRt__doc__RRRRR)R4R9(((s-/mit/python/lib/python2.6/test/test_socket.pyR+s$     tThreadedTCPSocketTestcBs&eZddZdZdZRS(trunTestcCs$ti|d|ti|dS(Nt methodName(RRR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCstititi|_dS(N(RRRtcli(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4scCs'|iid|_ti|dS(N(RBR R RR9(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9s  (RRRR4R9(((s-/mit/python/lib/python2.6/test/test_socket.pyR?s  tThreadedUDPSocketTestcBseZddZdZRS(R@cCs$ti|d|ti|dS(NRA(RRR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCstititi|_dS(N(RRRRB(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4s(RRRR4(((s-/mit/python/lib/python2.6/test/test_socket.pyRCs tSocketConnectedTestcBs8eZddZdZdZdZdZRS(R@cCsti|d|dS(NRA(R?R(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCs9ti||i|ii\}}||_dS(N(R?R RRtaccepttcli_conn(R tconntaddr((s-/mit/python/lib/python2.6/test/test_socket.pyR s  cCs'|iid|_ti|dS(N(RFR R R?R(R ((s-/mit/python/lib/python2.6/test/test_socket.pyRs  cCs6ti||iit|if|i|_dS(N(R?R4RBtconnecttHOSTRt serv_conn(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4s cCs'|iid|_ti|dS(N(RKR R R?R9(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9s  (RRRR RR4R9(((s-/mit/python/lib/python2.6/test/test_socket.pyRDs     tSocketPairTestcBs8eZddZdZdZdZdZRS(R@cCs'tii|d|ti|dS(NRA(tunittesttTestCaseRR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCsti\|_|_dS(N(Rt socketpairRRB(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR scCs|iid|_dS(N(RR R (R ((s-/mit/python/lib/python2.6/test/test_socket.pyRs cCsdS(N((R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4scCs'|iid|_ti|dS(N(RBR R RR9(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9s  (RRRR RR4R9(((s-/mit/python/lib/python2.6/test/test_socket.pyRLs     tGeneralModuleTestscBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZRS(cCstititi}t|}|i|i|i|id}y|iWntj onX|i ddS(NsSocket proxy still exists( RRRRt assertEqualtfilenoR R tReferenceErrorR2(R tstp((s-/mit/python/lib/python2.6/test/test_socket.pyt test_weakrefs  cCsad}d}d}|iti|d|iti|d|iti|ddS(Nc_s tidS(N(Rterror(targstkwargs((s-/mit/python/lib/python2.6/test/test_socket.pyt raise_errorsc_s tidS(N(Rtherror(RXRY((s-/mit/python/lib/python2.6/test/test_socket.pyt raise_herrorsc_s tidS(N(Rtgaierror(RXRY((s-/mit/python/lib/python2.6/test/test_socket.pytraise_gaierrorssError raising socket exception.(tfailUnlessRaisesRRW(R RZR\R^((s-/mit/python/lib/python2.6/test/test_socket.pyttestSocketErrors   cCs<titititititititidS(N( RRRRtSOCK_RAWtSOCK_RDMtSOCK_SEQPACKETt SOL_SOCKETt SO_REUSEADDR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttestCrucialConstantssc Csti}yti|}Wntij odSX|i|iddjdyti|\}}}Wntij odSX||g|}ti|}||jo!|id|t |fndS(NRisError resolving host to ip.s=Error testing host resolution mechanisms. (fqdn: %s, all: %s)( Rt gethostnamet gethostbynameRWtassert_tfindt gethostbyaddrtgetfqdnR2trepr(R thostnametipthnametaliasestipaddrstall_host_namestfqhn((s-/mit/python/lib/python2.6/test/test_socket.pyttestHostnameRess  cCsxttdody#tit}titdWqttj o.tit|jo|idqpqtXndS(Nt getrefcountis$socket.getnameinfo loses a reference(thasattrtsysRvRRt getnameinfot SystemErrorR2(R torig((s-/mit/python/lib/python2.6/test/test_socket.pyttestRefCountGetNameInfoscCs1ytiddWntij onXdS(Ntxi(R}iii(RRyRW(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttestInterpreterCrash scCshdti6dti6dti6dti6}x|iD]\}}d|>d}xKdddd ddd fD].}|i||@||||@|@qqW||}|i||@||it|d q;WdS( Ni iliiiiigE#i2Tvi"il( RthtonltntohlthtonstntohstitemsRQt assertRaisest OverflowError(R tsizestfunctsizetmaskR.tswapped((s-/mit/python/lib/python2.6/test/test_socket.pyttestNtoH(s , cCsddddddg}ddd d d d g}xB|D]:}ti|ti|ti|ti|q7Wxf|D]^}|itti||itti||itti||itti|q|WdS( Niiillliiilll(RRRRRRR(R t good_valuest bad_valuestk((s-/mit/python/lib/python2.6/test/test_socket.pyttestNtoHErrors6s   c Cs.|i}tidjo d}nd}xG|D]6}yti|d }PWq0tij oq0Xq0Wtiti|}|||yti|d }Wntij o d}nX||||ti|||ti|d ||dj o|ti|d |ndS(Ntlinux2tfreebsd4tfreebsd5tfreebsd6tfreebsd7tfreebsd8tdarwintdaytimetqotdtdomaintechottcptudp(RRRRRRsdarwin(RRR(RRR(RQRxtplatformRt getservbynameRWR t getservbyport(R teqtservicestserviceRtport2tudpport((s-/mit/python/lib/python2.6/test/test_socket.pyt testGetServByDs0         cCs|itidti}|i|id|itid|itidti}|i|id|itid|itidti}|i|id|i|ittid|it tiddS(Ni itspam( RQRtgetdefaulttimeoutR t gettimeoutR tsetdefaulttimeoutRt ValueErrorR6(R RT((s-/mit/python/lib/python2.6/test/test_socket.pyttestDefaultTimeouths         cs ttdpdSddkl}llfd}|id|d|id|d|id |d |id |d |id |d|id|d|id|d|id |d |id |ddS(Nt inet_ptoni(t inet_atonRRcs |S(((ta(RR(s-/mit/python/lib/python2.6/test/test_socket.pytsts0.0.0.0ss 255.0.255.0ss170.170.170.170ss1.2.3.4ss255.255.255.255(RwRRRRt assertEquals(R tftg((RRs-/mit/python/lib/python2.6/test/test_socket.pyttestIPv4toStringsc sttdpdSy,ddklll}|pdSWntj odSXfd}|id|d|id|d|id d|d |id |d dS(NRi(RtAF_INET6thas_ipv6cs |S(((R(RR(s-/mit/python/lib/python2.6/test/test_socket.pyRstis::s0::0tis1::sEvV $s$45ef:76cb:1a:56ef:afeb:bac:1924:aeaetRt(RwRRRRt ImportErrorR(R RR((RRs-/mit/python/lib/python2.6/test/test_socket.pyttestIPv6toStrings csttdpdSddkl}llfd}|id|d|id|d|id |d |id |d |id|d|id|d|id |d dS( Nt inet_ntopi(t inet_ntoaRRcs |S(((R(RR(s-/mit/python/lib/python2.6/test/test_socket.pyRss1.0.1.0ss 170.85.170.85sUUs255.255.255.255ss1.2.3.4s(RwRRRRR(R RR((RRs-/mit/python/lib/python2.6/test/test_socket.pyttestStringToIPv4sc sttdpdSy,ddklll}|pdSWntj odSXfd}|id|d |id|d|id |d dS(NRi(RRRcs |S(((R(RR(s-/mit/python/lib/python2.6/test/test_socket.pyRss::Ris::1iss!aef:b01:506:1001:ffff:9997:55:170s UpRtt(RwRRRRRR(R RR((RRs-/mit/python/lib/python2.6/test/test_socket.pyttestStringToIPv6s cCsti}|id|i\}}|i~tititi}|id|f|i}titi}|i|dd|fjd|d|i |d|dS(Ns0.0.0.0is %s invalidi(s0.0.0.0i( Rtbindt getsocknameR RRRhRgRiRQ(R ttempsockthostRtsocktnamet my_ip_addr((s-/mit/python/lib/python2.6/test/test_socket.pyt testSockNames    (cCsJtititi}|ititi}|i|djddS(Nisinitial mode is reuse(RRRt getsockoptRdRetfailIf(R Rtreuse((s-/mit/python/lib/python2.6/test/test_socket.pyttestGetSockOptscCsctititi}|ititid|ititi}|i|djddS(Niisfailed to set reuse mode(RRRt setsockoptRdReRR(R RR((s-/mit/python/lib/python2.6/test/test_socket.pyttestSetSockOptscCsLtititi}|id|i|iti|iddS(NiR(RRRt settimeoutR RRWtsend(R R((s-/mit/python/lib/python2.6/test/test_socket.pyttestSendAfterCloses  cCsetititi}|i|iti|i|iti|i|id|idS(Ni(RRRRQtfamilyttypetprotoR (R R((s-/mit/python/lib/python2.6/test/test_socket.pyttestNewAttributess cCsttidjodS|ittid|ittd|ittd|ittddS(Ntnttioctlt SIO_RCVALLt RCVALL_ONt RCVALL_OFF(tosRRiRwR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttest_sock_ioctls (RRRVR`RfRuR|R~RRRRRRRRRRRRRR(((s-/mit/python/lib/python2.6/test/test_socket.pyRPs(      $          t BasicTCPTestcBseZddZdZdZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZRS(R@cCsti|d|dS(NRA(RDR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCs&|iid}|i|tdS(Ni(RFtrecvRQtMSG(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyttestRecv scCs|iitdS(N(RKRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testRecvscCsL|iittd}|iid}||}|i|tdS(Nii(RFRtlenRRQ(R tseg1tseg2R3((s-/mit/python/lib/python2.6/test/test_socket.pyttestOverFlowRecvs cCs|iitdS(N(RKRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testOverFlowRecvscCs,|iid\}}|i|tdS(Ni(RFtrecvfromRQR(R R3RH((s-/mit/python/lib/python2.6/test/test_socket.pyt testRecvFromscCs|iitdS(N(RKRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testRecvFrom scCsX|iittd\}}|iid\}}||}|i|tdS(Nii(RFRRRRQ(R RRHRR3((s-/mit/python/lib/python2.6/test/test_socket.pyttestOverFlowRecvFrom#s" cCs|iitdS(N(RKRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testOverFlowRecvFrom*scCsLd}x+|iid}|pPn||7}q |i|dddS(NtiRi(RFRRQ(R R3tread((s-/mit/python/lib/python2.6/test/test_socket.pyt testSendAll-s cCsdd}|ii|dS(NRi(RKtsendall(R t big_chunk((s-/mit/python/lib/python2.6/test/test_socket.pyt _testSendAll7s cCsbttdpdS|ii}ti|titi}|id}|i|t dS(Ntfromfdi( RwRRFRRRRRRRQR(R tfdRR3((s-/mit/python/lib/python2.6/test/test_socket.pyt testFromFd;s cCs|iitdS(N(RKRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testFromFdDscCs&|iid}|i|tdS(Ni(RFRRQR(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyt testShutdownGscCs$|iit|iiddS(Ni(RKRRtshutdown(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testShutdownLs(RRRRRRRRRRRRRRRRR(((s-/mit/python/lib/python2.6/test/test_socket.pyRs            t BasicUDPTestcBsJeZddZdZdZdZdZdZdZRS(R@cCsti|d|dS(NRA(RCR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRRscCs,|iitt}|i|tdS(N(RRRRRQ(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyttestSendtoAndRecvUscCs#|iitdt|ifdS(Ni(RBtsendtoRRJR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testSendtoAndRecvZscCs2|iitt\}}|i|tdS(N(RRRRRQ(R R3RH((s-/mit/python/lib/python2.6/test/test_socket.pyR]scCs#|iitdt|ifdS(Ni(RBRRRJR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyRbscCs|it|iiddS(Ni(RRRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttestRecvFromNegativeescCs#|iitdt|ifdS(Ni(RBRRRJR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testRecvFromNegativeis( RRRRRRRRR(((s-/mit/python/lib/python2.6/test/test_socket.pyRPs      t TCPCloserTestcBseZdZdZRS(cCs||ii\}}|i|i}ti|gggd\}}}|i||g|i|idddS(Ng?iR(RRER RBtselectRQR(R RGRHtsdRtwriteterr((s-/mit/python/lib/python2.6/test/test_socket.pyt testClosens   $cCs*|iit|iftiddS(Ng?(RBRIRJRttimetsleep(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testClosews(RRRR (((s-/mit/python/lib/python2.6/test/test_socket.pyRls tBasicSocketPairTestcBs8eZddZdZdZdZdZRS(R@cCsti|d|dS(NRA(RLR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyR}scCs&|iid}|i|tdS(Ni(RRRQR(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyRscCs|iitdS(N(RBRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyRscCs|iitdS(N(RRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttestSendscCs&|iid}|i|tdS(Ni(RBRRQR(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyt _testSends(RRRRRR R (((s-/mit/python/lib/python2.6/test/test_socket.pyR {s     tNonBlockingTCPTestscBs\eZddZdZdZdZdZdZdZdZ d Z RS( R@cCsti|d|dS(NRA(R?R(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCsp|iidti}y|iiWntij onXti}|i||djddS(Nig?s Error setting non-blocking mode.(Rt setblockingRRERRWRi(R tstarttend((s-/mit/python/lib/python2.6/test/test_socket.pyttestSetBlockings  cCsdS(N((R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testSetBlockingscCs|iidy|ii\}}Wntij onX|idti|iggg\}}}|i|jo|ii\}}n|iddS(Nis'Error trying to do non-blocking accept.s'Error trying to do accept after select.(RRRERRWR2R(R RGRHRRR((s-/mit/python/lib/python2.6/test/test_socket.pyt testAccepts $cCs*tid|iit|ifdS(Ng?(RRRBRIRJR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testAccepts cCs|ii\}}dS(N(RRE(R RGRH((s-/mit/python/lib/python2.6/test/test_socket.pyt testConnectscCs-|iid|iit|ifdS(Ni (RBRRIRJR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testConnectscCs|ii\}}|idy|itt}Wntij onX|idt i |ggg\}}}||jo)|itt}|i |tn|iddS(Nis%Error trying to do non-blocking recv.s0Error during select call to non-blocking socket.( RRERRRRRRWR2RRQ(R RGRHR3RRR((s-/mit/python/lib/python2.6/test/test_socket.pyRs  ! cCs:|iit|iftid|iitdS(Ng?(RBRIRJRRRRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyRs ( RRRRRRRRRRR(((s-/mit/python/lib/python2.6/test/test_socket.pyR s       tFileObjectClassTestCasecBseZdZddZdZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZRS(iR@cCsti|d|dS(NRA(RDR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCs,ti||iid|i|_dS(Ntrb(RDR RFtmakefiletbufsizet serv_file(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR s cCs:|ii|i|iid|_ti|dS(N(RR RitclosedR RDR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyRs  cCs&ti||iid|_dS(Ntwb(RDR4RKRtcli_file(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4s cCs:|ii|i|iid|_ti|dS(N(RR RiRR RDR9(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9s  cCsL|iittd}|iid}||}|i|tdS(Ni(RRRRRQ(R t first_segt second_segR3((s-/mit/python/lib/python2.6/test/test_socket.pyt testSmallReads cCs!|iit|iidS(N(RRRtflush(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testSmallReadscCs#|ii}|i|tdS(N(RRRQR(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyt testFullReadscCs!|iit|iidS(N(RRRR (R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testFullReadscCsHd}x+|iid}|pPn||7}q |i|tdS(NRi(RRRQR(R tbuftchar((s-/mit/python/lib/python2.6/test/test_socket.pyttestUnbufferedReads cCs!|iit|iidS(N(RRRR"(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testUnbufferedRead scCs#|ii}|i|tdS(N(RtreadlineRQR(R tline((s-/mit/python/lib/python2.6/test/test_socket.pyt testReadlinescCs!|iit|iidS(N(RRRR"(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testReadlinescCs|iitd}|id||iitd}|id||ii}|id||ii}|id||ii}|it|dS(Ns A baloo iss a bears sA BALOO IS A BEAR. (RRRRQR*R(R t a_baloo_ist_a_bearR+((s-/mit/python/lib/python2.6/test/test_socket.pyttestReadlineAfterReadscCsA|iid|iid|iit|iidS(NsA baloo is a bear sA BALOO IS A BEAR. (RRRR"(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testReadlineAfterRead$scCsK|iitd}|id||ii}|id|dS(NsEnd Of tLine(RRRRQR*(R tend_of_R+((s-/mit/python/lib/python2.6/test/test_socket.pyttestReadlineAfterReadNoNewline*scCs|iiddS(Ns End Of Line(RR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testReadlineAfterReadNoNewline0scCs|i|ii dS(N(RiRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttestClosedAttr3scCs|i|ii dS(N(RiRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testClosedAttr6s(RRRRR RR4R9R!R#R$R%R(R)R,R-R0R1R4R5R6R7(((s-/mit/python/lib/python2.6/test/test_socket.pyRs(                t!UnbufferedFileObjectClassTestCasecBs&eZdZdZdZdZRS(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. (RR*RQRRFR(R R+((s-/mit/python/lib/python2.6/test/test_socket.pyttestUnbufferedReadlineEs cCs9|iidt|iidt|iidS(NsA. sB. (RRRR"(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testUnbufferedReadlineMs(RRR>RR9R:(((s-/mit/python/lib/python2.6/test/test_socket.pyR89s t#LineBufferedFileObjectClassTestCasecBseZdZRS(i(RRR(((s-/mit/python/lib/python2.6/test/test_socket.pyR;Rst$SmallBufferedFileObjectClassTestCasecBseZdZRS(i(RRR(((s-/mit/python/lib/python2.6/test/test_socket.pyR<WstNetworkConnectionTestcBseZdZdZRS(sProve network connection.cCs+tit|if|_|i|_dS(N(Rtcreate_connectionRJRRBRK(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4^s(RRR>R4(((s-/mit/python/lib/python2.6/test/test_socket.pyR=\st BasicTCPTest2cBseZdZRS(sLTests that NetworkConnection does not break existing TCP functionality. (RRR>(((s-/mit/python/lib/python2.6/test/test_socket.pyR?dstNetworkConnectionNoServercBseZdZRS(cs,ti|itifddS(NcstitfS((RR>RJ((R(s-/mit/python/lib/python2.6/test/test_socket.pyRms(Rtfind_unused_portR_RRW(R ((Rs-/mit/python/lib/python2.6/test/test_socket.pyttestWithoutServeris (RRRB(((s-/mit/python/lib/python2.6/test/test_socket.pyR@hstNetworkConnectionAttributesTestcBszeZddZdZdZdZeZdZeZdZ eZ dZ eZ dZ eZd ZRS( R@cCs$ti|d|ti|dS(NRA(RRR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRrscCsdS(N((R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4vscCs'|iid|_ti|dS(N(RBR R RR9(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9ys  cCs|ii\}}dS(N(RRE(R RGRH((s-/mit/python/lib/python2.6/test/test_socket.pyt _justAccept~scCs;tit|ifdd|_|i|iiddS(Nttimeoutii(RR>RJRRBRQR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testFamilys!cCss|itidjtidztit|if|_WdtidX|i |ii ddS(Ni*( RiRRR RR>RJRRBRR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testTimeoutDefaults  cCsy|itidjtidz%tit|ifdd|_WdtidX|i |ii ddS(NiRE( RiRRR RR>RJRRBRQR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testTimeoutNones  %cCs>tit|ifdd|_|i|iiddS(NREi(RR>RJRRBRQR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testTimeoutValueNameds!cCs;tit|ifd|_|i|iiddS(Ni(RR>RJRRBRQR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyt_testTimeoutValueNonameds(RRRR4R9RDt testFamilyRFttestTimeoutDefaultRGttestTimeoutNoneRHttestTimeoutValueNamedRIttestTimeoutValueNonamedRJ(((s-/mit/python/lib/python2.6/test/test_socket.pyRCps        tNetworkConnectionBehaviourTestcBsGeZddZdZdZdZeZdZdZRS(R@cCs$ti|d|ti|dS(NRA(RRR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCsdS(N((R ((s-/mit/python/lib/python2.6/test/test_socket.pyR4scCs'|iid|_ti|dS(N(RBR R RR9(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR9s  cCs3|ii\}}tid|iddS(Nisdone!(RRERRR(R RGRH((s-/mit/python/lib/python2.6/test/test_socket.pyttestInsideTimeouts cCsBtit|if|_}|id}|i|ddS(Nisdone!(RR>RJRRBRRQ(R Rtdata((s-/mit/python/lib/python2.6/test/test_socket.pyt_testInsideTimeoutscsEtit|ifdd|_|itifddS(NREics idS(i(R((R(s-/mit/python/lib/python2.6/test/test_socket.pyRs(RR>RJRRBR_RE(R ((Rs-/mit/python/lib/python2.6/test/test_socket.pyt_testOutsideTimeouts%( RRRR4R9RQttestOutsideTimeoutRSRT(((s-/mit/python/lib/python2.6/test/test_socket.pyRPs     tUrllib2FileobjectTestcBseZdZRS(cCsdddY}|}ti|}|i|i|i |}ti|dt}|i|i|idS(Nt MockSocketcBs eZeZdZdZRS(cSsdS(N((R ((s-/mit/python/lib/python2.6/test/test_socket.pyR"scSs t|_dS(N(tTrueR(R ((s-/mit/python/lib/python2.6/test/test_socket.pyR s(RRtFalseRR"R (((s-/mit/python/lib/python2.6/test/test_socket.pyRWs R ((Rt _fileobjectR RiRRX(R RWRTR((s-/mit/python/lib/python2.6/test/test_socket.pyRs    (RRR(((s-/mit/python/lib/python2.6/test/test_socket.pyRVstTCPTimeoutTestcBs#eZdZdZdZRS(cs)fd}iti|ddS(Ncs!iidiidS(Ng?(RRRE(RXRY(R (s-/mit/python/lib/python2.6/test/test_socket.pyt raise_timeoutss*Error generating a timeout exception (TCP)(R_RRE(R R\((R s-/mit/python/lib/python2.6/test/test_socket.pyttestTCPTimeoutscCst}y#|iid|ii}WnQtij o|idn0tij o t}n|idnX|p|idndS(Ngs%caught timeout instead of error (TCP)s!caught unexpected exception (TCP)s3accept() returned success when we did not expect it( RYRRRERRER2RWRX(R toktfoo((s-/mit/python/lib/python2.6/test/test_socket.pyttestTimeoutZeros csMttdpdS|iiddtfdYfd}titi|}zytidzy|ii}Wncti j o|i dnOj on=|i dt i d t ifnX|i d Wdtid XWn j o|i d nXWdtiti|XdS( Ntalarmg@tAlarmcBseZRS((RR(((s-/mit/python/lib/python2.6/test/test_socket.pyRbscs dS(N((tsignaltframe(Rb(s-/mit/python/lib/python2.6/test/test_socket.pyt alarm_handlersiscaught timeout instead of Alarms3caught other exception instead of Alarm: %s(%s): %ssnothing caughtisgot Alarm in wrong place(RwRcRRR7tSIGALRMRaRERRER2Rxtexc_infot tracebackt format_exc(R Ret old_alarmR_((Rbs-/mit/python/lib/python2.6/test/test_socket.pyttestInterruptedTimeouts0  #(RRR]R`Rk(((s-/mit/python/lib/python2.6/test/test_socket.pyR[s  tUDPTimeoutTestcBseZdZdZRS(cs)fd}iti|ddS(Ncs$iidiiddS(Ng?i(RRR(RXRY(R (s-/mit/python/lib/python2.6/test/test_socket.pyR\ss*Error generating a timeout exception (UDP)(R_RRE(R R\((R s-/mit/python/lib/python2.6/test/test_socket.pyttestUDPTimeoutscCst}y&|iid|iid}WnQtij o|idn0tij o t}n|idnX|p|idndS(Ngis%caught timeout instead of error (UDP)s!caught unexpected exception (UDP)s1recv() returned success when we did not expect it( RYRRRRRER2RWRX(R R^R_((s-/mit/python/lib/python2.6/test/test_socket.pyR`s (RRRmR`(((s-/mit/python/lib/python2.6/test/test_socket.pyRls tTestExceptionscBseZdZRS(cCsq|ittit|ittiti|ittiti|ittitidS(N(Rit issubclassRRWR7R[R]RE(R ((s-/mit/python/lib/python2.6/test/test_socket.pyttestExceptionTree.s(RRRp(((s-/mit/python/lib/python2.6/test/test_socket.pyRn,stTestLinuxAbstractNamespacecBs)eZdZdZdZdZRS(ilcCsd}tititi}|i||idtititi}|i|i|i|i|i||i|i |dS(Ntpython-test-helloi( RtAF_UNIXRRR RIRRERQt getpeername(R taddressts1ts2((s-/mit/python/lib/python2.6/test/test_socket.pyttestLinuxAbstractNamespace8s   cCsTdd|id}tititi}|i||i|i|dS(NRthi(t UNIX_PATH_MAXRRsRRRQR(R RuRT((s-/mit/python/lib/python2.6/test/test_socket.pyt testMaxNameCs cCsFdd|i}tititi}|iti|i|dS(NRRy(RzRRsRRRWR(R RuRT((s-/mit/python/lib/python2.6/test/test_socket.pyttestNameOverflowIs(RRRzRxR{R|(((s-/mit/python/lib/python2.6/test/test_socket.pyRq4s t BufferIOTestcBs>eZdZddZdZdZdZdZRS(sF Test the buffer versions of socket.recv() and socket.send(). R@cCsti|d|dS(NRA(RDR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRSscCshtiddd}|ii|}|i|tt|itt }|i|tdS(Ntct i(tarrayRFt recv_intoRQRRttostring(R R&tnbytesR3((s-/mit/python/lib/python2.6/test/test_socket.pyt testRecvIntoVs cCs tt}|ii|dS(N(tbufferRRKR(R R&((s-/mit/python/lib/python2.6/test/test_socket.pyt _testRecvInto]s cCsntiddd}|ii|\}}|i|tt|itt }|i|tdS(NR~Ri(RRFt recvfrom_intoRQRRR(R R&RRHR3((s-/mit/python/lib/python2.6/test/test_socket.pyttestRecvFromIntoas cCs tt}|ii|dS(N(RRRKR(R R&((s-/mit/python/lib/python2.6/test/test_socket.pyt_testRecvFromIntohs (RRR>RRRRR(((s-/mit/python/lib/python2.6/test/test_socket.pyR}Os     iiicCsttdptStiidptStdii}z3|~}x#|D]}|i dot SqWWWdQXt i o dGHntS(sCheck if the TIPC module is loaded The TIPC module is not loaded automatically on Ubuntu and probably other Linux distros. tAF_TIPCs /proc/modulesstipc Ns6TIPC module is not loaded, please 'sudo modprobe tipc'( RwRRYRtpathtisfiletopent__exit__t __enter__t startswithRXRtverbose(t_[1]RR+((s-/mit/python/lib/python2.6/test/test_socket.pytisTipcAvailableqs#  tTIPCTestcBseZdZRS(cCstititi}tititi}|ititidtittt f}|i |ti ttt tddf}|i t ||id\}}|i|i||i|t dS(Niiii(RRRbRRdRetTIPC_ADDR_NAMESEQt TIPC_STYPEt TIPC_LOWERt TIPC_UPPERRtTIPC_ADDR_NAMERRRRQR(R tsrvRBtsrvaddrtsendaddrR3trecvaddr((s-/mit/python/lib/python2.6/test/test_socket.pyttestRDMs    (RRR(((s-/mit/python/lib/python2.6/test/test_socket.pyRstTIPCThreadableTestcBs8eZddZdZdZdZdZRS(R@cCs'tii|d|ti|dS(NRA(RMRNRR(R RA((s-/mit/python/lib/python2.6/test/test_socket.pyRscCstititi|_|iititidtitt t f}|ii ||ii d|i |ii\|_|_dS(Nii(RRRRRRdReRRRRRR RRERGtconnaddr(R R((s-/mit/python/lib/python2.6/test/test_socket.pyR s   cCsotidtititi|_tittt tddf}|ii ||ii |_ dS(Ng?ii( RRRRRRBRRRRRIRtcliaddr(R RH((s-/mit/python/lib/python2.6/test/test_socket.pyR4s   cCs<|iid}|i|t|i|i|idS(Ni(RGRRQRRR(R R3((s-/mit/python/lib/python2.6/test/test_socket.pyt testStreamscCs!|iit|iidS(N(RBRRR (R ((s-/mit/python/lib/python2.6/test/test_socket.pyt _testStreams(RRRR R4RR(((s-/mit/python/lib/python2.6/test/test_socket.pyRs   c Cstttttttg}tidjo|i t t gn|i t t tttttttg ttdo|itntidjo|itnto|it|itnti}ti|ti |dS(NtmacROR(!RPRRR[RnR}R?RxRtextendRRlR RR8R;R<RVR@RCRPRwRtappendR RqRRRRtthreading_setupt run_unittesttthreading_cleanup(ttestst thread_info((s-/mit/python/lib/python2.6/test/test_socket.pyt test_mains0      t__main__(9RMttestRterrnoRRR'RRRhR"RxRRtweakrefRRcRJRRNRRRR?RCRDRLRPRRRR R RR8R;R<tobjectR=R?R@RCRPRVR[RlRnRqR}RRRRRRRR(((s-/mit/python/lib/python2.6/test/test_socket.pytsj              b ,LDg69 $