h}w SrSSKJr SSKrSSKJrJrJrJrJ r J r J r J r J r JrJr SSKJr SSKJrJrJrJrJrJr SSKJrJr SSKJrJrJr SS KJ r SS K!J"r"J#r#J$r$ SS K%J&r& SS K'J(r( SS K)J*r* SSK+J,r,J-r- "SS5r."SS\.\R^5r0"SS\.\Rb5r2"SS\05r3"SS\45r5"SS\R^5r6\"\Rn"\S5(+S5"SS\-55r8\"\Rn"\S5(+S5"SS\-55r9S,S jr:\"\RF"\S5(+S!5\"\:"\\\S"S#5(+S$5"S%S&\-555r;\"\RF"\S5(+S!5\*\"\:"\\ \ S'S(5(+S)5"S*S+\;5555rr?r@rArG__annotations__refusedrNrBrCr/r,rErE=s,0N)0G""r/rEc.\rSrSrSrSrSrSrSrSr g)ClientINrcURRU5 URb%URSso lURS5 ggr(rJ)r+rLr7s r,rNClient.datagramReceivedMsD D!    *%)%8%8$ "A" JJt  +r/crURb$URSso lURU5 Xlgr()r4errbackfailure)r+rYr7s r,connectionFailedClient.connectionFailedSs2    +&*&:&:D #A# IIg  r/cURb8URSsolUR[R"S55 SUlgNyupr2r4rXrConnectionRefusedErrorrQr6s r,connectionRefusedClient.connectionRefusedY?    +&*&:&:D #A# IIe2259 : r/)rYrGrQr4) r>r?r@rArGrQrNrZrarBrCr/r,rSrSIsNG  r/rSc\rSrSrSrSrg) GoodClient`cURb8URSsolUR[R"S55 SUlgr]r_r6s r,raGoodClient.connectionRefusedarcr/)rQr4N)r>r?r@rArarBrCr/r,rere`sr/rec\rSrSrSrSrg)BadClientErrorhzZ Raised by BadClient at the end of every datagramReceived call to try and screw stuff up. rCN)r>r?r@rA__doc__rBrCr/r,rjrjhsr/rjc(\rSrSrSrSrSrSrSrg) BadClientoz A DatagramProtocol which always raises an exception from datagramReceived. Used to test error handling behavior in the reactor for that method. NcXlg)zM Set the Deferred which will be called back when datagramReceived is called. Nr7r6s r, setDeferredBadClient.setDeferredws r/czURb$URSso0lURU5 [S5e)NzApplication code is very buggy!)r7r5rj)r+bytesrMr7s r,rNBadClient.datagramReceived~s3 66 IAv JJu >??r/rq) r>r?r@rArlr7rrrNrBrCr/r,rnrnos A@r/rn!This reactor does not support UDPc\rSrSrSrSrSrSrSr\ "\ RRS5S:HS 5S 5r S rS rS rSrSrg)UDPTestsc^^[5n[R"5=o!l[R "SUSS9mUU4SjnUR U5$)z] The C{type} of the host address of a listening L{DatagramProtocol}'s transport is C{"UDP"}. r 127.0.0.1 interfacec|>TR5nTRURS5 TR5$)NUDP)getHost assertEqualtype stopListening)ignoredrMpr+s r, cbStarted+UDPTests.test_oldAddress..cbStarteds/99;D   TYY .??$ $r/rErrr4r listenUDP addCallback)r+serverr7rrs` @r,test_oldAddressUDPTests.test_oldAddresssH %*^^%55 "   a; ? % }}Y''r/c^^^[5m[R"5=nTl[R "STSS9mUUU4SjnUU4SjnUR U5R U5$)z The L{DatagramProtocol}'s C{startProtocol} and C{stopProtocol} methods are called when its transports starts and stops listening, respectively. rr|r}c>TRTRS5 TRTRS5 TR5$)Nr2r)rr3r;r)rport1r+rs r,r*UDPTests.test_startStop..cbStarteds:   V^^Q /   V^^Q /&&( (r/c>>TRTRS5 gr1)rr;)rr+rs r, cbStopped*UDPTests.test_startStop..cbStoppeds   V^^Q /r/r)r+r7rrrrs` @@r,test_startStopUDPTests.test_startStopsZ %*^^%55F "!!!V{C )  0}}Y'33I>>r/c^^[5m[R"5=nTl[R "STSS9nSmUU4SjnUR TU5$)zZ Re-listening with the same L{DatagramProtocol} re-invokes the C{startProtocol} callback. rr|r}c"UR5$r(rrports r,r'UDPTests.test_rebind..cbStarteds%%' 'r/c>[R"5=nTl[R"STSS9nUR TU5$Nrr|r})rrr4rrr)rr7rrrs r,r'UDPTests.test_rebind..cbStoppeds<).)9 9A&!!!V{CA==A. .r/r)r+r7rrrrs @@r, test_rebindUDPTests.test_rebindsQ %*^^%55F "   a; ? ( / }}Y**r/c^^^[5m[R"5=nTl[R "STSS9mUUU4SjnUR U5 U4SjnUR U5 U$)zx A L{CannotListenError} exception is raised when attempting to bind a second protocol instance to an already bound port rr|r}c>TRTR5TRR55 [5nTR [ R [RTR5RUSS9 g)Nr|r}) rrrHrE assertRaisesrCannotListenErrorrrr)rserver2rr+rs r,r*UDPTests.test_bindError..cbStartedsi   T\\^V-=-=-E-E-G HhG   ''!! ##%  r/c$>TR5$r(rrs r, cbFinished+UDPTests.test_bindError..cbFinisheds%%' 'r/r)r+r7rrrrs` @@r,test_bindErrorUDPTests.test_bindErrors_ %*^^%55F "  FkB  i  ( j!r/c^^^^ ^ [5m [R"5=nT l[R "ST SS9m [ 5m[R"5=mTlUUU4SjnURU5nUU 4SjnURU5 UUU 4SjnURU5 U U4SjnURU5 U$)zv Datagrams can be sent with the transport's C{write} method and received via the C{datagramReceived} callback method. rr|r}c>>[R"STSS9TlT$r)rrport2)rclient clientStartedr+s r,cbServerStarted2UDPTests.test_sendPackets..cbServerStarteds **1f LDJ r/c>^^TRRSTRR5R5 TRR5nTRR5n[R "5=nTlTRRSURUR45 SSSURUR44/mUUUU4Sjm[R"T"S5U/SS9$) Nr|hello)a)bNcc>T(aW[R"5=nTlURT5 TRR "TR S56 U$gNr)rrrGrrHwritepop)rnextClientWrite cbClientSendr clientWritesrs r,rHUDPTests.test_sendPackets..cbClientStarted..cbClientSendsR>Cnn>NNOf&;#// =$$**L,<,.cbClientStarteds    $ $[&2B2B2J2J2L2Q2Q R$$,,.E$$,,.E161A AJ.    " "8ejj%**-E F#\D5::uzz:R3STL + +%%d#Z04 r/cR>TRR5nTRR5nTRTRSURUR 44/5 URUR 4nTRTRSU4SU4SU4/5 g)Nrrrr)rHrrr)rr)rrr clientAddrrr+rs r,cbSendsFinished2UDPTests.test_sendPackets..cbSendsFinisheds$$,,.E$$,,.E   V^^x%**ejj9Q.R-S T**ejj1J    #dJ%7$ 9KL r/c>[R"[R"TR5[R"TRR5/SS9$NTr)rrrrr)rrr+s r,r-UDPTests.test_sendPackets..cbFinishedsL%%''(;(;<'' (@(@A"&  r/)rErrr4rrrer) r+ serverStartedrr7rrrrrrrs ` @@@@r,test_sendPacketsUDPTests.test_sendPacketss 161AA .!!!V{C161AA . !  % %o 6 0 o&  o&  j!r/INFRASTRUCTUREAZUREPIPELINESz"Hangs on Pipelines due to firewallc^^^^^ [5m[R"5=nTl[R "STSS9m[ 5m [R"5=nT l[R "ST SS9m[R"X/SS9nUUU 4SjnURU5 UU4SjnURU5 U$)z 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. rr|r}TrcV>[R"5=nTlTRR SS5 [ S5HBnTRR SU4-5 TRR SU4-S5 MD TRU[R5$)Nr|P %dr|r) rrr4rHrranger assertFailurerr`)rrairr+rs r,r2UDPTests.test_connectionRefused..cbStarted3s9>9I I  6    $ $[" 52Y  &&ut|4  &&ut|5FG%%&79U9UV Vr/c>[R"[R"TR5[R"TR5/SS9$rrrrr)rrrs r,r3UDPTests.test_connectionRefused..cbFinished?sH%%''(:(:;''(;(;<"&  r/) rerrr4rrrErr) r+rrr7rrrrrrs ` @@@@r,test_connectionRefusedUDPTests.test_connectionRefuseds161AA .  FkB161AA .!!!V{C    =PT U W i   j!r/c,^^ ^ ^ ^ ^ [5m [R"5=nT l[R "ST SS9m Sm [ 5m [R"5=nT l[R"5=nT l[R "ST SS9m [R"X/SS9nU U U U 4SjnURU5 [R"XC/SS9nUU U 4SjnURU5 U U 4S jnURU5 U$) aC When a server fails to successfully read a packet the server should still be able to process future packets. The IOCP reactor had a historical problem where a failure to read caused the reactor to ignore any future reads. This test should prevent a regression. Note: This test assumes no one is listening on port 80 UDP. rr|r}sSending test packet to serverTrc>TRRSS5 TRRTSTR45 g)Ns$write to port no one is listening torr|)rHr_realPortNumber)rrr serverPorttest_data_to_sends r,cbClientAndServerStartedAUDPTests.test_serverReadFailure..cbClientAndServerStartedbsE    " "79J     " "!K1K1K#L r/cJ>TRTRSST5 gr)rr))rr+rrs r,verify_server_got_data?UDPTests.test_serverReadFailure..verify_server_got_dataus"   V^^A.q13D Er/c>[R"[R"TR5[R"TR5/SS9$rr)r clientPortrs r,cleanup0UDPTests.test_serverReadFailure..cleanupzsH%%'' (@(@A'' (@(@A"&  r/) rerrr4rrrErGrr)r+rr serverGotDataserver_client_started_dr all_data_sentrrrrrrrs` @@@@@r,test_serverReadFailureUDPTests.test_serverReadFailureKs161AA .&&q&KH <161AA .050@@ -&&q&KH "'"4"4  *T#    ++,DE** $ 4t  F !!"89  !!'*r/c^[5n[R"SUSS9nUR[R UR RSS5 UR RSS5 UR[UR RSS5 UR5$)z A call to the transport's connect method fails with an L{InvalidAddressError} 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. rr|r} localhostr) rerrrrInvalidAddressErrorrHr RuntimeErrorr)r+rrs r,test_badConnectUDPTests.test_badConnects  FkB   % %v'7'7'?'?b    b1 ,(8(8(@(@+rR!!##r/cN^^^^^^^^ [R"5mU4SjnTRU5 [5m[R "STSS9mU4SjnTR U5 TR5m[[S55m/m UUUUUUU 4SjmT"5 T$)zZ When datagramReceived raises an exception it is logged but the port is not disconnected. c>TR[5nTR[U5SS[U54-5 g)za Flush the exceptions which the reactor should have logged and make sure they're actually there. z'Incorrectly found %d errors, expected 2N)flushLoggedErrorsrjrlen)ignerrsr+s r, cbCompleted8UDPTests.test_datagramReceivedError..cbCompleteds: )).9D   D 1G3t9,V r/rr|r}cl>^[R"TR5RU4Sj5$)z_ Disconnect the port we started and pass on whatever was given to us in case it was a Failure. c>T$r(rC)rresults r,HUDPTests.test_datagramReceivedError..cbCleanup..svr/)rrraddBoth)r rs`r, cbCleanup6UDPTests.test_datagramReceivedError..cbCleanups( &&t'9'9:BBCUV Vr/<cr>^T(dT RS5 T RTRSS5 STR S54-n[ R"5nTRU5 TRRUTRTR45 UU U U4SjnU 4SjnURX#5 URTR5 [R"SUR[ R""S 55mg![a TR5 GNf=f) z 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. zNot enough packets receivedNzUDP Protocol lost its transportrrc>TR5 TRU5 [T5S:Xa#[R"STR S5 gT"5 g)zU A packet arrived. Cancel the timeout for it, record it, and maybe finish the test. rrN)cancelrKrr callLaterr5)packet finalDeferred makeAttemptsucceededAttempts timeoutCalls r,cbPacketReceivedRUDPTests.test_datagramReceivedError..makeAttempt..cbPacketReceivedsL ""$!((0()Q. %%a)?)?FMr/c>T"5 g)aT 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. NrC)errrs r,ebPacketTimeoutQUDPTests.test_datagramReceivedError..makeAttempt..ebPacketTimeouts  r/g?z&Timed out in testDatagramReceivedError)fail ExceptionrXfailIfIdenticalrHrrrrrrrr addCallbacks addErrbackrrr TimeoutError) rpacketDeferredrrrrMattemptsrrrr+rs @r,r8UDPTests.test_datagramReceivedError..makeAttempts ,II;<    $(I hll1o//F"^^-N   ~ .    " "6DIItyy+A B " "   ' '(8 J  % %m&;&; <!++&&""#KLKU!,!))+,sDD65D6) rrrrnrrrrlistr) r+rrrMr(rrrrrs ` @@@@@@@r,test_datagramReceivedError#UDPTests.test_datagramReceivedErrors (   !!+.  FkB W i(||~b ?8 8 t  r/c"SS5n[R"S[55nU"5UlUR SS5 UR UR /5nUR[U5S5 g)a9 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. c\rSrSrSrSrg)6UDPTests.test_NoWarningOnBroadcast..fakeSocketi cgr(rC)r+foobars r,sendto=UDPTests.test_NoWarningOnBroadcast..fakeSocket.sendto sr/rCN)r>r?r@rAr3rBrCr/r, fakeSocketr/ s r/r5rstest)z iN) rPortrErr flushWarningstest_NoWarningOnBroadcastrr)r+r5rwarningss r,r8"UDPTests.test_NoWarningOnBroadcastse   HHQ !< ./%%t'E'E&FG X*r/)rN)r>r?r@rArrrrrrosenvirongetrrrr+r8rBrCr/r,ryrysh( ?(+&8BH  '(,<<,' 'R:x$$gR+r/ryc^\rSrSrSr\R "\S5(dSrSr Sr Sr Sr g) ReactorShutdownInteractionTestsiz!Test reactor shutdown interactionNrwcl[5Ul[R"SURSS9Ulg)zStart a UDP portrr|r}N)rErrrrr*s r,setUp%ReactorShutdownInteractionTests.setUps%h %%a L r/c6URR5$)zStop the UDP port)rrr*s r,tearDown(ReactorShutdownInteractionTests.tearDown#syy&&((r/c^^[R"5m[R"5=nTRlUU4SjnUR U5 U4SjnTR U5 TRR R SSTRR R5R45 T$)z0Test reactor shutdown while in a recvfrom() loopc>TRRR5 [R"STR S5 gr)rrHconnectionLostrrr5)rfinishedr+s r,pktReceQReactorShutdownInteractionTests.testShutdownFromDatagramReceived..pktRece6s3 KK ! ! 0 0 2   a!2!2D 9r/c&>TR5 gr()rrr+s r, flushErrorsUReactorShutdownInteractionTests.testShutdownFromDatagramReceived..flushErrors@s  " " $r/s@r|) rrrrGrrHrrr)r+prrJrNrIs` @r, testShutdownFromDatagramReceived@ReactorShutdownInteractionTests.testShutdownFromDatagramReceived's>>#*/..*::T[[ ' : w % [) ## dkk&;&;&C&C&E&J&JK r/)rr) r>r?r@rArlr IReactorUDPrskiprArDrQrBrCr/r,r?r?s-+  ! !'4 0 02M )$r/r?c,[U[5nURUS45 [X5n[X5nUR XXg-5 UR 5 g![ a UR 5 gf=f!UR 5 f=f)z Bind a socket to the given network interface and attempt to join a multicast group with the given address family. This is used to determine whether the local networking stack configuration allows for multicast within the given address family. rTF)rr bindr setsockoptcloseOSError)afipprotojoingroupbindtos packgrouppackifs r,checkMulticastAvailabilityrbNs r:AFFFA;"$I r "F WI$67      s#A!! A>+B=A>>BBz'This reactor does not support multicast 225.0.0.2500.0.0.0z:The local networking stack does not enable IPv4 multicast.c\rSrSr%SrSrS\S'SrS\S'SrS\S 'S r S\S 'Sr S\S 'S r S\S'Sr S\S'Sr S\S'SrSrS SjrS SjrS SjrS SjrS Sjr\"\R.R15=(a \R.R35(+S5S5rSr\"\R.R15S5S Sj5rSrg)!MulticastTestsiezg Tests for sending and receiving multicast datagrams. (This suite supports IPv4, see below for IPv6.) rdstrr~ str | intexpectedInterfacer| clientAddressrcmulticastGroupalternateInterfacerinterfaceSynonym invalidGroup::1wrongAddressFamilyc[5Ul[5Ul[R "SURUR 5Ul[R "SURUR 5UlURRRURURRR5R5 gr)rErrSrrlistenMulticastr~rrrHrrjrrr*s r,rAMulticastTests.setUpsh h ,,Q T^^L ,,Q T^^L  %%    KK ! ! ) ) + 0 0 r/c[[URR5[URR5/5$r()rrrrrr*s r,rDMulticastTests.tearDowns8djj667djj667   r/c^TRRR[:wa [ S5eSU4SjjnU"TR 5 U"TR5 g)Nz+only IPv4 multicast has TTLs, IPv6 has hopsc2>[R"UR5(deTRURR 5S5 URR S5 TRURR 5S5 g)Nr2r)r providedByrHrgetTTLsetTTL)or+s r,checkttl(MulticastTests.testTTL..checkttlsj&11!++>> >>   Q[[//11 5 KK  q !   Q[[//11 5r/)r{zServer | ClientreturnNone)rrH addressFamilyrr"r)r+r|s` r,testTTLMulticastTests.testTTLsF ;; . .' 9HI I 6 r/c # URnURURRR 5S5 URRR 5nURRR U5IShvN [5URlURRRSXR45 URRIShvN UR[URR5S5 URRRS5 URURRR 5S5 URRRSXR45 [[[ 5S5IShvN UR[URR5S5 gGNwGNN:7f)z^ Test that after loopback mode has been set, multicast packets are delivered to their sender. r2Nrr)rkrrrHgetLoopbackModer joinGrouprrGrrrr)setLoopbackModerrr)r+r]rMs r, test_loopbackMulticastTests.test_loopbacksm ## ..>>@!D{{$$,,.kk##--e444%-Z " ##Huii.@Akk(((( T[[00115 --a0 ..>>@!D ##Huii.@Ag.222 T[[00115 5 ) 3s8B HHA'H7H 8CHH 5H H Hc# UR[5 URRR UR UR S9IShvN SSS5 gN !,(df  g=f7f)z| A sensible error will be reported when using the wrong address family literal for the 'interface' argument to 'joinGroup'. r}N)rrrrHrrkrpr*s r,test_wrongFamilyInterfaceJoin,MulticastTests.test_wrongFamilyInterfaceJoinsc   1 2++''11##t/F/F2  3 2 3 2s.A5@X@X  r/c^^^^[5m[R"STTR5mTRR R 5mTRR RTR5nUUU4SjnURU5 U4SjnURU5 U4SjnURU5 U$)zV Test that a multicast group can be joined and messages sent to and received from it. rc>[5=nTRlTRR STR TR 45 U$)N hello world)rrrGrHrrkr)rr7rMcr+s r,cbJoined/MulticastTests.test_multicast..cbJoineds>-5Z 7A * KK  nt/B/BDII.N OHr/c^>TRTRRSSS5 g)Nrr)rrr)rMs r,cbPacket/MulticastTests.test_multicast..cbPackets'   T[[003A6 Gr/c^>^[TR5nURU4Sj5 U$)Nc>T$r(rC)r passthroughs r,r @MulticastTests.test_multicast..cleanup.. s;r/)rrr)rr rs` r,r.MulticastTests.test_multicast..cleanups%"1??3F   6 7Mr/) rErrrr~rrHrrrkr)r+joinedrrrrMrrs` @@@r,test_multicastMulticastTests.test_multicasts H  # #Aq$.. 9{{$$,,.&&001D1DE  8$ H 8$  7# r/zjon non-linux platforms it appears multiple processes can listen, but not multiple sockets in same process?c# [5n[[5nURSUSURS9nUR 5n[ U[[45(deURn[5nURUUSURS9n[URRRUR5URUR5URUR5/5IShvN [5=ol[5=olURR#SURU45 [X/5IShvN UR%UR&SSS5 UR%UR&SSS5 [[)UR*5[)UR*5/5IShvN gNNN 7f)z Test that multiple sockets can listen on the same multicast port and that they both receive multicast messages directed to that address. rT)listenMultipler~Nr)rErrrrr~r isinstancerrrrrrHrrkrrGrrr)rr) r+ firstClientmreactor firstPortfpAddrportno secondClient secondPortd1d2s r,test_multiListenMulticastTests.test_multiListensh $W-,, {44>>- ""$&; "<====x --  nn .  %%//0C0CD##D$7$78$$T%8%89    +3*4 '+3:5 (##NT5H5H&4QRRH%%% ,,Q/2NC --a03^Di556j667    '  &  s8DG.G(AG.#G*$A>G."G,#G.*G.,G.)rrrrN)r~r)r>r?r@rArlr~rPrirjrkrlrmrnrprArDrrrrrrr platform isWindowsisVistarrrrBrCr/r,rfrfesIs#,y,$M3$'NC'$/ /"-i-#L####    60 .D ""$GW-=-=-E-E-G)G<  @ ""$  .  . r/rfff03::1::z/The local stack does not enable IPv6 multicast.c\rSrSr%SrSrS\S'SrS\S'SrS\S '\ "S \ "555r S \S '\ r S \S 'Sr S\S'SrS \S'SrS\S'Srg)MulticastTestsIPv6iHz; Tests for sending and receiving IPv6 multicast datagrams. rrgr~rorjrrkc#`# UH$oSRS5(dMUSv M& g7f)r2lorN) startswith).0idxnms r, MulticastTestsIPv6.^s%K~eq1D1DT1Jq~s. .rhrlrmrnrrir|rprCN)r>r?r@rArlr~rPrjrknextr rlrmrnrirprBrCr/r,rrHsp IsM3#NC#$(K|~K% #5i4L##$y$))r/r) rZr r[intr\rr]rgr^rgr~bool)=rl __future__rr;rrrrrrr r r r r unittestrtwisted.internetrrrrrrtwisted.internet.addressrrtwisted.internet.deferrrrtwisted.internet.errorrtwisted.internet.interfacesrrrtwisted.internet.taskrtwisted.pythonr twisted.test.testutilsr!twisted.trial.unittestr"r#r%DatagramProtocolrEConnectedDatagramProtocolrSrer"rjrnrSryr?rbrfrrCr/r,rs' #     MM=II5 -"25& UH-- UH66.Y@))@,J " "7D 113VWN+xN+XN+b J " "7D 113VW3h3X3l #+.7:DG .$$Wd33-". y A  V XV  V r$$Wd33-",D 6  **  *r/