ó [³XMc@s¬dZddlmZmZddlmZmZmZddlm Z m Z m Z m Z m Z mZddlmZdfd„ƒYZdee jfd „ƒYZd ee jfd „ƒYZd efd „ƒYZdefd„ƒYZde jfd„ƒYZdejfd„ƒYZdejfd„ƒYZdejfd„ƒYZe je eƒ ryde_ de_ ne j!e eƒ r˜de_ nd„Z"e"ƒdS(sG Tests for implementations of L{IReactorUDP} and L{IReactorMulticast}. iÿÿÿÿ(tunittesttutil(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(Rtd((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(RtdatataddrR((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(RRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR6scCs?|jdk r2|jd}|_|j|ƒn||_dS(N(RRterrbacktfailure(RR#R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytconnectionFailed<scCsH|jdk r;|jd}|_|jtjdƒƒnd|_dS(Ntyupi(RRR"RtConnectionRefusedErrorR (RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytconnectionRefusedBsN(RRRRR RR$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 (RR((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(RR((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)(RtbytesRR((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 assertEqualsttypet stopListening(tignoredR(Rtp(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbStarted|s (RRRRRt listenUDPt addCallback(RtserverRR7((RR6s9/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(R2RRR4(R5(Rtport1R:(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR7ŒscsˆjˆjdƒdS(Ni(R2R(R5(RR:(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbStoppeds(RRRRRR8R9(RRR7R=((RR:R<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(R4(R5tport((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR7žscs;tjƒ}ˆ_tjdˆddƒ}|jˆ|ƒS(NiR/s 127.0.0.1(RRRRR8R9(R5RR6(R:R7(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR=¡s(RRRRRR8R9(RRR6R=((R7R:s9/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( R2R1t transportRt assertRaisesRtCannotListenErrorRR8R?(R5tserver2(RR:R?(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR7²s  cs ˆjƒS(N(R4(R5(R?(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbFinished»s(RRRRRR8R9(RRR7RE((RR:R?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(RR8tport2(R5(Rtclientt 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(RRRR9RAtwritetpop(R5tnextClientWrite(R:RHt cbClientSendt clientWrites(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRRás  tfireOnOneErrback(RL(RMN( RAtconnectR1R?RRRROthostRt DeferredListtTrue(R5tcAddrtsAddrt serverSend(R:RH(RRRSs9/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(NRKRLRMRN(RAR1R2R RVR?(R5RYRZt clientAddr(RR:RH(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbSendsFinishedòs  cs4tjtjˆjƒtjˆjjƒgdtƒS(NRT(RRWRR4RGRX(R5(RR<(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyREs(RRRRRR8R(R9(Rt serverStartedRJRR\R^RE((RIRRHR:R<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.1RTcstjƒ}ˆ_ˆjjddƒxCtdƒD]5}ˆjjt|ƒƒˆjjt|ƒdƒq3Wˆj|t j ƒS(Ns 127.0.0.1iPi (s 127.0.0.1iP( RRRRARUtrangeROtstrt assertFailureRR&(R5R'ti(RR:RH(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR7scs1tjtjˆjƒtjˆjƒgdtƒS(NRT(RRWRR4RX(R5(RGR?(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRE,s( R(RRRRR8RRWRXR9(RRIR_RR7RE((RR:RHRGR?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(RR8RBt ValueErrorRARUt RuntimeErrorR4(RRHR?((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)R2tlen(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((Rl(tresult(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytas(RRR4taddBoth(Ro(R?(Ros9/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(tcancelRRkRt 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(Rw(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytebPacketTimeout•s gš™™™™™¹?s&Timed out in testDatagramReceivedErrorN(tfailR"tfailIfIdenticalRARRbRPRRR,RORVR?t addCallbackst addErrbackRRtRt TimeoutError(RutpacketDeferredRzR|(RvRRwRtattemptsRHRy(Rxs9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRwqs$    ( RRR9R+RR8RqR1Ra(RRnRr((RvRwRRƒRHRyR?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(Rl(RtportNoR6(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytstoppedListeningµs( R(RR8RbR1R?R…R†R‡RRR4R9(RRHR‰R((RˆRR6s9/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((Rtfootbar((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 tPortRtsocketROt flushWarningsttest_NoWarningOnBroadcastR2Rk(RR‹R6twarnings((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR“¼s  ( RRR;R>R@RFR`ReRiR„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(RR:RR8R?(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytsetUpÔs cCs |jjƒS(sStop the UDP port(R?R4(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(R:RAtconnectionLostRRtRR(R5(Rtfinished(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytpktReceìscsˆjƒdS(N(Rj(R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt flushErrorsõsti@s 127.0.0.1( RRR:RR9RAROR1R?(RtprRšR›((RR™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( RR:R!RHRtlistenMulticastR<RGRARUR1R?(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR–s    cCs(tt|jjƒt|jjƒgƒS(N(RRR<R4RG(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(RHR:R2RAtgetTTLtsetTTL(Rto((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(NRKs 225.0.0.250(RR:RRAROR?(R5R(RR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbJoined$scsˆjtˆjjƒdƒˆjjjdƒˆjˆjjjƒdƒˆjjjddˆj fƒt ƒ}t j d|j dƒ|S(NiiRKs 225.0.0.250(t assertEqualRkR:R RAtsetLoopbackModeR2tgetLoopbackModeROR?RRRtRR(R5R(RR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcbPacket*s cs ˆjtˆjjƒdƒdS(Ni(R¦RkR:R (R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbNoPacket6s(R2R:RAR¨R1t joinGroupR9(RtjoinedR¥R©Rª((RRs9/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(R¦RHRAtgetOutgoingInterfaceR:(R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt cbInterfacesJs(R¦RHRAR®R:tsetOutgoingInterfaceRR9(Rtd1td2RoR¯((Rs9/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(RHRAt leaveGroup(R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt clientJoinedYscsˆjjjdƒS(Ns 225.0.0.250(R:RAR«(R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt clientLeft]scsˆjjjdƒS(Ns 225.0.0.250(R:RAR´(R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyt serverJoinedas(RHRAR«R9(RRRµR¶R·((Rs9/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(RcRHRAR«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(RR:RRAROR?(R5R(RNRR(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR¥€scs"ˆjˆjjdddƒdS(Nis hello world(R2R:R (R5(R(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR©†scs)tˆjƒ}|j‡fd†ƒ|S(NcsˆS(N((Rl(t passthrough(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRpŒs(RR4R9(R»Ro(R6(R»s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pytcleanupŠs(RRR R:RAR1R«R9(RR¬R¥R©R¼((RNRRR6s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyttest_multicastus    csÍtƒ‰tjdˆdtƒ‰ˆjƒj‰tƒ‰tjˆˆdtƒ‰ˆjjjdƒ}‡‡‡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ƒ}ˆ_ˆjjddˆfƒt||gƒS(Ns hello worlds 225.0.0.250(RRRAROR(R5R±R²(tportnot firstClientt secondClient(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR·¤scs:ˆjˆjdddƒˆjˆjdddƒdS(Nis hello world(R2R (R5(RRÀ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((Rl(R»(s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyRp´s(RRR4R9(R»Ro(t secondPortt firstPort(R»s9/usr/lib/python2.7/dist-packages/twisted/test/test_udp.pyR¼°s  ( RRR RXR1R?R:RAR«R9Rq(RR¬R·RÂR¼((R¿RÃRRÀ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.trialRRttwisted.internet.deferRRRttwisted.internetRRRRR R 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»