/usr/lib/python2.6/site-packages/supervisor/medusa
Edit: /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyc (11634B)
Ñò
FATc @ s6 d Z d d k Z d d k l Z d d d „ ƒ YZ d d d „ ƒ YZ d d d „ ƒ YZ d
d d „ ƒ YZ d d d
„ ƒ YZ d d! d „ ƒ YZ d d" d „ ƒ YZ
d d# d „ ƒ YZ d d$ d „ ƒ YZ d d% d „ ƒ YZ
y d d k Z Wn e j
o
d Z n Xd d& d „ ƒ YZ d d' d „ ƒ YZ d S(( s< $Id: producers.py,v 1.1.1.1 2006/06/26 06:36:05 chrism Exp $iÿÿÿÿN( t find_prefix_at_endt simple_producerc B s# e Z d Z d d „ Z d „ Z RS( s producer for a stringi c C s | | _ | | _ d S( N( t datat buffer_size( t selfR R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt __init__ s c C s[ t | i ƒ | i j o( | i | i } | i | i | _ | S| i } d | _ | Sd S( Nt ( t lenR R ( R t result( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt more s ( t __name__t
__module__t __doc__R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR s t scanning_producerc B s# e Z d Z d d „ Z d „ Z RS( s: like simple_producer, but more efficient for large stringsi c C s | | _ | | _ d | _ d S( Ni ( R R t pos( R R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR # s c C sw | i t | i ƒ j oV | i } t t | i ƒ | i | i ƒ } | i | | !} | i t | ƒ | _ | Sd Sd S( NR ( R R R t minR ( R t lpt rpR ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ( s ( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR
! s t lines_producerc B s e Z d Z d „ Z d „ Z RS( s producer for a list of linesc C s
| | _ d S( N( t lines( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR 8 s c C sD | i o2 | i d } | i d | _ t i | d ƒ d Sd Sd S( Ni2 s
R ( R t stringt join( R t chunk( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ; s
( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR 5 s t buffer_list_producerc B s e Z d Z d „ Z d „ Z RS( s producer for a list of stringsc C s d | _ | | _ d S( Ni ( t indext buffers( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR H s c C sF | i t | i ƒ j o d S| i | i } | i d | _ | Sd S( NR i ( R R R ( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR M s
( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR C s t
file_producerc B s& e Z d Z d Z d „ Z d „ Z RS( s( producer wrapper for file[-like] objectsi i c C s d | _ | | _ d S( Ni ( t donet file( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR [ s c C sT | i o d S| i i | i ƒ } | p! | i i ƒ | ` d | _ d S| Sd S( NR i ( R R t readt out_buffer_sizet close( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR _ s
i ( R
R R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR U s t output_producerc B sM e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( s; Acts like an output file; suitable for capturing sys.stdoutc C s
d | _ d S( NR ( R ( R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR u s c C s8 t i | d ƒ } t i | d ƒ } | i | | _ d S( Ns
s
( R t splitfieldsR R ( R R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt writex s c C s | i | d | _ d S( Ns
( R ( R t line( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt writeline} s c C s$ | i t i | d ƒ d | _ d S( Ns
( R R t
joinfields( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt
writelines€ s c C s d S( N( ( R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt flush† s c G s d S( N( ( R t args( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt softspace‰ s c C s4 | i o" | i d } | i d | _ | Sd Sd S( Ni R ( R ( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR Œ s
(
R
R R R R" R$ R& R' R) R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR s s t composite_producerc B s e Z d Z d „ Z d „ Z RS( s$ combine a fifo of producers into onec C s
| | _ d S( N( t producers( R R+ ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR – s c C sU xN t | i ƒ o9 | i d } | i ƒ } | o | S| i i d ƒ q Wd Sd S( Ni R ( R R+ R t pop( R t pt d( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ™ s
( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR* ” s t 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 S( NR ( t producert bufferR ( R R0 R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ¬ s c C sb xI t | i ƒ | i j o/ | i i ƒ } | o | i | | _ q Pq W| i } d | _ | S( NR ( R R1 R R0 R ( R R t r( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ± s i ( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR/ ¥ s t 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 S( Ni ( R0 t functiont bytes( R R0 R4 ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR Ä s c C s` | i oN | i i ƒ } | p d | _ | i | i ƒ n | i t | ƒ | _ | Sd Sd S( NR ( R0 R t NoneR4 R5 R ( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR É s
( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR3 ½ s t 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 S( N( R0 t footers( R R0 R8 ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ç s c C sw | i oe | i i ƒ } | 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
R ( R0 R R R6 R8 R R ( R R ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR ë s
N( R
R R R6 R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR7 Ý s t compressed_producerc B s# e Z d Z d d „ Z d „ Z RS( s
Compress another producer on-the-fly, using ZLIB
[Unfortunately, none of the current browsers seem to support this]
i c C s | | _ t i | ƒ | _ d S( N( R0 t zlibt compressobjt
compressor( R R0 t level( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR s c C sk | i oY d } xK | pC | i i ƒ } | p d | _ | i i ƒ S| i i | ƒ } q W| Sd Sd S( NR ( R0 R R6 R= R' t compress( R t cdataR ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR s
( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR: s
t escaping_producerc B s& e Z d Z d d d „ Z d „ Z RS( s0 A producer that escapes a sequence of characterss
.s
..c C s1 | | _ | | _ | | _ d | _ t | _ d S( NR ( R0 t esc_fromt esc_toR1 R ( R R0 RB RC ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR , s
c C sŽ | i } | i } | i | i i ƒ } | oW t i | | | ƒ } | i | | ƒ } | o | | | _ | | Sd | _ | Sn | Sd S( NR ( RB RC R1 R0 R R t replaceR ( R RB RC R1 t i( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyR 3 s
( R
R R R R ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyRA ' s ( ( ( ( ( ( ( ( ( ( ( ( ( t RCS_IDR t asynchatR R R
R R R R R* R/ R3 R7 R; t ImportErrorR6 R: RA ( ( ( s? /usr/lib/python2.6/site-packages/supervisor/medusa/producers.pyt s$ ! $ !