h.SrSSKrSSKJr SSKJrJrJrJr SSK J r SSK J r SSK Jr SSKJr "S S 5r\"\ 5"S S 55r\"\R&\R(5"S S55rSrSr\4SjrSrSr\"\R&\R(5"SS55r"SS\R85r"SS\R<5rSSjr SSjr!g)zF Testing support for protocols -- loopback between client and server. N) implementer)defer interfacesmainprotocol)IAddress) deferLater)policies)failurec<\rSrSrSrSrSrSrSrSr \ r Sr S r g) _LoopbackQueuez Trivial wrapper around a list to give it an interface like a queue, which the addition of also sending notifications by way of a Deferred whenever the list has something added to it. NFc/UlgN)_queueselfs a/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/protocols/loopback.py__init___LoopbackQueue.__init__"s  cURRU5 URb%URSso lURS5 ggr)rappend_notificationDeferredcallback)rvds rput_LoopbackQueue.put%sD 1  % % 1,0,F,F )A) JJt  2rc,[UR5$r)boolrrs r __nonzero___LoopbackQueue.__nonzero__+sDKK  rc8URRS5$Nr)rpoprs rget_LoopbackQueue.get0s{{q!!r)rr) __name__ __module__ __qualname____firstlineno____doc__r disconnectrrr"__bool__r'__static_attributes__rrr r s/ !J !H"rr c\rSrSrSrg)_LoopbackAddress4r1N)r)r*r+r,r0r1rrr3r34srr3cX\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrg)_LoopbackTransport9FNcXlgr)q)rr9s rr_LoopbackTransport.__init__?srcz[U[5(d [S5eURR U5 g)Nz"Can only write bytes to ITransport) isinstancebytes TypeErrorr9rrdatas rwrite_LoopbackTransport.writeBs+$&&@A A  4rcXURRSRU55 gNr)r9rjoinriovecs r writeSequence _LoopbackTransport.writeSequenceGs  388E?#rc\SURlURRS5 g)NT)r9r.rrs rloseConnection!_LoopbackTransport.loseConnectionJs   4rc$UR5 g)z2 Abort the connection. Same as L{loseConnection}. N)rKrs rabortConnection"_LoopbackTransport.abortConnectionNs rc[5$rr3rs rgetPeer_LoopbackTransport.getPeerT !!rc[5$rrQrs rgetHost_LoopbackTransport.getHostWrTrcZURbeXlX lUR5 gr)producerstreamingProducer _pollProducerrrY streamings rregisterProducer#_LoopbackTransport.registerProducer[s)}}$$$ !* rc0URceSUlgrrYrs runregisterProducer%_LoopbackTransport.unregisterProduceras}}((( rcxURb-UR(dURR5 gggr)rYrZresumeProducingrs rr[ _LoopbackTransport._pollProduceres- == $T-C-C MM ) ) +.D $r)rYr9rZ)r)r*r+r, disconnectingrYrrArHrKrNrRrVr^rbr[r0r1rrr6r69s>MH $ "" ,rr6cpU(a/UR5nUcgURU5 U(aM.gg)z L{identityPumpPolicy} is a policy which delivers each chunk of data written to the given queue as-is to the target. This isn't a particularly realistic policy. @see: L{loopbackAsync} N)r' dataReceived)queuetargetr=s ridentityPumpPolicyrljs/   = E" %rc/nU(a.UR5nUcOURU5 U(aM.U(a!URSRU55 gg)z L{collapsingPumpPolicy} is a policy which collapses all outstanding chunks into a single string and delivers it to the target. @see: L{loopbackAsync} Nr)r'rrirE)rjrkr=chunks rcollapsingPumpPolicyrozsR E   =  U %  CHHUO, rc[5n[5nUR[U55 UR[U55 [XXU5$)a Establish a connection between C{server} and C{client} then transfer data between them until the connection is closed. This is often useful for testing a protocol. @param server: The protocol instance representing the server-side of this connection. @param client: The protocol instance representing the client-side of this connection. @param pumpPolicy: When either C{server} or C{client} writes to its transport, the string passed in is added to a queue of data for the other protocol. Eventually, C{pumpPolicy} will be called with one such queue and the corresponding protocol object. The pump policy callable is responsible for emptying the queue and passing the strings it contains to the given protocol's C{dataReceived} method. The signature of C{pumpPolicy} is C{(queue, protocol)}. C{queue} is an object with a C{get} method which will return the next string written to the transport, or L{None} if the transport has been disconnected, and which evaluates to C{True} if and only if there are more items to be retrieved via C{get}. @return: A L{Deferred} which fires when the connection has been closed and both sides have received notification of this. )r makeConnectionr6_loopbackAsyncBody)serverclient pumpPolicyserverToClientclientToServers r loopbackAsyncrxsP6$%N#%N ,^<= ,^<=   rcT^U4SjnS=n=pxU"XU5nU"X#U5nU(dDU(d=[R"5n XlXlU R[UUUUT5 U $UR (a SnU"XU5 OUR (a SnU"X#U5 U(a|UR [R"[R55 UR [R"[R55 [R"S5$GM!)a? Transfer bytes from the output queue of each protocol to the input of the other. @param server: The protocol instance representing the server-side of this connection. @param serverToClient: The L{_LoopbackQueue} holding the server's output. @param client: The protocol instance representing the client-side of this connection. @param clientToServer: The L{_LoopbackQueue} holding the client's output. @param pumpPolicy: See L{loopbackAsync}. @return: A L{Deferred} which fires when the connection has been closed and both sides have received notification of this. c~>SnU(a T"X5 SnU(a!U(dURR5 U$)NFT) transportr[)sourcer9rksentrus rpump _loopbackAsyncBody..pumps6 q !D     * * , rFTN) rDeferredr addCallback_loopbackAsyncContinuer.connectionLostr FailurerCONNECTION_DONEsucceed) rsrvrtrwrur~r. clientSent serverSentrs ` rrrrrs(  /44 4Z&&9 &&9 * A34 034 0 MM&  H  $ $J  0  & &J  0   ! !'//$2F2F"G H  ! !'//$2F2F"G H==& &I rc VSUlSUlSSKJn [US[UUUUU5$)Nrreactor)rtwisted.internetrr rr)ignoredrsrvrtrwrurs rrrs> ,0N(+/N( )    rcd\rSrSrSrSrSrSrSSjrSr Sr Sr S r S r S rS rS rSrSrg) LoopbackRelayirrNcXlX lgr)rklogFile)rrkrs rrLoopbackRelay.__init__s   rcURU-UlUR(a(URRS[U5-5 gg)Nzloopback writing %s )bufferrrAreprr?s rrALoopbackRelay.writes:kkD( << LL  6dC D rcDURSRU55 grD)rArErFs rrHLoopbackRelay.writeSequence"s 388E?#rc(URS:XagUR(aURR5 UR(apUR(a1URR S[ UR5-5 URnSUlURRU5 URS:XaESUlURR[R"[R55 gg)Nzloopback receiving %s r) shouldLoserYrerrrArrkrirr rrr)rrs r clearBufferLoopbackRelay.clearBuffer%s ??b  == MM ) ) + ;;|| ""#>r)rrrYrrkr)r)r*r+r,rrrgrYrrArHrrKrVrRr^rbrr0r1rrrrsJ FJMHE $N  !?rrc&\rSrSrSrSrSrSrg)LoopbackClientFactoryiIcRSUl[R"5UlXlgr%) disconnectedrrdeferredr)rrs rrLoopbackClientFactory.__init__Js(  rcUR$r)r)raddrs r buildProtocol#LoopbackClientFactory.buildProtocolOs }}rcHSUlURRS5 g)Nr)rrr)r connectorreasons rclientConnectionLost*LoopbackClientFactory.clientConnectionLostRs t$r)rrrN)r)r*r+r,rrrr0r1rrrrIs! %rrc \rSrSrSrSrSrg) _FireOnCloseiWcx[RRXU5 [R"5Ulgr)r ProtocolWrapperrrrr)rrfactorys rr_FireOnClose.__init__Xs&  ))$'B( rcx[RRX5 URR S5 gr)r rrrr)rrs rr_FireOnClose.connectionLost\s(  //= t$rrN)r)r*r+r,rrr0r1rrrrWs )%rrc^^ SSKJn [R"[R "55n[ XP5m X5lU 4SjUlURX%SS9m[U5nX6lURSTR5RU5 URnURU 4Sj5 URU4Sj5 U$)zBRun session between server and client protocol instances over TCP.rrc>T$rr1r serverWrappers rloopbackTCP..h=rz 127.0.0.1) interfacec>TR$rrxrs rrrn M22rc$>TR5$r stopListeningr serverPorts rrroJ446r)rrr WrappingFactoryrFactoryrnoisyr listenTCPr connectTCPrVportrr) rsrtrrrfclientFrrrs @@r loopbackTCPras(  !1!1!34A +MG0AO""4k"BJ#F+GM {J$6$6$8$=$=wGAMM23MM67 Hrc^^ [R"5nSSKJn [R "[ R"55n[XP5m X%l U 4SjUl URX55m[U5nX&l URX65 URnURU 4Sj5 URU4Sj5 U$)zJRun session between server and client protocol instances over UNIX socket.rrc>T$rr1rs rrloopbackUNIX..{rrc>TR$rrrs rrrrrc$>TR5$rrrs rrrrr)tempfilemktemprrr rrrrrr listenUNIXr connectUNIXrr) rsrtrpathrrrrrrs @@r loopbackUNIXrss ?? D(  !1!1!34A +MG0AO##D,J#F+GM &AMM23MM67 Hr)rT)T)"r-rzope.interfacerrrrrrtwisted.internet.interfacesrtwisted.internet.taskr twisted.protocolsr twisted.pythonr r r3 ITransport IConsumerr6rlrorxrrrr ClientFactoryrrrrrr1rrrs  &>>0,'"""8 X    Z " "J$8$89-,-,:-,` # -".@#LD'N4 Z " "J$8$893?3?:3?l %H22 %%8++% $ r