Yf&dZddlmZddlmZmZmZmZmZddl m Z ddl m Z m Z mZm Z ddlmZddlmZddlmZmZdd lmZmZmZdd lmZ dd l mZeZn #e$rd ZYnwxYwdd lmZm Z ddl!m"Z"m#Z#ddl$m%Z%ddl&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7m8Z8m9Z9ddl:m;Z;ddlZ>m?Z?m@Z@mAZAddlBmCZCddlDmEZEmFZFmGZGmHZHddlImJZJddlKmLZLddlMmNZNddlOmPZPmQZQmRZRddlSmTZTddlUmVZVeTdZWd ZXeTdd!ZXGd"d#ZYd$ZZGd%d&e?Z[Gd'd(e=Z\e e2Gd)d*e=Z]Gd+d,eYeCe>Z^Gd-d.eYeCZ_Gd/d0Z`Gd1d2ZaGd3d4ZbGd5d6eaebeCeGZcGd7d8e`ebeCeGZdGd9d:eHeCZeefge^hefge_hefgechefgedhefgeehGd;dsendmsg extension unavailable, extended UNIX features disabledceZdZdZdZdS)UNIXFamilyMixinzK Test-helper defining mixin for things related to AF_UNIX sockets. cd}|}t|||||}||t t |j|dS)z} 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 methodNamepathfactoryrBreactorunixPorts Q/var/www/html/env/lib/python3.11/site-packages/twisted/internet/test/test_unix.py _modeTestzUNIXFamilyMixin._modeTestOsy ##%%/77J//gDIII    d!344d;;;;;N)__name__ __module__ __qualname____doc__rOrPrNr@r@Js- < < < < >>rPN)rQrRrSrTrr'r]rrrr__annotations__rdrhrUrPrNr\r\bsg@J?V>X$y/!:;XXX111?????rPr\c(eZdZdZdZdZdZdZdS)SendFileDescriptorz 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. Nc"||_||_dS)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)rHrmrns rN__init__zSendFileDescriptor.__init__s rPc|j|j|jr|j|j|jdS)zn Send C{self.fd} and, if it is not L{None}, C{self.data}. Then close the connection. N) transportsendFileDescriptorrmrnwriteloseConnectionrHs rNconnectionMadez!SendFileDescriptor.connectionMadesX ))$'222 9 , N  + + + %%'''''rPc>tj||||_dSN)r,connectionLostreasonrHrzs rNryz!SendFileDescriptor.connectionLosts *4888 rP)rQrRrSrTrzrorvryrUrPrNrkrkxsRF   (((rPrkc2eZdZdZdZdZdZdZdZdZ dS)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. Ncl|jt|_|jSt|jS)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. )rzrwaitingrrus rNwaitForDescriptorz'ReceiveFileDescriptor.waitForDescriptors/ ; #::DL<  $$ $rPcH|j|d|_dS)z Fire the waiting Deferred, initialized by C{waitForDescriptor}, with the file descriptor just received. N)rcallback)rH descriptors rNfileDescriptorReceivedz,ReceiveFileDescriptor.fileDescriptorReceiveds% j))) rPc |jA|jttd|dd|_dSdS)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.)rerrbackr7 ExceptionrHrns rN dataReceivedz"ReceiveFileDescriptor.dataReceivedsZ < # L  "QT"Q"Q"QRRSS    DLLL $ #rPctj|||j!|j|d|_||_dS)zj Fail the waiting Deferred, initialized by C{waitForDescriptor}, if there is one. N)r,ryrrrzr{s rNryz$ReceiveFileDescriptor.connectionLostsG *4888 < # L  ( ( (DL rP) rQrRrSrTrzrrrrryrUrPrNr}r}sf  FG % % %         rPr}cneZdZdZefZeZdZe e j ddZ dZ e e j ddZdZe e edZe e ed Ze e ed Zd Ze e ed Ze e jd e e edZe e edZe e edZe e edZdS)UNIXTestsBuilderz= Builder defining tests relating to L{IReactorUNIX}. cp|d|tdS)zs The UNIX socket created by L{IReactorUNIX.listenUNIX} is created with the mode specified. listenUNIXN)rOrr*rus rN test_modezUNIXTestsBuilder.test_modes, |T[[]]MOODDDDDrP8Abstract namespace UNIX sockets only supported on Linux.ct|}|}|d|zt}||t d|zdS)z On Linux, a UNIX socket path may begin with C{''} to indicate a socket in the abstract namespace. L{IReactorUNIX.listenUNIX} accepts such a path. N)rZrCrr*rFgetHostrrHrJrLports rN#test_listenOnLinuxAbstractNamespacez4UNIXTestsBuilder.test_listenOnLinuxAbstractNamespacesoT""##%%!!$+}?? TD[)A)ABBBBBrPc d}|tjd||}|t 5|dtddddS#1swxYwYdS)z L{IReactorUNIX.listenUNIX} raises L{CannotListenError} if the underlying port's createInternetSocket raises a socket error. c td)Nz FakeBasePort forced socket.error)OSErrorrus rNraiseSocketErrorz=UNIXTestsBuilder.test_listenFailure..raiseSocketErrors<== =rPcreateInternetSocketznot-usedN)patchrBasePortrC assertRaisesr!rr*)rHrrLs rNtest_listenFailurez#UNIXTestsBuilder.test_listenFailures  > > > 4="8:JKKK##%%   0 1 1 < <   z=?? ; ; ; < < < < < < < < < < < < < < < < < .SaveAddressct|||_|dS)N)hostpeer)dictrgetPeer addressesrt)rHrqs rNmakeConnectionzCUNIXTestsBuilder.test_addresses..SaveAddress.makeConnection sO!%"**,,93D3D3F3F"""((*****rPN)rQrRrSrrUrPrN SaveAddressrs# + + + + +rPrrrN)r,r0 endpointsrFr)rHrrdrhs rNtest_addresseszUNIXTestsBuilder.test_addressess + + + + +- + + +ffdnEEE )&163CF3KLLL )&163CF3KLLLLLrPcddlmtdtdt }|}fd}|||td| fdt|j dS) z L{IUNIXTransport.sendFileDescriptor} accepts an integer file descriptor and sends a copy of it to the process reading from the connection. r)fromfd)r>rjunkc<|tt}t|||dSrx)r r rrF getsocknameassertNotEqualfileno)rreceivedrsrHs rNcheckDescriptorzAUNIXTestsBuilder.test_sendFileDescriptor..checkDescriptor=svj';??H *      Q]]__h.B.B.D.D E E E    HOO,=,= > > > > >rPz-Sending file descriptor encountered a problemc6jSrxrqrtignoredrds rNz:UNIXTestsBuilder.test_sendFileDescriptor..M&"2"A"A"C"CrPN) r rbindrkrr}r addCallback addErrbackr:addBothr0r)rHrhdrrrrds` @@@rNtest_sendFileDescriptorz(UNIXTestsBuilder.test_sendFileDescriptor.s "!!!!! HH w#AHHJJ88&((  $ $ & & ? ? ? ? ? ? ? o&&& SIJJJ CCCCDDDffdnEEEEErPcGddt}Gddt}|}|}||_t||||j||jddS)z If a L{IUNIXTransport.sendFileDescriptor} call fills up the send buffer, any registered producer is paused. ceZdZdZdS)SUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..DoesNotReadc8|jdSrx)rqpauseProducingrus rNrvzbUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..DoesNotRead.connectionMadeYs--/////rPNrQrRrSrvrUrPrN DoesNotReadrXs# 0 0 0 0 0rPrc0eZdZdZdZdZdZdZdZdS)`UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptorsFc(t_jdfd}t|_jjj_jdtddS)NTcjjjddS)Nx)rqrrr rrsrusrNsenderzUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.connectionMade..sendercsCN55dk6H6H6J6JKKKN((.....rPrzSend loop failure) r rqregisterProducerr+taskrLclockstartrr:)rHrs` rNrvzoUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.connectionMade_s$hh //d;;;/////(// "&."8  ""--c3FGGGGGrPc.|dSrx _disconnectrus rN stopProducingznUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.stopProducingk  """""rPc.|dSrxrrus rNresumeProducingzpUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.resumeProducingnrrPcnd|_|j|dS)NT)pausedrqunregisterProducerrrus rNrzoUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.pauseProducingqs5" 11333  """""rPc|j|j|jjdSrx)rstoprqabortConnectionotherrus rNrzlUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors._disconnectvsE    ..000 $4466666rPN) rQrRrSrrvrrrrrUrPrNSendsManyFileDescriptorsr\sgF H H H # # # # # # # # #  7 7 7 7 7rPrz*sendFileDescriptor producer was not pausedN)r,rr0r assertTruer)rHrrrdrhs rN-test_sendFileDescriptorTriggersPauseProducingz>UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducingQs 0 0 0 0 0- 0 0 0 7 7 7 7 7': 7 7 7>*)++ ffdnEEE  'STTTTTrPct}t|dt}g}|}||j|fdt|||j| |dt|d t| j jtdS)ag 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}. Nc6jSrxrrs rNrz=UNIXTestsBuilder.test_fileDescriptorOverrun..rrPr)r rkrr}rrappendr0rassertIsInstancer7trapr"rzvaluer#)rHcargorhresultrrds @rNtest_fileDescriptorOverrunz+UNIXTestsBuilder.test_fileDescriptorOverruns#ELLNND99&((  $ $ & & &-    CCCCDDDffdnEEE fQi111q '((( fm13HIIIIIrPcddlm}ddlm}ddlm}dt tGfddt}Gdd |}|tt\}}| |j | |j |} ||| } t\} } t\} }| t| | t|d }| | g}||\}}||||| |t#| j||t)|t)| j| jr+fd |D}||| jd Sd S) a 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) _SendmsgMixinsendmsgc<t|}|j|jfSrx)rst_devst_ino)rmfss rNdeviceInodeTuplezTUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..deviceInodeTuplesrBIry) )rPc eZdZdZfdZdS)PUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocolc"g|_g|_dSrx)fdsdeviceInodesReceivedrus rNrozYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocol.__init__s,.)))rPc|j||j|t|dSrx)rrrr)rHrmrs rNrzgUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocol.fileDescriptorReceivedsI###)001A1A"1E1EFFFb rPN)rQrRrSror)rsrN FakeProtocolrs= / / /       rPrc0eZdZdZdZdZdZdZdZdS)PUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiverc"||_||_dSrx)r protocol)rHsktprotos rNrozYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.__init__s! % rPcdSrxrUrs rN _dataReceivedz^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver._dataReceivedrPcdSrxrUrus rNrzXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.getHostrrPcdSrxrUrus rNrzXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.getPeerrrPcdSrxrU)rHos rN _getLogPrefixz^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver._getLogPrefixrrPN) rQrRrS bufferSizeror rrrrUrPrN FakeReceiverrsdJ & & &              rPrssome data needs to be sentc&g|] }|SrUrU).0rmrs rN zNUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..s%III 0 0 4 4IIIrPN)r rtwisted.internet.unixrtwisted.python.sendmsgrrr$r,rr addCleanuprrrdoReadrFlenr assertFalseset intersectionr)rHancillaryPackerrrrrr sendSocket recvSocketr receiver fileOneFD fileOneName fileTwoFD fileTwoName dataToSend fdsToSend ancillary expectedCountdeviceInodesSentrs @rN)_sendmsgMixinFileDescriptorReceivedDriverz:UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriversO: &%%%%%777777222222 * * * , - -       .   . -      =   &",G[!A!A J  ()))  ())) < E22") ;!( ;  ,,,  ,,,2  * #2?9#=#= = J 222 UY777 Y44S^^DDEEE 9 KIIIIyIII    -u/I J J J J J K KrPcHddlmfd}||dS)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_RIGHTSc<ttdg|Rfg}d}||fS)Niir rr*r+r,r1s rNr!z[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSG..ancillaryPackers2$j$t2Hi2H2H2HIJIMm+ +rPNrr1r.rHr!r1s @rN1test_multiFileDescriptorReceivedPerRecvmsgOneCMSGzBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSGsL 655555 , , , , , 66GGGGGrPz=Multi control message ancillary sendmsg not supported on Mac.cHddlmfd}||dS)z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: two CMSGs with one FD each. rr0c,fd|D}d}||fS)Nc@g|]}ttd|fS)ir5)rrmr1s rNrzpUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs..ancillaryPacker..s(UUUR*j$sB--@UUUrPr4rUr6s rNr!z\UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs..ancillaryPackers,UUUU9UUUIMm+ +rPNr7r8s @rN2test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGszCUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs sL 655555 , , , , , 66GGGGGrPcPddlmd}fd}g}t|j|t |j|d|||dtfd|D}| |dd S) z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: unsupported CMSGs. rrcg}d}||fS)NrrU)r*r+r,s rNr!z[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..ancillaryPacker0sIMm+ +rPc@d}dg}d}|||S)Ns some data)NNrPr)ReceivedMessage)r argskwargsrnr+flagsrs rNfakeRecvmsgUnsupportedAncillaryzkUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..fakeRecvmsgUnsupportedAncillary5s-D*+IE**4EBB BrPrecvmsgz#received unsupported ancillary datac3,K|]}|dvVdS)formatNrU)reexpectedMessages rN zUUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..Ds,CCqOq{2CCCCCCrPz+Expected message not found in logged eventsN) twisted.pythonrr9rrr;rr.anyr)rHr!rFeventsfoundrKrs @@rN1test_multiFileDescriptorReceivedPerRecvmsgBadCMSGzBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG!s +***** , , ,  C C C C C FM"""  666 7I'FGGG 66GGG@CCCCFCCCCC LMMMMMrPcddlm}|\}}g}t|j|t |jGddt }||d}t}t||||j | | d| d|dd }d } t|j|j| | } |D]:} | D] \} } | | | krn!dS;|d | d t+|ddS)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. rrceZdZdZdS)RUNIXTestsBuilder.test_avoidLeakingFileDescriptors..RecordEndpointAddressesc|j|_|j|_t |dSrx)rqr hostAddressr peerAddressrkrvrus rNrvzaUNIXTestsBuilder.test_avoidLeakingFileDescriptors..RecordEndpointAddresses.connectionMade\sH#'>#9#9#;#; #'>#9#9#;#; "11$77777rPNrrUrPrNRecordEndpointAddressesrT[s# 8 8 8 8 8rPrXrFrPrz%(protocolName)s (on %(hostAddress)r) does not provide IFileDescriptorReceiver; closing file descriptor received (from %(peerAddress)r).r,)rVrW protocolNamerIzExpected event (z) not found in logged events ()N)r rr9rrr;rkrr,r0rr setblockingrFrecvrrWrVitemsgetrr )rHr probeClient probeServerrOrXrdrhrIclsName expectedEventlogEventkvs rN test_avoidLeakingFileDescriptorsz1UNIXTestsBuilder.test_avoidLeakingFileDescriptorsGs &%%%%%#-:<< [FM"""  666 8 8 8 8 8&8 8 8 8 )(););)=)=wGG$&&ffdnEEE  &&& k..t44555 :  (**       H%++--  1 Q''E( III"MM     rPcttGfddt}t}t |d}|}t ||jt|j ddt|j dddS)z L{IUNIXTransport.sendFileDescriptor} sends file descriptors before L{ITransport.write} sends normal bytes. c&eZdZdZfdZdZdS)JUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEventsc<tj|g|_dSrx)r,rvrOrus rNrvzYUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.connectionMades#24888  rPct||jt |dSrx)rrrOrtype) innerSelfrrHs rNrzaUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.fileDescriptorReceiveds<z222 ''Z(8(899999rPc:|j|dSrx)rOextendrs rNrzWUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.dataReceiveds ""4(((((rPN)rQrRrSrvrrrusrN RecordEventsrisL ! ! ! : : : : : ) ) ) ) )rPrprrN) rr$r,r rkrr0rrFintrObytes)rHrprrdrhs` rN#test_descriptorDeliveredBeforeBytesz4UNIXTestsBuilder.test_descriptorDeliveredBeforeBytess , - - ) ) ) ) ) ) ). ) ) . - )#ELLNNG<<ffdnEEE fmA./// % abb(9":":;;;;;rPN)rQrRrSrTr'r]r\rrrr=isLinuxrrrrrsendmsgSkipReasonrrrr.r9isMacOSXr>rQrfrtrUrPrNrrs' IEEE V H   E C C  C < < < V H   EOO OMMM, VK*++ F F,+ FD VK*++.U.U,+.U` VK*++JJ,+J.aKaKaKF VK*++ H H,+ H VG VK*++ H H,+  H VK*++#N#N,+#NJ VK*++JJ,+JX VK*++<<,+<<c8||j|SaZ Connect to a listening UNIX socket. @param reactor: The reactor under test. @type reactor: L{IReactorUNIX} @param address: The listening's address. @type address: L{UNIXAddress} @param factory: The client factory. @type factory: L{ClientFactory} @return: The connector rrfrHrLaddressrKs rNconnectToListenerz!SocketUNIXMixin.connectToListener""7<999rPN)rQrRrSrTr'r&r]rrrrrirrrUrPrNrrsm ?$y/!:;  :::::rPrceZdZdZdZdZdS)ListenUNIXMixinzZ Mixin which uses L{IReactorTCP.listenUNIX} to hand out listening UNIX ports. cPtdd}|||S)z0 Get a UNIX port from a reactor r_r`ra)rr)rHrLrKrJs rNrz ListenUNIXMixin.getListeningPorts, W#...!!$000rPc8||j|Srrrs rNrz!ListenUNIXMixin.connectToListenerrrPN)rQrRrSrTrrrUrPrNrrs< 111:::::rPrcPeZdZUefZeeeee d<dZ dZ dS)UNIXPortTestsMixinr]cX|dt|jS)zZ Get the message expected to be logged when a UNIX port starts listening. z starting on r6rrf)rHrrKs rN#getExpectedStartListeningLogMessagez6UNIXPortTestsMixin.getExpectedStartListeningLogMessage#s+MM T\\^^5H(I(IMMMrPcVdt|jdS)zJ Get the expected connection lost message for a UNIX port z (UNIX Port z Closed)r)rHrs rNgetExpectedConnectionLostLogMsgz2UNIXPortTestsMixin.getExpectedConnectionLostLogMsg)s)I\$,,..*=>>HHHHrPN) rQrRrSr'r]rrrrrirrrUrPrNrr s]?Ko$y/!:;MMMNNN IIIIIrPrceZdZdZdS)UNIXPortTestsBuilderz. Tests for L{IReactorUNIX.listenUnix} NrQrRrSrTrUrPrNrr0 rPrceZdZdZdS)UNIXFDPortTestsBuilderz3 Tests for L{IReactorUNIX.adoptStreamPort} NrrUrPrNrr;rrPrc*eZdZeeefZdZdZdZ dS)%UNIXAdoptStreamConnectionTestsBuilderc|}ddlm}Gddt}|tt \}}|d||j||j| }|}| |t|}| |dS)z {IReactorSocket.adoptStreamConnection} returns None if the given factory's buildProtocol returns None. rrceZdZdZdS)XUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone..NoneFactorycdSrxrU)rHrs rN buildProtocolzfUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone..NoneFactory.buildProtocol\strPN)rQrRrSrrUrPrN NoneFactoryr[s#     rPrFN) rCr rr*rr r[rrradoptStreamConnection assertIsNone) rHrLrrs1s2s1FDrKrs rNtest_buildProtocolReturnsNonezCUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNoneMs##%%%%%%%%     -   G[11B u !!! !!!yy{{+--..tWgFF &!!!!!rPcfd}}|dd}|||dS)z> Helper method to test UNIX server addresses. c|\}}} td|j}d|jjd|dt |jd|jjd||jj|jj d} |t|j dS#|j wxYw)Nr>zzAccumulatingProtocol,,r) r8rrfrFrq sessionnostrlogstrrK peerAddressesrrrt) protocolsrhrdrportPathrWrHs rN connectedzOUNIXAdoptStreamConnectionTestsBuilder.test_ServerAddressUNIX..connectedns#, FFD 26r4<<>>;NOO   '111888=())    '11188=$+ %n:1= %%k;??? //11111 //1111s B=C!!C<N) interface addressFamily)rCgetConnectedClientAndServerr runReactor)rHrrLrs` rNtest_ServerAddressUNIXz.firstServerConnecteds[   1 1 1   1 1 1  ) )%/*@*@*B*BGV T T T T TrPc>jr|Srx)runningr)rrLs rNrzOUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..stops  MrPcB|\}}||fdSrx)r)rrhrddeferredrs rNrzPUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..starts-&NFF   vvt4 5 5 5 5 5rP)r3rprotocolConnectionMadeprotocolConnectionLostr2rrrrrrrrrf)rHrLrr firstServerrhrJr lostDeferredr startDeferredrrrrds ` @@@rNrzAUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServers&'' -5ZZ * ""(0 %(0 % ""(0 %(0 %W#...!!$ 44 U U U U U U *667KLLL$  *F,I J        T"""::D!!!%  *F,I J   6 6 6 6 6 6 !!%(((DLLNN/888rPN) rQrRrSr%r&r'r]rrrrUrPrNrrFsS """8 ! ! !D66666rPrc>eZdZdZefZdZedZdZ dZ dS)UnixClientTestsBuilderz7 Define tests for L{IReactorUNIX.connectUNIX}. NcF|jt||_|jS)z Return a path usable by C{connectUNIX} and C{listenUNIX}. @return: A path instance, built with C{_abstractPath}. )_pathrZrus rNrJzUnixClientTestsBuilder.paths# : &t,,DJzrPc8||j|S)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. )rrJrHrLrKs rNrzUnixClientTestsBuilder.listens!!$)W555rPc8||j|S)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. )rrJrs rNconnectzUnixClientTestsBuilder.connects""49g666rP) rQrRrSrTr'r]rpropertyrJrrrUrPrNrrsd' E X 6 6 6 7 7 7 7 7rPr)jrThashlibrosrrrrrpprintr r r r r rstructrtempfilerrtypingrrrunittestrr_AF_UNIX ImportErrorzope.interfacerrtwisted.internetrrtwisted.internet.addressrtwisted.internet.deferrrrtwisted.internet.endpointsrr twisted.internet.errorr!r"r#twisted.internet.interfacesr$r%r&r'twisted.internet.protocolr(r)r*twisted.internet.taskr+&twisted.internet.test.connectionmixinsr,r-r.r/r0#twisted.internet.test.reactormixinsr1twisted.internet.test.test_tcpr2r3r4r5twisted.python.compatr6twisted.python.failurer7twisted.python.filepathr8twisted.python.logr9r:r;twisted.python.reflectr<twisted.python.runtimer=rrvr@rZr\rkr}rryrrrrrrglobalsupdatemakeTestCaseClassesrrUrPrNrs 22222222222222;;;;;;;;;;;;$$$$$$$$++++++++++******GGGGG 21111111--------000000@@@@@@@@@@MMMMMMMM  UTTTTTTTTT------?>>>>> /.....******????????????????000000++++++ -0 1 1=)**6K <<<<<<<<")))?????/???,""""","""J  $%%;;;;;/;;&%;|S<S<S<S<S<8LS<S<S>> 6JJLLMMM*7*7*7*7*7^-C*7*7*7Z ';;==>>>>>sAA! A!