+ jRt^RIHt^RIHt^RIHt^RIHtH t H t H t ^RI H t Ht^RIHtHt^RIHt^RIHtHtHtHt^R IHt^R IHt^R IHt^R IH t ^R I!H"t"H#t#H$t$H%t%H&t&H't'H(t(H)t)H*t*H+t+H,t,H-t-H.t.H/t/H0t0H1t1H2t2H3t3^RI4H5t5H6t6H7t7H8t8H9t9H:t:H;t;HH?t?^RI@HAtA^RIBHCtCHDtD^RIEHFtFHGtG!RR]H4tI!RR]H4tJ]A!RR./4tKRtLRtMRtNRtORtP!RR] 4tQ!R R!4tR!R"R#]R] 4tS!R$R%]R] 4tT!R&R'] 4tU!R(R)4tV!R*R+4tW!R,R-] 4tX]!]C4!R.R/44tY!R0R1] 4tZ!R2R3] 4t[!R4R5] 4t\!R6R7] 4t]!R8R9] 4t^R:#);z& Tests for L{twisted.web._newclient}. )Optional) implementer) verifyObject)CancelledErrorDeferredfailsucceed)ConnectionDoneConnectionLost) IConsumer IPushProducer)Protocol)AccumulatingProtocolEventLoggingObserverStringTransport StringTransportWithDisconnection)globalLogPublisher) LineReceiver)Failure)TestCase)BODYDONEHEADERSTATUSUNKNOWN_LENGTH BadHeadersBadResponseVersionChunkedEncoderConnectionAborted ExcessWriteHTTPClientParser HTTPParserLengthEnforcingConsumer ParseErrorRequestNotSentTransportProxyProducerWrongBodyLengthmakeStatefulDispatcher) HTTP11ClientProtocolPotentialDataLossRequestRequestGenerationFailedRequestTransmissionFailedResponse ResponseDoneResponseFailedResponseNeverReceived) _DataLoss)Headers) IBodyProducer IResponse)bytesLinearWhitespaceComponentssanitizedBytesc]tRt^CtRtRtR#)ArbitraryExceptionzY A unique, arbitrary exception type which L{twisted.web._newclient} knows nothing about. N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r9A/usr/lib/python3/dist-packages/twisted/web/test/test_newclient.pyr8r8CsrAr8c]tRt^JtRtRtR#)AnotherArbitraryExceptionzA Similar to L{ArbitraryException} but with a different identity. r9Nr:r9rArBrDrDJsrArDhost example.comc\aaVV3RlpSPW4pVPV4V#)aU Assert that the given L{Deferred} fails with the exception given by C{mainType} and that the exceptions wrapped by the instance of C{mainType} it fails with match the list of exception types given by C{reasonTypes}. This is a helper for testing failures of exceptions which subclass L{_newclient._WrapperException}. @param self: A L{TestCase} instance which will be used to make the assertions. @param deferred: The L{Deferred} which is expected to fail with C{mainType}. @param mainType: A L{_newclient._WrapperException} subclass which will be trapped on C{deferred}. @param reasonTypes: A sequence of exception types which will be trapped on the resulting C{mainType} exception instance's C{reasons} sequence. @return: A L{Deferred} which fires with the C{mainType} instance C{deferred} fails with, or which fails somehow. c <\VPS4FwrVPV4K SP\ VP4\ S4RVP RS R24V#)zlen(z ) != len())zipreasonstrap assertEquallen)errreasontype reasonTypesselfs& rBcbFailed-assertWrapperExceptionTypes..cbFailednse [9LF KK :     3;;-y Q 7  rA) assertFailure addCallback)rSdeferredmainTyperRrTdsf&&f rBassertWrapperExceptionTypesr[Us+2 8.AMM( HrAc$\W\V4#)zc A simple helper to invoke L{assertWrapperExceptionTypes} with a C{mainType} of L{ResponseFailed}. )r[r/rSrXrRs&&&rBassertResponseFailedr^}s 't~{ SSrAc$\W\V4#)zl A simple helper to invoke L{assertWrapperExceptionTypes} with a C{mainType} of L{RequestGenerationFailed}. )r[r+r]s&&&rBassertRequestGenerationFailedr`s ' / rAc$\W\V4#)zn A simple helper to invoke L{assertWrapperExceptionTypes} with a C{mainType} of L{RequestTransmissionFailed}. )r[r,r]s&&&rBassertRequestTransmissionFailedrbs ' 1; rAc(\R^R\V4#)z Helper function for creating a Response which uses the given transport. All of the other parameters to L{Response.__init__} are filled with arbitrary values. Only use this method if you don't care about any of them. OKHTTPrg)r-_boringHeaders transports&rBjustTransportResponserks OS% KKrAc*a]tRt^toRtRtRtVtR#)MakeStatefulDispatcherTestsz& Tests for L{makeStatefulDispatcher}. c !RR4pV!4pVPVP4R4RVnVPVP4R4RVnVP\VP4R#)zs A method defined with L{makeStatefulDispatcher} invokes a second method based on the current state of the object. cHa]tRt^toRtRt]!R]4tRtRtRt Vt R#)CMakeStatefulDispatcherTests.test_functionCalledByState..FooAcR#Nr9rSs&rBbarGMakeStatefulDispatcherTests.test_functionCalledByState..Foo.barsrAquuxcR#)ar9rts&rB_quux_AKMakeStatefulDispatcherTests.test_functionCalledByState..Foo._quux_ArAcR#)br9rts&rB_quux_BKMakeStatefulDispatcherTests.test_functionCalledByState..Foo._quux_Br|rAr9N) r;r<r=r>_staterur'rzrr@__classdictcell__ __classdict__s@rBFoorps,F )5C   rArryBr~CN)rMrur assertRaises RuntimeError)rSrstatefuls& rBtest_functionCalledByState6MakeStatefulDispatcherTests.test_functionCalledByStatesc  5 - - , 5rAr9N)r;r<r=r>r?rr@rrs@rBrmrms66rArmcpa]tRt^toRtRtRtRtRtRt Rt Rt R t R t R tR tV3R ltRtVtR#)_HTTPParserTestszh Base test class for L{HTTPParser} which is responsible for the bulk of the task of parsing HTTP bytes. Nc \.p\4pVPVnVP\ 44VP VP \4VPRVP,4VP VR.4VP VP \4R#)zR L{HTTPParser} calls its C{statusReceived} method when it receives a status line. HTTP/1.1 200 OKN) r!appendstatusReceivedmakeConnectionrrMstater dataReceivedsepr)rSstatusprotocols& rBtest_statusCallback$_HTTPParserTests.test_statusCallbacks <"(-- 12 00488;< "4!56 0rAc/p\4pVPVnVP\ 44VP RVP ,4W3#)r)r! __setitem__headerReceivedrrrrrSheaderrs& rB_headerTestSetup!_HTTPParserTests._headerTestSetupsN<"("4"4 120488;<rAc VP4wrVPRVP,4VPVP4VPVRR/4VPVP\ 4R#)zM L{HTTPParser} calls its C{headerReceived} method when it receives a header. s X-Foo:barX-FoobarNrrrrMrrrs& rBtest_headerCallback$_HTTPParserTests.test_headerCallbacksi  002lTXX56 dhh' (F!34 .rAc VP4wrVPRVP,4VPRVP,4VPRVP,4VPVP4VPVRR/4VPVP\ 4R#)z| If a header is split over multiple lines, L{HTTPParser} calls C{headerReceived} with the entire value once it is received. X-Foo: bars bazs quuxrs bar baz quuxNrrs& rBtest_continuedHeaderCallback-_HTTPParserTests.test_continuedHeaderCallbacks  002mdhh67g01i$((23dhh' (, .rAc &VP4wrVPP.RO4pVPRV,4VPRV,4VPVP4VP VRRRR/4R#)zt Leading and trailing linear whitespace is stripped from the header value passed to the C{headerReceived} callback. sX-Bar:sX-Foo:rrsX-BarN)s s bar s rA)rrjoinrrM)rSrrvalues& rBtest_fieldContentWhitespace,_HTTPParserTests.test_fieldContentWhitespacesy  002 @Ai%/0i%/0dhh' (FHf!EFrAc aa.oVP4wpoVV3RlpVSnSPVP4VP S\ .4VP SP \4R#)zO After the last header is received, L{HTTPParser} calls C{allHeadersReceived}. cT<SPSP4\SnR#rs)rrr)calledrsrBallHeadersReceivedD_HTTPParserTests.test_allHeadersCallback..allHeadersReceiveds MM(.. )#HNrAN)rrrrrMrrr)rSrrrrs& @@rBtest_allHeadersCallback(_HTTPParserTests.test_allHeadersCallbacksd 002 $'9#dhh' &* 0rAc VP4wrVPVP4VPV/4VPVP\ 4R#)zX If there are no headers in the message, L{HTTPParser} does not call C{headerReceived}. Nrrs& rBtest_noHeaderCallback&_HTTPParserTests.test_noHeaderCallbacksK  002dhh' $ .rAc \4pVP\44VPRVP,4VPRVP,4VPRVP,4VPVP4RRR.3.pVP V\ VPP444R#)zK All headers received by L{HTTPParser} are added to L{HTTPParser.headers}. rr X-Foo: bazrrbazN) r!rrrrrMlistheadersgetAllRawHeaders)rSrexpecteds& rBtest_headersSavedOnResponse,_HTTPParserTests.test_headersSavedOnResponse#s < 120488;<mdhh67mdhh67dhh'/01 4(8(8(I(I(K#LMrAc \4p.ROpVF)pVPVPV4RV: R24K+ VPVPR4R4R#)z L{HTTPParser.isConnectionControlHeader} returns C{True} for headers which are always connection control headers (similar to "hop-by-hop" headers from RFC 2616 section 13.5.1) and C{False} for other headers. z Expecting z. to be a connection control header, but wasn'tsdatez`Expecting the arbitrarily selected 'date' header to not be a connection control header, but was.N)content-length connections keep-alivestestrailersstransfer-encodingsupgradesproxy-connection)r! assertTrueisConnectionControlHeader assertFalse)rSrconnHeaderNamesrs& rBtest_connectionControlHeaders._HTTPParserTests.test_connectionControlHeaders1sc <  &F OO226:"% &   . .w 7 4 rAc \4pVP\44VP\ 44VP \ VP\ 44R#)zQ L{HTTPParser.switchToBodyMode} raises L{RuntimeError} if called more than once. N)r!rrswitchToBodyModeobjectrrrSrs& rBtest_switchToBodyMode&_HTTPParserTests.test_switchToBodyModeOsF < 12!!&(+ ,(A(A68LrAc6<V^8dQh/S[S[,;R&#)r)rbytes)formatrs"rB __annotate___HTTPParserTests.__annotate__s % rAr9)r;r<r=r>r?rrrrrrrrrrr__annotate_func__r@rrs@rBrrsN  C 1  / / G1"/ N <MWrArc]tRtRtRtRtRtR#)$HTTPParserRFCComplaintDelimeterTestsiZz4 L{_HTTPParserTests} using standard CR LF newlines.  r9Nr;r<r=r>r?rr@r9rArBrrZs CrArc]tRtRtRtRtRtR#)'HTTPParserNonRFCComplaintDelimeterTestsibz- L{_HTTPParserTests} using bare LF newlines.  r9Nrr9rArBrrbs CrArca]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRt Rt!R t"R!t#R"t$R#t%R$t&R%t'Vt(R&#)'HTTPClientParserTestsijzX Tests for L{HTTPClientParser} which is responsible for parsing HTTP response messages. c `\RR4pVPVPR4R4R#)zR L{HTTPClientParser.parseVersion} parses a status line into its three components. Ns CANDY/7.2)sCANDYr)r rM parseVersionrs& rBtest_parseVersion'HTTPClientParserTests.test_parseVersionps, $D$/ ..|<>NOrAc aaa\RR4p\oVPoVVV3RlpV!R4V!R4V!R4V!R4V!R4V!R4R#) zZ L{HTTPClientParser.parseVersion} raises L{ValueError} when passed an unparsable version. Ncf<SPSSV4pSPVPV4R#rs)rrMdata)sexcefrSs& rB checkParsing@HTTPClientParserTests.test_parseBadVersion..checkParsings+##Aq!,C   SXXq )rAfoos foo/bar/bazsfoo/sfoo/..sfoo/a.bs foo/-1.-1)r rr)rSrrrrsf @@rBtest_parseBadVersion*HTTPClientParserTests.test_parseBadVersionxsX $D$/   ! ! * V^$WYZ \"rAc z\RR\R4p\VR4pVP\ 44VP R4VP VPPR4VP VPP^4VP VPPR4R#)z L{HTTPClientParser.statusReceived} parses the version, code, and phrase from the status line and stores them on the response object. GET/NHTTP/1.1 200 OK rdre r*rhr rrrrMresponseversioncodephraserSrequestrs& rBtest_responseStatusParsing0HTTPClientParserTests.test_responseStatusParsings &$=#GT2 1245 **22OD **//5 **1159rAc z\RR\R4p\VR4pVP\ 44VP R4VP VPPR4VP VPP^4VP VPPR4R#)z L{HTTPClientParser.statusReceived} can parse a status line without a phrase (though such lines are a violation of RFC 7230, section 3.1.2; nevertheless some broken servers omit the phrase). rrNsHTTP/1.1 200 rArerrs& rB test_responseStatusWithoutPhrase6HTTPClientParserTests.test_responseStatusWithoutPhrases &$=#GT2 1212 **22OD **//5 **1137rAc Paa\RR4oVV3RlpV!R4V!R4R#)zt L{HTTPClientParser.statusReceived} raises L{ParseError} if it is called with a status line which cannot be parsed. Nc<SP\SPV4pSPVPV4R#rs)rr#rrMr)rrrrSs& rBrBHTTPClientParserTests.test_badResponseStatus..checkParsings1##J0G0GKC   SXXq )rArsHTTP/1.1 bar OK)r )rSrrsf @rBtest_badResponseStatus,HTTPClientParserTests.test_badResponseStatuss+ $D$/ * V '(rAc ra /p.p.p.o \WP4pVPVn\ 4pVP V4VP V4VPVPnV 3RlVPn VP V4VPVPR4VPVP\4VPV.4VPVR.4VPS R.4VPVPP^4V#)a Assert that L{HTTPClientParser} parses the given C{response} to C{request}, resulting in a response with no body and no extra bytes and leaving the transport in the producing state. @param request: A L{Request} instance which might have caused a server to return the given response. @param status: A string giving the status line of the response to be parsed. @param response: A string giving the response to be parsed. @return: A C{dict} of headers from the response. c&<SPR4#)Tr)bodyDataFinishedsrB3HTTPClientParserTests._noBodyTest..s6F6M6Md6SrA producingrAT)r rrrrrrr_bodyDataReceived_bodyDataFinishedrM producerStaterrlength) rSrrrrfinishedbodyrrjr s &&&& @rB _noBodyTest!HTTPClientParserTests._noBodyTests #G__="("4"4#%  * f%.2kk+.S+h' 00+> . r" C5) )D62 **1115 rAc ~\RR\R4pRpRpVPWV4pVPVRR/4R#)z If the response is to a HEAD request, no body is expected, the body callback is not invoked, and the I{Content-Length} header is passed to the header callback. HEADrNrsContent-Length: 10 sContent-Lengths10)r*rhrrM)rSrrrrs& rBtest_headResponse'HTTPClientParserTests.test_headResponsesF '4>'4!!'8< "3U!;.drArs X-Foo: bar rx-foorr r*rhrrrrM connHeadersr2rrassertIdenticalrrrs& rBtest_responseHeaders*HTTPClientParserTests.test_responseHeaderss $ FD.$ 79J   1245/0g& --wr{; **22GXx.r)rArsX-Multiline: a s b rs x-multilinesa br+rs& rBtest_responseHeadersMultiline3HTTPClientParserTests.test_responseHeadersMultilines $ FD.$ 79J   124534l+g& --wr{;     % %w /L'M  X..55~FrAc  \\RR\R4R4pVP\ 44VP R4VP R4VP R4VP R4VP VPP\/44VP VP\R R .R R ./44VP VPP^{4R#) z^ The connection control headers are added to the parser's C{connHeaders} L{Headers} instance. rrNcR#rsr9r&s&rBr >HTTPClientParserTests.test_connectionHeaders..)r)rArContent-Length: 123 sConnection: close rr123rsclose r r*rhrrrrMrrr2r,rrs& rBtest_connectionHeaders,HTTPClientParserTests.test_connectionHeaders#s $ FD.$ 79J   12458967g& **22GBK@   &-(L M  **1137rAc \\RR\R4R4pVP\ 44VP R4VP R4VP R4VP VPP\RR ./44VP VP\/44VP VPP^4R#) z If a HEAD request is made, the I{Content-Length} header in the response is added to the response headers, not the connection control headers. rrNcR#rsr9r&s&rBr RHTTPClientParserTests.test_headResponseContentLengthEntityHeader..=strArr8rrr9r:rs& rB*test_headResponseContentLengthEntityHeader@HTTPClientParserTests.test_headResponseContentLengthEntityHeader7s $ GT>4 8:K   124589g&     % %w0AF8/L'M  --wr{; **1115rAc .p\\RR\R4VP4p\ 4pVP V4VP R4.pVPVPnVP R4VP R4VPVPR4VPVP\4VP R 4VPVR .4VPVP\4VP R 4VPVR R .4VPVP\4VPVR.4R#) z If a response includes a body with a length given by the I{Content-Length} header, the bytes which make up the body are passed to the C{_bodyDataReceived} callback on the L{HTTPParser}. rrNrsContent-Length: 10 rpausedrAsxxxxxxsyyyy)r r*rhrrrrrrrMrrrrrSrrrjrs& rBtest_contentLength(HTTPClientParserTests.test_contentLengthIs+ # FD.$ 7 $%  *45.2kk+78g& 00(; .h' z* .h' (34 . C5)rAc .p\\RR\R4VP4pVP \ 44VP R4.pVPVPnVP R4VP R4VPVP\4VPV.4VPVR.4VPVPP^4R#)z If a response includes a I{Content-Length} header indicating zero bytes in the response, L{Response.length} is set accordingly and no data is delivered to L{Response._bodyDataReceived}. rrNrContent-Length: 0 rrA) r r*rhrrrrrrrMrrrrSrrrs& rBtest_zeroContentLength,HTTPClientParserTests.test_zeroContentLengthhs # FD.$ 7   1245.2kk+67g& . r" C5) **1115rAc \\RR\R4R4pVP\ 44VP \ VPR4R#)z If a response includes multiple, distinct I{Content-Length} headers, L{HTTPClientParser.dataReceived} raises L{ValueError} to indicate that the response is invalid and the transport is now unusable. rrNs9HTTP/1.1 200 OK Content-Length: 1 Content-Length: 2 r r*rhrrr ValueErrorrrs& rB)test_multipleDistinctContentLengthHeaders?HTTPClientParserTests.test_multipleDistinctContentLengthHeaderssL $GFD.$$OQUV 12    ! !  rAc \\RR\R4R4pVP\ 44VP R4VP VPP^4VP VP\4R#)z If a response includes multiple, yet equal, I{Content-Length} headers, L{HTTPClientParser.dataReceived} successfully handles and passes single length for body processing rrNs9HTTP/1.1 200 OK Content-Length: 1 Content-Length: 1 r r*rhrrrrMrrrrrs& rB&test_multipleEqualContentLengthHeaders?rAc T.p\\RR\R4VP4pVP \ 44VP R4VP R4VP R4VPVP\4VPVR.4R#)z If extra bytes are received past the end of the headers of a response to a HEAD request, they are passed to the finish callback. rrNrsContent-Length: 12 rcrdrerfs& rBtest_extraBytesPassedBackHEAD3HTTPClientParserTests.test_extraBytesPassedBackHEADs # GT>4 8(//   124578;< . $=#>?rAc z.p\\RR\R4VP4pVP \ 44VP R4.pVPVPnVP R4VP R4VPV.4VPVPP\4VP R4VPVR.4VP R 4VPVRR .4VP R 4VPVR .4R#) z If the response headers indicate the response body is encoded with the I{chunked} transfer encoding, the body is decoded according to that transfer encoding before being passed to L{Response._bodyDataReceived}. rrNrsTransfer-Encoding: chunked rs3 aasbc sbcs 0 extrasextra) r r*rhrrrrrrrMr-rrrIs& rBtest_chunkedResponseBody.HTTPClientParserTests.test_chunkedResponseBodys # FD.$ 7   1245.2kk+?@g& r" X..55~F i( v&i( e}- /0 H:.rAc .p\\RR\R4VP4p\ 4pVP V4VP R4.pVPVPnVP R4VP R4VP R4VPVRR.4VP\R44VPVR .4R#) z If a response does not include a I{Transfer-Encoding} or a I{Content-Length}, the end of response body is indicated by the connection being closed. rrNrrrrzsimulated end of connectionrA) r r*rhrrrrrrrMconnectionLostr rDs& rBtest_unknownContentLength/HTTPClientParserTests.test_unknownContentLength)s # FD.$ 7 $%  *45.2kk+g&f%f% /0/L MN C5)rAc V.p\\RR\R4VP4p\ 4pVP V4VP R4.pVPVPnVP R4VPVR.4VPVR.4R#)z According to RFC 2616, section 4.4, point 3, if I{Content-Length} and I{Transfer-Encoding: chunked} are present, I{Content-Length} MUST be ignored rrNrs@Content-Length: 102 Transfer-Encoding: chunked 3 abc 0 abcrA) r r*rhrrrrrrrMrDs& rB%test_contentLengthAndTransferEncoding;HTTPClientParserTests.test_contentLengthAndTransferEncodingAs # FD.$ 7 $%  *45.2kk+   x( C5)rAc \4p\\RR\R4R4pVP V4VP pVP \\444\W\.4#)z If L{HTTPClientParser.connectionLost} is called before the headers are finished, the C{_responseDeferred} is fired with the L{Failure} passed to C{connectionLost}. rrN) rr r*rhr_responseDeferredrqrr8r^)rSrjrresponseDeferreds& rBtest_connectionLostBeforeBody3HTTPClientParserTests.test_connectionLostBeforeBody_sf $% #GFD.$$OQUV *#55(:(< =>#D=O.fakeBodyDataFinisheds $& &rA log_failurers)rcreateWithCleanuprrr r*rhrryrWrrrrq assertEqualsrNassertIsInstancerr8flushLoggedErrors)rS logObserverrjrrreventrs& rBtest_connectionLostWithError2HTTPClientParserTests.test_connectionLostWithErrorns +<.r)rA) r r*rhryrrrqr rVr0rSrrZs& rBtest_noResponseAtAll*HTTPClientParserTests.test_noResponseAtAllsb $ GT>4 8:J   & & 12 01!!!%:;;rAc B\\RR\R4R4pVPpVP \ 44VP R4VP\44VPV\4PVP\4#)z If a partial response was received and the connection is lost, the resulting error is L{ResponseFailed}, but not L{ResponseNeverReceived}. rrNcR#rsr9rs&rBr BHTTPClientParserTests.test_someResponseButNotAll..r)rA2) r r*rhryrrrrqr rVr/rWrrs& rBtest_someResponseButNotAll0HTTPClientParserTests.test_someResponseButNotAlls $ GT>4 8:J   & & 12d# 01!!!^4@@  ! !>  rAc :Rp\\RR\R4R4pVP\ 44VP V4VP \VRR4RJ4VPVP\4VP\\VPP444^4VP\\VPP444^4VP VP 4R#)za If a response in the 1XX range is received it just gets swallowed and the parser resets itself. HTTP/1.1 103 Early Hints Server: socketserver/1.0.0 Link: ; rel=preload; as=style Link: ; rel=preload; as=script rrNcR#rsr9rs&rBr CHTTPClientParserTests.test_1XXResponseIsSwallowed..TrAr)r r*rhrrrrgetattrrMrrrNrrrr,_everReceivedData)rSsample103Responsers& rBtest_1XXResponseIsSwallowed1HTTPClientParserTests.test_1XXResponseIsSwalloweds   $ FD.$ 79I   12/0 *d;tCD 0 T("2"2"C"C"EFGK T("6"6"G"G"IJKQO 223rAc RpRp\\RR\R4R4pVP\ 44VP W,4VP VPP^4VP VPP\/44VP VP\RR./44VP VPP^{4R#) zy When a 1XX response is swallowed, the final response that follows it is the only one that gets sent to the application. r(HTTP/1.1 200 OK Content-Length: 123 rrNcR#rsr9rs&rBr UHTTPClientParserTests.test_1XXFollowedByFinalResponseOnlyEmitsFinal..rrArr9 r r*rhrrrrMrrrr2r,rrSrfollowing200Responsers& rB-test_1XXFollowedByFinalResponseOnlyEmitsFinalCHTTPClientParserTests.test_1XXFollowedByFinalResponseOnlyEmitsFinals    Y# FD.$ 79I   12/FG **//5 **22GBK@ --w8IF87T/UV **1137rAc RpRp\\RR\R4R4pVP\ 44VP VV,V,V,4VP VPP^4VP VPP\/44VP VP\RR./44VP VPP^{4R#) zX It is acceptable for multiple 1XX responses to come through, all of which get ignored. rrrrNcR#rsr9rs&rBr KHTTPClientParserTests.test_multiple1XXResponsesAreIgnored..rrArr9rrs& rB#test_multiple1XXResponsesAreIgnored9HTTPClientParserTests.test_multiple1XXResponsesAreIgnoreds    Y# FD.$ 79I   12   # #  **//5 **22GBK@ --w8IF87T/UV **1137rAc z\P!V\4pRp\\ RR\ R4R4pVP \44VPV4VP^\V44V^,pVPVR,R4VPVR,^g4R#) z6 When a 1XX response is ignored, Twisted emits a log. rrrNcR#rsr9rs&rBr HHTTPClientParserTests.test_ignored1XXResponseCausesLog.. rrA log_formatz#Ignoring unexpected {code} responser) rrrr r*rhrrrrrN)rSrrrrs& rB test_ignored1XXResponseCausesLog6HTTPClientParserTests.test_ignored1XXResponseCausesLogs+<r?rrrrrrrrr"r.r3r;r@rErJrOrSrVrYr\r`rgrjrnrrrvr{rrrrrrrr@rrs@rBrrjs P#, : 8)&"H =44G G&8(6$*>62 $/$  /    @"@"#/J*0*< R3: < $44828<..rArc<a]tRtRtoRtRtRtRtRtRt Rt Vt R#) SlowRequestiah L{SlowRequest} is a fake implementation of L{Request} which is easily controlled externally (for example, by code in a test method). @ivar stopped: A flag indicating whether C{stopWriting} has been called. @ivar finished: After C{writeTo} is called, a L{Deferred} which was returned by that method. L{SlowRequest} will never fire this L{Deferred}. rFc8\4VnVP#rs)rrrSrjs&&rBwriteToSlowRequest.writeTo%s  }}rAcRVnR#TNstoppedrts&rB stopWritingSlowRequest.stopWriting)  rA)rrN) r;r<r=r>r?methodr persistentrrr@rrs@rBrrs* FGJrArc.a]tRtRtoRtRtRtRtVtR#) SimpleRequesti-z L{SimpleRequest} is a fake implementation of L{Request} which writes a short, fixed string to the transport passed to its C{writeTo} method and returns a succeeded L{Deferred}. This vaguely emulates the behavior of a L{Request} with no body producer. Fc:VPR4\R4#) SOME BYTESN)writerrs&&rBrSimpleRequest.writeTo7s &t}rAr9N) r;r<r=r>r?rrr@rrs@rBrr-sJrArca]tRtRtoRtRtRtRtRtRt Rt R(R lt R t R t R tRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRt R t!R!t"R"t#R#t$R$t%R%t&R&t'R't(Vt)R #))HTTP11ClientProtocolTestsi<zQ Tests for the HTTP 1.1 client protocol implementation, L{HTTP11ClientProtocol}. c \4Vn\4VnVPP VP4R#)zB Create an L{HTTP11ClientProtocol} connected to a fake transport. N)rrjr(rrrts&rBsetUpHTTP11ClientProtocolTests.setUpBs.)*,.  $$T^^4rAc VPP\44VPVPP 4R4R#)zn L{HTTP11ClientProtocol.request} accepts a L{Request} and calls its C{writeTo} method with its own transport. rN)rrrrMrjrrts&rB test_request&HTTP11ClientProtocolTests.test_requestJs5 mo. --/?rAc aSPP\44V3RlpSPSPP\ 44\ 4pVP V4V#)z The second time L{HTTP11ClientProtocol.request} is called, it returns a L{Deferred} which immediately fires with a L{Failure} wrapping a L{RequestNotSent} exception. c\<SPSPP4R4R#rANrMrjrignoredrSs&rB cbNotSent?HTTP11ClientProtocolTests.test_secondRequest..cbNotSentZ   T^^113S 9rA)rrrrVrr$rWrSrrZsf rBtest_secondRequest,HTTP11ClientProtocolTests.test_secondRequestRsT km, :   t}}44]_E~ V i rAc aSPP\\R444V3RlpSP SPP \ 44\4pVPV4V#)z L{HTTP11ClientProtocol.request} returns a L{Deferred} which immediately fires with a L{Failure} wrapping a L{RequestNotSent} if called after the protocol has been disconnected. z sad transportc\<SPSPP4R4R#rrrs&rBrLHTTP11ClientProtocolTests.test_requestAfterConnectionLost..cbNotSentirrA) rrqrr rVrrr$rWrsf rBtest_requestAfterConnectionLost9HTTP11ClientProtocolTests.test_requestAfterConnectionLostas\ $$W^O-L%MN :   t}}44]_E~ V i rAc a!RR4pSPPV!44pV3Rlp\SV\.4pVP V4V#)z If the L{Deferred} returned by L{Request.writeTo} fires with a L{Failure}, L{HTTP11ClientProtocol.request} disconnects its transport and returns a L{Deferred} which fires with a L{Failure} of L{RequestGenerationFailed} wrapping the underlying failure. c*a]tRtRtoRtRtRtVtR#)CHTTP11ClientProtocolTests.test_failedWriteTo..BrokenRequestixFc(\\44#rs)rr8rs&&rBrKHTTP11ClientProtocolTests.test_failedWriteTo..BrokenRequest.writeTo{s.011rAr9Nr;r<r=r>rrr@rrs@rB BrokenRequestrxsJ 2 2rArc<SPSPP4SPP \ \ R444R#)zyou asked for itN)rrj disconnectingrrqrr rs&rBrT>HTTP11ClientProtocolTests.test_failedWriteTo..cbFaileds8 OODNN88 9 MM ( (@R1S)T UrA)rrr`r8rW)rSrrZrTsf rBtest_failedWriteTo,HTTP11ClientProtocolTests.test_failedWriteTopsP 2 2 MM ! !-/ 2 V *$4F3G H hrAc x!RR4pVPPV!44p\W\.4#)z If L{Request.writeTo} raises an exception, L{HTTP11ClientProtocol.request} returns a L{Deferred} which fires with a L{Failure} of L{RequestGenerationFailed} wrapping that exception. c*a]tRtRtoRtRtRtVtR#)MHTTP11ClientProtocolTests.test_synchronousWriteToError..BrokenRequestiFc\4hrsrrs&&rBrUHTTP11ClientProtocolTests.test_synchronousWriteToError..BrokenRequest.writeTos (**rAr9Nrrs@rBrrsJ + +rAr)rrr`r8)rSrrZs& rBtest_synchronousWriteToError6HTTP11ClientProtocolTests.test_synchronousWriteToErrors5 + + MM ! !-/ 2,T7I6JKKrANc J\4pVPPV4p\W\.4pVP VP 4VPP\\ 444VPVP 4VR8XdVPPR4V#VR8Xd_VPP\\444VP\4pVP\!V4^4V#V#)a  If L{HTTP11ClientProtocol}'s transport is disconnected before the L{Deferred} returned by L{Request.writeTo} fires, the L{Deferred} returned by L{HTTP11ClientProtocol.request} fires with a L{Failure} of L{RequestTransmissionFailed} wrapping the underlying failure. callbackNerrback)rrrrbr8rrrqrrrrrrDrrMrN)rSmoderrZerrorss&& rB*test_connectionLostDuringRequestGenerationDHTTP11ClientProtocolTests.test_connectionLostDuringRequestGenerations- MM ! !' * +D6H5I J ) $$W-?-A%BC ( :     % %d +Y     $ $W-F-H%I J++,EFF   S[! , rAc $VPR4#)z If the request passed to L{HTTP11ClientProtocol} finishes generation successfully after the L{HTTP11ClientProtocol}'s connection has been lost, nothing happens. rrrts&rB+test_connectionLostBeforeGenerationFinishedEHTTP11ClientProtocolTests.test_connectionLostBeforeGenerationFinisheds >>zJJrAc $VPR4#)z If the request passed to L{HTTP11ClientProtocol} finished generation with an error after the L{HTTP11ClientProtocol}'s connection has been lost, nothing happens. rrrts&rB)test_connectionLostBeforeGenerationFailedCHTTP11ClientProtocolTests.test_connectionLostBeforeGenerationFaileds >>yIIrAc aa\P!S\4oVV3RlpSPR4P V4#)z If the request passed to L{HTTP11ClientProtocol} finished generation with an error after the L{HTTP11ClientProtocol}'s connection has been lost, an error is logged that gives a non-confusing hint to user on what went wrong. c<SP^\S44S^,pSPRV4SPVR,R4SPVR,R4R#)rgrrzJError writing request, but not in valid state to finalize request: {state}rCONNECTION_LOSTN)rrNassertInrM)ignorerrrSs& rBchecknHTTP11ClientProtocolTests.test_errorMessageOnConnectionLostBeforeGenerationFailedDoesNotConfuse..checksa   a[!1 2NE MM- /   l#/    U7^-> ?rAr)rrrrrW)rSr rsf @rBEtest_errorMessageOnConnectionLostBeforeGenerationFailedDoesNotConfuse_HTTP11ClientProtocolTests.test_errorMessageOnConnectionLostBeforeGenerationFailedDoesNotConfusesA+<>yIUU   rAc aSPP\RR\R44pV3RlpVP V4SPP R4V#)z When a response is delivered to L{HTTP11ClientProtocol}, the L{Deferred} previously returned by the C{request} method is called back with a L{Response} instance and the connection is closed. rrNc<SPVP^4SPVP\44SP SP P 4SPSPPR4R#) QUIESCENTN) rMrrr2rrjrrr)rrSs&rB cbRequestIHTTP11ClientProtocolTests.test_receiveSimplestResponse..cbRequests_   X]]C 0   X--wy 9 OODNN88 9   T]]00+ >rAs9HTTP/1.1 200 OK Content-Length: 0 Connection: close rrr*rhrWrrSrZrsf rBtest_receiveSimplestResponse6HTTP11ClientProtocolTests.test_receiveSimplestResponsesU MM ! !'&$"M N ? i  ""  rAc aSPP\RR\R44pV3RlpVP V4SPP R4V#)z The headers included in a response delivered to L{HTTP11ClientProtocol} are included on the L{Response} instance passed to the callback returned by the C{request} method. rrNc^<\RRR./4pSPVPV4R#)r*rrN)r2rMr)rrrSs& rBrHHTTP11ClientProtocolTests.test_receiveResponseHeaders..cbRequests-66*:;.cbResponse..*1668JrA) rrclosedDeferred deliverBodyrMrrrrW)r whenFinishedr%rquiescentResultrSrjsf @rB cbResponse]HTTP11ClientProtocolTests.test_receiveResponseBeforeRequestGenerationDone..cbResponse#sq$&A.6j 8L1+   #   X^^-T U OOI33 4   _b 1++,JK KrAcb<VwrSPVPR4SPVP^4SPVPR4SPVP\ RR./44SPVR4SP PR4R#)rfrdr*rfoobarNre)rMrrrrr2rr)resultrrrrSs& rB cbAllResponse`HTTP11ClientProtocolTests.test_receiveResponseBeforeRequestGenerationDone..cbAllResponse.s#NH   X-- ?   X]]C 0   X__e 4   X--w6(7K/L M   T9 -    % %d +rA)rr(rrrrrrW)rSrZr,r1rr+rrjsf @@@@rB/test_receiveResponseBeforeRequestGenerationDoneIHTTP11ClientProtocolTests.test_receiveResponseBeforeRequestGenerationDone s#% '(>(>? *-   W %   L L j! , m$rAc (\4p\4pW!nVPV4R\P ,pVP \RR\R44pVPRV,R,4\W\.4#)za The connection is closed when the server respond with a header which is above the maximum line. rmrrNsHTTP/1.1 200 OK X-Foo: s X-Ignored: ignored ) rr(rrr MAX_LENGTHrr*rhrr^r )rSrjrlongLinerZs& rB"test_receiveResponseHeadersTooLong4H I ! "%  $Dn-=>>rAc aa\4oSPPS4pSPPR4RpVP V4VV3RlpVP V4V#)z If response bytes are delivered to L{HTTP11ClientProtocol} before the request completes, calling C{connectionLost} on the protocol will result in protocol being moved to C{'CONNECTION_LOST'} state. s8HTTP/1.1 400 BAD REQUEST Content-Length: 9 tisk tiskcaa\4o\4;pSnSPS4VP VV3Rl4#)c <SSP3#rsr#r$s&rBr ڄHTTP11ClientProtocolTests.test_connectionLostAfterReceivingResponseBeforeRequestGenerationDone..cbResponse..jr'rA)rrr(r)rW)rr*r%sf @rBr,rHTTP11ClientProtocolTests.test_connectionLostAfterReceivingResponseBeforeRequestGenerationDone..cbResponsefs:$&A.6j 8L1+   #++,JK KrAc<SPPR4SPP\ \ 444SP SPPR4R#)Nr )rrrrqrr8rMr)r rrSs&rBr1uHTTP11ClientProtocolTests.test_connectionLostAfterReceivingResponseBeforeRequestGenerationDone..cbAllResponsensM    % %d + MM ( (1C1E)F G   T]]113D ErA)rrrrrW)rSrZr,r1rsf @rBDtest_connectionLostAfterReceivingResponseBeforeRequestGenerationDone^HTTP11ClientProtocolTests.test_connectionLostAfterReceivingResponseBeforeRequestGenerationDoneWsd - MM ! !' * ""   L j! F m$rAc 0aa\4o\4;pSnSPP \ RR\ R44pSPPR4.pVPVP4SPV.4SPPR4V^,pVPS4SPPR4SPPR4VV3RlpVPV4V#) z The C{deliverBody} method of the response object with which the L{Deferred} returned by L{HTTP11ClientProtocol.request} fires can be used to get the body of the response. rrNs%HTTP/1.1 200 OK Content-Length: 6 rrrc~<SPSPR4SPP\4R#)r/N)rMr closedReasonrLr.)rrrSs&rBr1IHTTP11ClientProtocolTests.test_receiveResponseBody..cbAllResponses+   X]]I 6  ! ! & &| 4rA) rrr(rrr*rhrrWrrMr))rSr*requestDeferredr0rr1rsf @rBtest_receiveResponseBody2HTTP11ClientProtocolTests.test_receiveResponseBodyws ()19; x.--// FD.$ 7  "" A ##FMM2 $ ""5)!9X& ""6* ""6* 5   /rAc PVPP\RR\R44pVPP R4.pVP VP 4V^,p\4pVPV4VPP R4VPP R4VPVPR4VPP\\R444VPP\ 4R#) z If the length of the response body is unknown, the protocol passed to the response's C{deliverBody} method has its C{connectionLost} method called with a L{Failure} wrapping a L{PotentialDataLoss} exception. rrNsHTTP/1.1 200 OK rrr/z low-level transport disconnected)rrr*rhrrWrrr)rMrrqrr rErLr)rSrGr0rrs& rBEtest_responseBodyFinishedWhenConnectionLostWhenContentLengthIsUnknown_HTTP11ClientProtocolTests.test_responseBodyFinishedWhenConnectionLostWhenContentLengthIsUnknowns--// FD.$ 7  ""#AB##FMM2!9')X& ""6* ""6*  2 $$ N#EF G  ""#45rAc `VPP\RR\R44pVPP R4.pVP VP 4V^,p\4pVPV4VPP R4VPP R4VPVPR4VPP\\444\V\VP 4\\".4#)z If the final chunk has not been received when the connection is lost (for any reason), the protocol passed to C{deliverBody} has its C{connectionLost} method called with a L{Failure} wrapping the exception for that reason. rrNs/HTTP/1.1 200 OK Transfer-Encoding: chunked 3 foo s3 bar r/)rrr*rhrrWrrr)rMrrqrr8r^rrEr1rKs& rB4test_chunkedResponseBodyUnfinishedWhenConnectionLostNHTTP11ClientProtocolTests.test_chunkedResponseBodyUnfinishedWhenConnectionLosts--// FD.$ 7  "" L ##FMM2!9')X& ""?3 ""?3  2 $$W-?-A%BC# $x,,-0BI/N  rAc aSPP\RR\R44pSPP R4\ SV\ .4pV3RlpVPV4V#)z If the parser L{HTTP11ClientProtocol} delivers bytes to in C{dataReceived} raises an exception, the exception is wrapped in a L{Failure} and passed to the parser's C{connectionLost} and then the L{HTTP11ClientProtocol}'s transport is disconnected. rrNsunparseable garbage goes here c<SPSPP4SPVP^,P P R4SPP\\R444R#)sunparseable garbage goes herez it is doneN) rrjrrMrKrrrrqrr )rrSs&rBrTLHTTP11ClientProtocolTests.test_parserDataReceivedException..cbFaileds_ OODNN88 9    A$$))+K  MM ( ( 1M)N OrA)rrr*rhrr^r#rW)rSrGrZrTsf rB test_parserDataReceivedException:HTTP11ClientProtocolTests.test_parserDataReceivedExceptionse--// FD.$ 7  ""#GH  E P hrAc VPP\RR\R44pVPPP pVP VPVP 4VPP\\R444VP VPR4\W\.4#)z When the HTTP response parser is disconnected, the L{TransportProxyProducer} which was connected to it as a transport is stopped. rrNzconnection done) rrr*rh_parserrjr- _producer_disconnectParserrr r^)rSrGrjs& rBtest_proxyStopped+HTTP11ClientProtocolTests.test_proxyStoppeds --// FD.$ 7 MM))33  Y00$..A ''?P0Q(RS Y00$7#DN;KLLrAc \4p\4pVPV4.p.pVP4P VP 4VP4P VP 4VP W43..34VPVP4VP\\444VP VR.4VP VR.4R#)z L{HTTP11ClientProtocol.abort} will tell the transport to close its connection when it is invoked, and returns a C{Deferred} that fires when the connection is lost. N) rr(rabortrWrrMrrrqrr )rSrjrr1r2s& rBtest_abortClosesConnection4HTTP11ClientProtocolTests.test_abortClosesConnections $% ') *  $$RYY/$$RYY/ "B8,  //0 (8 9: dV$ dV$rAc H\4p\4pVPV4VP\ \ 444.pVP 4PVP4VPVR.4VPVPR4R#)zq L{HTTP11ClientProtocol.abort} called after the connection is lost returns a C{Deferred} that fires immediately. Nr ) rr(rrqrr r_rWrrMrrSrjrr0s& rBtest_abortAfterConnectionLost7HTTP11ClientProtocolTests.test_abortAfterConnectionLosts} $% ') *(8 9:$$V]]3 $( *;<a]tRtRtoRtV3RltV3RltRtVtR#)QHTTP11ClientProtocolTests.test_abortAfterResponseHeaders..BodyDestinationiPzH A body response protocol which immediately aborts the HTTP connection. c (<SP4R#)z Abort the HTTP connection. N)r_rs&rBconnectionMade`HTTP11ClientProtocolTests.test_abortAfterResponseHeaders..BodyDestination.connectionMadeVs rAc *<SPV4R#)z` Make the reason for the losing of the connection available to the unit test via C{testResult}. N)r)rSrP testResults&&rBrq`HTTP11ClientProtocolTests.test_abortAfterResponseHeaders..BodyDestination.connectionLost\s ""6*rAr9N) r;r<r=r>r?rprqr@r)rrrss@rBBodyDestinationrnPs   !  + +rAruc<VPS!44SPSP4SP\ \ 444R#)z Connect the L{BodyDestination} response body protocol to the response, and then simulate connection loss after ensuring that the HTTP connection has been aborted. N)r)rrrqrr )rrurrSrjs&rBr)MHTTP11ClientProtocolTests.test_abortAfterResponseHeaders..deliverBodycs>  !2 3 OOI33 4  # #GN,<$= >rAcH<SPVP\4R#rs)rrr-)errorrSs&rB checkErrorLHTTP11ClientProtocolTests.test_abortAfterResponseHeaders..checkErrorms  ! !%..( ;rA) rr(rrr*rhrrr rWr^rr1) rSr0r)rzrXrurrsrjs f @@@@rBtest_abortAfterResponseHeaders8HTTP11ClientProtocolTests.test_abortAfterResponseHeaders<s$D1 ') *!!'&$"MNUVZ  + +h +& ? ? < ;'' *0)< ##J//rAc  vaaa.oVVV3Rlp\4p\V4oSPV4SP\ RR\ RRR74pSP R4SPS.4.pVPVP4V^,p\4p\4Vn VPPV3Rl4VPV4SP R 4VPP\ 4SPSSR .4SPSP"R4SPSP$R4SPSP&R4SPSP(R4SPSP*R4R#) a If after a response is done the {HTTP11ClientProtocol} stays open and returns to QUIESCENT state, all per-request state is reset and the C{quiescentCallback} is called with the protocol instance. This is useful for implementing a persistent connection pool. The C{quiescentCallback} is called *before* the response-receiving protocol's C{connectionLost}, so that new requests triggered by end of first request can re-use a persistent connection. c<SPVS4SPVPR4SPV4R#rNrMrrr%rr+rSs&rBrHHTTP11ClientProtocolTests.test_quiescentCallbackCalled..callback5   Q )   QWWk 2  " "1 %rArrNTrs&HTTP/1.1 200 OK Content-length: 3 c&<SPR4#) response doner )rr+s&rBr HHTTP11ClientProtocolTests.test_quiescentCallbackCalled..s..?rArur)rr(rrr*rhrrMrWrrrr(r)rErLr.rY_finishedRequest_currentRequest_transportProxyry) rSrrjrGr0r bodyProtocolrr+s f @@rBtest_quiescentCallbackCalled6HTTP11ClientProtocolTests.test_quiescentCallbackCalledvsx & $% '1 *"** FD.$4 H  UV "-##FMM2!9,- &.j ###// ?  \*f%!!&&|4 8_*EF ))40 22D9 1148 1148 33T:rAc  aaa.oVVV3Rlp\4p\V4oSPV4SP\ RR\ RRR74pSP R4SPV4pSPVPR4SP\S4^4SPVPR 4R#) a The C{quiescentCallback} passed to L{HTTP11ClientProtocol} will only be invoked once that protocol is in a state similar to its initial state. One of the aspects of this initial state is the producer-state of its transport; an L{HTTP11ClientProtocol} begins with a transport that is producing, i.e. not C{pauseProducing}'d. Therefore, when C{quiescentCallback} is invoked the protocol will still be producing. c<SPVS4SPVPR4SPV4R#rrrs&rBr]HTTP11ClientProtocolTests.test_transportProducingWhenQuiescentAfterFullBody..callbackrrArrNTrs)HTTP/1.1 200 OK Content-length: 3 BBBDEFERRED_CLOSEr) rr(rrr*rhrsuccessResultOfrMrrNr)rSrrjrGrrr+sf @@rB1test_transportProducingWhenQuiescentAfterFullBodyKHTTP11ClientProtocolTests.test_transportProducingWhenQuiescentAfterFullBodys & $% '1 *"** FD.$4 H    ''8 *:; _-q1 00+>rAc  aaa.oVVV3Rlp\4p\V4oSPV4SP\ RR\ RRR74pVP SP4SPR4SP\S4^4SPS^,S4SPS^,\4R#)zp The quiescentCallback is called before the request C{Deferred} fires, in cases where the response has no body. c<SPVS4SPVPR4SPV4R#rrrs&rBrUHTTP11ClientProtocolTests.test_quiescentCallbackCalledEmptyResponse..callbackrrArrNTr&HTTP/1.1 200 OK Content-length: 0 )rr(rrr*rhrWrrrMrNr-rr-)rSrrjrGrr+sf @@rB)test_quiescentCallbackCalledEmptyResponseCHTTP11ClientProtocolTests.test_quiescentCallbackCalledEmptyResponses  & $% '1 *"** FD.$4 H  ##O$:$:;UV _-q1 _Q/: oa0(;rAc  .p\4p\VP4pVPV4VP \ RR\ RRR74pVPR4.pVPVP4V^,p\4pVPV4VPP\4VPV.4VPVP 4R#)z If after a response is done the {HTTP11ClientProtocol} returns a C{Connection: close} header in the response, the C{quiescentCallback} is not called and the connection is lost. rrNTrs9HTTP/1.1 200 OK Content-length: 0 Connection: close rr(rrrr*rhrrWrr)rErLr.rMrrrSr+rjrrGr0rrs& rBtest_quiescentCallbackNotCalled9HTTP11ClientProtocolTests.test_quiescentCallbackNotCalleds #% '(>(>? *"** FD.$4 H    ##FMM2!9+- \*!!&&|4 "-  //0rAc  .p\4p\VP4pVPV4VP \ RR\ RRR74pVPR4.pVPVP4V^,p\4pVPV4VPP\4VPV.4VPVP 4R#)z If the request was non-persistent (i.e. sent C{Connection: close}), the C{quiescentCallback} is not called and the connection is lost. rrNFrrrrs& rB1test_quiescentCallbackNotCalledNonPersistentQueryKHTTP11ClientProtocolTests.test_quiescentCallbackNotCalledNonPersistentQuerys #% '(>(>? *"** FD.$5 I  UV##FMM2!9+- \*!!&&|4 "-  //0rAc  Rp\P!V\4p\4p\ V4pVP V4VP \RR\RRR74pVPR4.pVPVP4V^,p\4pVPV4VPP\ 4VP#^\%V44V^,p V R,p VP'V P(\*4VP-\*4VP/VP04R#) z` If C{quiescentCallback} throws an exception, the error is logged and protocol is disconnected. c\4hrs)ZeroDivisionError)r%s&rBrHHTTP11ClientProtocolTests.test_quiescentCallbackThrows..callback5s #% %rArrNTrrr)rrrrr(rrr*rhrrWrrr)rErLr.rrNrrrrrr) rSrrrjrrGr0rrrrs & rBtest_quiescentCallbackThrows6HTTP11ClientProtocolTests.test_quiescentCallbackThrows/s  &+<2BCCrAc aaa\4p\4pVPV4\V4oRR/oV3RloVV3RlpVSnVP \ RR\S44pSPPR4VP4VPVP4VPSR,4\W\.4#)z The L{Deferred} returned by L{HTTP11ClientProtocol.request} will fire with a L{RequestGenerationFailed} failure containing a L{CancelledError} exception if the request was cancelled before a C{bodyProducer} has finished producing. cancelledFc<RSR&R#)TrNr9)rnonLocals&rBrJHTTP11ClientProtocolTests.assertCancelDuringBodyProduction..cancels $(H[ !rAcJ<VSn\S4SnSP#rsconsumerrr)rrproducers&rBstartProducingRHTTP11ClientProtocolTests.assertCancelDuringBodyProduction..startProducings$ (H  ( 0H $$ $rAPOST/barsxxxxx)rr(rStringProducerrrr*rhrrrrrr`r) rSproducerLengthrjrrr0rrrs && @@@rB assertCancelDuringBodyProduction:HTTP11ClientProtocolTests.assertCancelDuringBodyProductionss$% ') *!.1' ) % #1!!''7NH"UV)   ../ -.,TN;KLLrAc $VP^ 4#)a The L{Deferred} returned by L{HTTP11ClientProtocol.request} will fire with a L{RequestGenerationFailed} failure containing a L{CancelledError} exception if the request was cancelled before a C{bodyProducer} with an explicit length has finished producing. )rrts&rBtest_cancelDuringBodyProduction9HTTP11ClientProtocolTests.test_cancelDuringBodyProductions44R88rAc ,VP\4#)z The L{Deferred} returned by L{HTTP11ClientProtocol.request} will fire with a L{RequestGenerationFailed} failure containing a L{CancelledError} exception if the request was cancelled before a C{bodyProducer} with C{UNKNOWN_LENGTH} has finished producing. )rrrts&rB&test_cancelDuringChunkedBodyProduction@HTTP11ClientProtocolTests.test_cancelDuringChunkedBodyProductions44^DDrA)rrjrs)*r;r<r=r>r?rrrrrrrrrrrrr3r8rArHrLrPrVr\rbrfrir|rrrrrrrrrrrr@rrs@rBrr<s 5@  4L @KJ 0.$0d?4@'R6: @8 M%* =G 80t7;r,?\<41>12!1F "D M>9EErArcFa]tRtRtoRtRtRtRtRtRt Rt R t Vt R #) ria L{StringProducer} is a dummy body producer. @ivar stopped: A flag which indicates whether or not C{stopProducing} has been called. @ivar consumer: After C{startProducing} is called, the value of the C{consumer} argument to that method. @ivar finished: After C{startProducing} is called, a L{Deferred} which was returned by that method. L{StringProducer} will never fire this L{Deferred}. FcWnR#rs)r)rSrs&&rB__init__StringProducer.__init__s rAcDWn\4VnVP#rsr)rSrs&&rBrStringProducer.startProducings   }}rAcRVnR#rrrts&rB stopProducingStringProducer.stopProducingrrAcR#rsr9rts&rBpauseProducingStringProducer.pauseProducing rAcR#rsr9rts&rBresumeProducingStringProducer.resumeProducingrrA)rrrrN) r;r<r=r>r?rrrrrrr@rrs@rBrrs/ G    rArca]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtRtRtRtRRltRtRtRtRtRtRtVtR#) RequestTestsiz Tests for L{Request}. c$\4VnR#rs)rrjrts&rBrRequestTests.setUps (*rAc \RR\R4PVP4VP VPP 4R4R#)zS L{Request.writeTo} formats the request data and writes it to the given transport. rrNs8GET / HTTP/1.1 Connection: close Host: example.com r*rhrrjrMrrts&rBtest_sendSimplestRequest%RequestTests.test_sendSimplestRequestsD nd3;;DNNK  NN "  rAc \RR\RRR7pVPVP4VP VPP 4R4R#)z? A pesistent request does not send 'Connection: close' header. rrNTrs%GET / HTTP/1.1 Host: example.com r)rSreqs& rB"test_sendSimplestPersistentRequest/RequestTests.test_sendSimplestPersistentRequestsGfdNDTJ DNN#  NN " B rAc \RRR.RR./4p\RRVR4PVP4VPP 4P R 4pVP V^,R 4VP VR RR R .4V^VR R1VP4VP V.R O4R#)zN L{Request.writeTo} formats header data and writes it to the given transport. r*rrrErFr/fooNrGET /foo HTTP/1.1rA)Connection: closesHost: example.comrr)r2r*rrjrsplitrMsort)rSrliness& rBtest_sendRequestHeaders$RequestTests.test_sendRequestHeaderss 8ff%5w@PQR$/77G$$&,,W5 q#78 rsc3Z0 !HeBCj    V rAc \Fp\RV.RR./4p\4p\RRVR4P V4VP 4P R4pVPV^,R4VPVR RR R .4V^VR R1VPR 4VPR 4VPVR \,.4K R#)zM Linear whitespace in request header values is replaced with a single space. r*rEsexample.invalidrrNrrrArsHost: example.invalidsX-Foo: r) r5r2rr*rrrrMremover6)rS componentrrjrs& rB-test_sanitizeLinearWhitespaceInRequestHeaders:RequestTests.test_sanitizeLinearWhitespaceInRequestHeaderss 9Ix)g@R?STUG')I FGWd 3 ; ;I FOO%++G4E   U1X'; <   U23Z#s 4a%* LL- . LL1 2   UZ.%@$A B9rAc \\4p\RR\V4pVP VP 4VP VPR4VPVP PV4VPVP P4VPVP P4R4VP P4VPPR4VPPR4VP P#R4VPVP PR4VPVP P4R4R#)z L{Request.writeTo} uses chunked encoding to write data from the request body producer to the given transport. It registers the request body producer with the transport. rrNsXPOST /bar HTTP/1.1 Connection: close Transfer-Encoding: chunked Host: example.com s!3 xxx f yyyyyyyyyyyyyyy 0 sxxxsyyyyyyyyyyyyyyy)rrr*rhrrjassertNotIdenticalrr-rr streamingrMrclearrrrrSrrs& rBtest_sendChunkedRequestBody(RequestTests.test_sendChunkedRequestBody s  ".1'7NHE'  1 148 T^^44h? 001  NN "   ) *""4( T^^44d;  NN " P rAc Ta\\4p\RR\V4pVP SP 4pSP P 4VPP\44V3RlpSPV\4pVPV4V#)ab If L{Request} is created with a C{bodyProducer} without a known length and the L{Deferred} returned from its C{startProducing} method fires with a L{Failure}, the L{Deferred} returned by L{Request.writeTo} fires with that L{Failure} and the body producer is unregistered from the transport. The final zero-length chunk is not written to the transport. rrc<SPSPP4R4SPSPPR4R#r)rMrjrr-rrs&rBrTCRequestTests.test_sendChunkedRequestBodyWithError..cbFailed<s:   T^^113S 9  !8!8$ ?rA) rrr*rhrrjrrrr8rVrW)rSrr writeDeferredrTrZsf rB$test_sendChunkedRequestBodyWithError1RequestTests.test_sendChunkedRequestBodyWithError-s".1'7NHE7  !!"4"67 @   }.@ A hrAc \^4p\RR\V4pVPVP4VP VP R4VPVPPV4VPVPP4VPVPP4R4VPP4VP PR4VPP!R4VPVPPR4VPVPP4R4R#)z If L{Request} is created with a C{bodyProducer} with a known length, that length is sent as the value for the I{Content-Length} header and chunked encoding is not used. rrNsOPOST /bar HTTP/1.1 Connection: close Content-Length: 3 Host: example.com ru)rr*rhrrjrrr-rrrrMrrrrrrs& rBtest_sendRequestBodyWithLength+RequestTests.test_sendRequestBodyWithLengthDs "!$'7NHE'  1 148 T^^44h? 001  NN "   '""4( T^^44d; --/8rAc \VR\R4pVPVP4VP VPP 4VR,4R#)z Verify that the message generated by a L{Request} initialized with the given method and C{None} as the C{bodyProducer} includes I{Content-Length: 0} in the header. @param method: The HTTP method issue in the request. @type method: L{bytes} rNsK /foo HTTP/1.1 Connection: close Content-Length: 0 Host: example.com r)rSrrs&& rB_sendRequestEmptyBodyWithLength,RequestTests._sendRequestEmptyBodyWithLengthasO&'>4@'  NN "   rAc (VPR4R#)z If I{PUT} L{Request} is created without a C{bodyProducer}, I{Content-Length: 0} is included in the header and chunked encoding is not used. sPUTNrrts&rBtest_sendPUTRequestEmptyBody)RequestTests.test_sendPUTRequestEmptyBodyvs ,,V4rAc (VPR4R#)z If I{POST} L{Request} is created without a C{bodyProducer}, I{Content-Length: 0} is included in the header and chunked encoding is not used. rNrrts&rBtest_sendPOSTRequestEmptyBody*RequestTests.test_sendPOSTRequestEmptyBody~s ,,W5rAc V\^4p\RR\V4pVPVP4pVP P R4VPPR4VPVPPR4VPV\4#)z If L{Request} is created with a C{bodyProducer} with a known length and the producer does not produce that many bytes, the L{Deferred} returned by L{Request.writeTo} fires with a L{Failure} wrapping a L{WrongBodyLength} exception. rrabN) rr*rhrrjrrrrr-rrVr&rSrrrs& rB#test_sendRequestBodyWithTooFewBytes0RequestTests.test_sendRequestBodyWithTooFewBytess"!$'7NHE7 &""4( T^^44d;!!-AArAc aaa\^4o\RR\S4pVPSP4pSP P R4SPSP4SP P R4SPSP4SPSPPR4VVV3RlpSPV\4pVPV4V#)a Verify that when too many bytes have been written by a body producer and then the body producer's C{startProducing} L{Deferred} fires that the producer is unregistered from the transport and that the L{Deferred} returned from L{Request.writeTo} is fired with a L{Failure} wrapping a L{WrongBodyLength}. @param finisher: A callable which will be invoked with the body producer after too many bytes have been written to the transport. It should fire the startProducing Deferred somehow. rrrcdNcJ<SPSPP4R4SPP4SP \ SP PR4S!S4SPSPP4R4R#)sQPOST /bar HTTP/1.1 Connection: close Content-Length: 3 Host: example.com absefrAN)rMrjrrrrrr)rfinisherrrSs&rBrTCRequestTests._sendRequestBodyWithTooManyBytesTest..cbFaileds   $$&  NN "   k8+<+<+B+BE J X    T^^113S 9rA)rr*rhrrjrrrrrr-rrVr&rW)rSrrrrTrZrsff @rB$_sendRequestBodyWithTooManyBytesTest1RequestTests._sendRequestBodyWithTooManyBytesTests"!$'7NHE7 & ))*& (() T^^44d; ::   }o > hrAc *RpVPV4#) If L{Request} is created with a C{bodyProducer} with a known length and the producer tries to produce more than than many bytes, the L{Deferred} returned by L{Request.writeTo} fires with a L{Failure} wrapping a L{WrongBodyLength} exception. c<VPPR4R#rsrrrs&rBrCRequestTests.test_sendRequestBodyWithTooManyBytes..finisher    & &t ,rA)rrSrs& rB$test_sendRequestBodyWithTooManyBytes1RequestTests.test_sendRequestBodyWithTooManyBytess -88BBrAc laa\P!S\4oVV3RlpSPV4#)rc6<VPP\44S^,pSPRV4VR,pSP VP \4SP \4pSP\V4^4R#)rTrN) rrr8r rrrrMrN)rrrrrrSs& rBrHRequestTests.test_sendRequestBodyErrorWithTooManyBytes..finishersv    % %&8&: ;NE MM- /m$A  ! !!''+= >++,>?F   S[! ,rA)rrrr)rSrrsf @rB)test_sendRequestBodyErrorWithTooManyBytes6RequestTests.test_sendRequestBodyErrorWithTooManyBytess0+<'>F --/5rAc RRpVPVPV4\4#)a If the request body producer indicates it is done by firing the L{Deferred} returned from its C{startProducing} method but then goes on to write too many bytes, the L{Deferred} returned by {Request.writeTo} fires with a L{Failure} wrapping L{WrongBodyLength}. c<VPPR4R#rsrrs&rBrPRequestTests.test_sendRequestBodyFinishedEarlyThenTooManyBytes..finisher- r rA)rVr/r&r!s& rB1test_sendRequestBodyFinishedEarlyThenTooManyBytes>RequestTests.test_sendRequestBodyFinishedEarlyThenTooManyBytes% s- -!!  > >x H   rAc RRpVPVPV4\4#)a  If the request body producer indicates an error by firing the L{Deferred} returned from its C{startProducing} method but then goes on to write too many bytes, the L{Deferred} returned by {Request.writeTo} fires with that L{Failure} and L{WrongBodyLength} is logged. cLVPP\44R#rs)rrr8rs&rBrORequestTests.test_sendRequestBodyErroredEarlyThenTooManyBytes..finisher= s    % %&8&: ;rA)rVr/r8r!s& rB0test_sendRequestBodyErroredEarlyThenTooManyBytes=RequestTests.test_sendRequestBodyErroredEarlyThenTooManyBytes5 s- <!!  > >x H   rANc \\4p\RR\V4pVP VP 4pVP PV4VP P4VP\VPPR4VPVP P4R4V#)z If the request body producer with an unknown length tries to write after firing the L{Deferred} returned by its C{startProducing} method, the C{write} call raises an exception and does not write anything to the underlying transport. rrrrA)rrr*rhrrjrrrrrrrrMr)rS_withrrrs&& rB0test_sendChunkedRequestBodyFinishedThenWriteMore=RequestTests.test_sendChunkedRequestBodyFinishedThenWriteMoreE s".1'7NHE7 ""5)  +x'8'8'>'>G --/5rAc rVP\\444pVPV\4#)z If the request body producer with an unknown length tries to write after firing the L{Deferred} returned by its C{startProducing} method with a L{Failure}, the C{write} call raises an exception and does not write anything to the underlying transport. )r=rr8rV)rSrZs& rB9test_sendChunkedRequestBodyFinishedWithErrorThenWriteMoreFRequestTests.test_sendChunkedRequestBodyFinishedWithErrorThenWriteMoreV s6  A A &( ) !!!%788rAc \^4p\RR\V4pVPVP4pVP VPP V4VPVPP4VPPR4VPVPP4R4VPVPP4VPP!\#\%444VPVPP4VP VPP R4VP'V\$4#)z If the L{Deferred} returned from the C{startProducing} method of the L{IBodyProducer} passed to L{Request} fires with a L{Failure}, the L{Deferred} returned from L{Request.writeTo} fails with that L{Failure}. rrrsQPOST /bar HTTP/1.1 Connection: close Content-Length: 5 Host: example.com abN)rr*rhrrjr-rrrrrrMrrrrrrr8rVrs& rBtest_sendRequestBodyWithError*RequestTests.test_sendRequestBodyWithErrorb s"!$'7NHE7  T^^44h? 001&  NN "   556!!'*<*>"?@ 556 T^^44d;!!-1CDDrAc  \RR\/4R4pVP\VPVP 4VP VP P4R4\RR\RRR./4R4pVP\VPVP 4VP VP P4R4R#)z L{Request.writeTo} raises L{BadHeaders} if there is not exactly one I{Host} header and writes nothing to the given transport. rrNrAsHostrFs example.org)r*r2rrrrjrMr)rSrs& rBtest_hostHeaderRequired$RequestTests.test_hostHeaderRequired s &$ T: *goot~~F --/5 D'7^^,L"MNPT  *goot~~F --/5rAc \^4p\RR\V4pVPVP4VP VP 4VP4VPVP 4R#)zK L{Request.stopWriting} calls its body producer's C{stopProducing} method. rrN) rr*rhrrjrrrrrs& rBtest_stopWritingRequestTests.test_stopWriting s` "!$&$A' ))* (()rAc \P!V\4p\^4pRpW2n\ RR\ V4pVPVP4VP4VP\VP\44^4VP^\V44V^,pVPRV4VR,pVP!VP"\4R#)z~ If the body producer's C{stopProducing} method raises an exception, L{Request.stopWriting} logs it and does not re-raise it. c\R4hzstopProducing is bustedrr9rArBbrokenStopProducingBRequestTests.test_brokenStopProducing..brokenStopProducing s$%>? ?rArrrN)rrrrrr*rhrrjrrMrNrr8rr rr)rSrrrNrrrs& rBtest_brokenStopProducing%RequestTests.test_brokenStopProducing s +<r?rrrrrrrrrr r rrr"r'r,r/r4r9r=r@rCrFrIrPr@rrs@rBrrs+     "C" B.9: *56 B?B CC(M6&  " 9%EN 6 *;;rArcXa]tRtRtoRtRtRtRtR RltRt Rt R t R t R t VtR #)LengthEnforcingConsumerTestsi z' Tests for L{LengthEnforcingConsumer}. c\4Vn\^ 4Vn\ 4Vn\ VPVP VP4VnR#) N)rr0rrrrjr"enforcerrts&rBr"LengthEnforcingConsumerTests.setUp s@j &r* (*/ MM4>>4;;  rAc NVPPR4VPVPP 4R4VPP 4VPPR4VPVPP 4R4R#)z L{LengthEnforcingConsumer.write} calls the wrapped consumer's C{write} method with the bytes it is passed as long as there are fewer of them than the C{length} attribute indicates remain to be received. rusdefN)rVrrMrjrrrts&rB test_write'LengthEnforcingConsumerTests.test_write sr F# --/8  F# --/8rAc VPPR4VP\VPP4R#)z L{LengthEnforcingConsumer._noMoreWritesExpected} raises L{WrongBodyLength} if it is called before the indicated number of bytes have been written. Ns xxxxxxxxx)rVrrr&_noMoreWritesExpectedrts&rBtest_finishedEarly/LengthEnforcingConsumerTests.test_finishedEarly s0 H% /4==+N+NOrAc VPPR4VPVPP4VPPR4VP VPP4V'dVPP 4VPVP\4#)a If it is called with a total number of bytes exceeding the indicated limit passed to L{LengthEnforcingConsumer.__init__}, L{LengthEnforcingConsumer.write} fires the L{Deferred} with a L{Failure} wrapping a L{WrongBodyLength} and also calls the C{stopProducing} method of the producer. x xxxxxxxxxx) rVrrrrrr\rVr0r&)rS_unregisterAfters&&rBtest_writeTooMany.LengthEnforcingConsumerTests.test_writeTooMany s I& ../ D!  --.  MM / / 1!!$++??rAc ZVPPR4VPP4VPVPP 4VP \VPPR4VPVPP 4R#)z If L{LengthEnforcingConsumer.write} is called after L{LengthEnforcingConsumer._noMoreWritesExpected}, it calls the producer's C{stopProducing} method and raises L{ExcessWrite}. r`Nra) rVrr\rrrrrrrts&rBtest_writeAfterNoMoreExpected:LengthEnforcingConsumerTests.test_writeAfterNoMoreExpected sp I& ++- ../ +t}}':':DA  --.rAc $VPR4#)z L{LengthEnforcingConsumer._noMoreWritesExpected} does nothing (in particular, it does not raise any exception) if called after too many bytes have been passed to C{write}. T)rcrts&rBtest_finishedLate.LengthEnforcingConsumerTests.test_finishedLate s %%d++rAc VPPR4VPVPP4R4R#)z If L{LengthEnforcingConsumer._noMoreWritesExpected} is called after the correct number of bytes have been written it returns L{None}. Nra)rVrr-r\rts&rB test_finished*LengthEnforcingConsumerTests.test_finished s3 I& T]]@@BDIrAc aV3RlpVSPnV3RlpSP4pVPV4V#)a If L{LengthEnforcingConsumer.write} calls the producer's C{stopProducing} because too many bytes were written and the C{stopProducing} method raises an exception, the exception is logged and the L{LengthEnforcingConsumer} still errbacks the finished L{Deferred}. cX<\PSP4\R4hrM)rrrr8rtsrBrNRLengthEnforcingConsumerTests.test_stopProducingRaises..brokenStopProducing s!  ( ( 7$%>? ?rAcd<SP\SP\44^4R#)rgN)rMrNrr8rs&rB cbFinishedILengthEnforcingConsumerTests.test_stopProducingRaises..cbFinished s$   S!7!78J!KLa PrA)rrrcrW)rSrNrrrZsf rBtest_stopProducingRaises5LengthEnforcingConsumerTests.test_stopProducingRaises s> @': # Q  " " $ j!rA)rVrr0rjN)F)r;r<r=r>r?rrYr]rcrfrirlrtr@rrs@rBrSrS s:  9P@ /,JrArSc6a]tRtRtoRtRtRtRtRtVt R#)RequestBodyConsumerTestsi! z Tests for L{ChunkedEncoder} which sits between an L{ITransport} and a request/response body producer and chunked encodes everything written to it. c  fVP\\\\ 4444R#)z3 L{ChunkedEncoder} instances provide L{IConsumer}. N)rrr rrrts&rBtest_interface'RequestBodyConsumerTests.test_interface( s  Y?P0QRSrAc \4p\V4pVPR4VPVP 4R4VP 4VPR4VPVP 4R4R#)ze L{ChunkedEncoder.write} writes to the transport the chunked encoded form of the bytes passed to it. rrONsxxxxxxxxxxxxxxxxs10 xxxxxxxxxxxxxxxx )rrrrMrr)rSrjencoders& rBrY#RequestBodyConsumerTests.test_write. sg $%  + f *O< i  *,KLrAc n\4p\4p\V4pVPVR4VP VP V4VP VP4VP4VP VP R4VPVP4R4R#)z L{ChunkedEncoder.registerProducer} registers the given streaming producer with its transport and L{ChunkedEncoder.unregisterProducer} writes a zero-length chunk to its transport and unregisters the transport's producer. TNs0 ) rrrregisterProducerr-rrrunregisterProducerrMr)rSrjrr|s& rBtest_producerRegistration2RequestBodyConsumerTests.test_producerRegistration; s$% 8 +  40 Y//:  ++,""$ Y//6 *L9rAr9N) r;r<r=r>r?ryrYrr@rrs@rBrwrw! s  T M::rArwcNa]tRtRtoRtRtRtRtRtRt Rt R t R t Vt R #) TransportProxyProducerTestsiM zb Tests for L{TransportProxyProducer} which proxies the L{IPushProducer} interface of a transport. c VVP\\\R444R#)z? L{TransportProxyProducer} instances provide L{IPushProducer}. N)rrr r%rts&rBry*TransportProxyProducerTests.test_interfaceS s  ]4J44PQRrAc \4p\V4pVPVPV4VP 4VPVPR4R#)zf L{TransportProxyProducer.stopProxying} drops the reference to the wrapped L{IPushProducer} provider. N)rr%r-rZ stopProxyingrSrjproxys& rB%test_stopProxyingUnreferencesProducerATransportProxyProducerTests.test_stopProxyingUnreferencesProducerY sJ $% &y1 U__i8  U__d3rAc x\4pVP4\V4pVPVPR4VP 4VPVPR4VP4VP 4VP 4VPVPR4R#)z L{TransportProxyProducer.resumeProducing} calls the wrapped transport's C{resumeProducing} method unless told to stop proxying. rCrN)rrr%rMrrrrs& rBtest_resumeProducing0TransportProxyProducerTests.test_resumeProducingd s $%   "&y1 00(;  00+>  "   00(;rAc X\4p\V4pVPVPR4VP 4VPVPR4VP 4VP 4VP 4VPVPR4R#)z L{TransportProxyProducer.pauseProducing} calls the wrapped transport's C{pauseProducing} method unless told to stop proxying. rrCN)rr%rMrrrrrs& rBtest_pauseProducing/TransportProxyProducerTests.test_pauseProducingz s $% &y1 00+>  00(;!!#   00+>rAc b\4p\V4pVPVPR4VP 4VPVPR4\4p\V4pVP 4VP 4VPVPR4R#)z} L{TransportProxyProducer.stopProducing} calls the wrapped transport's C{stopProducing} method unless told to stop proxying. rrN)rr%rMrrrrs& rBtest_stopProducing.TransportProxyProducerTests.test_stopProducing s $% &y1 00+>  00)<#% &y1   00+>rAc n\4p\4pVPV4W!n\ V4pVP VP 4VPVPR4VP4VPVPR4VPVP 4R#)z[ L{TransportProxyProducer.loseConnection} calls the wrapped transport's C{loseConnection}. rN) rrrrr%r connectedrMrloseConnectionrrSrjrrs& rB test_loseConnectionWhileProxying  00+> ,,-rAc \4p\4pVPV4W!n\ V4pVP 4VP VP4VP4VP VP4R#)zU L{TransportProxyProducer.loseConnection} does nothing when the proxy is not active. N) rrrrr%rrrrrs& rBtest_loseConnectionNotProxying:TransportProxyProducerTests.test_loseConnectionNotProxying sp 56 ') *%&y1   ++,   ++,rAr9N)r;r<r=r>r?ryrrrrrrr@rrs@rBrrM s3 S 4<,?*?(.*--rArc~a]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtVtR#) ResponseTestsi z Tests for L{Response}. c j\\44pVP\\V44R#)z- L{Response} instances provide L{IResponse}. N)rkrrrr4rSrs& rBtest_verifyInterface"ResponseTests.test_verifyInterface s$)):;  Y9:rAc Ba.o\4p!V3RlR\4pV!4p\V4pVPV4SwpVP 4VP VP R4VP4VP VP R4R#)z The L{IProtocol} provider passed to L{Response.deliverBody} has its C{makeConnection} method called with an L{IPushProducer} provider hooked up to the response as an argument. c.<a]tRtRtoV3RltRtVtR#)7ResponseTests.test_makeConnection..SomeProtocoli c*<SPV4R#rsr )rSr producerss&&rBrFResponseTests.test_makeConnection..SomeProtocol.makeConnection s  *rAr9Nr;r<r=r>rr@r)rrs@rB SomeProtocolr s + +rArrCrN)rr rkr)rrMrr)rSrjrrr theProducerrs& @rBtest_makeConnection!ResponseTests.test_makeConnection s  #%  +8 + >(3X&! ""$ 00(;##% 00+>rAc a.o!V3RlR\4pV!4p\\44pVPV4VP R4VP SR.4R#)z The L{IProtocol} provider passed to L{Response.deliverBody} has its C{dataReceived} method called with bytes received as part of the response body. c.<a]tRtRtoV3RltRtVtR#)5ResponseTests.test_dataReceived..ListConsumeri c*<SPV4R#rsr rSrrs&&rBrBResponseTests.test_dataReceived..ListConsumer.dataReceived  T"rAr9Nr;r<r=r>rr@rrrs@rB ListConsumerr  # #rArrN)r rkrr)rrM)rSrrrrs& @rBtest_dataReceivedResponseTests.test_dataReceived sZ  #8 # >():;X&""6* )rAc La.o!V3RlR\4pV!4p\\44pVPV4VP 4S^,P \ 4VP\S4^4VPVPR4R#)z The L{IProtocol} provider passed to L{Response.deliverBody} has its C{connectionLost} method called with a L{Failure} wrapping L{ResponseDone} when the response's C{_bodyDataFinished} method is called. c.<a]tRtRtoV3RltRtVtR#)7ResponseTests.test_connectionLost..ListConsumeri c*<SPV4R#rsr )rSrPlosts&&rBrqFResponseTests.test_connectionLost..ListConsumer.connectionLost s F#rAr9N)r;r<r=r>rqr@r)rrs@rBrr s $ $rArN) r rkrr)rrLr.rMrNr- _bodyProtocol)rSrrrrs& @rBtest_connectionLost!ResponseTests.test_connectionLost s $8 $ >():;X&""$ Q \" TA& X33T:rAc La.o!V3RlR\4pV!4p\\44pVPR4VPR4VP V4VPR4VP S.RO4VP VPR4R#)z If data is delivered to the L{Response} before a protocol is registered with C{deliverBody}, that data is buffered until the protocol is registered and then is delivered. c.<a]tRtRtoV3RltRtVtR#)8ResponseTests.test_bufferEarlyData..ListConsumeri! c*<SPV4R#rsr rs&&rBrEResponseTests.test_bufferEarlyData..ListConsumer.dataReceived" rrAr9Nrrs@rBrr! rrArrrrN)rrr)r rkrrr)rMr- _bodyBuffer)rSrrrrs& @rBtest_bufferEarlyData"ResponseTests.test_bufferEarlyData s  #8 # >():;""6*""6*X&""6*  89 X1148rAc \\44pVP\44VP \ VP\44R#)zJ L{Response.deliverBody} raises L{RuntimeError} if called more than once. N)rkrr)r rrrs& rB test_multipleStartProducingFails.ResponseTests.test_multipleStartProducingFails0 s; )):;XZ( ,(<(.ListConsumerip c><SPVP4R#rs)rr)rSrjtransportStates&&rBrHResponseTests.test_transportResumed..ListConsumer.makeConnectionq s%%i&=&=>rAr9Nr)rrs@rBrrp s ? ?rArrCrN)r rrrkrMrr))rSrrjrrrs& @rBtest_transportResumed#ResponseTests.test_transportResumedi s  ?8 ?$%   ">(3 00(;X& (4 00+>rAc @\4p\V4pVPR4VPR4VP4\ 4pVP V4VP VPR4VPP\4R#)z If the entire body is delivered to the L{Response} before the response's C{deliverBody} method is called, the protocol passed to C{deliverBody} is immediately given the body data and then disconnected. rrr/N) rrkrrrr)rMrrErLr.rSrjrrs& rB)test_bodyDataFinishedBeforeStartProducing7ResponseTests.test_bodyDataFinishedBeforeStartProducing} s|$% (3""6*""6*""$')X&  2""<0rAc \4p\V4p\4pVPV4VP VP R4VP \\444VPP\4R#)z The L{Failure} passed to L{Response._bodyDataFinished} when the response is in the I{connected} state is passed to the C{connectionLost} method of the L{IProtocol} provider passed to the L{Response}'s C{deliverBody} method. CONNECTEDN) rrkrr)rMrrrr8rErLrs& rB#test_finishedWithErrorWhenConnected1ResponseTests.test_finishedWithErrorWhenConnected sn$% (3')X& +6""7+=+?#@A""#56rAc \4p\V4pVPVPR4VP \ \ 444\4pVPV4VPP\ 4R#)z The L{Failure} passed to L{Response._bodyDataFinished} when the response is in the I{initial} state is passed to the C{connectionLost} method of the L{IProtocol} provider passed to the L{Response}'s C{deliverBody} method. INITIALN) rrkrMrrrr8rr)rErLrs& rB!test_finishedWithErrorWhenInitial/ResponseTests.test_finishedWithErrorWhenInitial sn$% (3 )4""7+=+?#@A')X&""#56rAr9N)r;r<r=r>r?rrrrrrrrrrrrrrrr@rrs@rBrr s`;?,*&;29.JJLLDD?(1$7&77rArN)_r?typingrzope.interfacerzope.interface.verifyrtwisted.internet.deferrrrrtwisted.internet.errorr r twisted.internet.interfacesr r twisted.internet.protocolr twisted.internet.testingrrrrtwisted.loggerrtwisted.protocols.basicrtwisted.python.failurertwisted.trial.unittestrtwisted.web._newclientrrrrrrrrrrr r!r"r#r$r%r&r'twisted.web.clientr(r)r*r+r,r-r.r/r0twisted.web.httpr1twisted.web.http_headersr2twisted.web.iwebr3r4twisted.web.test.requesthelperr5r6 Exceptionr8rDrhr[r^r`rbrkrmrrrrrrrrrrSrwrrr9rArBrs&.JJA@. .0*+(   ',5  'N#345% PTL6(6BSMSMl+;X.>h .Hh .V0  f Ef ER ]     Fp;8p;fb8bJ):x):X{-({-|h7Hh7rA