/usr/lib/python2.6/site-packages/supervisor
Edit: /usr/lib/python2.6/site-packages/supervisor/http.pyc (22766B)
FATc @ s d d k l Z d d k l Z d d k l Z d d k l Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k
Z
d d k Z d d k Z d d k
Z
d d k Z g Z d d d YZ d d d YZ d
d! d YZ d d" d
YZ d e i f d YZ d e i f d YZ d e i f d YZ d e f d YZ d e f d YZ d d# d YZ d d$ d YZ d d% d YZ d Z d S(& i( t http_date( t http_server( t producers( t filesysNt deferring_chunked_producerc B s# e Z d Z d d Z d Z RS( s' A producer that implements the 'chunked' transfer coding for HTTP/1.1.
Here is a sample usage:
request['Transfer-Encoding'] = 'chunked'
request.push (
producers.chunked_producer (your_producer)
)
request.done()
c C s | | _ | | _ d | _ d S( Ng?( t producert footerst delay( t selfR R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyt __init__ s c C s | i ow | i i } | t j o t S| o d t | | f Sd | _ | i o t i d g | i d d Sd Sn d Sd S( Ns %x
%s
t 0s
s
s 0
t ( R t moret NOT_DONE_YETt lent NoneR t stringt join( R t data( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR ! s
N( t __name__t
__module__t __doc__R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s t deferring_composite_producerc B s e Z d Z d Z d Z RS( s$ combine a fifo of producers into onec C s | | _ d | _ d S( Ng?( R R ( R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR 6 s c C sg x` t | i oK | i d } | i } | t j o t S| o | S| i i d q Wd Sd S( Ni R ( R R R R
t pop( R t pt d( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR : s
( R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR 4 s t deferring_globbing_producerc B s# e Z d Z d d Z d Z RS( s
'glob' the output from a producer into a particular buffer size.
helps reduce the number of calls to send(). [this appears to
gain about 30% performance on requests to a single channel]
i i c C s( | | _ d | _ | | _ d | _ d S( NR g?( R t buffert buffer_sizeR ( R R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR O s c C st x[ t | i | i j oA | i i } | t j o t S| o | i | | _ q Pq W| i } d | _ | S( NR ( R R R R R R
( R R t r( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR U s
i ( R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR H s t deferring_hooked_producerc B s e Z d Z d Z d Z RS( s
A producer that will call
when it empties,.
with an argument of the number of bytes produced. Useful
for logging/instrumentation purposes.
c C s( | | _ | | _ d | _ d | _ d S( Ni g?( R t functiont bytesR ( R R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR j s c C sr | i o` | i i } | t j o t S| p d | _ | i | i n | i t | | _ | Sd Sd S( NR ( R R R
R R R R ( R t result( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR p s
( R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR c s t deferring_http_requestc B s2 e Z d Z d Z d Z d Z d Z RS( s The medusa http_request class uses the default set of producers in
medusa.prodcers. We can't use these because they don't know anything about
deferred responses, so we override various methods here. This was added
to support tail -f like behavior on the logtail handler c O s t i t i t i | i } d } d } d } | i d j o? | d j o( | i d p
d } q~ d | d R1 Rs R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR" s
T 2t deferring_http_channelc B sA e Z d Z e Z e i Z e i d Z d Z d Z RS( i c C s\ | } | i o9 | i } | | _ | | } | | i j o t St Sn t i i | S( N( R t writable_checkt Truet FalseR t http_channelt writable( R t tt nowt last_writable_checkt elapsed( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR E s
c C s x t | i o | i i } | d j o* | i p | i i | i n d St | t o" | i i | i | | _ d S| i } | t
j o | i | _ d S| o | i | | _ d S| i i q d Sq d S( s Implement deferreds N( R t
producer_fifot firstR t
ac_out_bufferR R$ t
isinstanceRb R R
R ( R R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyt
refill_bufferS s*
c C sD | i o | i i n&| i } d | _ t i | d } x" | o | d o | d } qB W| p | i d S| d } t i | \ } } } t i | d } t i | \ } } d | j o5 | o t i
| d | } qt i
| } n t | | | | | | } | i i
| i i i
| d j o, | i d t | d | i d
d Sx | i i D] }
|
i | o y | | _ |
i | Wns | i i i
t i \ \ } } }
} } } | i d | | | |
f d y | i d Wq*q*Xn Xd SqW| i d
d S( s We only override this to use 'deferring_http_request' class
instead of the normal http_request class; it sucks to need to override
this R s
i i NRM t ?s Bad HTTP request: %st errori s' Server Error: %s, %s: file: %s line: %si i ( R4 t found_terminatort in_bufferR Rh R5 R t
crack_requestt join_headerst
splitqueryR_ R" t request_countert incrementRA t total_requestsR t log_infot reprR t handlerst matcht handle_requestt
exceptionst asyncoret compact_traceback( R R) t linesRE R` t uriR* t rpatht rqueryR t ht filet funt lineR t vt tbinfo( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR r s\
! (
R R t ac_out_buffer_sizeR R RD R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR < s t supervisor_http_serverc B s2 e Z e Z d Z d Z d Z d d Z RS( c C s d d k l } | p | i t i } n | i | } | | _ t i i | | i | g | _
| i d | i d S( sj Override __init__ to do logger setup earlier so it can
go to our logger object instead of stdout i( RB i N(
t medusaRB t file_loggert syst stdoutt unresolving_loggerR t
dispatcherR t
set_socketR t setblockingt set_reuse_addr( R t sockt
logger_objectRB ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyt prebind s
c C s d d k l } d d k l } | i d | | _ | | _ | | _ | | _ | | _ | i
d | t i t i | i
| i f d S( Ni( t counter( t VERSION_STRINGi s2 Medusa (V%s) started at %s
Hostname: %s
Port:%s
( t medusa.counterR t medusa.http_serverR t listent
total_clientsR R t bytes_outt bytes_inR RD t ctimeRc RH ( R R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyt postbind s
t infoc C sC d } t | d d d j o
| i } n | i i | | d S( NR t ip( t getattrR R RB R1 ( R t messaget typeR ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s
N( R R R t
channel_classR R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s
t supervisor_af_inet_http_serverc B s e Z d Z d Z RS( s+ AF_INET version of supervisor HTTP server c C s | | _ | | _ t i t i t i } | i | | | i | | f | i i \ } } | p) | i d d t i t i
} n y t i | d | _ Wn/ t i
j
o | i d d | | _ n X| i d S( Ns Computing default hostnamet warningi s Cannot do reverse lookup( R RH t sockett AF_INETt SOCK_STREAMR t bindt getsocknameR t
gethostbynamet gethostnamet
gethostbyaddrRc R R ( R R RH R R RG ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s ( R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s t supervisor_af_unix_http_serverc B s e Z d Z d Z d Z RS( s+ AF_UNIX version of supervisor HTTP server c
C s | | _ | | _ d | t i f } y t i | Wn t i j
o n Xxt i t i t i } zg| i | t i
| | y t i | | Wn t i j
o | i | } | o t i t
i n d | } t i i | y t i | Wn n X| i t i d wU n Xy t i | | d | d Wnk t i j
o\ } | d t
i j o< d } t | | t | t i t i d f q n X| i | | PWd y t i | Wn t i j
o n XXqU d | _ | i d S( Ns %s.%ds Unlinking stale socket %s
g333333?i i s Not permitted to chown %s to uid/gid %s; adjust "sockchown" value in config file or on command line to values that the current user (%s) can successfully chowns ( R RH R\ t getpidt unlinkR R t AF_UNIXR R t chmodt linkt checkusedt errnot
EADDRINUSER t stderrt writeR$ RD t sleept chownt EPERMt
ValueErrorR t pwdt getpwuidt geteuidR Rc R (
R t
socketnamet sockchmodt sockchownR t tempnameR t usedt msgt why( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR
sZ
c C sq t i t i t i } y7 | i | | i d | i d } | i Wn t i j
o t SXt Sd S( Ns GET / HTTP/1.0
i (
R R R t connectt sendt recvR$ R R R ( R R t sR ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR T s
( R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR
s Gt tail_f_producerc B s# e Z d Z d Z d Z RS( c C s[ t | d | _ | | _ d | _ | i } | | j o | | | _ n
d | _ d S( Nt rbg?i ( t openR RE R t fsizet sz( R RE t filenamet headR ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR a s
c C s y | i } Wn t j
o d SX| | i } | d j o d | _ d S| d j o4 | i i | d | i i | } | | _ | St S( NR i s ==> File truncated <==
i ( R t OSErrorR R t seekt readR
( R t newszt bytes_addedR ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR k s
c C s t i | i i t i S( N( R\ t fstatR t filenot statt ST_SIZE( R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR | s ( R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR ` s
t logtail_handlerc B s/ e Z d Z d Z d Z d Z d Z RS( s Logtail HTTP Request Handlers /logtailc C s
| | _ d S( N( t supervisord( R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s c C s2 | i \ } } } } | t | i | i j S( N( R^ R Rf ( R RE Rf Rn Ro Rp ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s c
C si | i d j o | i d d S| i \ } } } } d | j o t i | } n x' | o | d d j o | d } q] W| i d d \ } } | i i i | } | d j o | i d d S| i
i } | d j p t i
i | o | i d d St i | t i } t i | | d (
R RE Rf Rn Ro Rp t processNamet processR t mtime( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s.
!
( R R t IDENTRf R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s
t mainlogtail_handlerc B s/ e Z d Z d Z d Z d Z d Z RS( s! Main Logtail HTTP Request Handlers /mainlogtailc C s
| | _ d S( N( R ( R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s c C s2 | i \ } } } } | t | i | i j S( N( R^ R Rf ( R RE Rf Rn Ro Rp ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s c C s | i d j o | i d d S| i i i } | d j p t i i | o | i d d St i | t i
} t i | | d ( R RE R R ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s
!
( R R R Rf R R R ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s
c s% i p d S i } i } d d f d Y} | } i i } | t i j o+ i i \ } } t | | d | } n[ | t i j o: i i }
i } i
} t |
| | d | } n t d | d d k
l }
d d k l } |
| } t | } t | } t i i t i i t } t i i | d } t i | } | | | } | o] h | | 6} d d k l } | | | } | | | } | | | } | | | } n i i d
| i | | i | | i | | i | | S( Nt
LogWrapperc s e Z f d Z RS( c s2 | i d o | d } n i i | d S( Ns
i( t endswithRB R ( R R ( R ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR1 s ( R R R1 ( ( R ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyR s R s Cannot determine socket type %ri( t supervisor_xmlrpc_handler( t supervisor_ui_handlert ui( t auth_handlers0 Running without any HTTP authentication checking( ( t http_portt
http_usernamet
http_passwordt familyR R t addressR R R R R R t xmlrpcR t webR R R R\ Rf t abspatht dirnamet __file__R R t
os_filesystemt medusa.auth_handlerR RB t criticalt install_handler( R R t usernamet passwordR t wrapperR RG RH t hsR R R R R t
xmlrpchandlert tailhandlert maintailhandlert heret templatedirt
filesystemt uihandlert usersR ( ( R s3 /usr/lib/python2.6/site-packages/supervisor/http.pyt make_http_server sN
( ( ( ( ( ( ( ( R R R R R R R\ R RD R R R R R R~ R
R R R R t http_requestR" R R R R R R R R R6 ( ( ( s3 /usr/lib/python2.6/site-packages/supervisor/http.pyt s6 " 5V 3