Ic . @ s d Z d d k Z d d k Z d d k Z d d k Z e i d Z d d k Z d d k Z y d d k Z
Wn e j
o d d k
Z
n Xe e i
e i e Z d d k Z d d k Z d d k Z d d k Z d d k l Z d d k l Z d d k Z y$ d d k l Z d d k l Z Wn e j
o
e Z n Xd d k Z d Z e d d
Z e d d d
d d d d d d d d d d d d d d Z e i! d e d d d Z" d d! d" d# d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 d5 d6 g Z# d7 e$ f d8 YZ% d9 e& f d: YZ' d; e$ f d< YZ( d= e$ f d> YZ) d? e& f d@ YZ* dA e& f dB YZ+ e o dC e i
f dD YZ, n dC e i
f dE YZ, dF e, f dG YZ- dH e$ f dI YZ. e dJ Z/ e Z0 dK e i1 f dL YZ2 dM e$ f dN YZ3 dO f dP YZ4 y d d k5 Z5 WnU e j
oI y d dQ k6 l7 Z7 l8 Z8 Wn e j
o dR Z9 n XdS Z9 n XdT Z9 dU e$ f dV YZ: d S(W s
A high-speed, production ready, thread pooled, generic WSGI server.
Simplest example on how to use this module directly
(without using CherryPy's application machinery):
from cherrypy import wsgiserver
def my_crazy_app(environ, start_response):
status = '200 OK'
response_headers = [('Content-type','text/plain')]
start_response(status, response_headers)
return ['Hello world!
']
server = wsgiserver.CherryPyWSGIServer(
('0.0.0.0', 8070), my_crazy_app,
server_name='www.cherrypy.example')
The CherryPy WSGI server can serve as many WSGI applications
as you want in one instance by using a WSGIPathInfoDispatcher:
d = WSGIPathInfoDispatcher({'/': my_crazy_app, '/blog': my_blog_app})
server = wsgiserver.CherryPyWSGIServer(('0.0.0.0', 80), d)
Want SSL support? Just set these attributes:
server.ssl_certificate =
server.ssl_private_key =
if __name__ == '__main__':
try:
server.start()
except KeyboardInterrupt:
server.stop()
This won't call the CherryPy engine (application side) at all, only the
WSGI server, which is independant from the rest of CherryPy. Don't
let the name "CherryPyWSGIServer" throw you; the name merely reflects
its origin, not its coupling.
For those of you wanting to understand internals of this module, here's the
basic call flow. The server's listening thread runs a very tight loop,
sticking incoming connections onto a Queue:
server = CherryPyWSGIServer(...)
server.start()
while True:
tick()
# This blocks until a request comes in:
child = socket.accept()
conn = HTTPConnection(child, ...)
server.requests.put(conn)
Worker threads are kept in a pool and poll the Queue, popping off and then
handling each connection in turn. Each connection can consist of an arbitrary
number of requests and their responses, so we run a nested loop:
while True:
conn = server.requests.get()
conn.communicate()
-> while True:
req = HTTPRequest(...)
req.parse_request()
-> # Read the Request-Line, e.g. "GET /page HTTP/1.1"
req.rfile.readline()
req.read_headers()
req.respond()
-> response = wsgi_app(...)
try:
for chunk in response:
if chunk:
req.write(chunk)
finally:
if hasattr(response, "close"):
response.close()
if req.close_connection:
return
iNs (?i)%2F( t unquote( t urlparse( t SSL( t cryptoc G sZ t t } g } | D]' } | | j o | t t | q q ~ } t i | i S( s Return error numbers for all errors in errnames on this platform.
The 'errno' module contains different global constants depending on
the specific platform (OS). This function will return the list of
numeric values for a given list of potential names.
( t dirt errnot getattrt dictt fromkeyst keys( t errnamest errno_namest _[1]t kt nums( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt plat_specific_errorsn s ;t EINTRt WSAEINTRt EPIPEt EBADFt WSAEBADFt ENOTSOCKt WSAENOTSOCKt ETIMEDOUTt WSAETIMEDOUTt ECONNREFUSEDt WSAECONNREFUSEDt
ECONNRESETt
WSAECONNRESETt ECONNABORTEDt WSAECONNABORTEDt ENETRESETt WSAENETRESETt EHOSTDOWNt EHOSTUNREACHs timed outt EAGAINt EWOULDBLOCKt WSAEWOULDBLOCKt ACCEPTs ACCEPT-CHARSETs ACCEPT-ENCODINGs ACCEPT-LANGUAGEs
ACCEPT-RANGESt ALLOWs
CACHE-CONTROLt
CONNECTIONs CONTENT-ENCODINGs CONTENT-LANGUAGEt EXPECTs IF-MATCHs
IF-NONE-MATCHt PRAGMAs PROXY-AUTHENTICATEt TEt TRAILERs TRANSFER-ENCODINGt UPGRADEt VARYt VIAt WARNINGs WWW-AUTHENTICATEt WSGIPathInfoDispatcherc B s e Z d Z d Z d Z RS( sv A WSGI dispatcher for dispatch based on the PATH_INFO.
apps: a dict or list of (path_prefix, app) pairs.
c C sw y | i } Wn t j
o n X| i | i g } | D]" \ } } | | i d | f qE ~ | _ d S( Nt /( t itemst AttributeErrort sortt reverset rstript apps( t selfR8 R t pt a( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt __init__ s
c C s | d p d } xx | i D]m \ } } | i | d p
| | j o@ | i } | d | | d <| t | | d <| | | Sq W| d d
d g d g S( Nt PATH_INFOR2 t SCRIPT_NAMEs
404 Not Founds Content-Types
text/plains Content-Lengtht 0t ( s Content-Types
text/plain( s Content-LengthR? ( R8 t
startswitht copyt len( R9 t environt start_responset pathR: t app( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt __call__ s
!
( t __name__t
__module__t __doc__R< RH ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR1 s t MaxSizeExceededc B s e Z RS( ( RI RJ ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRL s t SizeCheckWrapperc B s_ e Z d Z d Z d Z d
d Z d
d Z d d Z d Z d Z
d Z RS( s? Wraps a file-like object, raising MaxSizeExceeded if too large.c C s | | _ | | _ d | _ d S( Ni ( t rfilet maxlent
bytes_read( R9 RN RO ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR< s c C s. | i o | i | i j o
t n d S( N( RO RP RL ( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt
_check_length s c C s5 | i i | } | i t | 7_ | i | S( N( RN t readRP RC RQ ( R9 t sizet data( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRR s
c C s | d j o6 | i i | } | i t | 7_ | i | Sg } x| t ot | i i d } | i t | 7_ | i | i | t | d j p | d d j o d i | SqL Wd S( Ni is
R@ ( t NoneRN t readlineRP RC RQ t Truet appendt join( R9 RS RT t res( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRV s
$i c C sw d } g } | i } xX | oP | i | | t | 7} d | j o
| j n o Pn | i } q W| S( Ni ( RV RX RC ( R9 t sizehintt totalt linest line( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt readlines s
c C s | i i d S( N( RN t close( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR` s c C s | S( N( ( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt __iter__ s c C s2 | i i } | i t | 7_ | i | S( N( RN t nextRP RC RQ ( R9 RT ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRb s
N( RI RJ RK R< RQ RU RR RV R_ R` Ra Rb ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRM s
t HTTPRequestc B s e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
d Z d d
Z d d Z d Z d
Z RS( s An HTTP Request (and response).
A single HTTP connection may consist of multiple request/response pairs.
send: the 'send' method from the connection's socket object.
wsgi_app: the WSGI application to call.
environ: a partial WSGI environ (server and connection entries).
The caller MUST set the following entries:
* All wsgi.* entries, including .input
* SERVER_NAME and SERVER_PORT
* Any SSL_* entries
* Any custom entries like REMOTE_ADDR and REMOTE_PORT
* SERVER_SOFTWARE: the value to write in the "Server" response header.
* ACTUAL_SERVER_PROTOCOL: the value to write in the Status-Line of
the response. From RFC 2145: "An HTTP server SHOULD send a
response version equal to the highest version for which the
server is at least conditionally compliant, and whose major
version is less than or equal to the one received in the
request. An HTTP server MUST NOT send a version for which
it is not at least conditionally compliant."
outheaders: a list of header tuples to write in the response.
ready: when True, the request has been parsed and is ready to begin
generating the response. When False, signals the calling Connection
that the response should not be generated and the connection should
close.
close_connection: signals the calling Connection that the request
should close. This does not imply an error! The client and/or
server may each request that the connection be closed.
chunked_write: if True, output will be encoded with the "chunked"
transfer-coding. This value is set automatically inside
send_headers.
i c C sq | d | _ | | _ | i | _ | | _ t | _ t | _ d | _ g | _ t | _
t | _ t | _ d S( Ns
wsgi.inputR@ (
RN t wfileRB RD t wsgi_appt Falset readyt started_responset statust
outheaderst sent_headerst close_connectiont
chunked_write( R9 Rd RD Re ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR< s
c C sQ | i | i _ d | i _ y | i Wn! t j
o | i d d SXd S( s; Parse the next HTTP request start-line and message-headers.i s 413 Request Entity Too LargeN( t max_request_header_sizeRN RO RP t _parse_requestRL t simple_response( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt
parse_request- s
c C s | i i } | p t | _ d S| d j o( | i i } | p t | _ d Sn | i } y% | i i d d \ } } } Wn$ t j
o | i d d d SX| | d ~ }
d
i |
} | | d <| | d s %2FR= t QUERY_STRINGi i t ACTUAL_SERVER_PROTOCOLi s 505 HTTP Version Not Supportedt SERVER_PROTOCOLs
HTTP/%s.%st SERVER_NAMEt CONTENT_LENGTHs 413 Request Entity Too Larges HTTP/1.1t HTTP_CONNECTIONR` s
Keep-Alivet HTTP_TRANSFER_ENCODINGt ,t chunkeds 501 Unimplementedt HTTP_EXPECTs 100-continueid ( RN RV Rf Rg RD t stript splitt
ValueErrorRp R t quoted_slashR RY t intt mint response_protocolt read_headerst reprt argst max_request_body_sizet getRW Rl RU t lowert chunked_read( R9 t request_lineRD t methodRF t req_protocolt schemet locationt paramst qst fragR t xt atomst rpt server_protocolt spt ext mrbst tet _[2]t enc( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRo 8 s
%
0
&
O
c C sf | i } x t o | i i } | p t d n | d j o Pn | d d j o | i } nN | i d d \ } } | i i | i } } d | i d d } | t j o3 | i
| } | o d
i | | f } q n | | | | g } | i D] \ } }
| | d |
d q~ 7} WnV t j
oJ t | t p t d n t |
t p t d q n X| i d | i i d i | d S(# s< Assert, process, and send the HTTP response message-headers.i i s content-lengthi i i i0 s HTTP/1.1Rs t HEADs Transfer-EncodingR} t
connectiont
ConnectionR` s
Keep-Alivei t datet Datet servert Servert SERVER_SOFTWARERv Rr s
s : s, WSGI response header key %r is not a string.s. WSGI response header value %r is not a string.R@ N( i i i0 ( s Transfer-Encodings chunked( s
Connections close( s
Connections
Keep-Alive( Rj R R Ri RW Rl R RD Rm RX R RN RO RP RR t rfc822t
formatdatet TypeErrort
isinstanceR Rd R RY ( R9 R t keyt valuet hkeysRi RS R R R
R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR sJ 0
! >
N( RI RJ RK Rn R R< Rq Ro R R R R Rp RU RE R R ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRc s ! # t
NoSSLErrorc B s e Z d Z RS( s> Exception raised when a client speaks HTTP to an HTTPS socket.( RI RJ RK ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s t
FatalSSLAlertc B s e Z d Z RS( sC Exception raised when the SSL implementation signals a fatal alert.( RI RJ RK ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s t
CP_fileobjectc B sJ e Z d Z d Z d Z d Z d Z d d Z d d Z RS( s- Faux file object attached to a socket object.c C sf x_ | oW y | i | } | | } Wq t i j
o$ } | i d t j o q] q Xq Wd S( s! Sendall for non-blocking sockets.i N( t sendR R R t socket_errors_nonblocking( R9 RT t
bytes_sentt e( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s c C s | i i | S( N( t _sockR ( R9 RT ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s c C s: | i o, d i | i } g | _ | i | n d S( NR@ ( t _wbufRY R ( R9 t buffer( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt flush s
c C sq xj t ob y | i i | SWq t i j
o8 } | i d t j o | i d t j o qh q Xq Wd S( Ni ( RW R t recvR R R R t socket_error_eintr( R9 RS R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s ic C s t | i | i } | i } | i d d | d j oQ t i | _ x4 t o, | i | } | p Pn | i | qM W| i S| i
} | | j oF | i d | i | } t i | _ | i i | i | St i | _ x t o | | } | i | } | p Pn t | } | | j o
| o | S| | j o | i | ~ Pn | | j p t
d | | f | i | | | 7} ~ q W| i Sd S( Ni i s recv(%d) returned %d bytes( t maxt _rbufsizet default_bufsizet _rbufR R RW R R t getvaluet tellRR RC R ( R9 RS t rbufsizeR RT t buf_lent rvt leftt n( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRR sL
!
c C s | i } | i d d | i d j op | i d | i | } | i d p t | | j o* t i | _ | i i | i | S~ n | d j oI| i d j o | i d | i g } t i | _ d } | i } x7 | d j o) | d } | p Pn | i | q Wd i
| S| i d d t i | _ x t o | i | i } | p Pn | i d } | d j o7 | d 7} | i | | | i i | | ~ Pn | i | q]W| i S| i d d | i } | | j oF | i d | i | } t i | _ | i i | i | St i | _ xt o | i | i } | p Pn | | }
| i d d |
} | d j oG | d 7} | i i | | | o | i | | Pq | | Sn t | } | | j o
| o | S| |
j o* | i | |
| i i | |
Pn | i | | | 7} qsW| i Sd S( Ni i s
i R@ ( R R R RV t endswithRC R R RR R RU R RX RY RW t findR ( R9 RS R t blinet buffersRT R t nlR R R R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRV - s
#
( RI RJ RK R R R R RR RV ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s
e Z d Z d Z d Z d Z d Z d Z d Z RS( s, SSL file object attached to a socket object.i g{Gz?c O s t i } xt oy | | | SWnMt i j
o t i | i n)t i j
o t i | i nt i j
oZ } | o | i d j o d S| i d } | o | t j o d St
i | n t i j
o } | o | i d
j o d Sd } y | i d d d } Wn t j
o n X| d j o
t n t | i n n Xt i | | i j o t
i d q q Wd S( s Wrap the given call with SSL error-trapping.
is_reader: if False EOF errors will be raised. If True, EOF errors
will return "" (to emulate normal sockets).
is Unexpected EOFR@ i i s http requests timed outN( is Unexpected EOF( is Unexpected EOF( t timeRW R t
WantReadErrort sleept ssl_retryt WantWriteErrort SysCallErrorR R R R t ErrorRU t
IndexErrorR R t ssl_timeoutt timeout( R9 t is_readert callR t kwargst startR t errnumt thirdarg( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt
_safe_call s>
c O st g } t t | i } xU t oM | i t | | | } | i | | i i } | p d i | Sq Wd S( NR@ ( t superR R RW R RX R t pendingRY ( R9 R R R t rRT R: ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR H s
c O s" | i t t t | i | | S( N( R Rf R R R ( R9 R R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR R s c O s" | i t t t | i | | S( N( R Rf R R R ( R9 R R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR U s ( RI RJ RK R R R R R R ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s .
t HTTPConnectionc B sh e Z d Z d Z e Z h d d 6d d 6e d 6e d 6e d 6e i d
6Z
d Z d Z d
Z
RS( sq An HTTP connection (active socket).
socket: the raw socket object (usually TCP) for this connection.
wsgi_app: the WSGI application for this server/connection.
environ: a WSGI environ template. This will be copied for each request.
rfile: a fileobject for reading from the socket.
send: a function for writing (+ flush) to the socket.
ii i s wsgi.versiont https wsgi.url_schemes wsgi.multithreads wsgi.multiprocesss
wsgi.run_onces wsgi.errorsc C s | | _ | | _ | i i | _ | i i | t oh t | t i oU | i } t | d | i
| _ | | i _ t | d d | _
| | i
_ n. t | d | i
| _ t | d d | _
t | i d | i d Like print_exc() but return a string. Backport for Python 2.3.R@ N( R R RY t tracebackt format_exceptionRU ( t limitt etypeR t tb( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s #t WorkerThreadc B s& e Z d Z d Z d Z d Z RS( s@ Thread which continuously polls a Queue for Connection objects.
server: the HTTP Server which spawned this thread, and which owns the
Queue and is placing active connections into it.
ready: a simple flag for the calling server to know when this thread
has begun polling the Queue.
Due to the timing issues of polling a Queue, a WorkerThread does not
check its own 'ready' flag after it has started. To stop the thread,
it is necessary to stick a _SHUTDOWNREQUEST object onto the Queue
(one for each running WorkerThread).
c C s& t | _ | | _ t i i | d S( N( Rf Rg R t threadingt ThreadR< ( R9 R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR< s c C s yn t | _ x^ t oV | i i i } | t j o d S| | _ z | i Wd | i d | _ Xq WWn' t
t f j
o } | | i _ n Xd S( N(
RW Rg R t requestsR t _SHUTDOWNREQUESTt connR R` RU R R t interrupt( R9 R% t exc( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt run s
N( RI RJ RK RU R% R< R( ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s t
ThreadPoolc B sk e Z d Z d d d Z d Z d Z e e d e i Z d Z d Z d Z
d
d Z RS( s A Request Queue for the CherryPyWSGIServer which pools threads.
ThreadPool objects must provide min, get(), put(obj), start()
and stop(timeout) attributes.
i
ic C sF | | _ | | _ | | _ g | _ t i | _ | i i | _ d S( N( R R R t _threadst Queuet _queueR ( R9 R R R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR< s c C s x0 t | i D] } | i i t | i q Wx2 | i D]' } | i d | i | i q= Wx0 | i D]% } x | i p t
i d q{ Wqr Wd S( s Start the pool of threads.s CP WSGIServer g?N( t xrangeR R* RX R R t setNamet getNameR Rg R R ( R9 t it worker( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR s
c C s< t g } | i D]! } | i d j o | | q q ~ S( s3 Number of worker threads which are idle. Read-only.N( RC R* R% RU ( R9 R t t( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt _get_idle s t docc C s& | i i | | t j o d Sd S( N( R, t putR$ ( R9 t obj( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR5 s
c C s x t | D]t } | i d j o t | i | i j o Pn t | i } | i d | i | i i | | i q
Wd S( s. Spawn new worker threads (not above self.max).i s CP WSGIServer N(
R- R RC R* R R R. R/ RX R ( R9 t amountR0 R1 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt grow s
)c C s x< | i D]1 } | i p | i i | | d 8} q
q
W| d j oD xA t t | t | i | i D] } | i i t qr Wn d S( s- Kill off worker threads (not below self.min).i i N( R* t isAlivet removeR- R RC R, R5 R$ ( R9 R7 R2 R0 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt shrink" s
& i c C sH x! | i D] } | i i t q
Wt i } x| i o| i i } | | j o | i o y | d j p
| d j o | i n | i | | i oq | i
} | oS | i i oE t
o' t | i t
i o | i i q| i i t i n | i n Wq?t t f j
o } q?Xq3 q3 Wd S( Ni ( R* R, R5 R$ R! t
currentThreadR R9 RU RY R% RN t closedR R R R t shutdownt SHUT_RDR R ( R9 R R1 t currentt ct exc1( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt stop3 s,
( RI RJ RK R< R R3 t propertyt idleR5 R8 R; RC ( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR) s
t
SSLConnectionc ! B s: e Z d Z d Z x d% D] Z d# e e f d$ Uq WRS(& s| A thread-safe wrapper for an SSL.Connection.
*args: the arguments to create the wrapped SSL.Connection(*args).
c G s% t i | | _ t i | _ d S( N( R R t _ssl_connR! t RLockt _lock( R9 R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR< \ s t get_contextR R R R RR t renegotiatet bindt listent connectt acceptt setblockingt filenoR> R` t get_cipher_listt getpeernamet getsocknamet
getsockoptt
setsockoptt makefilet get_app_datat set_app_datat state_stringt
sock_shutdownt get_peer_certificatet want_readt
want_writet set_connect_statet set_accept_statet
connect_exR t
settimeouts def %s(self, *args):
self._lock.acquire()
try:
return self._ssl_conn.%s(*args)
finally:
self._lock.release()
N(! RJ s pendings sends writes recvs readRK s binds listens connects acceptRP s filenos shutdowns closeRR RS s getsocknameRU s
setsockoptRW RX RY RZ R[ R\ R] R^ R_ R` Ra s sendalls
settimeout( RI RJ RK R< t f( ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRF V s ( t windllt WinErrorc C s d S( s= Dummy function, since neither fcntl nor ctypes are available.N( ( R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt prevent_socket_inheritancew s c C s0 t i i | i d d p
t n d S( s6 Mark the given socket fd as non-inheritable (Windows).i i N( Rd t kernel32t SetHandleInformationRQ Re ( R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRf { s c C sB | i } t i | t i } t i | t i | t i B d S( s4 Mark the given socket fd as non-inheritable (POSIX).N( RQ t fcntlt F_GETFDt F_SETFDt
FD_CLOEXEC( R t fdt old_flags( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRf s t CherryPyWSGIServerc B s
e Z d Z d Z d Z d Z e Z d Z e
Z e Z
h Z d Z d Z d d d d d d d Z d Z d Z e e e Z d
Z d Z d Z e e e d
d Z d Z d d Z d Z d Z d Z e e e d
d Z d Z d Z! RS( s An HTTP server for WSGI.
bind_addr: The interface on which to listen for connections.
For TCP sockets, a (host, port) tuple. Host values may be any IPv4
or IPv6 address, or any valid hostname. The string 'localhost' is a
synonym for '127.0.0.1' (or '::1', if your hosts file prefers IPv6).
The string '0.0.0.0' is a special IPv4 entry meaning "any active
interface" (INADDR_ANY), and '::' is the similar IN6ADDR_ANY for
IPv6. The empty string or None are not allowed.
For UNIX sockets, supply the filename as a string.
wsgi_app: the WSGI 'application callable'; multiple WSGI applications
may be passed as (path_prefix, app) pairs.
numthreads: the number of worker threads to create (default 10).
server_name: the string to set for WSGI's SERVER_NAME environ entry.
Defaults to socket.gethostname().
max: the maximum number of queued requests (defaults to -1 = no limit).
request_queue_size: the 'backlog' argument to socket.listen();
specifies the maximum number of queued connections (default 5).
timeout: the timeout in seconds for accepted connections (default 10).
nodelay: if True (the default since 3.1), sets the TCP_NODELAY socket
option.
protocol: the version string to write in the Status-Line of all
HTTP responses. For example, "HTTP/1.1" (the default). This
also limits the supported features used in the response.
SSL/HTTPS
---------
The OpenSSL module must be importable for SSL functionality.
You can obtain it from http://pyopenssl.sourceforge.net/
ssl_certificate: the filename of the server SSL certificate.
ssl_privatekey: the filename of the server's private key file.
If either of these is None (both are None by default), this server
will not use SSL. If both are given and are valid, they will be read
on server start and used in the SSL context for the listening socket.
s HTTP/1.1s 127.0.0.1s CherryPy/3.1.1i
ii c C s t | d | p d d | | _ t | o
| | _ n t i d t t | | _ | | _ | p t i
} n | | _ | | _ | | _
| | _ d S( NR i R s The ability to pass multiple apps is deprecated and will be removed in 3.2. You should explicitly include a WSGIPathInfoDispatcher instead.( R) R# t callableRe t warningst warnt DeprecationWarningR1 t bind_addrR t gethostnamet server_namet request_queue_sizeR t shutdown_timeout( R9 Rt Re t
numthreadsRv R Rw R Rx ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR< s "
c C s
| i i S( N( R# R ( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt _get_numthreads s c C s | | i _ d S( N( R# R ( R9 R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt _set_numthreads s c C s d | i | i i | i f S( Ns %s.%s(%r)( RJ t __class__RI Rt ( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt __str__ s c C s | i S( N( t
_bind_addr( R9 ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt _get_bind_addr s c C s> t | t o! | d d j o t d n | | _ d S( Ni R@ sz Host values of '' or None are not allowed. Use '0.0.0.0' (IPv4) or '::' (IPv6) instead to listen on all active interfaces.( R@ N( R t tupleRU R R~ ( R9 R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyt _set_bind_addr s ! R4 s, The interface on which to listen for connections.
For TCP sockets, a (host, port) tuple. Host values may be any IPv4
or IPv6 address, or any valid hostname. The string 'localhost' is a
synonym for '127.0.0.1' (or '::1', if your hosts file prefers IPv6).
The string '0.0.0.0' is a special IPv4 entry meaning "any active
interface" (INADDR_ANY), and '::' is the similar IN6ADDR_ANY for
IPv6. The empty string or None are not allowed.
For UNIX sockets, supply the filename as a string.c C s@ d | _ t | i t od y t i | i Wn n Xy t i | i d Wn n Xt i t i
d d | i f g } nu | i \ } } y+ t i | | t i t i
d t i
} Wn7 t i j
o( t i t i
d d | i f g } n Xd | _ d } x} | D]u } | \ } } } } }
y | i | | | Wn? t i j
o0 } | i o | i i n d | _ q
n XPq
W| i p t i | n | i i d | i i | i | i i t | _ xc | i oX | i | i o@ x" | i t j o t i d qW| i o
| i q7qqWd S( s Run the server forever.i i R@ s No socket could be createdi g?N( RU t
_interruptR Rt t
basestringt ost unlinkt chmodR t AF_UNIXt SOCK_STREAMt getaddrinfot AF_UNSPECt
AI_PASSIVEt gaierrort AF_INETRL R R` Rb RM Rw R# R RW Rg t tickR& R R ( R9 t infot hostt portR RZ t aft socktypet protot canonnamet sa( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyR sZ %&
i c C s t i | | | | _ t | i | i i t i t i d | i o | i i t i t i d n | i o | i o t
d j o t d n t
i
t
i } | i | i | i | i t | | i | _ | i t | i t og | i d d j oS | t i j oC y | i i t i t i d Wqht t i f j
o qhXqln | i i | i d S( s. Create (or recreate) the actual socket object.i s( You must install pyOpenSSL to use HTTPS.i s ::N( R Rf RV t
SOL_SOCKETt SO_REUSEADDRt nodelayt IPPROTO_TCPt TCP_NODELAYt ssl_certificatet ssl_private_keyR RU t ImportErrort Contextt
SSLv23_METHODt use_privatekey_filet use_certificate_fileRF t populate_ssl_environR Rt R t AF_INET6t IPPROTO_IPV6t IPV6_V6ONLYR4 R RL ( R9 t familyt typeR t ctx( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRL D s(
$
c C s y,| i i \ } } t | | i p d St | d o | i | i n | i i } | i d d j o d | i | d Xx t i | | t i t i
D] } | \ } } } } }
d } yC t i | | | } | i d | i | | f | i Wq t i j
o | o | i q6q Xq Wn t | d o | i n d | _ n | i i | i d S( s5 Gracefully shutdown a server that is serving forever.R i i s Bad file descriptorg ?R` N( Rf Rg R RU R Rt R RT R R R R R R Rb RN R` R R# RC Rx ( R9 R R R R RZ R R R R R R ( ( sD /usr/lib/python2.6/site-packages/paste/script/wsgiserver/__init__.pyRC s4
c
C sc t | i d i } t i t i | } h d d 6d d 6} | i h | i d 6| i d 6 x d | i f d | i
f g D] \ } } t | d
d !} d | } | | | M s
#? Ei 'b