vg!#dZ ddlmZddlmZGddZGddZGdd ZGd d ZGd d Z GddZ GddZ GddZ GddZ GddZ ddlZn #e$rdZYnwxYwGddZGddZdS)z;$Id: producers.py,v 1.9 2004/04/21 13:56:28 akuchling Exp $)find_prefix_at_end)as_bytesc eZdZdZddZdZdS)simple_producerzproducer for a stringc"||_||_dSN)data buffer_sizeselfr r s X/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/supervisor/medusa/producers.py__init__zsimple_producer.__init__s &ct|j|jkr/|jd|j}|j|jd|_|S|j}d|_|SNr)lenr r r results rmorezsimple_producer.mores\  ??T- - -Y0 001F $"2"3"34DIMYFDIMrNr__name__ __module__ __qualname____doc__rrrrrrs=''''rrc eZdZdZddZdZdS)scanning_producerz:like simple_producer, but more efficient for large stringsrc0||_||_d|_dSNr)r r posr s rrzscanning_producer.__init__#s &rc|jt|jkrd|j}tt|j|j|jz}|j||}|xjt|z c_|SdSr)r"rr minr )r lprprs rrzscanning_producer.more(sw 8c$)nn $ $B NNHt//BYr"u%F HHF #HHM3rNrrrrrrr!s=DD     rrceZdZdZdZdZdS)lines_producerzproducer for a list of linesc||_dSr )linesr r*s rrzlines_producer.__init__8s  rc|jr;|jdd}|jdd|_d|dzSdS)N2 )r*join)r chunks rrzlines_producer.more;sH : JssOEBCCDJ;;u%%. .2rNrrrrr(r(5s8&&rr(ceZdZdZdZdZdS)buffer_list_producerzproducer for a list of stringsc"d|_||_dSr!)indexbuffers)r r6s rrzbuffer_list_producer.__init__Hs  rc|jt|jkrdS|j|j}|xjdz c_|SNr)r5rr6r r s rrzbuffer_list_producer.moreLs@ :T\** * *3< +D JJ!OJJKrNrrrrr3r3Cs8((rr3c"eZdZdZdZdZdZdS) file_producerz(producer wrapper for file[-like] objectsc"d|_||_dSr!)donefile)r r@s rrzfile_producer.__init__Zs  rc|jrdS|j|j}|s$|j|`d|_dS|Sr8)r?r@readout_buffer_sizecloser:s rrzfile_producer.more^sW 9 39>>4#788D  !!!I s rN)rrrrrCrrrrrr<r<Ts?22O     rr<c<eZdZdZdZdZdZdZdZdZ dZ d S) output_producerz;Acts like an output file; suitable for capturing sys.stdoutcd|_dSrr r s rrzoutput_producer.__init__ts  rcz|d}d|}|xj|z c_dS)N r.)splitr0r )r r r*s rwritezoutput_producer.writews8 4  {{5!! T rc*|j|zdz|_dSNr.rH)r lines r writelinezoutput_producer.writeline|sI$v- rcP|jd|zdz|_dSrO)r r0r+s r writelineszoutput_producer.writeliness%I E 2 22V; rcdSr rrIs rflushzoutput_producer.flush rcdSr r)r argss r softspacezoutput_producer.softspacerVrc^|jr%|jdd}|jdd|_|SdS)Nir/rHrs rrzoutput_producer.mores6 9 Ytt_F #$$DIM2rN) rrrrrrMrQrSrUrYrrrrrFrFrsEE ...<<<      rrFceZdZdZdZdZdS)composite_producerz$combine a fifo of producers into onec||_dSr ) producers)r r^s rrzcomposite_producer.__init__s "rct|jrS|jd}|}|r|S|jdt|jSdS)Nrr)rr^rpop)r pds rrzcomposite_producer.moresk$.!! q!AA &""1%%% $.!! 3rNrrrrr\r\s8..###     rr\c eZdZdZddZdZdS)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] r=c0||_d|_||_dSr)producerbufferr )r rfr s rrzglobbing_producer.__init__s   &rct|j|jkrI|j}|r|j|z|_nnt|j|jkI|j}d|_|Sr)rrgr rfr)r r rs rrzglobbing_producer.moresw$+!111=%%''D "kD0  $+!111 K rN)r=rrrrrdrdsA ''''     rrdceZdZdZdZdZdS)hooked_producerz A producer that will call when it empties,. with an argument of the number of bytes produced. Useful for logging/instrumentation purposes. c0||_||_d|_dSr!)rffunctionbytes)r rfrms rrzhooked_producer.__init__s     rc|jr\|j}|s"d|_||jn|xjt |z c_|SdS)Nr/)rfrrmrnrrs rrzhooked_producer.morese = ]''))F * $  tz**** c&kk) M2rNrrrrrkrks<      rrkc eZdZdZddZdZdS)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"||_||_dSr )rffooters)r rfrss rrzchunked_producer.__init__s   rc|jrv|j}|r*dt|z}t|dz|zdzSd|_|jr!ddg|jzdzSdSdS)Nz%xs 0s s0 r)rfrrrrsr0)r r ss rrzchunked_producer.mores = =%%''D (3t99${{W,t3g== $ <("<<(=>>LL'<3rr rrrrrqrqsA     rrqNc eZdZdZddZdZdS)compressed_producerz: Compress another producer on-the-fly, using ZLIB cF||_tj||_dSr )rfzlib compressobj compressor)r rflevels rrzcompressed_producer.__init__s  *E22rc|jr]d}|sW|j}|s d|_|jS|j|}|W|SdSr)rfrr}rUcompress)r cdatar s rrzcompressed_producer.more sz = E <}))++<$(DM?00222 O44d;;E  <L3rN)ryrrrrrxrxsA3333     rrxc eZdZdZddZdZdS)escaping_producerz0A producer that escapes a sequence of characters . ..cV||_||_||_d|_t|_dSr)rfesc_fromesc_torgr)r rfrrs rrzescaping_producer.__init__ s,      "4rc |j}|j}|j|jz}|rR|||}|||}|r|| d|_|d| Sd|_|S|Sr)rrrgrfrreplacer)r rrrgis rrzescaping_producer.more's=;t}11333  ^^Hf55F''::A $aRSSk crc{""  MrN)rrrrrrrrs=::5555rr)RCS_IDsupervisor.medusa.asynchat_25rsupervisor.compatrrrr(r3r<rFr\rdrkrqr{ ImportErrorrxrrrrrsX G=<<<<<&&&&&& (        "<<"0@:KKKK DDD@sBB"!B"