Ac!#6dZ ddlmZddlmZGddZGddZGdd ZGd d ZGd d Z GddZ GddZ GddZ GddZ GddZ ddlZGddZGddZy#e$rdZYwxYw)z;$Id: producers.py,v 1.9 2004/04/21 13:56:28 akuchling Exp $)find_prefix_at_end)as_bytesceZdZdZddZdZy)simple_producerzproducer for a stringc ||_||_yN)data buffer_sizeselfr r s =/usr/lib/python3/dist-packages/supervisor/medusa/producers.py__init__zsimple_producer.__init__s &ct|j|jkDr9|jd|j}|j|jd|_|S|j}d|_|SNr)lenr r r results r morezsimple_producer.moresb  ?T-- -YY0 0 01F $"2"2"34DIMYYFDIMrNi__name__ __module__ __qualname____doc__rrrr rrs'rrceZdZdZddZdZy)scanning_producerz:like simple_producer, but more efficient for large stringsc.||_||_d|_yNr)r r posr s r rzscanning_producer.__init__#s &rc*|jt|jkrq|j}tt|j|j|jz}|j||}|xjt|z c_|Syr)r!rr minr )r lprprs r rzscanning_producer.more(sr 88c$))n $B NHHt///BYYr"%F HHF #HMrNrrrrr rr!sD rrceZdZdZdZdZy)lines_producerzproducer for a list of linesc||_yr)linesr r)s r rzlines_producer.__init__8s  rc|jr7|jdd}|jdd|_dj|dzSy)N2 )r)join)r chunks r rzlines_producer.more;s@ ::JJsOEBCDJ;;u%. .rNrrrr r'r'5s&rr'ceZdZdZdZdZy)buffer_list_producerzproducer for a list of stringsc d|_||_yr )indexbuffers)r r5s r rzbuffer_list_producer.__init__Hs  rc|jt|jk\ry|j|j}|xjdz c_|SNr)r4rr5r r s r rzbuffer_list_producer.moreLs> ::T\\* *<< +D JJ!OJKrNrrrr r2r2Cs(rr2c eZdZdZdZdZdZy) file_producerz(producer wrapper for file[-like] objectsc d|_||_yr )donefile)r r?s r rzfile_producer.__init__Zs  rc|jry|jj|j}|s$|jj |`d|_y|Sr7)r>r?readout_buffer_sizecloser9s r rzfile_producer.more^sI 9999>>4#7#78D !I  rN)rrrrrBrrrrr r;r;Ts2O rr;c:eZdZdZdZdZdZdZdZdZ dZ y ) output_producerz;Acts like an output file; suitable for capturing sys.stdoutcd|_yrr r s r rzoutput_producer.__init__ts  rcr|jd}dj|}|xj|z c_y)N r-)splitr/r )r r r)s r writezoutput_producer.writews, 4 {{5! T rc2|j|zdz|_yNr-rG)r lines r writelinezoutput_producer.writeline|sII$v- rcP|jdj|zdz|_yrN)r r/r*s r writelineszoutput_producer.writeliness II E 22V; rcyrrrHs r flushzoutput_producer.flush rcyrr)r argss r softspacezoutput_producer.softspacerUrcf|jr%|jdd}|jdd|_|Sy)Nir.rGrs r rzoutput_producer.mores1 99YYt_F #$DIMrN) rrrrrrLrPrRrTrXrrrr rErErs(E .<  rrEceZdZdZdZdZy)composite_producerz$combine a fifo of producers into onec||_yr) producers)r r]s r rzcomposite_producer.__init__s "rct|jrT|jd}|j}|r|S|jjdt|jrTy)Nrr)rr]rpop)r pds r rzcomposite_producer.moresT$..!q!AA""1% $..!rNrrrr r[r[s.# rr[ceZdZdZddZdZy)globbing_producerz '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] c.||_d|_||_yr)producerbufferr )r rer s r rzglobbing_producer.__init__s   &rct|j|jkrU|jj }|r|j|z|_nn#t|j|jkrU|j}d|_|Sr)rrfr rer)r r rs r rzglobbing_producer.moresq$++!1!11==%%'D"kkD0  $++!1!11 KK rN)r<rrrr rcrcs ' rrcceZdZdZdZdZy)hooked_producerz A producer that will call when it empties,. with an argument of the number of bytes produced. Useful for logging/instrumentation purposes. c.||_||_d|_yr )refunctionbytes)r rerls r rzhooked_producer.__init__s     rc|jr`|jj}|s$d|_|j|j|S|xjt |z c_|Sy)Nr.)rerrlrmrrs r rzhooked_producer.moresX ==]]'')F $  tzz*M c&k) MrNrrrr rjrjs  rrjceZdZdZddZdZy)chunked_producera'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() Nc ||_||_yr)refooters)r rerrs r rzchunked_producer.__init__s   rc|jrt|jj}|r"dt|z}t|dz|zdzSd|_|jr"dj dg|jzdzSyy)Nz%xs 0s s0 r)rerrrrrr/)r r ss r rzchunked_producer.moresx ====%%'D3t9${W,t3g== $ <<"<<(=>LL'rrrrrr rprps rrpNceZdZdZddZdZy)compressed_producerz: Compress another producer on-the-fly, using ZLIB cF||_tj||_yr)rezlib compressobj compressor)r relevels r rzcompressed_producer.__init__s  **E2rc|jrad}|s[|jj}|s!d|_|jjS|jj |}|s[|Syr)rerr{rTcompress)r cdatar s r rzcompressed_producer.more sc ==E}}))+$(DM??0022 OO44d;E LrN)rrrr rwrws3 rrwceZdZdZddZdZy)escaping_producerz0A producer that escapes a sequence of characterscR||_||_||_d|_t|_yr)reesc_fromesc_torfr)r rerrs r rzescaping_producer.__init__ s&      "4rc|j}|j}|j|jj z}|r@|j ||}|j ||}|r|| d|_|d| Sd|_|S|Sr)rrrfrerreplacer)r rrrfis r rzescaping_producer.more's==;;t}}1133 ^^Hf5F'':A$aRSk cr{""  MrN)z .z ..rrrr rrs:5rr)RCS_IDsupervisor.medusa.asynchat_25rsupervisor.compatrrrr'r2r;rEr[rcrjrpry ImportErrorrwrrrr rs G=& (  "<<"0@:@G Ds5BBB