ó S+šNc@s¦dZddlmZddlmZmZmZddlmZm Z m Z m Z m Z m Z ddlmZdfd„ƒYZdeejfd „ƒYZd eejfd „ƒYZd efd „ƒYZdefd„ƒYZdejfd„ƒYZdejfd„ƒYZdejfd„ƒYZdejfd„ƒYZe je eƒ rsde_de_ne j e eƒ r’de_nd„Z!e!ƒdS(sG Tests for implementations of L{IReactorUDP} and L{IReactorMulticast}. iÿÿÿÿ(tunittest(tDeferredt gatherResultst maybeDeferred(tprotocoltreactorterrortdefert interfacestudp(truntimetMixincBs5eZdZdZdZd„Zd„Zd„ZRS(icCs g|_dS(N(tpackets(tself((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt__init__scCs?d|_|jdk r;|jd}|_|jdƒndS(Ni(tstartedtstartedDeferredtNonetcallback(R td((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt startProtocols cCs d|_dS(Ni(tstopped(R ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt stopProtocol sN( t__name__t __module__RRRRRRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR s   tServercBseZdZdZd„ZRS(icCsL|jj||fƒ|jdk rH|jd}|_|jdƒndS(N(R tappendtpacketReceivedRR(R tdatataddrR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytdatagramReceived)sN(RRRRtrefusedR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR$stClientcBs/eZdZdZd„Zd„Zd„ZRS(icCsF|jj|ƒ|jdk rB|jd}|_|jdƒndS(N(R RRRR(R RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR6scCs?|jdk r2|jd}|_|j|ƒn||_dS(N(RRterrbacktfailure(R R"R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytconnectionFailed<scCsH|jdk r;|jd}|_|jtjdƒƒnd|_dS(Ntyupi(RRR!RtConnectionRefusedErrorR(R R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytconnectionRefusedBsN(RRRRRRR#R&(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR 1s   t GoodClientcBseZd„ZRS(cCsH|jdk r;|jd}|_|jtjdƒƒnd|_dS(NR$i(RRR!RR%R(R R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR&Ks(RRR&(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR'IstBadClientErrorcBseZdZRS(sf Raised by BadClient at the end of every datagramReceived call to try and screw stuff up. (RRt__doc__(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR(Sst BadClientcBs&eZdZdZd„Zd„ZRS(s A DatagramProtocol which always raises an exception from datagramReceived. Used to test error handling behavior in the reactor for that method. cCs ||_dS(se Set the Deferred which will be called back when datagramReceived is called. N(R(R R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt setDeferredbscCsB|jdk r2|jd}|_|j|ƒntdƒ‚dS(NsApplication code is very buggy!(RRRR((R tbytesRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRjsN(RRR)RRR+R(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR*[s t UDPTestCasecBsbeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z RS( csStƒ}tjƒ}|_tjd|ddƒ‰‡‡fd†}|j|ƒS(su The C{type} of the host address of a listening L{DatagramProtocol}'s transport is C{"UDP"}. it interfaces 127.0.0.1cs)ˆjƒ}ˆj|jdƒˆjƒS(NtUDP(tgetHostt assertEqualttypet stopListening(tignoredR(R tp(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbStarted|s (RRRRRt listenUDPt addCallback(R tserverRR6((R R5s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_oldAddressts  csqtƒ‰tjƒ}ˆ_tjdˆddƒ‰‡‡‡fd†}‡‡fd†}|j|ƒj|ƒS(s± The L{DatagramProtocol}'s C{startProtocol} and C{stopProtocol} methods are called when its transports starts and stops listening, respectively. iR.s 127.0.0.1cs0ˆjˆjdƒˆjˆjdƒˆjƒS(Nii(R1RRR3(R4(R tport1R9(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR6ŒscsˆjˆjdƒdS(Ni(R1R(R4(R R9(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbStoppeds(RRRRRR7R8(R RR6R<((R R9R;s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_startStopƒs  cs_tƒ‰tjƒ}ˆ_tjdˆddƒ}d„‰‡‡fd†}|jˆ|ƒS(sr Re-listening with the same L{DatagramProtocol} re-invokes the C{startProtocol} callback. iR.s 127.0.0.1cSs |jƒS(N(R3(R4tport((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR6žscs;tjƒ}ˆ_tjdˆddƒ}|jˆ|ƒS(NiR.s 127.0.0.1(RRRRR7R8(R4RR5(R9R6(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR<¡s(RRRRRR7R8(R RR5R<((R6R9s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt test_rebind•s   csvtƒ‰tjƒ}ˆ_tjdˆddƒ‰‡‡‡fd†}|j|ƒ‡fd†}|j|ƒ|S(s A L{CannotListenError} exception is raised when attempting to bind a second protocol instance to an already bound port iR.s 127.0.0.1csWˆjˆjƒˆjjƒƒtƒ}ˆjtjtjˆjƒj |ddƒdS(NR.s 127.0.0.1( R1R0t transportRt assertRaisesRtCannotListenErrorRR7R>(R4tserver2(R R9R>(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR6²s  cs ˆjƒS(N(R3(R4(R>(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbFinished»s(RRRRRR7R8(R RR6RD((R R9R>s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_bindError©s   csØtƒ‰tjƒ}ˆ_tjdˆddƒ‰tƒ‰tjƒ‰ˆ_‡‡‡fd†}|j|ƒ}‡‡fd†}|j|ƒ‡‡‡fd†}|j|ƒ‡‡fd†}|j|ƒ|S(sŽ Datagrams can be sent with the transport's C{write} method and received via the C{datagramReceived} callback method. iR.s 127.0.0.1cstjdˆddƒˆ_ˆS(NiR.s 127.0.0.1(RR7tport2(R4(R tclientt clientStarted(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbServerStartedÍscsLjjjdˆjjƒjƒˆjjƒ}ˆjjƒ}tjƒ}ˆ_ˆjjd|j|jfƒdd d|j|jffg‰‡‡‡‡fd†‰tj ˆdƒ|gdt ƒS( Ns 127.0.0.1thellotatbtccsGˆrCtjƒ}ˆ_|jˆƒˆjjˆjdƒŒ|SdS(Ni(RRRR8R@twritetpop(R4tnextClientWrite(R9RGt cbClientSendt clientWrites(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRQás  tfireOnOneErrback(RK(RLN( R@tconnectR0R>RRRRNthostRt DeferredListtTrue(R4tcAddrtsAddrt serverSend(R9RG(RQRRs9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbClientStartedÓs    csŠˆjjƒ}ˆjjƒ}ˆjˆjd|j|jffgƒ|j|jf}ˆjˆjd|fd|fd|fgƒdS(NRJRKRLRM(R@R0R1R RUR>(R4RXRYt clientAddr(R R9RG(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbSendsFinishedòs  cs4tjtjˆjƒtjˆjjƒgdtƒS(NRS(RRVRR3RFRW(R4(R R;(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRDs(RRRRRR7R'R8(R t serverStartedRIRR[R]RD((RHR RGR9R;s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_sendPacketsÁs     csÈtƒ‰tjƒ}ˆ_tjdˆddƒ‰tƒ‰tjƒ}ˆ_tjdˆddƒ‰tj||gdtƒ}‡‡‡fd†}|j |ƒ‡‡fd†}|j |ƒ|S(sÎ A L{ConnectionRefusedError} exception is raised when a connection attempt is actively refused by the other end. Note: This test assumes no one is listening on port 80 UDP. iR.s 127.0.0.1RScstjƒ}ˆ_ˆjjddƒxCtdƒD]5}ˆjjt|ƒƒˆjjt|ƒdƒq3Wˆj|t j ƒS(Ns 127.0.0.1iPi (s 127.0.0.1iP( RRRR@RTtrangeRNtstrt assertFailureRR%(R4R&ti(R R9RG(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR6scs1tjtjˆjƒtjˆjƒgdtƒS(NRS(RRVRR3RW(R4(RFR>(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRD,s( R'RRRRR7RRVRWR8(R RHR^RR6RD((R R9RGRFR>s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_connectionRefused s      cCsvtƒ}tjd|ddƒ}|jt|jjddƒ|jjddƒ|jt|jjddƒ|jƒS(s A call to the transport's connect method fails with a L{ValueError} when a non-IP address is passed as the host value. A call to a transport's connect method fails with a L{RuntimeError} when the transport is already connected. iR.s 127.0.0.1t localhostiP( R'RR7RAt ValueErrorR@RTt RuntimeErrorR3(R RGR>((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_badConnect6s   cs¯tjƒ‰‡fd†}ˆj|ƒtƒ‰tjdˆddƒ‰‡fd†}ˆj|ƒˆjƒ‰tdƒ‰g‰‡‡‡‡‡‡‡fd†‰ˆƒˆS(sr When datagramReceived raises an exception it is logged but the port is not disconnected. cs9ˆjtƒ}ˆjt|ƒddt|ƒfƒdS(s… Flush the exceptions which the reactor should have logged and make sure they're actually there. is'Incorrectly found %d errors, expected 2N(tflushLoggedErrorsR(R1tlen(tignterrs(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbCompletedPsiR.s 127.0.0.1cs"tjˆjƒj‡fd†ƒS(sƒ Disconnect the port we started and pass on whatever was given to us in case it was a Failure. csˆS(N((Rk(tresult(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytas(RRR3taddBoth(Rn(R>(Rns9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbCleanup\si<csýˆs.yˆjdƒWq.ˆjƒq.Xnˆjˆjddƒtˆjdƒƒ}tjƒ}ˆj |ƒˆjj |ˆj ˆj fƒ‡‡‡‡fd†}‡fd†}|j ||ƒ|jˆjƒtjd|jtjdƒƒ‰dS( s6 Send one packet to the listening BadClient. Set up a 0.1 second timeout to do re-transmits in case the packet is dropped. When two packets have been received by the BadClient, stop sending and let the finalDeferred's callbacks do some assertions. sNot enough packets receivedsUDP Protocol lost its transporticsMˆjƒˆj|ƒtˆƒdkrBtjdˆjdƒnˆƒdS(s… A packet arrived. Cancel the timeout for it, record it, and maybe finish the test. iiN(tcancelRRjRt callLaterRR(tpacket(tsucceededAttemptst makeAttemptt timeoutCallt finalDeferred(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbPacketReceived…s   cs ˆƒdS(sÄ The packet wasn't received quickly enough. Try sending another one. It doesn't matter if the packet for which this was the timeout eventually arrives: makeAttempt throws away the Deferred on which this function is the errback, so when datagramReceived callbacks, so it won't be on this Deferred, so it won't raise an AlreadyCalledError. N((terr(Rv(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytebPacketTimeout•s gš™™™™™¹?s&Timed out in testDatagramReceivedErrorN(tfailR!tfailIfIdenticalR@RRaRORRR+RNRUR>t addCallbackst addErrbackRRsRt TimeoutError(RttpacketDeferredRyR{(RuRRvR tattemptsRGRx(Rws9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRvqs$    ( RRR8R*RR7RpR0R`(R RmRq((RuRvR R‚RGRxR>Rs9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_datagramReceivedErrorIs     !7csŠtƒ}tjd|ƒ‰tˆjƒjƒ‰ˆjtˆƒjˆƒdkƒ‡‡‡fd†}t j ˆj ƒ}|j |ƒ|S(s” The port number being listened on can be found in the string returned from calling repr() on L{twisted.internet.udp.Port}. iiÿÿÿÿcs&ˆjtˆƒjˆƒdkƒdS(Niÿÿÿÿ(tfailIftreprtfind(Rk(R tportNoR5(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytstoppedListeningµs( R'RR7RaR0R>R„R…R†RRR3R8(R RGRˆR((R‡R R5s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt test_portRepr¬s " cCssddd„ƒY}tjdtƒƒ}|ƒ|_|jdd ƒ|j|jgƒ}|jt|ƒdƒdS( si C{''} is an alternative way to say C{'255.255.255.255'} ({socket.gethostbyname("")} returns C{'255.255.255.255'}), so because it becomes a valid IP address, no deprecation warning about passing hostnames to L{twisted.internet.udp.Port.write} needs to be emitted by C{write()} in this case. t fakeSocketcBseZd„ZRS(cSsdS(N((R tfootbar((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytsendtoÅs(RRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRŠÄsittests iÒN((s iÒ( R tPortRtsocketRNt flushWarningsttest_NoWarningOnBroadcastR1Rj(R RŠR5twarnings((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR’¼s  ( RRR:R=R?RER_RdRhRƒR‰R’(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR-rs     J +  c tReactorShutdownInteractioncBs)eZdZd„Zd„Zd„ZRS(s!Test reactor shutdown interactioncCs.tƒ|_tjd|jddƒ|_dS(sStart a UDP portiR.s 127.0.0.1N(RR9RR7R>(R ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytsetUpÔs cCs |jjƒS(sStop the UDP port(R>R3(R ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttearDownÙscstjƒ‰tjƒ}ˆj_‡‡fd†}|j|ƒ‡fd†}ˆj|ƒˆjjjdddˆjjjƒjfƒˆS(s0Test reactor shutdown while in a recvfrom() loopcs*ˆjjjƒtjdˆjdƒdS(Ni(R9R@tconnectionLostRRsRR(R4(R tfinished(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytpktReceìscsˆjƒdS(N(Ri(R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt flushErrorsõsti@s 127.0.0.1( RRR9RR8R@RNR0R>(R tprR™Rš((R R˜s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt testShutdownFromDatagramReceivedÝs   (RRR)R•R–R(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR”Ñs  tMulticastTestCasecBsŸeZd„Zd„Zd„Zd„Zd„Zd„Zd„Ze j j ƒrpe j j ƒ rpde_ nd„Zd „Ze j j ƒrd e_nRS( cCsqtƒ|_tƒ|_tjd|jƒ|_tjd|jƒ|_|jjj d|jjj ƒj ƒdS(Nis 127.0.0.1( RR9R RGRtlistenMulticastR;RFR@RTR0R>(R ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR•s    cCs(tt|jjƒt|jjƒgƒS(N(RRR;R3RF(R ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR–scCscx\|j|jfD]H}|j|jjƒdƒ|jjdƒ|j|jjƒdƒqWdS(Nii(RGR9R1R@tgetTTLtsetTTL(R to((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttestTTLscs¡ˆjˆjjjƒdƒˆjjjƒ‰ˆjjjdƒ}‡‡fd†}|j|ƒ‡‡fd†}|j|ƒ‡fd†}|j|ƒ|S(sv Test that after loopback mode has been set, multicast packets are delivered to their sender. is 225.0.0.250cs6tƒ}ˆj_ˆjjjddˆjfƒ|S(NRJs 225.0.0.250(RR9RR@RNR>(R4R(RR (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbJoined$scsˆjtˆjjƒdƒˆjjjdƒˆjˆjjjƒdƒˆjjjddˆjfƒt ƒ}t j d|j dƒ|S(NiiRJs 225.0.0.250(R1RjR9R R@tsetLoopbackModetgetLoopbackModeRNR>RRRsRR(R4R(RR (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbPacket*s cs ˆjtˆjjƒdƒdS(Ni(R1RjR9R (R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbNoPacket6s(R1R9R@R¦R0t joinGroupR8(R tjoinedR¤R§R¨((RR s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt test_loopbacks   cs”ˆjˆjjjƒdƒˆjˆjjjƒdƒˆjjjdƒ}ˆjjjdƒ}t||gƒ}‡fd†}|j|ƒ|S(sK Test C{getOutgoingInterface} and C{setOutgoingInterface}. s0.0.0.0s 127.0.0.1cs<ˆjˆjjjƒdƒˆjˆjjjƒdƒdS(Ns 127.0.0.1(R1RGR@tgetOutgoingInterfaceR9(R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbInterfacesJs(R1RGR@R¬R9tsetOutgoingInterfaceRR8(R td1td2RnR­((R s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_interface=s csmˆjjjdƒ}‡fd†}|j|ƒ‡fd†}|j|ƒ‡fd†}|j|ƒ|S(sE Test that multicast a group can be joined and left. s 225.0.0.250csˆjjjdƒS(Ns 225.0.0.250(RGR@t leaveGroup(R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt clientJoinedYscsˆjjjdƒS(Ns 225.0.0.250(R9R@R©(R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt clientLeft]scsˆjjjdƒS(Ns 225.0.0.250(R9R@R²(R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt serverJoinedas(RGR@R©R8(R RR³R´Rµ((R s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_joinLeaveSs   cCs"|j|jjjdƒtjƒS(sŠ Test that an attempt to join an address which is not a multicast address fails with L{error.MulticastJoinError}. s 127.0.0.1(RbRGR@R©RtMulticastJoinError(R ((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_joinFailurehssWindows' multicast is wonkycs tƒ‰tjdˆƒ‰ˆjjjƒ‰ˆjjjdƒ}‡‡‡fd†}|j|ƒ‡fd†}|j|ƒ‡fd†}|j|ƒ|S(sn Test that a multicast group can be joined and messages sent to and received from it. is 225.0.0.250cs3tƒ}ˆj_ˆjjddˆjfƒ|S(Ns hello worlds 225.0.0.250(RR9RR@RNR>(R4R(RMRR (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR¤€scs"ˆjˆjjdddƒdS(Nis hello world(R1R9R (R4(R (s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR§†scs)tˆjƒ}|j‡fd†ƒ|S(NcsˆS(N((Rk(t passthrough(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRoŒs(RR3R8(R¹Rn(R5(R¹s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcleanupŠs(RRRŸR9R@R0R©R8(R RªR¤R§Rº((RMRR R5s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_multicastus    cs÷tƒ‰tjdˆdtƒ‰ˆjƒj‰tƒ‰tjˆˆdtƒ‰d‰tˆjjj ˆƒˆj ˆƒˆj ˆƒgƒ}‡‡‡‡fd†}|j |ƒ‡‡‡fd†}|j |ƒ‡‡fd†}|j |ƒ|S(s¢ Test that multiple sockets can listen on the same multicast port and that they both receive multicast messages directed to that address. itlistenMultiples 225.0.0.250csItƒ}ˆ_tƒ}ˆ_ˆjjdˆˆfƒt||gƒS(Ns hello world(RRR@RNR(R4R¯R°(tportnottheGroupt firstClientt secondClient(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRµ¨scs:ˆjˆjdddƒˆjˆjdddƒdS(Nis hello world(R1R (R4(R R¿RÀ(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt gotPackets¯scs>ttˆjƒtˆjƒgƒ}|j‡fd†ƒ|S(NcsˆS(N((Rk(R¹(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRo¸s(RRR3R8(R¹Rn(t secondPortt firstPort(R¹s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRº´s  ( RRRŸRWR0R>RR9R@R©R8Rp(R RªRµRÁRº((R½RÂR R¾R¿RÀRÃs9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_multiListen“s$      sjon non-linux platforms it appears multiple processes can listen, but not multiple sockets in same process?(RRR•R–R£R«R±R¶R¸R tplatformt isWindowstisVistattodoR»RÄtskip(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRžs   "      )s!This reactor does not support UDPs'This reactor does not support multicastcCsddl}|jjdƒrŒtdƒjƒ}|jdƒrŒ|jƒd}|jdƒd ddgkr‰tjj }d|_ q‰qŒndS(Niÿÿÿÿs /proc/versions Linux versionit.t2s&figure out why this fails in linux 2.2( tostpathtexiststopentreadt startswithtsplitRžt testInterfacetim_funcRÈ(RÌtstf((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcheckForLinux22Ès  N("R)t twisted.trialRttwisted.internet.deferRRRttwisted.internetRRRRRR ttwisted.pythonR R tDatagramProtocolRtConnectedDatagramProtocolR R't ExceptionR(R*tTestCaseR-R”Ržt IReactorUDPRRÉtIReactorMulticastR×(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyts*.  ÿ`1À