+
Dfj}.
)Sequence)exc_info)ListUnion)warn) implementer)blockingCallFromThread)Logger)Failure)INTERNAL_SERVER_ERROR) IResource) NOT_DONE_YETc R V ^8 d QhR\ \ \ 3, R\ /# stringreturn)r strbytes)formats "2/usr/lib/python3/dist-packages/twisted/web/wsgi.py __annotate__r % s# + +c5j) +c + c \ V \ 4 ' d! V P R4 P R4 # V P R4 # )a;
Convert C{string} to a WSGI "bytes-as-unicode" string.
If it's a byte string, decode as ISO-8859-1. If it's a Unicode string,
round-trip it to bytes and back using ISO-8859-1 as the encoding.
@type string: C{str} or C{bytes}
@rtype: C{str}
@raise UnicodeEncodeError: If C{string} contains non-ISO-8859-1 chars.
iso-8859-1)
isinstancer encodedecoder s &r _wsgiStringr % s: &# }}\*11,??}}\**r c 0 V ^8 d QhR\ R\ /# r )r r )r s "r r r 7 s
'
's
'u
'r c $ V P R4 # )z
Convert C{string} from a WSGI "bytes-as-unicode" string to an
ISO-8859-1 byte string.
@type string: C{str}
@rtype: C{bytes}
@raise UnicodeEncodeError: If C{string} contains non-ISO-8859-1 chars.
r )r r s &r _wsgiStringToBytesr" 7 s == &&r c \ a ] tR t^Dt o Rt]! 4 tV 3R lR ltV 3R lR ltR t Rt
V t R# ) _ErrorStreama
File-like object instances of which are used as the value for the
C{'wsgi.errors'} key in the C{environ} dictionary passed to the application
object.
This simply passes writes on to L{logging} system as
error events from the C{'wsgi'} system. In the future, it may be desirable
to expose more information in the events it logs, such as the application
object which generated the message.
c $ < V ^8 d QhRS[ RR/# )r datar N)r )r
__classdict__s "r r _ErrorStream.__annotate__R s L L# L$ Lr c \ V\ 4 ' g( \ RV: R\ V4 P : R24 hV P
P
VRRV3R7 R# )z
Generate an event for the logging system with the given bytes as the
message.
This is called in a WSGI application thread, not the I/O thread.
@type data: str
@raise TypeError: if C{data} is not a native string.
z"write() argument must be str, not ()wsgiT)systemisErrormessageN)r r TypeErrortype__name___logerror)selfr& s &&r write_ErrorStream.writeR sN $$$d,,.
VTD7Kr c 4 < V ^8 d QhRS[ S[, RR/# )r iovecr N)r r )r r' s "r r r( g s # #S #d #r c F V P RP V4 4 R# )a"
Join the given lines and pass them to C{write} to be handled in the
usual way.
This is called in a WSGI application thread, not the I/O thread.
@param iovec: A C{list} of C{'\n'}-terminated C{str} which will be
logged.
@raise TypeError: if C{iovec} contains any non-native strings.
N)r6 join)r5 r9 s &&r
writelines_ErrorStream.writelinesg s
2775>"r c R# )z
Nothing is buffered, so flushing does nothing. This method is required
to exist by PEP 333, though.
This is called in a WSGI application thread, not the I/O thread.
N r5 s &r flush_ErrorStream.flushu s r r@ N) r2
__module__ __qualname____firstlineno____doc__r r3 r6 r= rB __static_attributes____classdictcell__r' s @r r$ r$ D s3 8DL L* # # r r$ c N a ] tR t^~t o RtR tR R ltR R ltR R ltR t Rt
V t R# )
_InputStreamal
File-like object instances of which are used as the value for the
C{'wsgi.input'} key in the C{environ} dictionary passed to the application
object.
This only exists to make the handling of C{readline(-1)} consistent across
different possible underlying file-like object implementations. The other
supported methods pass through directly to the wrapped object.
c Wn R# )z\
Initialize the instance.
This is called in the I/O thread, not a WSGI application thread.
N_wrapped)r5 inputs &&r __init___InputStream.__init__ s
r Nc t Vf V P P 4 # V P P V4 # )zk
Pass through to the underlying C{read}.
This is called in a WSGI application thread, not the I/O thread.
)rO readr5 sizes &&r rT _InputStream.read s1 <==%%' '}}!!$''r c VR8X g Vf V P P 4 # V P P V4 # )z
Pass through to the underlying C{readline}, with a size of C{-1} replaced
with a size of L{None}.
This is called in a WSGI application thread, not the I/O thread.
)rO readlinerU s &&r rZ _InputStream.readline s7 2: ==))+ +}}%%d++r c t Vf V P P 4 # V P P V4 # )zp
Pass through to the underlying C{readlines}.
This is called in a WSGI application thread, not the I/O thread.
)rO readlinesrU s &&r r] _InputStream.readlines s1 <==**, ,}}&&t,,r c , \ V P 4 # )zo
Pass through to the underlying C{__iter__}.
This is called in a WSGI application thread, not the I/O thread.
)iterrO rA s &r __iter___InputStream.__iter__ s DMM""r rN N) r2 rD rE rF rG rQ rT rZ r] ra rH rI rJ s @r rL rL ~ s( ( , -# #r rL c d a ] tR t^t o RtRt]! 4 tR tR t R R lt
R t R t R t
R
tR tV tR# )
_WSGIResponsea
Helper for L{WSGIResource} which drives the WSGI application using a
threadpool and hooks it up to the L{http.Request}.
@ivar started: A L{bool} indicating whether or not the response status and
headers have been written to the request yet. This may only be read or
written in the WSGI application thread.
@ivar reactor: An L{IReactorThreads} provider which is used to call methods
on the request in the I/O thread.
@ivar threadpool: A L{ThreadPool} which is used to call the WSGI
application object in a non-I/O thread.
@ivar application: The WSGI application object.
@ivar request: The L{http.Request} upon which the WSGI environment is
based and to which the application's output will be sent.
@ivar environ: The WSGI environment L{dict}.
@ivar status: The HTTP response status L{str} supplied to the WSGI
I{start_response} callable by the application.
@ivar headers: A list of HTTP response headers supplied to the WSGI
I{start_response} callable by the application.
@ivar _requestFinished: A flag which indicates whether it is possible to
generate more response data or not. This is L{False} until
L{http.Request.notifyFinish} tells us the request is done,
then L{True}.
Fc 8 R V n Wn W n W0n W@n V P P 4 P
V P 4 VP ' d$ RRP VP 4 , pMRpVP ' d$ RRP VP 4 , pMRpVP P R^4 p\ V4 ^8X d RpM V^, pVP 4 p R\ VP 4 R\ V P" 4 R\ \% V P& 4 4 R\ V4 R\ V4 R \ V4 R
\ VP) R 4 ;' g R 4 R
\ VP) R4 ;' g R 4 R\ VP+ 4 4 R\ \% VP- 4 P& 4 4 R\ VP. 4 / V n RV P n VP4 P7 4 Fj w rR\ V
4 P9 4 P; RR4 , p
RP R V 4 4 P; RR4 V P0 V
& Kl V P0 P= RR$RVP? 4 ;' d R ;' g R R R R R R!R R"\A 4 R#\C VPD 4 /4 R# )%F /r ?REQUEST_METHOD REMOTE_ADDR REMOTE_PORT SCRIPT_NAME PATH_INFO QUERY_STRING CONTENT_TYPEs content-typer; CONTENT_LENGTHs content-length SERVER_NAME SERVER_PORTSERVER_PROTOCOLNHTTP_-_,c 3 8 " T F p\ V4 x K R # 5irc )r ).0vs & r )_WSGIResponse.__init__.. s )I&Q+a..&s
z wsgi.versionzwsgi.url_schemehttpshttpz
wsgi.run_oncezwsgi.multithreadTzwsgi.multiprocessz wsgi.errorsz
wsgi.input) )#startedreactor
threadpool applicationrequest notifyFinishaddBoth _finishedprepathr< postpathurisplitlengetClientAddressr methodhostr port getHeadergetRequestHostnamegetHost clientprotoenvirondefaultContentTyperequestHeadersgetAllRawHeadersupperreplaceupdateisSecurer$ rL content) r5 r r r r
scriptNamepathInfoparts queryString
remotePeernamevaluess &&&&& r rQ _WSGIResponse.__init__ s| $& !!#++DNN; ??? '// ::J J dii(8(8 99HH !!$* u:? K (K --/
k'.. 9 ;z7 ;s:??';< ;z2 X. K 4 K(9(9/(J(P(Pb Q k'*;*;+> ?
" +/ ' # 2 2 C C ELD[ . 4 4 6 > >sC HHD "%)I&)I!I!Q!Qc"DLL F
!7#3#3#5#A#A'#K#KV "D#U |~ l7?? ;+
r c RV n R# )zK
Record the end of the response generation for the request being
serviced.
TN)_requestFinished)r5 ignoreds &&r r _WSGIResponse._finished2 s
!% r Nc V P ' d$ Ve V^, P V^, 4 h\ V\ 4 ' g/ \ RP V\
V4 P 4 4 h\ V\ 4 ' d Mk\ V\ 4 ' d/ \ RV: R\
V4 P : R2\ R7 M'\ RV: R\
V4 P : R24 hV F p\ V\ 4 ' d Mk\ V\ 4 ' d/ \ RV: R\
V4 P : R2\ R7 M'\ RV: R\
V4 P : R24 h\ V4 ^8w d \ RV: 24 hV F( p\ V\ 4 ' d K \ R V: 24 h K Wn W n V P # )
z
The WSGI I{start_response} callable. The given values are saved until
they are needed to generate the response.
This will be called in a non-I/O thread.
z!status must be str, not {!r} ({})z headers should be a list, not r* r+ )categoryz headers must be a list, not z)header should be a (str, str) tuple, not z'header must be a (str, str) tuple, not z%header must be (str, str) tuple, not )r with_tracebackr r r0 r r1 r2 listr r RuntimeWarningtupler statusheadersr6 )r5 r r excInfoheaderelems &&&& r
startResponse_WSGIResponse.startResponse9 s <<.wsgiWrite s$ ))+ LL t $r T)r r r )r5 r& r s ff r r6 _WSGIResponse.write~ s1 B %
)$,, 4<<P DL4DLs 3 <c j V P P R^4 w r\ V4 pV P P V\ V4 4 V P FT w r4VP 4 R9 g K V P P P \ V4 \ V4 4 KV R# )z
Set the response code and response headers on the request object, but
do not flush them. The caller is responsible for doing a write in
order for anything to actually be written out in response to the
request.
This must be called in the I/O thread.
N)serverdate)
r r intr setResponseCoder" r lowerresponseHeaders addRawHeader)r5 coder/ r values & r r "_WSGIResponse._sendResponseHeaders s ))$2
4y $$T+=g+FG <.wsgiFinish s3 ,,," 113LL'') -r c < SP P R \ W!V4 R7 V ' d SP P 4 R# SP P \ 4 SP P 4 R# )zWSGI application error)failureN)r3 r r
r loseConnectionr r r )r r1 r tracebackr5 s &&&&r wsgiError$_WSGIResponse.run..wsgiError s^ !!,ge96U " LL//1LL001FGLL'')r T) r r r r6 r getattrr callFromThreadr
BaseExceptionr )r5 appIteratorr r r r s f r r _WSGIResponse.run s B **4<<9K9KLK#JJt$((( $
K$7E
*
LL ' '
DLL A - N
*
LL ' ' 4<< M(* M Ns AB, B, ,AC10C1) r r r r r r r r r rc )r2 rD rE rF rG r r r3 rQ r r r6 r r r rH rI rJ s @r re re sG B 8DN
`%CJ) V(/' ' r re c @ a ] tR tRt o RtRtR tR tR tR t Rt
V t R # )
WSGIResourcei a/
An L{IResource} implementation which delegates responsibility for all
resources hierarchically inferior to it to a WSGI application.
The C{environ} argument passed to the application, includes the
C{REMOTE_PORT} key to complement the C{REMOTE_ADDR} key.
@ivar _reactor: An L{IReactorThreads} provider which will be passed on to
L{_WSGIResponse} to schedule calls in the I/O thread.
@ivar _threadpool: A L{ThreadPool} which will be passed on to
L{_WSGIResponse} to run the WSGI application object.
@ivar _application: The WSGI application object.
Tc * Wn W n W0n R # rc )_reactor _threadpool _application)r5 r r r s &&&&r rQ WSGIResource.__init__ s
% 'r c \ V P V P V P V4 pVP 4 \
# )a
Turn the request into the appropriate C{environ} C{dict} suitable to be
passed to the WSGI application object and then pass it on.
The WSGI application object is given almost complete control of the
rendering process. C{NOT_DONE_YET} will always be returned in order
and response completion will be dictated by the application object, as
will the status, headers, and the response body.
)re r r r r r
)r5 r responses && r renderWSGIResource.render
s9 ! MM4++T->->
r c \ R4 h)z
Reject attempts to retrieve a child resource. All path segments beyond
the one which refers to this resource are handled by the WSGI
application object.
z/Cannot get IResource children from WSGIResource RuntimeError)r5 r r s &&&r getChildWithDefault WSGIResource.getChildWithDefault s LMMr c \ R4 h)z
Reject attempts to add a child resource to this resource. The WSGI
application object handles all path segments beneath this resource, so
L{IResource} children can never be found.
z0Cannot put IResource children under WSGIResourcer )r5 pathchilds &&&r putChildWSGIResource.putChild" s MNNr )r r r N) r2 rD rE rF rG isLeafrQ r r r rH rI rJ s @r r r s- $ F(
NO Or r N) rG collections.abcr sysr typingr r warningsr zope.interfacer twisted.internet.threadsr twisted.loggerr twisted.python.failurer
twisted.web.httpr twisted.web.resourcer twisted.web.serverr
r r" r$ rL re r __all__r@ r r r s
% & ; ! * 2 * + +$
'7 7 t<# <#~o o d
Y8O 8O 8Ov
r