Vh~dZddlmZddlmZmZmZmZmZddl m Z ddl m Z m Z mZm Z ddlmZddlmZddlmZmZdd lmZmZmZmZmZdd lmZ dd l mZeZdd l m!Z!m"Z"ddl#m$Z$m%Z%m&Z&m'Z'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5ddl6m7Z7m8Z8m9Z9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFddlGmHZHddlImJZJmKZKmLZLmMZMmNZNddlOmPZPddlQmRZRddlSmTZTddlUmVZVmWZWmXZXddlYmZZZddl[m\Z\m]Z]ddl^m_Z_dd l`maZaeZd!Zbd"ZceZd!d#ZcGd$d%Zdd&ZeGd'd(eDZfGd)d*eBZge"e7Gd+d,eBZhGd-d.edeHeCZiGd/d0edeHZjGd1d2ZkGd3d4ZlGd5d6ZmGd7d8elemeHeMZnGd9d:ekemeHeMZoGd;deHeEZteqjetjee]d?k7d@GdAdBeaZuy #e$rd ZYawxYw)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 disabledceZdZdZdZy)UNIXFamilyMixinzK Test-helper defining mixin for things related to AF_UNIX sockets. cd}|j}t|||||}|j|jt t |j |y)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 methodNamepathfactoryrKrunixPorts O/home/dcms/DCMS/lib/python3.12/site-packages/twisted/internet/test/test_unix.py _modeTestzUNIXFamilyMixin._modeTestRsY ##%/77J/gDI  d!3!34d;N)__name__ __module__ __qualname____doc__rWrXrVrIrIMs  >rXN)rYrZr[r\rr,rerrrr__annotations__rlrpr]rXrVrdrdes7@J?V?V>X$y/!:;X1?rXrdc&eZdZdZdZdZdZdZy)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 ||_||_y)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)rQrurvs rV__init__zSendFileDescriptor.__init__s rXc|jj|j|jr%|jj |j|jj y)zn Send C{self.fd} and, if it is not L{None}, C{self.data}. Then close the connection. N) transportsendFileDescriptorrurvwriteloseConnectionrQs rVconnectionMadez!SendFileDescriptor.connectionMadesG ))$''2 99 NN  + %%'rXc>tj||||_yN)r1connectionLostreasonrQrs rVrz!SendFileDescriptor.connectionLosts**48 rX)rYrZr[r\rrwr~rr]rXrVrsrs{sF (rXrsc0eZdZdZdZdZdZdZdZdZ y)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. Ncz|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. )rr!waitingr"r}s rVwaitForDescriptorz'ReceiveFileDescriptor.waitForDescriptors0 ;; #:DL<<  $ $rXcH|jj|d|_y)z Fire the waiting Deferred, initialized by C{waitForDescriptor}, with the file descriptor just received. N)rcallback)rQ descriptors rVfileDescriptorReceivedz,ReceiveFileDescriptor.fileDescriptorReceiveds j) rXc |j9|jjttd|dd|_yy)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= ExceptionrQrvs rV dataReceivedz"ReceiveFileDescriptor.dataReceivedsF << # LL  $4TH **48 << # LL  (DL rX) rYrZr[r\rrrrrrr]rXrVrrs' FG %   rXrceZdZdZefZeZdZe e j ddZ dZ e e j ddZdZe e edZe e ed Ze e ed Zd Ze e ed Ze e j.d e e edZe e edZe e edZe e edZy)UNIXTestsBuilderz= Builder defining tests relating to L{IReactorUNIX}. cV|jd|jty)zs The UNIX socket created by L{IReactorUNIX.listenUNIX} is created with the mode specified. listenUNIXN)rWrr/r}s rV test_modezUNIXTestsBuilder.test_modes |T[[]MODrX8Abstract namespace UNIX sockets only supported on Linux.ct|}|j}|jd|zt}|j |j t d|zy)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)rbrLrr/rOgetHostr rQrSrports rV#test_listenOnLinuxAbstractNamespacez4UNIXTestsBuilder.test_listenOnLinuxAbstractNamespacesUT"##%!w!!$+}? TD[)ABrXcd}|jtjd||j}|j t 5|j dtdddy#1swYyxYw)z L{IReactorUNIX.listenUNIX} raises L{CannotListenError} if the underlying port's createInternetSocket raises a socket error. ctd)Nz FakeBasePort forced socket.error)OSErrorr}s rVraiseSocketErrorz=UNIXTestsBuilder.test_listenFailure..raiseSocketErrors<= =rXcreateInternetSocketznot-usedN)patchrBasePortrL assertRaisesr&rr/)rQrrs rVtest_listenFailurez#UNIXTestsBuilder.test_listenFailurese  > 4=="8:JK##%   0 1 < G  z=? ; < < .SaveAddressct|j|j|_|j y)N)hostpeer)dictrgetPeer addressesr|)rQrys rVmakeConnectionzCUNIXTestsBuilder.test_addresses..SaveAddress.makeConnection#s3!%"**,93D3D3F"((*rXN)rYrZr[rr]rXrV SaveAddressr"s +rXrrrN)r1r5 endpointsrOr)rQrrlrps rVtest_addresseszUNIXTestsBuilder.test_addressess} +- +ffdnnE ))&163C3CF3KL ))&163C3CF3KLrXcjddlmtjdtj dt }|j }fd}|j||jtd|jfdt|jy) 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|tt}t|jj |j j j |j yr)r r rrO getsocknameassertNotEqualfileno)rreceivedrsrQs rVcheckDescriptorzAUNIXTestsBuilder.test_sendFileDescriptor..checkDescriptor@sYj';?H *    Q]]_h.B.B.D E    HOO,= >rXz-Sending file descriptor encountered a problemc8jjSrryr|ignoredrls rVz:UNIXTestsBuilder.test_sendFileDescriptor..P&"2"2"A"A"CrXN) r rbindrsrrr addCallback addErrbackr@addBothr5r)rQrpdrrrrls` @@@rVtest_sendFileDescriptorz(UNIXTestsBuilder.test_sendFileDescriptor1s " H w#AHHJ8&(  $ $ & ? o& SIJ CDffdnnErXcGddt}Gddt}|}|}||_t||||j|j |j dy)z If a L{IUNIXTransport.sendFileDescriptor} call fills up the send buffer, any registered producer is paused. ceZdZdZy)SUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..DoesNotReadc8|jjyr)rypauseProducingr}s rVr~zbUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..DoesNotRead.connectionMade\s--/rXNrYrZr[r~r]rXrV DoesNotReadr[s 0rXrc.eZdZdZdZdZdZdZdZy)`UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptorsFc.t_jjdfd}t|_jj j_jjdjtdy)NTcjjjjjj dy)Nx)ryrzr rr{r}srVsenderzUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.connectionMade..senderfs4NN55dkk6H6H6JKNN((.rXrzSend loop failure) r ryregisterProducerr0taskrclockstartrr@)rQrs` rVr~zoUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.connectionMadebsf$h //d;/(/ "&.."8"8  "--c3FGrXc$|jyr _disconnectr}s rV stopProducingznUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.stopProducingn  "rXc$|jyrrr}s rVresumeProducingzpUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.resumeProducingqrrXcfd|_|jj|jy)NT)pausedryunregisterProducerrr}s rVrzoUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors.pauseProducingts%" 113  "rXc|jj|jj|jjjyr)rstopryabortConnectionotherr}s rVrzlUNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducing..SendsManyFileDescriptors._disconnectys6  ..0 $$446rXN) rYrZr[rr~rrrrr]rXrVSendsManyFileDescriptorsr_s!F H # # #  7rXrz*sendFileDescriptor producer was not pausedN)r1rr5r assertTruer)rQrrrlrps rV-test_sendFileDescriptorTriggersPauseProducingz>UNIXTestsBuilder.test_sendFileDescriptorTriggersPauseProducingTsY 0- 0 7': 7>*+ ffdnnE  'STrXct}t|jdt}g}|j }|j |j |j fdt|||j|j|dt|djt|jjjty)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}. Nc8jjSrrrs rVrz=UNIXTestsBuilder.test_fileDescriptorOverrun..rrXr)r rsrrrrappendr5rassertIsInstancer=trapr'rvaluer()rQcargorpresultrrls @rVtest_fileDescriptorOverrunz+UNIXTestsBuilder.test_fileDescriptorOverruns#ELLND9&(  $ $ & &--  CDffdnnE fQi1q '( fmm113HIrXcjddlm}ddlm}ddlm}dt tGfddt}Gdd |}|tt\}}|j|j|j|j|} ||| } t\} } t\} }|jt| |jt|d }| | g}||\}}||||| j|j!t#| j$||j't)|j+t)| j$| j$r2|Dcgc] }| }}|j!|| j,y y cc}w) 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) _SendmsgMixinsendmsgcHt|}|j|jfSr)rst_devst_ino)rufss rVdeviceInodeTuplezTUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..deviceInodeTuplesrBIIryy) )rXceZdZdZfdZy)PUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocolc g|_g|_yr)fdsdeviceInodesReceivedr}s rVrwzYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocol.__init__s,.)rXc|jj||jj|t|yr)r rr r)rQrurs rVrzgUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeProtocol.fileDescriptorReceiveds4#))001A"1EFb rXN)rYrZr[rwr)rsrV FakeProtocolrs  / rXr c.eZdZdZdZdZdZdZdZy)PUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiverc ||_||_yr)r protocol)rQsktprotos rVrwzYUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.__init__s! % rXcyrr]rs rV _dataReceivedz^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver._dataReceivedrXcyrr]r}s rVrzXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.getHostrrXcyrr]r}s rVrzXUNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver.getPeerrrXcyrr])rQos rV _getLogPrefixz^UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriver..FakeReceiver._getLogPrefixrrXN) rYrZr[ bufferSizerwrrrrr]rXrV FakeReceiverrs J &    rXrssome data needs to be sentN)r rtwisted.internet.unixrtwisted.python.sendmsgrrr)r1rr addCleanuprrrdoReadrOlenr  assertFalseset intersectionr )rQancillaryPackerrrrr r sendSocket recvSocketrreceiver fileOneFD fileOneName fileTwoFD fileTwoName dataToSend fdsToSend ancillary expectedCountrudeviceInodesSentrs @rV)_sendmsgMixinFileDescriptorReceivedDriverz:UNIXTestsBuilder._sendmsgMixinFileDescriptorReceivedDriversx: &72 * , - .  .  = &",G[!A J  (()  (() E2") ;!( ;  ,  ,2  * #29#= = J 2 UYY7 Y44S^DE 99?HI 0 4I I   -u/I/I J IsF0c>ddlmfd}|j|y)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_RIGHTSc8ttdg|fg}d}||fS)Niir r)r/r0r1r6s rVr&z[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSG..ancillaryPacker s,$j$t2Hi2HIJIMm+ +rXNrr6r3rQr&r6s @rV1test_multiFileDescriptorReceivedPerRecvmsgOneCMSGzBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgOneCMSGs 6 , 66GrXz=Multi control message ancillary sendmsg not supported on Mac.c>ddlmfd}|j|y)z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: two CMSGs with one FD each. rr5c Z|Dcgc]}ttd|f}}d}||fScc}w)Nir9r:)r/rur0r1r6s rVr&z\UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGs..ancillaryPackers9KTUR*j$sB-@UIUMm+ +Vs(Nr;r<s @rV2test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGszCUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgTwoCMSGss 6 , 66GrXc*ddlmd}fd}g}t|j|j t |j|j d||j|dtfd|D}|j|dy ) z _SendmsgMixin handles multiple file descriptors per recvmsg, calling L{IFileDescriptorReceiver.fileDescriptorReceived} once per received file descriptor. Scenario: unsupported CMSGs. rrcg}d}||fS)Nrr])r/r0r1s rVr&z[UNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..ancillaryPacker3sIMm+ +rXc8d}dg}d}j|||S)Ns some data)NNrXr)ReceivedMessage)rargskwargsrvr0flagsrs rVfakeRecvmsgUnsupportedAncillaryzkUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..fakeRecvmsgUnsupportedAncillary8s*D*+IE**4EB BrXrecvmsgz#received unsupported ancillary datac3,K|] }|dv yw)formatNr]).0eexpectedMessages rV zUUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG..GsCqOq{2Csz+Expected message not found in logged eventsN) twisted.pythonrr?rr rArr3anyr)rQr&rIeventsfoundrOrs @@rV1test_multiFileDescriptorReceivedPerRecvmsgBadCMSGzBUNIXTestsBuilder.test_multiFileDescriptorReceivedPerRecvmsgBadCMSG$s~ + ,  C FMM"  6 7I'FG 66G@CFCC LMrXcddlm}|\}}g}t|j|j t |jGddt }||jd}t}t||||j|j|jd|jd|jdd }d } t|j |j"| | } |D]1} | j%D]\} } | | j'| k7s0y|j)d | d t+|dy)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. rrceZdZdZy)RUNIXTestsBuilder.test_avoidLeakingFileDescriptors..RecordEndpointAddressesc|jj|_|jj|_t j |yr)ryr hostAddressr peerAddressrsr~r}s rVr~zaUNIXTestsBuilder.test_avoidLeakingFileDescriptors..RecordEndpointAddresses.connectionMade_s:#'>>#9#9#; #'>>#9#9#; "11$7rXNrr]rXrVRecordEndpointAddressesrX^s 8rXr\rFrXrz%(protocolName)s (on %(hostAddress)r) does not provide IFileDescriptorReceiver; closing file descriptor received (from %(peerAddress)r).r1)rZr[ protocolNamerLzExpected event (z) not found in logged events ()N)r rr?rr rArsrr1r5rr setblockingrOrecvrr[rZitemsgetr"r )rQr probeClient probeServerrSr\rlrprLclsName expectedEventlogEventkvs rV test_avoidLeakingFileDescriptorsz1UNIXTestsBuilder.test_avoidLeakingFileDescriptorsJsJ &#-< [FMM"  6 8&8 8 )););)=wG$&ffdnnE  & k..t45 :  (****    H%++- 1 Q'     II" rXchttGfddt}t}t |j d}|}t ||jjt|jdjdt|jddy)z L{IUNIXTransport.sendFileDescriptor} sends file descriptors before L{ITransport.write} sends normal bytes. c$eZdZdZfdZdZy)JUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEventsc<tj|g|_yr)r1r~rSr}s rVr~zYUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.connectionMades#2248  rXczjt||jjt |yr)r rrSrtype) innerSelfrrQs rVrzaUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.fileDescriptorReceiveds*z2  ''Z(89rXc:|jj|yr)rSextendrs rVrzWUNIXTestsBuilder.test_descriptorDeliveredBeforeBytes..RecordEvents.dataReceiveds ""4(rXN)rYrZr[r~rrr}srV RecordEventsrms ! : )rXrtrrN) rr)r1r rsrr5rrOintrSbytes)rQrtrrlrps` rV#test_descriptorDeliveredBeforeBytesz4UNIXTestsBuilder.test_descriptorDeliveredBeforeBytess , - ). ) . )#ELLNG<ffdnnE fmmA./ % ab(9":;rXN)rYrZr[r\r,rerdrrrrCisLinuxrrrrrsendmsgSkipReasonrrrr3r=isMacOSXrArUrjrxr]rXrVrrs' IE H   E C  C < H   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*+<,?xHHrXN) rYrZr[r,rerrrrrqrrr]rXrVrr#s)?Ko$y/!:;MN IrXrceZdZdZy)UNIXPortTestsBuilderz. Tests for L{IReactorUNIX.listenUnix} NrYrZr[r\r]rXrVrr3 rXrceZdZdZy)UNIXFDPortTestsBuilderz3 Tests for L{IReactorUNIX.adoptStreamPort} Nrr]rXrVrr>rrXrc(eZdZeeefZdZdZdZ y)%UNIXAdoptStreamConnectionTestsBuilderc|j}ddlm}Gddt}|tt \}}|j d|j|j|j|j|j}|}|j|t|}|j|y)z {IReactorSocket.adoptStreamConnection} returns None if the given factory's buildProtocol returns None. rrceZdZdZy)XUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone..NoneFactorycyrr])rQrs rV buildProtocolzfUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNone..NoneFactory.buildProtocol_srXN)rYrZr[rr]rXrV NoneFactoryr^s rXrFN) rLr rr/rr r_r rradoptStreamConnection assertIsNone) rQrrrs1s2s1FDrTrs rVtest_buildProtocolReturnsNonezCUNIXAdoptStreamConnectionTestsBuilder.test_buildProtocolReturnsNonePs##%% - G[1B u ! !yy{-...tWgF &!rXcfd}j}j|dd}|j|j|y)z> Helper method to test UNIX server addresses. c,|\}}} td|jj}jd|jj d|dt |jjd|jj d||jj|jjd}j|t|jjy#|jjwxYw)NrGzzAccumulatingProtocol,,r) r>rrnrOry sessionnostrlogstrrT peerAddressesrr r|) protocolsrprlrportPathr[rQs rV connectedzOUNIXAdoptStreamConnectionTestsBuilder.test_ServerAddressUNIX..connectedqs#, FFD 26r4<<>;N;NO  ''118=(()   ''118=$$++ %nn::1= %%k;?  //1  //1s CC77DN) interface addressFamily)rLgetConnectedClientAndServerr runReactor)rQrrrs` rVtest_ServerAddressUNIXz.firstServerConnectedsL G  1 G  1 )G ) )%//*@*@*BGV TrXcBjrj|Sr)runningr)rrs rVrzOUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..stops MrXc8|\}}j||fyr)r)rrprldeferredrs rVrzPUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..starts!&NFF   vvt4 5rX)r9r!protocolConnectionMadeprotocolConnectionLostr8rrrr#rrrrrn)rQrrr firstServerrprSr lostDeferredr startDeferredrrrrls ` @@@rVrzAUNIXAdoptStreamConnectionTestsBuilder.getConnectedClientAndServers,&' -5Z * "(0 %(0 % "(0 %(0 %W#.!w!!$ 4 U **667KL$  * *F,I,I J   T":D!%  * *F,I,I J  6 !!%(DLLN//8rXN) rYrZr[r*r+r,rerrrr]rXrVrrIs# "8 !D6rXrc6eZdZdZefZdZedZdZ dZ y)UnixClientTestsBuilderz7 Define tests for L{IReactorUNIX.connectUNIX}. NcR|jt||_|jS)z Return a path usable by C{connectUNIX} and C{listenUNIX}. @return: A path instance, built with C{_abstractPath}. )_pathrbr}s rVrSzUnixClientTestsBuilder.paths$ :: &t,DJzzrXc<|j|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. )rrSrQrrTs rVrzUnixClientTestsBuilder.listens"w!!$))W55rXc<|j|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. )rrSrs rVconnectzUnixClientTestsBuilder.connects#w""499g66rX) rYrZr[r\r,rerpropertyrSrrr]rXrVrrs2' E  6 7rXrposixz%UNIX sockets only supported on POSIX.cJeZdZdZdZdZdeeegdfddfdZdZ d Z d Z y) RealSocketTestsz, Test real UNIX socket connections. unixpathcKtjjtsJt }tj |j |}t|tjsJ||_ |j|jt}tj|j ||jd{|j sJ|j#|j j$|j#|j&|j(j+t,j.y7|w)z| A port created with L{IReactorTCP.listenUNIX} can be connected to with L{IReactorTCP.connectUNIX}. N)rr, providedByrr7rrS isinstancerPortrr cleanUpr8rr lastProtocolrmade disconnected lostReasonrrConnectionDone)rQfrclientFs rVtest_closePortInProtocolFactoryz/RealSocketTests.test_closePortInProtocolFactorys &&11':::  !!$))Q/$)))  "!#DIIw/#### ,,112 ))* 4 45 sCE E A=ErNreturnc^KtjjtsJt }t }||_tj|j|}|j|jt}t }||_tj|j|t||gd{\}}||||jsJ|jsJ|jj|jjy7aw)z Invoke the given callback with a client protocol and a server protocol which have been connected to each other. N)rr,rrr9r!rrrSr rNr8rr#ryr|) rQr serverFactoryserverConnMaderrclientConnMadeserverProtocolclientProtocols rV_connectedClientAndServerTestz-RealSocketTests._connectedClientAndServerTests&&11':::') 9A/= ,!!$))]; **+!#(0 )7&DIIw//< ^ ,0 * & 0''''''''  //1  //1* sCD- D+ A"D-clKdtdtddffd }j|d{y7w)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. rrrNc||fD]}tjj|jsJ|j}j |j d|j dj |j d|j dj |j dy)NrTF)r ITCPTransportrryrO getTcpNoDelay setTcpNoDelayrrpryrQs rVcheckz.RealSocketTests.test_tcpNoDelay..checkAs%n5 ?!//::1;;GGGKK   !8!8!:A>''-  !8!8!:A>''.  !8!8!:A> ?rXrErrQrs` rVtest_tcpNoDelayzRealSocketTests.test_tcpNoDelay:s: ?0 ?BV ?  ?00777 )424clKdtdtddffd }j|d{y7w)a 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}. rrrNc||fD]}tjj|jsJ|j}j |j d|j dj |j d|j dj |j dy)NFT)rrrryrOgetTcpKeepAlivesetTcpKeepAlivers rVrz0RealSocketTests.test_tcpKeepAlive..checkWs%n5 E!//::1;;GGGKK   !:!:! E0 EBV E  E00777rcKtjjtsJt }tj d|d|j d{|jjtjy7.w)zb Tests whether attempting to establish connection to non-existing UNIX path fails z non-existing)timeoutN) rr,rrr8r failDeferredrrr ConnectError)rQrs rV test_FailingzRealSocketTests.test_Failingesh&&11':::!#NGQ?""""E../ #sAB B/B ) rYrZr[r\rSrrrErrrrr]rXrVrrsH D6,2 "68L!Mt!ST2 2<8*8, 0rXr)vr\hashlibrosrrrrrpprintr r r r r rstructrtempfilerrtypingrrrrrunittestrr_AF_UNIX ImportErrorzope.interfacerrtwisted.internetrrrrrtwisted.internet.addressr twisted.internet.deferr!r"r#twisted.internet.endpointsr$r%twisted.internet.errorr&r'r(twisted.internet.interfacesr)r*r+r,twisted.internet.protocolr-r.r/twisted.internet.taskr0&twisted.internet.test.connectionmixinsr1r2r3r4r5#twisted.internet.test.reactormixinsr6twisted.internet.test.test_tcpr7r8r9r:r;twisted.python.compatr<twisted.python.failurer=twisted.python.filepathr>twisted.python.logr?r@rAtwisted.python.reflectrBtwisted.python.runtimerCrDtwisted.test.test_tcprEtwisted.trial.unittestrFrrzrIrbrdrsrrr}rrrrrrglobalsupdatemakeTestCaseClassesrrr]rXrVr)s 22;;$::*G1BB0@@M  UT-?/*???096+ 0 1)*6K <<")?/?,","J $%;/;&;|S<8LS 6JJLM*7^-C*7Z ';;=> !HIp0hp0Jp0UGsJ11J<;J<