;ò
`©ÇDc @ s d Z d Z d Z d k Z d k Z d k Z d k Z d k Z d k Z d k
Z
d k Z d k Z y d k
Z
d k Z e Z Wn+ e j
o d k Z
d k Z e Z n Xe e
d ƒ o
d e
_ n d g Z d Z d Z d Z d Z d Z d
Z d Z d Z d
Z d Z! d Z" d Z# d Z$ d Z% e% Z& d Z' d Z( d Z) d Z* d
Z+ d Z, d Z- d Z. d
Z/ d Z0 d Z1 d Z2 d Z3 d Z4 d Z5 d Z6 e i7 e5 ƒ Z8 e i7 e6 ƒ Z9 e: o" d k; Z; d Z< d Z= d „ Z> n d e? f d „ ƒ YZ@ d e@ f d „ ƒ YZA d e? f d „ ƒ YZB d! e? f d" „ ƒ YZC d# e? f d$ „ ƒ YZD d d% „ ZE d& „ ZF d' e? f d( „ ƒ YZG d) e? f d* „ ƒ YZH d+ eH f d, „ ƒ YZI d- e? f d. „ ƒ YZJ d/ eJ f d0 „ ƒ YZK d1 e? f d2 „ ƒ YZL d eL f d3 „ ƒ YZM eN d4 j o d5 „ ZO eM eO ƒ iP ƒ n d S(6 s
fcgi - a FastCGI/WSGI gateway.
For more information about FastCGI, see .
For more information about the Web Server Gateway Interface, see
.
Example usage:
#!/usr/bin/env python
from myapplication import app # Assume app is your WSGI application object
from fcgi import WSGIServer
WSGIServer(app).run()
See the documentation for WSGIServer/Server for more information.
On most platforms, fcgi will fallback to regular CGI behavior if run in a
non-FastCGI context. If you want to force CGI behavior, set the environment
variable FCGI_FORCE_CGI to "Y" or "y".
s Allan Saddi s
$Revision$Ns SHUT_WRi s
WSGIServeri i i i i i i i i i
i s FCGI_MAX_CONNSs
FCGI_MAX_REQSs FCGI_MPXS_CONNSs !BBHHBxs !HB5xs !LB3xs !B7xs
/tmp/fcgi.logc C sd t | j o d Sn yA t t d ƒ } | i d t i ƒ d d !| f ƒ | i ƒ Wn n Xd S( Ns as %sfcgi: %s
i iüÿÿÿ(
s DEBUGs levels opens DEBUGLOGs fs writes times ctimes msgs close( s levels msgs f( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _debug s
$s InputStreamc B sh t Z d Z d „ Z d „ Z d „ Z d d „ Z e d „ Z d d „ Z d „ Z
d
„ Z d „ Z RS( s‘
File-like object representing FastCGI input streams (FCGI_STDIN and
FCGI_DATA). Supports the minimum methods required by WSGI spec.
c C sI | | _ | i i | _ d | _ g | _ d | _ d | _ t
| _ d S( Ns i ( s conns selfs _conns servers inputStreamShrinkThresholds _shrinkThresholds _bufs _bufLists _poss _avails Falses _eof( s selfs conn( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__‘ s c C s` | i | i j oI | i | i | _ | i | i 8_ d | _ | i d j p t ‚ n d S( s6 Gets rid of already read data (since we can't rewind).i N( s selfs _poss _shrinkThresholds _bufs _avails AssertionError( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
_shrinkBufferž s c C s | i i ƒ d S( s( Waits for more data to become available.N( s selfs _conns
process_input( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _waitForData§ s iÿÿÿÿc C sï | i | i j o | i o d Sn xg t o_ | d j p | i | i | j o) | i o | i } PqŠ | i ƒ q( q( | i | } Pq( W| i o( | i d i
| i ƒ 7_ g | _ n | i | i | !} | | _ | i ƒ | Sd S( Ns i (
s selfs _poss _avails _eofs Trues ns newPoss _waitForDatas _bufLists _bufs joins rs
_shrinkBuffer( s selfs ns rs newPos( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys read« s& $
c C s# | i | i j o | i o d Sn x— t o | i o( | i d i | i ƒ 7_ g | _ n | i i d | i ƒ } | d j o) | i o | i } Pqº | i ƒ q( q( | d } Pq( W| t
j o) | i | | j o | i | } qõ n | i | i | !} | | _ | i ƒ | Sd S( Ns s
i i ( s selfs _poss _avails _eofs Trues _bufLists _bufs joins finds is newPoss _waitForDatas lengths Nones rs
_shrinkBuffer( s selfs lengths is rs newPos( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys readlineÅ s.
i c C s{ d } g } | i ƒ } xX | oP | i | ƒ | t | ƒ 7} d | j o
| j n o Pn | i ƒ } q W| Sd S( Ni ( s totals liness selfs readlines lines appends lens sizehint( s selfs sizehints liness lines total( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys readlinesä s
c C s | Sd S( N( s self( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __iter__ð s c C s& | i ƒ } | o
t ‚ n | Sd S( N( s selfs readlines rs
StopIteration( s selfs r( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys nextó s
c C s> | o
t | _ n& | i i | ƒ | i t | ƒ 7_ d S( N( s datas Trues selfs _eofs _bufLists appends _avails len( s selfs data( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys add_dataù s
(
s __name__s
__module__s __doc__s __init__s
_shrinkBuffers _waitForDatas reads Nones readlines readliness __iter__s nexts add_data( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys InputStreamΠs
s MultiplexedInputStreamc B sA t Z d Z d „ Z d „ Z d d „ Z e d „ Z d „ Z RS( sÊ
A version of InputStream meant to be used with MultiplexedConnections.
Assumes the MultiplexedConnection (the producer) and the Request
(the consumer) are running in different threads.
c C s8 t t | ƒ i | ƒ t i ƒ } t i | ƒ | _ d S( N(
s supers MultiplexedInputStreams selfs __init__s conns threadings RLocks locks Conditions _lock( s selfs conns lock( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__ s c C s | i i ƒ d S( N( s selfs _locks wait( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _waitForData s iÿÿÿÿc C s< | i i ƒ z t t | ƒ i | ƒ SWd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedInputStreams reads ns release( s selfs n( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys read s
c C s< | i i ƒ z t t | ƒ i | ƒ SWd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedInputStreams readlines lengths release( s selfs length( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys readline s
c C sI | i i ƒ z' t t | ƒ i | ƒ | i i ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedInputStreams add_datas datas notifys release( s selfs data( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys add_data" s
( s __name__s
__module__s __doc__s __init__s _waitForDatas reads Nones readlines add_data( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys MultiplexedInputStream s
s OutputStreamc B sG t Z d Z e d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( sØ
FastCGI output stream (FCGI_STDOUT/FCGI_STDERR). By default, calls to
write() or writelines() immediately result in Records being sent back
to the server. Buffering should be done in a higher level!
c C sC | | _ | | _ | | _ | | _ g | _ t
| _ t
| _ d S( N(
s conns selfs _conns reqs _reqs types _types buffereds _buffereds _bufLists Falses dataWrittens closed( s selfs conns reqs types buffered( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__0 s c C s t | ƒ } xz | or t | | i i i t ƒ } t
| i | i i ƒ } | | _ | | | _ | i i | ƒ | | } | | 8} q Wd S( N( s lens datas lengths mins selfs _reqs servers maxwrites FCGI_HEADER_LENs toWrites Records _types requestIds recs
contentLengths contentDatas _conns writeRecord( s selfs datas toWrites lengths rec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _write9 s
c C sZ | i p t ‚ | o d Sn t | _ | i o | i i | ƒ n | i | ƒ d S( N(
s selfs closeds AssertionErrors datas Trues dataWrittens _buffereds _bufLists appends _write( s selfs data( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys writeF s
c C s4 | i p t ‚ x | D] } | i | ƒ q Wd S( N( s selfs closeds AssertionErrors liness lines write( s selfs liness line( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
writelinesS s c C s: | i o, d i | i ƒ } g | _ | i | ƒ n d S( Ns ( s selfs _buffereds joins _bufLists datas _write( s selfs data( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys flushY s
c C sX | i o | i o? | i ƒ t | i | i i ƒ } | i i
| ƒ t | _ n d S( s/ Sends end-of-stream notification, if necessary.N( s selfs closeds dataWrittens flushs Records _types _reqs requestIds recs _conns writeRecords True( s selfs rec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys closea s
(
s __name__s
__module__s __doc__s Falses __init__s _writes writes
writeliness flushs close( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys OutputStream* s
s TeeOutputStreamc B s2 t Z d Z d „ Z d „ Z d „ Z d „ Z RS( sq
Simple wrapper around two or more output file-like objects that copies
written data to all streams.
c C s
| | _ d S( N( s
streamLists selfs _streamList( s selfs
streamList( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__n s c C s% x | i D] } | i | ƒ q
Wd S( N( s selfs _streamLists fs writes data( s selfs datas f( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys writeq s
c C s" x | D] } | i | ƒ q Wd S( N( s liness lines selfs write( s selfs liness line( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
writelinesu s c C s" x | i D] } | i ƒ q
Wd S( N( s selfs _streamLists fs flush( s selfs f( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys flushy s
( s __name__s
__module__s __doc__s __init__s writes
writeliness flush( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys TeeOutputStreami s
s
StdoutWrapperc B s2 t Z d Z d „ Z d „ Z d „ Z d „ Z RS( sN
Wrapper for sys.stdout so we know if data has actually been written.
c C s | | _ t | _ d S( N( s stdouts selfs _files Falses dataWritten( s selfs stdout( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__ s c C s( | o
t | _ n | i i | ƒ d S( N( s datas Trues selfs dataWrittens _files write( s selfs data( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys write… s
c C s" x | D] } | i | ƒ q Wd S( N( s liness lines selfs write( s selfs liness line( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
writelinesŠ s c C s t | i | ƒ Sd S( N( s getattrs selfs _files name( s selfs name( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __getattr__Ž s ( s __name__s
__module__s __doc__s __init__s writes
writeliness __getattr__( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
StdoutWrapper} s
c C sú t | | ƒ } | d @o3 t i d | | | d !ƒ d d @} | d 7} n | d 7} t | | ƒ } | d @o3 t i d | | | d !ƒ d d @} | d 7} n | d 7} | | | | !} | | 7} | | | | !} | | 7} | | | f f Sd S( sv
Decodes a name/value pair.
The number of bytes decoded as well as the name/value pair
are returned.
i€ s !Li i iÿÿÿi N( s ords ss poss
nameLengths structs unpacks valueLengths names value( s ss poss values
nameLengths valueLengths name( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys decode_pair‘ s %
%
c C s– t | ƒ } | d j o t | ƒ } n t i d | d Bƒ } t | ƒ } | d j o | t | ƒ 7} n | t i d | d Bƒ 7} | | | Sd S( sI
Encodes a name/value pair.
The encoded string is returned.
i€ s !Ll N( s lens names
nameLengths chrs ss structs packs values valueLength( s names values ss
nameLengths valueLength( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys encode_pair s
s Recordc B sY t Z d Z e e d „ Z d „ Z e e ƒ Z d „ Z d „ Z e e ƒ Z d „ Z
RS( sD
A FastCGI Record.
Used for encoding/decoding records.
c C s: t | _ | | _ | | _ d | _ d | _ d | _ d S( Ni s ( s FCGI_VERSION_1s selfs versions types requestIds
contentLengths
paddingLengths contentData( s selfs types requestId( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__Ç s c C sÎ g } d } x¨ | o y | i | ƒ } WnL t i j
o= } | d t i
j o t i | g g g ƒ q qx ‚ n X| o Pn | i | ƒ t
| ƒ } | | 7} | | 8} q Wd i | ƒ | f Sd S( sŠ
Attempts to receive length bytes from a socket, blocking if necessary.
(Socket may be blocking or non-blocking.)
i s N( s dataLists recvLens lengths socks recvs datas sockets errors es errnos EAGAINs selects appends lens dataLens join( s socks lengths dataLens es dataLists recvLens data( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _recvallÏ s&
c C s= y | i | t ƒ \ } } Wn
t ‚ n X| t j o
t ‚ n t i t | ƒ \ | _
| _ | _ | _
| _ t o0 t d d | i ƒ | i | i | i
f ƒ n | i
oP y" | i | | i
ƒ \ | _ } Wn
t ‚ n X| | i
j o
t ‚ qn | i o+ y | i | | i ƒ Wq9t ‚ q9Xn d S( s' Read and decode a Record from a socket.i s< read: fd = %d, type = %d, requestId = %d, contentLength = %dN( s selfs _recvalls socks FCGI_HEADER_LENs headers lengths EOFErrors structs unpacks FCGI_Headers versions types requestIds
contentLengths
paddingLengths __debug__s _debugs filenos contentData( s selfs socks headers length( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys readè s.
0 0
c C s• t | ƒ } x‚ | oz y | i | ƒ } WnL t i j
o= } | d t i
j o t i g | g g ƒ q qx ‚ n X| | } | | 8} q Wd S( sY
Writes data to a socket and does not return until all the data is sent.
i N( s lens datas lengths socks sends sents sockets errors es errnos EAGAINs select( s socks datas es lengths sent( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _sendall
s
c C sÏ | i d @| _ t o0 t d d | i ƒ | i | i | i f ƒ n t i
t | i | i | i | i | i ƒ } | i | | ƒ | i o | i | | i ƒ n | i o | i | d | i ƒ n d S( s& Encode and write a Record to a socket.i i s= write: fd = %d, type = %d, requestId = %d, contentLength = %ds N( s selfs
contentLengths
paddingLengths __debug__s _debugs socks filenos types requestIds structs packs FCGI_Headers versions headers _sendalls contentData( s selfs socks header( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys write s 0
( s __name__s
__module__s __doc__s FCGI_UNKNOWN_TYPEs FCGI_NULL_REQUEST_IDs __init__s _recvalls staticmethods reads _sendalls write( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys RecordÁ s " s Requestc B s8 t Z d Z d „ Z d „ Z d e d „ Z d „ Z RS( s8
Represents a single FastCGI request.
These objects are passed to your handler and is the main interface
between your handler and the fcgi module. The methods should not
be called by your handler. However, server, params, stdin, stdout,
stderr, and data are free for your handler's use.
c C sp | | _ | i | _ h | _ | | ƒ | _ t | | t ƒ | _ t | | t
d t ƒ| _ | | ƒ | _
d S( Ns buffered( s conns selfs _conns servers paramss inputStreamClasss stdins OutputStreams FCGI_STDOUTs stdouts FCGI_STDERRs Trues stderrs data( s selfs conns inputStreamClass( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__7 s c C sº y | i i | ƒ \ } } Wn[ t i d | i ƒ | i i ƒ | i i
o | i i | ƒ n t d f \ } } n Xt
o t d d | | f ƒ n | i ƒ | i | | ƒ d S( s< Runs the handler, flushes the streams, and ends the request.s filei i s# protocolStatus = %d, appStatus = %dN( s selfs servers handlers protocolStatuss appStatuss tracebacks print_excs stderrs flushs stdouts dataWrittens errors FCGI_REQUEST_COMPLETEs __debug__s _debugs _flushs _end( s selfs protocolStatuss appStatus( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys runA s
l c C s | i i | | | ƒ d S( N( s selfs _conns end_requests appStatuss protocolStatus( s selfs appStatuss protocolStatus( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _endS s c C s | i i ƒ | i i ƒ d S( N( s selfs stdouts closes stderr( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _flushV s
( s __name__s
__module__s __doc__s __init__s runs FCGI_REQUEST_COMPLETEs _ends _flush( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys Request. s
s
CGIRequestc B s/ t Z d Z d „ Z d e d „ Z d „ Z RS( s4 A normal CGI request disguised as a FastCGI request.c C s| d | _ t | _ d | _ t | _ | | _ t t i
ƒ | _ t i
| _
t t i ƒ | _ t i | _ t i ƒ | _ d S( Ni i ( s selfs requestIds FCGI_RESPONDERs roles flagss Falses aborteds servers dicts oss environs paramss syss stdins
StdoutWrappers stdouts stderrs StringIOs data( s selfs server( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__\ s l c C s t i | ƒ d S( N( s syss exits appStatus( s selfs appStatuss protocolStatus( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _endj s c C s d S( N( ( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _flushm s ( s __name__s
__module__s __doc__s __init__s FCGI_REQUEST_COMPLETEs _ends _flush( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
CGIRequestZ s s
Connectionc B s¡ t Z d Z e Z e Z d „ Z d „ Z d „ Z d „ Z
d „ Z d e e
d „ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d
„ Z d „ Z d „ Z RS( sæ
A Connection with the web server.
Each Connection is associated with a single socket (which is
connected to the web server) and is responsible for handling all
the FastCGI message processing for that socket.
c C s( | | _ | | _ | | _ h | _ d S( N( s socks selfs _socks addrs _addrs servers _requests( s selfs socks addrs server( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__| s c C s˜ y | i i t i ƒ Wn d Sn XyX xQ t oI t i | i g g g ƒ \ } } } | p | i i
d ƒ o Pq+ q+ WWn n X| i i ƒ d S( s Close the Connection's socket.Ni ( s selfs _socks shutdowns sockets SHUT_WRs Trues selects rs ws es recvs close( s selfs es rs w( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _cleanupSocket„ s $ c C sŠ t | _ xp | i oe y | i ƒ Wq t j
o Pq t i t i f j
o% } | d t i
j o Pn ‚ q Xq W| i ƒ d S( s& Begin processing data from the socket.i N( s Trues selfs
_keepGoings
process_inputs EOFErrors selects errors sockets es errnos EBADFs _cleanupSocket( s selfs e( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys run“ s
c C s| xb | i oW y+ t i | i g g g d ƒ \ } } } Wn t j
o
t ‚ n X| o Pq q W| i o d Sn t ƒ } | i | i ƒ | i t
j o | i | ƒ nÇ | i t j o | i | ƒ n¦ | i t j o | i | ƒ n… | i t j o | i | ƒ nd | i t j o | i | ƒ nC | i t j o | i | ƒ n" | i t j o | i | ƒ n d S( s? Attempt to read a single Record from the socket and process it.f1.0N( s selfs
_keepGoings selects _socks rs ws es
ValueErrors EOFErrors Records recs reads types FCGI_GET_VALUESs _do_get_valuess FCGI_BEGIN_REQUESTs _do_begin_requests FCGI_ABORT_REQUESTs _do_abort_requests FCGI_PARAMSs
_do_paramss
FCGI_STDINs _do_stdins FCGI_DATAs _do_datas requestIds FCGI_NULL_REQUEST_IDs _do_unknown_type( s selfs es rs ws rec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
process_input¢ s8
+
c C s | i | i ƒ d S( s/
Write a Record to the socket.
N( s recs writes selfs _sock( s selfs rec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys writeRecordÇ s l c C s¬ t t | i ƒ } t i t | | ƒ | _
t | _ | i | ƒ | o | i | i =n t o t d d | i ƒ n | i t @ o | i o | i ƒ t | _ n d S( s
End a Request.
Called by Request objects. An FCGI_END_REQUEST Record is
sent to the web server. If the web server no longer requires
the connection, the socket is closed, thereby ending this
Connection (run() returns).
i s end_request: flags = %dN( s Records FCGI_END_REQUESTs reqs requestIds recs structs packs FCGI_EndRequestBodys appStatuss protocolStatuss contentDatas FCGI_EndRequestBody_LENs
contentLengths selfs writeRecords removes _requestss __debug__s _debugs flagss FCGI_KEEP_CONNs _cleanupSockets Falses
_keepGoing( s selfs reqs appStatuss protocolStatuss removes rec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys end_requestÍ s
c C s¯ t t ƒ } d } xw | | i j of t | i | ƒ \ } \ } } | i i i
| ƒ } | t j o" | i t | t | ƒ ƒ 7_ q q Wt | i ƒ | _ | i | ƒ d S( s6 Handle an FCGI_GET_VALUES request from the web server.i N( s Records FCGI_GET_VALUES_RESULTs outrecs poss inrecs
contentLengths decode_pairs contentDatas names values selfs servers
capabilitys gets caps Nones encode_pairs strs lens writeRecord( s selfs inrecs outrecs caps poss values name( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _do_get_valuesæ s
'c C s¦ t i t | i ƒ \ } } | i i | | i
ƒ } | i | | f \ | _ | _ | _ t
| _ | i o | i o | i | d t d t
ƒn | | i | i t t ƒ } t i t | i ƒ | _ t | _
| i t
ƒ d S( s4 Handle an unknown request type. Respond accordingly.N( s Records FCGI_UNKNOWN_TYPEs outrecs structs packs FCGI_UnknownTypeBodys inrecs types contentDatas FCGI_UnknownTypeBody_LENs
contentLengths selfs writeRecords rec( s selfs inrecs outrec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _do_unknown_type- s
( s __name__s
__module__s __doc__s Falses _multiplexeds InputStreams _inputStreamClasss __init__s _cleanupSockets runs
process_inputs writeRecords FCGI_REQUEST_COMPLETEs Trues end_requests _do_get_valuess _do_begin_requests _do_abort_requests _start_requests
_do_paramss _do_stdins _do_datas _do_unknown_type( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
Connectionq s" %
s MultiplexedConnectionc B s} t Z d Z e Z e Z d „ Z d „ Z d „ Z d e
e d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z d „ Z RS( s[
A version of Connection capable of handling multiple requests
simultaneously.
c C s> t t | ƒ i | | | ƒ t i ƒ } t i
| ƒ | _ d S( N( s supers MultiplexedConnections selfs __init__s socks addrs servers threadings RLocks locks Conditions _lock( s selfs socks addrs servers lock( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__< s c C sP | i i ƒ x | i o | i i ƒ q W| i i ƒ t t | ƒ i ƒ d S( N( s selfs _locks acquires _requestss waits releases supers MultiplexedConnections _cleanupSocket( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _cleanupSocketF s
c C s6 | i i ƒ z | i | i ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires recs writes _socks release( s selfs rec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys writeRecordO s
l c C sR | i i ƒ z0 t t | ƒ i | | | | ƒ | i i
ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedConnections end_requests reqs appStatuss protocolStatuss removes notifys release( s selfs reqs appStatuss protocolStatuss remove( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys end_requestY s
c C s< | i i ƒ z t t | ƒ i | ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedConnections _do_begin_requests inrecs release( s selfs inrec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _do_begin_requestd s
c C s< | i i ƒ z t t | ƒ i | ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedConnections _do_abort_requests inrecs release( s selfs inrec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _do_abort_requestk s
c C s t i | i f ƒ d S( N( s threads start_new_threads reqs run( s selfs req( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _start_requestr s c C s< | i i ƒ z t t | ƒ i | ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedConnections
_do_paramss inrecs release( s selfs inrec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys
_do_paramsu s
c C s< | i i ƒ z t t | ƒ i | ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedConnections _do_stdins inrecs release( s selfs inrec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _do_stdin| s
c C s< | i i ƒ z t t | ƒ i | ƒ Wd | i i ƒ Xd S( N( s selfs _locks acquires supers MultiplexedConnections _do_datas inrecs release( s selfs inrec( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _do_dataƒ s
( s __name__s
__module__s __doc__s Trues _multiplexeds MultiplexedInputStreams _inputStreamClasss __init__s _cleanupSockets writeRecords FCGI_REQUEST_COMPLETEs end_requests _do_begin_requests _do_abort_requests _start_requests
_do_paramss _do_stdins _do_data( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys MultiplexedConnection4 s
s Serverc B s¥ t Z d Z e Z e Z d d Z e d e e e d „ Z
d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z d
d „ Z d „ Z e d
„ Z d „ Z d „ Z RS( sß
The FastCGI server.
Waits for connections from the web server, processing each
request.
If run in a normal CGI context, it will instead instantiate a
CGIRequest and run the handler through there.
i i c C s | t j o
| | _ n | | _ t o¢ y# d k } | i | i ƒ d } Wn t j
o
d } n X| } | o t | _
| d 9} n
t | _
h t | <t | <t | o d p d <| _ n. t | _
h t d <t d <t d <| _ | | _ | | _ d S( s^
handler, if present, must reference a function or method that
takes one argument: a Request object. If handler is not
specified at creation time, Server *must* be subclassed.
(The handler method below is abstract.)
maxwrite is the maximum number of bytes (per Record) to write
to the server. I've noticed mod_fastcgi has a relatively small
receive buffer (8K or so).
bindAddress, if present, must either be a string or a 2-tuple. If
present, run() will open its own listening socket. You would use
this if you wanted to run your application as an 'external' FastCGI
app. (i.e. the webserver would no longer be responsible for starting
your app) If a string, it will be interpreted as a filename and a UNIX
socket will be opened. If a tuple, the first element, a string,
is the interface name/IP to bind to, and the second element (an int)
is the port number.
Set multiplexed to True if you want to handle multiple requests
per connection. Some FastCGI backends (namely mod_fastcgi) don't
multiplex requests at all, so by default this is off (which saves
on thread creation/locking overhead). If threads aren't available,
this keyword is ignored; it's not possible to multiplex requests
at all.
Ni id i i ( s handlers Nones selfs maxwrites thread_availables resources getrlimits
RLIMIT_NOFILEs maxConnss ImportErrors maxReqss multiplexeds MultiplexedConnections _connectionClasss
Connections FCGI_MAX_CONNSs
FCGI_MAX_REQSs FCGI_MPXS_CONNSs
capabilitys bindAddresss _bindAddresss umasks _umask( s selfs handlers maxwrites bindAddresss umasks multiplexeds resources maxReqss maxConns( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__œ s(
6 $ c C s' | i t j oÞ t } t i t t i t i ƒ } y | i ƒ WnQ t i j
oB } | d t i j o
t } q“ | d t i j o ‚ q“ n X| p" t i i d d ƒ i ƒ i d ƒ o* | i | ƒ } | i ƒ t i d ƒ q n2t } t | i ƒ t j ol t i t i t i ƒ } y t i | i ƒ Wn t! j
o n X| i" t j o t i# | i" ƒ } qánl t | i ƒ t$ j p t% ‚ t& | i ƒ d j p t% ‚ t i t i t i ƒ } | i' t i( t i) d ƒ | i* | i ƒ | i+ t i, ƒ | t j o t i# | ƒ n | Sd S( Ni s FCGI_FORCE_CGIs Ns Yi i (- s selfs _bindAddresss Nones Trues isFCGIs sockets fromfds FCGI_LISTENSOCK_FILENOs AF_INETs SOCK_STREAMs socks getpeernames errors es errnos ENOTSOCKs Falses ENOTCONNs oss environs gets uppers
startswiths cgirequest_classs reqs runs syss exits oldUmasks types strs AF_UNIXs unlinks OSErrors _umasks umasks tuples AssertionErrors lens
setsockopts
SOL_SOCKETs SO_REUSEADDRs binds listens SOMAXCONN( s selfs oldUmasks reqs es isFCGIs sock( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _setupSocketÙ sB
-
c C s | i ƒ d S( s Closes the main socket.N( s socks close( s selfs sock( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _cleanupSocket
s c C s‘ g i } t i t i t i f D] } | | t i | ƒ f ƒ q ~ | _ t i t i | i
ƒ t i t i | i ƒ t i t i | i ƒ d S( N( s appends _[1]s signals SIGHUPs SIGINTs SIGTERMs xs getsignals selfs _oldSIGss _hupHandlers _intHandler( s selfs _[1]s x( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _installSignalHandlers s Kc C s. x' | i D] \ } } t i | | ƒ q
Wd S( N( s selfs _oldSIGss signums handlers signal( s selfs handlers signum( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _restoreSignalHandlers s
c C s t | _ t | _ d S( N( s Trues selfs _hupReceiveds Falses
_keepGoing( s selfs signums frame( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _hupHandler s c C s
t | _ d S( N( s Falses selfs
_keepGoing( s selfs signums frame( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _intHandler s f1.0c
C sÌ t i i d ƒ } | t j o t d „ | i d ƒ ƒ } n | i ƒ } t
| _ t | _
| i ƒ xA| i o6y( t i | g g g | ƒ \ } } } Wn6 t i j
o' } | d t i j o qi n ‚ n X| oÀ y | i ƒ \ } } Wn? t i j
o0 } | d t i t i f j o qi n ‚ n X| o! t | ƒ d j p | d | j o | i ƒ qi n | i | | | ƒ } t i! | i" f ƒ n | i# ƒ qi W| i$ ƒ | i% | ƒ | i
Sd S( s€
The main loop. Exits on SIGHUP, SIGINT, SIGTERM. Returns True if
SIGHUP was received, False otherwise.
s FCGI_WEB_SERVER_ADDRSc C s
| i ƒ S( N( s xs strip( s x( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys * s s ,i i N(& s oss environs gets web_server_addrss Nones maps splits selfs _setupSockets socks Trues
_keepGoings Falses _hupReceiveds _installSignalHandlerss selects timeouts rs ws es errors errnos EINTRs accepts
clientSocks addrs sockets EAGAINs lens closes _connectionClasss conns threads start_new_threads runs _mainloopPeriodics _restoreSignalHandlerss _cleanupSocket(
s selfs timeouts web_server_addrss ws
clientSocks socks rs conns es addr( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys run# sB
( +
c C s d S( si
Called with just about each iteration of the main loop. Meant to
be overridden.
N( ( s self( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _mainloopPeriodicX s c C s$ | i o t | _ | | _ n d S( s
Protected convenience method for subclasses to force an exit. Not
really thread-safe, which is why it isn't public.
N( s selfs
_keepGoings Falses reloads _hupReceived( s selfs reload( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys _exit_ s
c C s t | i i d ‚ d S( s
Default handler, which just raises an exception. Unless a handler
is passed at initialization time, this must be implemented by
a subclass.
s .handlerN( s NotImplementedErrors selfs __class__s __name__( s selfs req( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys handlerh s c C s0 d k } | i i d | i t i ƒ ƒ ƒ d S( st
Called by Request if an exception occurs within the handler. May and
should be overridden.
Ns Content-Type: text/html
( s cgitbs reqs stdouts writes htmls syss exc_info( s selfs reqs cgitb( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys errorp s ( s __name__s
__module__s __doc__s Requests
request_classs
CGIRequests cgirequest_classs inputStreamShrinkThresholds Nones Falses __init__s _setupSockets _cleanupSockets _installSignalHandlerss _restoreSignalHandlerss _hupHandlers _intHandlers runs _mainloopPeriodics _exits handlers error( ( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys ServerŠ s
= 4 5 c B s2 t Z d Z e e e d „ Z d „ Z d „ Z RS( s|
FastCGI server that supports the Web Server Gateway Interface. See
.
c K sv | i d ƒ o | d =n t t | ƒ i | | t j o
h } n | | _ | | _ | | _ t
i ƒ | _ d S( s
environ, if present, must be a dictionary-like object. Its
contents will be copied into application's environ. Useful
for passing application-specific variables.
Set multithreaded to False if your application is not MT-safe.
s handlerN(
s kws has_keys supers
WSGIServers selfs __init__s environs Nones applications
multithreadeds threads
allocate_locks _app_lock( s selfs applications environs umasks
multithreadeds kw( ( s4 /home/.underwood/jarrodhroberson/vertigrated/fcgi.pys __init__~ s
c
sQ ˆ i t j o t d f Sn ˆ i } | i | i ƒ d d f | d <ˆ i | d <| i t
j o
ˆ i }
n t t
i ˆ i f ƒ }
|
| d Hello World!
Hello World!
s | %s | %s |
s fps
wsgi.inputs environs keep_blank_valuesi s' | Form data |
|---|
s