֛hSrSSKJr SSKJrJrJrJrJr SSK J r SSK J r J r JrJ r SSKJr SSKJr SSKJrJr SS KJrJrJrJrJr SS KJr SS K Jr \rSS K J!r!J"r" SSK#J$r$J%r%J&r&J'r'J(r( SSK)J*r* SSK+J,r,J-r-J.r. SSK/J0r0J1r1 SSK2J3r3J4r4J5r5 SSK6J7r7J8r8J9r9J:r: SSK;Jr> SSK?J@r@ SSKAJBrBJCrCJDrDJErEJFrF SSKGJHrH SSKIJJrJJKrKJLrLJMrMJNrN SSKOJPrP SSKQJRrR SSKSJTrT SSKUJVrVJWrWJXrX SSKYJZrZ SSK[J\r\J]r] SSK^J_r_ SS K`Jara \Z"S!5rbS"rc\Z"S!5bS#rc"S$S%5rdS&re"S'S(\D5rf"S)S*\B5rg\""\75"S+S,\B55rh"S-S.\d\H\C5ri"S/S0\d\H5rj"S1S25rk"S3S45rl"S5S65rm"S7S8\l\m\H\M5rn"S9S:\k\m\H\M5ro"S;S<\N\H5rp\q"5R\iR55 \q"5R\jR55 \q"5R\nR55 \q"5R\oR55 \q"5R\pR55 "S=S>\H\E5rt\q"5R\tR55 \"\]S?:gS@5"SASB\a55rug !\a S rGNcf=f)Cz/ Tests for implementations of L{IReactorUNIX}. )md5)closefstatstatunlinkurandom)pformat)AF_INET SOCK_STREAM SOL_SOCKETsocket)S_IMODE)pack)mkstempmktemp)AnyCallableOptionalSequenceType)skipIf)AF_UNIXN) Interface implementer)baseerror interfacesreactortcp) UNIXAddress)Deferredfail gatherResults)UNIXClientEndpointUNIXServerEndpoint)CannotListenErrorConnectionClosedFileDescriptorOverrun)IFileDescriptorReceiver IReactorFDSetIReactorSocket IReactorUNIX) ClientFactoryDatagramProtocol ServerFactory) LoopingCall)ConnectableProtocolConnectionTestsMixinEndpointCreatorStreamClientTestsMixinrunProtocolsWithReactor)ReactorBuilder)ClosingFactoryMyClientFactoryMyServerFactoryStreamTransportTestsMixinWriteSequenceTestsMixin) nativeString)Failure)_coerceToFilesystemEncoding) addObservererrremoveObserver) requireModule)platform platformType)AccumulatingProtocol)TestCaseztwisted.python.sendmsgz>sendmsg extension unavailable, extended UNIX features disabledc\rSrSrSrSrSrg)UNIXFamilyMixinMzC Test-helper defining mixin for things related to AF_UNIX sockets. cSnUR5n[XQ5"X#US9nUR5 UR[ [ U5R 5U5 g)ze Assert that the mode of the created unix socket is set to the mode specified to the reactor method. i)modeN) buildReactorgetattr stopListening assertEqualrrst_mode)self methodNamepathfactoryrLrunixPorts cC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_unix.py _modeTestUNIXFamilyMixin._modeTestRsS ##%7/DI  d!3!34d;N)__name__ __module__ __qualname____firstlineno____doc__rX__static_attributes__r[rZrWrIrIMs  >rZr[N)r\r]r^r_r`rr,rjrrrr__annotations__rqrvrar[rZrWrhrhes7@J?V?V>X$y/!:;X1?rZrhc.\rSrSrSrSrSrSrSrSr g)SendFileDescriptor{z L{SendFileDescriptorAndBytes} sends a file descriptor and optionally some normal bytes and then closes its connection. @ivar reason: The reason the connection was lost, after C{connectionLost} is called. NcXlX lg)z @param fd: A C{int} giving a file descriptor to send over the connection. @param data: A C{str} giving data to send over the connection, or L{None} if no data is to be sent. N)fddata)rRr}r~s rW__init__SendFileDescriptor.__init__s rZcURRUR5 UR(a%URR UR5 URR 5 g)zV Send C{self.fd} and, if it is not L{None}, C{self.data}. Then close the connection. N) transportsendFileDescriptorr}r~writeloseConnectionrRs rWconnectionMade!SendFileDescriptor.connectionMadesG ))$''2 99 NN  + %%'rZc<[R"X5 XlgN)r1connectionLostreasonrRrs rWr!SendFileDescriptor.connectionLosts**48 rZ)r~r}r) r\r]r^r_r`rrrrrar[rZrWrzrz{sF (rZrzc8\rSrSrSrSrSrSrSrSr Sr Sr g) ReceiveFileDescriptora] L{ReceiveFileDescriptor} provides an API for waiting for file descriptors to be received. @ivar reason: The reason the connection was lost, after C{connectionLost} is called. @ivar waiting: A L{Deferred} which fires with a file descriptor once one is received, or with a failure if the connection is lost with no descriptor arriving. Nc|URc[5UlUR$[UR5$)z Return a L{Deferred} which will fire with the next file descriptor received, or with a failure if the connection is or has already been lost. )rr!waitingr"rs rWwaitForDescriptor'ReceiveFileDescriptor.waitForDescriptors0 ;; #:DL<<  $ $rZcHURRU5 SUlg)zi Fire the waiting Deferred, initialized by C{waitForDescriptor}, with the file descriptor just received. N)rcallback)rR descriptors rWfileDescriptorReceived,ReceiveFileDescriptor.fileDescriptorReceiveds j) rZc URb:URR[[SU<S3555 SUlgg)a/ Fail the waiting Deferred, if it has not already been fired by C{fileDescriptorReceived}. The bytes sent along with a file descriptor are guaranteed to be delivered to the protocol's C{dataReceived} method only after the file descriptor has been delivered to the protocol's C{fileDescriptorReceived}. NzReceived bytes (z) before descriptor.)rerrbackr= ExceptionrRr~s rW dataReceived"ReceiveFileDescriptor.dataReceivedsF << # LL  $4TH.raiseSocketErrors<= =rZcreateInternetSocketznot-usedN)patchrBasePortrM assertRaisesr&rr/)rRrrs rWtest_listenFailure#UNIXTestsBuilder.test_listenFailuresZ  > 4=="8:JK##%   0 1   z=? ;2 1 1s A// A=c[U5nUR5nUR"SU-[55nUR UR 5[ SU-55 g)zK L{IReactorUNIX.connectUNIX} also accepts a Linux abstract namespace path. rN)rfrM connectUNIXr-rPgetDestinationr )rRrTr connectors rW$test_connectToLinuxAbstractNamespace5UNIXTestsBuilder.test_connectToLinuxAbstractNamespace sVT"##%''t ]_E  113[5MNrZc"SS[5nU"5nU"5n[XX0R5 URURSURS5 URURSURS5 g)z A client's transport's C{getHost} and C{getPeer} return L{UNIXAddress} instances which have the filesystem path of the host and peer ends of the connection. c\rSrSrSrSrg)4UNIXTestsBuilder.test_addresses..SaveAddressi"cz[UR5UR5S9UlUR 5 g)N)hostpeer)dictrgetPeer addressesr)rRrs rWmakeConnectionCUNIXTestsBuilder.test_addresses..SaveAddress.makeConnection#s3!%"**,93D3D3F"((*rZ)rN)r\r]r^r_rrar[rZrW SaveAddressr"s +rZrrrN)r1r5 endpointsrPr)rRrrqrvs rWtest_addressesUNIXTestsBuilder.test_addressessy +- +fnnE ))&163C3CF3KL ))&163C3CF3KLrZcn^^^^SSKJm [5mTRS5 [TR 5S5m[ 5nUR 5nUUU4SjnURU5 UR[S5 URU4Sj5 [TTUTR5 g) z L{IUNIXTransport.sendFileDescriptor} accepts an integer file descriptor and sends a copy of it to the process reading from the connection. r)fromfd)rGrjunkc>T"U[[5n[U5 TRTR 5UR 55 TR TR 5UR 55 gr)r r rrP getsocknameassertNotEqualfileno)rreceivedrsrRs rWcheckDescriptorAUNIXTestsBuilder.test_sendFileDescriptor..checkDescriptor@sYj';?H *    Q]]_h.B.B.D E    HOO,= >rZz-Sending file descriptor encountered a problemc8>TRR5$rrrignoredrqs rW:UNIXTestsBuilder.test_sendFileDescriptor..P&"2"2"A"A"CrZN) r rbindrzrrr addCallback addErrbackr@addBothr5r)rRrvdrrrrqs` @@@rWtest_sendFileDescriptor(UNIXTestsBuilder.test_sendFileDescriptor1s " H w#AHHJ8&(  $ $ & ? o& SIJ CDffdnnErZc"SS[5n"SS[5nU"5nU"5nXCl[XX@R5 UR UR S5 g)zm If a L{IUNIXTransport.sendFileDescriptor} call fills up the send buffer, any registered producer is paused. c\rSrSrSrSrg)SUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..DoesNotReadi[c8URR5 gr)rpauseProducingrs rWrbUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..DoesNotRead.connectionMade\s--/rZr[Nr\r]r^r_rrar[rZrW DoesNotReadr[s 0rZrc6\rSrSrSrSrSrSrSrSr Sr g ) `UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptorsi_Fc0^[5TlTRRTS5 U4Sjn[U5TlTRR TRlTRRS5R[S5 g)NTc>TRRTRR55 TRR S5 g)Nx)rrr rrrsrWsenderUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.connectionMade..senderfs4NN55dkk6H6H6JKNN((.rZrzSend loop failure) r rregisterProducerr0taskrclockstartrr@)rRrs` rWroUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.connectionMadebsf$h //d;/(/ "&.."8"8  "--c3FGrZc$UR5 gr _disconnectrs rW stopProducingnUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.stopProducingn  "rZc$UR5 grrrs rWresumeProducingpUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.resumeProducingqrrZcfSUlURR5 UR5 g)NT)pausedrunregisterProducerrrs rWroUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.pauseProducingts%" 113  "rZcURR5 URR5 URRR5 gr)rstoprabortConnectionotherrs rWrlUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors._disconnectys6  ..0 $$446rZ)r r rN) r\r]r^r_r rrrrrrar[rZrWSendsManyFileDescriptorsr_s!F H # # #  7rZrz*sendFileDescriptor producer was not pausedN)r1rr5r assertTruer )rRrrrqrvs rW-test_sendFileDescriptorTriggersPauseProducing>UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducingTsS 0- 0 7': 7>*+ fnnE  'STrZc^[5n[UR5S5m[5n/nUR 5nUR UR 5 UR U4Sj5 [UTX R5 URUS[5 USR[5 URTRR[5 g)a7 If L{IUNIXTransport.sendFileDescriptor} is used to queue a greater number of file descriptors than the number of bytes sent using L{ITransport.write}, the connection is closed and the protocol connected to the transport has its C{connectionLost} method called with a failure wrapping L{FileDescriptorOverrun}. Nc8>TRR5$rrrs rWr=UNIXTestsBuilder.test_fileDescriptorOverrun..rrZr)r rzrrrrappendr5rassertIsInstancer=trapr'rvaluer()rRcargorvresultrrqs @rWtest_fileDescriptorOverrun+UNIXTestsBuilder.test_fileDescriptorOverruns#ELLND9&(  $ $ & &--  CDffnnE fQi1q '( fmm113HIrZcp^SSKJn SSKJn SSKJn Sm[ [5"U4SjS[55n"SS U5nU"[[5upxURUR5 URUR5 U"5n U"X5n [5up[5upUR[U 5 UR[U5 S nX/nU"U5unnU"XU5 U R5 UR![#U R$5U5 UR'[)U5R+[)U R$555 U R$(a5UVs/sH nT"U5PM nnUR!UU R,5 g g s snf) a9 Drive _SendmsgMixin via sendmsg socket calls to check that L{IFileDescriptorReceiver.fileDescriptorReceived} is called once for each file descriptor received in the ancillary messages. @param ancillaryPacker: A callable that will be given a list of two file descriptors and should return a two-tuple where: The first item is an iterable of zero or more (cmsg_level, cmsg_type, cmsg_data) tuples in the same order as the given list for actual sending via sendmsg; the second item is an integer indicating the expected number of FDs to be received. r socketpair) _SendmsgMixinsendmsgcH[U5nURUR4$r)rst_devst_ino)r}fss rWdeviceInodeTupleTUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..deviceInodeTuplesrBIIryy) )rZc(>\rSrSrSrU4SjrSrg)PUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocolic /Ul/Ulgr)fdsdeviceInodesReceivedrs rWrYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocol.__init__s,.)rZc>URRU5 URRT"U55 [U5 gr)r/rr0r)rRr}r*s rWrgUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocol.fileDescriptorReceiveds4#))001A"1EFb rZ)r0r/N)r\r]r^r_rrra)r*srW FakeProtocolr-s /  rZr4c6\rSrSrSrSrSrSrSrSr Sr g ) PUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceivericXlX lgr)r protocol)rRsktprotos rWrYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.__init__s ! % rZcgrr[rs rW _dataReceived^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver._dataReceivedrZcgrr[rs rWrXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.getHostr@rZcgrr[rs rWrXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.getPeerr@rZcgrr[)rRos rW _getLogPrefix^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver._getLogPrefixr@rZ)r9r N) r\r]r^r_ bufferSizerr>rrrGrar[rZrW FakeReceiverr6s J &    rZrJssome data needs to be sentN)r r"twisted.internet.unixr#twisted.python.sendmsgr%rr)r1rr addCleanuprrrdoReadrPlenr/ assertFalseset intersectionr0)rRancillaryPackerr"r#r%r4rJ sendSocket recvSocketr;receiver fileOneFD fileOneName fileTwoFD fileTwoName dataToSend fdsToSend ancillary expectedCountr}deviceInodesSentr*s @rW)_sendmsgMixinFileDescriptorReceivedDriver:UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriversm: &72 * , - .  .  = &",G[!A   (()  (() 2") !(   ,  ,2 * #29#= = 2 UYY7 Y44S^DE 99?HIy 0 4y I   -u/I/I J IsF3c@^SSKJm U4SjnURU5 g)z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: single CMSG with two FDs. r SCM_RIGHTSc6>[T[S/UQ764/nSnX4$)Niir r)r\r]r^rds rWrS[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSG..ancillaryPacker s*$j$t2Hi2HIJIM+ +rZNrLrdr`rRrSrds @rW1test_multiFileDescriptorReceivedPerRecvmsgOneCMSGBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSGs 6 , 66GrZz=Multi control message ancillary sendmsg not supported on Mac.c@^SSKJm U4SjnURU5 g)z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: two CMSGs with one FD each. rrcc ^>UVs/sHn[T[SU54PM nnSnX#4$s snf)Nirgrh)r\r}r]r^rds rWrS\UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs..ancillaryPackers8KTU9R*j$sB-@9IUM+ +Vs*Nrjrks @rW2test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGsCUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGss 6 , 66GrZc.^^SSKJm SnU4Sjn/n[UR5 UR [ UR5 UR TSU5 URU5 Sm[U4SjU55nURUS5 g ) z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: unsupported CMSGs. rr$c/nSnX4$)Nrr[)r\r]r^s rWrS[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..ancillaryPacker3sIM+ +rZc6>SnS/nSnTRX4U5$)Ns some data)NNrZr)ReceivedMessage)r:argskwargsr~r]flagsr%s rWfakeRecvmsgUnsupportedAncillarykUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..fakeRecvmsgUnsupportedAncillary8s(D*+IE**4EB BrZrecvmsgz#received unsupported ancillary datac34># UH nTUS;v M g7f)formatNr[).0eexpectedMessages rW UUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..GsCFqOq{2Fsz+Expected message not found in logged eventsN) twisted.pythonr%r?rrMrArr`anyr)rRrSr|eventsfoundrr%s @@rW1test_multiFileDescriptorReceivedPerRecvmsgBadCMSGBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG$s~ + ,  C FMM"  6 7I'FG 66G@CFCC LMrZcSSKJn U"5up#/n[UR5 UR [ UR5 "SS[ 5nU"UR5S5n[5n[XXpR5 UR5 URS5 URSURS55 S nS n [UR UR"U US 9n UH3n U R%5HupXR'U 5:wdM M1 g UR)S U <S [+U5<S35 g)z If associated with a protocol which does not provide L{IFileDescriptorReceiver}, file descriptors received by the L{IUNIXTransport} implementation are closed and a warning is emitted. rr!c\rSrSrSrSrg)RUNIXTestsBuilder.test_avoidLeakingFileDescriptors..RecordEndpointAddressesi^cURR5UlURR5Ul[ R U5 gr)rr hostAddressr peerAddressrzrrs rWraUNIXTestsBuilder.test_avoidLeakingFileDescriptors..RecordEndpointAddresses.connectionMade_s:#'>>#9#9#; #'>>#9#9#; "11$7rZ)rrNrr[rZrWRecordEndpointAddressesr^s 8rZrrFrZr7z%(protocolName)s (on %(hostAddress)r) does not provide IFileDescriptorReceiver; closing file descriptor received (from %(peerAddress)r).r1)rr protocolNamerzExpected event (z) not found in logged events ()N)r r"r?rrMrArzrr1r5rr setblockingrPrecvrrritemsgetr"r )rRr" probeClient probeServerrrrqrvrclsName expectedEventlogEventkvs rW test_avoidLeakingFileDescriptors1UNIXTestsBuilder.test_avoidLeakingFileDescriptorsJs6 &#-< FMM"  6 8&8 8 )););)=wG$&fnnE  & k..t45 :  (****   H%++- Q'.   II" rZch^[[5"U4SjS[55n[5n[ UR 5S5nU"5n[ TX4TR5 TR[URS5 TRS[URSS55 g)zl L{IUNIXTransport.sendFileDescriptor} sends file descriptors before L{ITransport.write} sends normal bytes. c.>\rSrSrSrU4SjrSrSrg)JUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEventsic>[R"U5 /Ulgr)r1rrrs rWrYUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.connectionMades#2248  rZcz>TR[U5 URR[ U55 gr)rMrrrtype) innerSelfrrRs rWraUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.fileDescriptorReceiveds*z2  ''Z(89rZc:URRU5 gr)rextendrs rWrWUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.dataReceiveds ""4(rZ)rN)r\r]r^r_rrrrarsrW RecordEventsrs ! : )rZrrrN) rr)r1r rzrr5rrPintrbytes)rRrrrqrvs` rW#test_descriptorDeliveredBeforeBytes4UNIXTestsBuilder.test_descriptorDeliveredBeforeBytess , - ). ) . )#ELLNG<fdnnE fmmA./ % ab(9":;rZr[N)r\r]r^r_r`r,rjrhrrrrCisLinuxrrrrr%sendmsgSkipReasonrrrr`rlisMacOSXrrrrrrar[rZrWrrs' IE    E C  C <    EO OM, K*+ F, FD K*+.U,.U` K*+J,J.aKF K*+ H, H G K*+ H,  H K*+#N,#NJ K*+J,JX K*+<,[[5n[SSS9nURU5 UR S5 UR S5 UR "UR5URU5UR5 $!UR5 f=f)zR Get a UNIX port from a reactor, wrapping an already-initialized file descriptor. rlrmrnF) r rrrlistenradoptStreamPortrfamilyr)rRrrUportSockrTs rWgetListeningPort SocketUNIXMixin.getListeningPortsv '?W#. dU# **8??+?xHHrZr[N)r\r]r^r_r,rjrrrrrxrrrar[rZrWrr#s)?Ko$y/!:;MN IrZrc\rSrSrSrSrg)UNIXPortTestsBuilderi3z& Tests for L{IReactorUNIX.listenUnix} r[Nr\r]r^r_r`rar[rZrWrr3 rZrc\rSrSrSrSrg)UNIXFDPortTestsBuilderi>z+ Tests for L{IReactorUNIX.adoptStreamPort} r[Nrr[rZrWrr>rrZrc0\rSrSr\\\4rSrSr Sr Sr g)%UNIXAdoptStreamConnectionTestsBuilderiIcUR5nSSKJn "SS[5nU"[[ 5upEUR S5 URUR5 URUR5 UR5nU"5nUR"U[U5nURU5 g)zh {IReactorSocket.adoptStreamConnection} returns None if the given factory's buildProtocol returns None. rr!c\rSrSrSrSrg)XUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone..NoneFactoryi^cgrr[)rRrs rW buildProtocolfUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone..NoneFactory.buildProtocol_srZr[N)r\r]r^r_rrar[rZrW NoneFactoryr^s rZrFN) rMr r"r/rr rrMrradoptStreamConnection assertIsNone) rRrr"rs1s2s1FDrUrs rWtest_buildProtocolReturnsNoneCUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNonePs##%% - G[1 u ! !yy{-..tWgF &!rZc^U4SjnTR5nTRUSSS9nURU5 TRU5 g)z. Helper method to test UNIX server addresses. c2>Uupn[SUR5R5nTRSURR <SU<S3[ UR55 TRSURR <SU<3URR5 URRSnTRU[5 URR5 g!URR5 f=f)NrGzzAccumulatingProtocol,,r) r>rrtrPr sessionnostrlogstrrU peerAddressesrr r) protocolsrvrqrportPathrrRs rW connectedOUNIXAdoptStreamConnectionTestsBuilder.test_ServerAddressUNIX..connectedqs#, FD 26r4<<>;N;NO  ''118=(()   ''118=$$++ %nn::1= %%k;?  //1  //1s CC::DN) interface addressFamily)rMgetConnectedClientAndServerr runReactor)rRrrrs` rWtest_ServerAddressUNIXTR"UR5 TR"UR5 TR"URR 5[ T5 gr) removeReaderr removeWriterrrr)r;rrqs rWfirstServerConnected_UNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..firstServerConnectedsF   1   1  ) )%//*@*@*BGV TrZcL>TR(aTR"5 U$r)runningr )rrs rWr OUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..stops MrZc4>UupTRXT45 gr)r)rrvrqdeferredrs rWrPUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..starts&NF   vt4 5rZ)r9r!protocolConnectionMadeprotocolConnectionLostr8rrrr#rrrrrt)rRrrr firstServerrvrTr lostDeferredr  startDeferredrrrrqs ` @@@rWrAUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServers&&' -5Z * "(0 %(0 % "(0 %(0 %W#.!!$4 U **667KL$  * *F,I,I J   T":D!%  * *F,I,I J  6 !!%(DLLN//8rZr[N) r\r]r^r_r*r+r,rjrrrrar[rZrWrrIs# "8 !D6rZrc>\rSrSrSr\4rSr\S5r Sr Sr Sr g)UnixClientTestsBuilderiz/ Define tests for L{IReactorUNIX.connectUNIX}. NcTURc[U5UlUR$)zs Return a path usable by C{connectUNIX} and C{listenUNIX}. @return: A path instance, built with C{_abstractPath}. )_pathrfrs rWrTUnixClientTestsBuilder.paths$ :: &t,DJzzrZc<UR"URU5$)z Start an UNIX server with the given C{factory}. @param reactor: The reactor to create the UNIX port in. @param factory: The server factory. @return: A UNIX port instance. )rrTrRrrUs rWrUnixClientTestsBuilder.listens!!$))W55rZc<UR"URU5$)z Start an UNIX client with the given C{factory}. @param reactor: The reactor to create the connection in. @param factory: The client factory. @return: A UNIX connector instance. )rrTr"s rWconnectUnixClientTestsBuilder.connects""499g66rZ)r) r\r]r^r_r`r,rjrpropertyrTrr%rar[rZrWrrs2' E  6 7rZrposixz%UNIX sockets only supported on POSIX.cT\rSrSrSrSrSrS\\\/S4SS4Sjr S r S r S r S r g) RealSocketTestsiz$ Test real UNIX socket connections. unixpathc# [RR[5(de[ 5n[R "UR U5n[U[R5(deX!l URUR5 [5n[R"UR U5 URIShvN UR (deUR#UR R$5 UR#UR&5 UR(R+[,R.5 gN7f)zd A port created with L{IReactorTCP.listenUNIX} can be connected to with L{IReactorTCP.connectUNIX}. N)rr, providedByrr7rrT isinstancerPortrrMcleanUpr8rr lastProtocolrmade disconnected lostReasonrrConnectionDone)rRfrclientFs rWtest_closePortInProtocolFactory/RealSocketTests.test_closePortInProtocolFactorys &&11'::::  !!$))Q/$))))  "!#DIIw/#### ,,112 ))* 4 45 sCEEBErNreturncv# [RR[5(de[ 5n[ 5nX2l[R"URU5nURUR5 [5n[ 5nXel[R"URU5 [X6/5IShvN upxU"Xx5 UR(deUR(deURR5 URR5 gNi7f)zq Invoke the given callback with a client protocol and a server protocol which have been connected to each other. N)rr,r-rr9r!rrrTrMrOr8rr#rr) rRr serverFactoryserverConnMaderr7clientConnMadeserverProtocolclientProtocols rW_connectedClientAndServerTest-RealSocketTests._connectedClientAndServerTests&&11'::::') 9A/=,!!$))]; **+!#(0 )7&DIIw//<  ,0 * & 0''''''''  //1  //1* sC D9 D7A*D9cp^# S[S[SS4U4SjjnTRU5IShvN gN7f)z The transport of a protocol connected with L{IReactorTCP.connectUNIX} or L{IReactor.TCP.listenUNIX} can have L{ITCPTransport.getTcpNoDelay} or L{ITCPTransport.setTcpNoDelay} called without error. r?r@r:Nc>X4Hn[RRUR5(deURnTR UR 5S5 UR S5 TR UR 5S5 UR S5 TR UR 5S5 M g)NrTF)r ITCPTransportr-rrP getTcpNoDelay setTcpNoDelayr?r@prrRs rWcheck.RealSocketTests.test_tcpNoDelay..checkAs%5!//::1;;GGGGKK   !8!8!:A>''-  !8!8!:A>''.  !8!8!:A>6rZrErArRrJs` rWtest_tcpNoDelayRealSocketTests.test_tcpNoDelay:s9 ?0 ?BV ?  ?00777 +646cp^# S[S[SS4U4SjjnTRU5IShvN gN7f)z The transport of a protocol connected with L{IReactorTCP.connectUNIX} or L{IReactor.TCP.listenUNIX} can have its I{SO_KEEPALIVE} state inspected and manipulated with L{ITCPTransport.getTcpKeepAlive} and L{ITCPTransport.setTcpKeepAlive}. r?r@r:Nc>X4Hn[RRUR5(deURnTR UR 5S5 UR S5 TR UR 5S5 UR S5 TR UR 5S5 M g)NFT)rrEr-rrPgetTcpKeepAlivesetTcpKeepAliverHs rWrJ0RealSocketTests.test_tcpKeepAlive..checkWs%5!//::1;;GGGGKK   !:!:!twisted.python.logr?r@rAtwisted.python.reflectrBtwisted.python.runtimerCrDtwisted.test.test_tcprEtwisted.trial.unittestrFr%rrIrfrhrzrrrrrrrrrglobalsupdatemakeTestCaseClassesrr*r[rZrWrs 22;;$::*G1BB0@@M  UT-?/*???096+ 0 1)*6K <<")?/?,","J $%;/;&;|S<8LS 6JJLM*7^-C*7Z ';;=> !HIp0hp0Jp0UGsJ22J>=J>