o f!#@sdZ ddlmZddlmZGdddZGdddZGdd d ZGd d d ZGd d d Z GdddZ GdddZ GdddZ GdddZ GdddZzddlZWn eyfdZYnwGdddZGdddZdS)z;$Id: producers.py,v 1.9 2004/04/21 13:56:28 akuchling Exp $)find_prefix_at_end)as_bytesc@"eZdZdZdddZddZdS) simple_producerzproducer for a stringcC||_||_dSN)data buffer_sizeselfr r r N/var/www/html/venv/lib/python3.10/site-packages/supervisor/medusa/producers.py__init__ zsimple_producer.__init__cCsFt|j|jkr|jd|j}|j|jd|_|S|j}d|_|SN)lenr r r resultr r rmoreszsimple_producer.moreNr__name__ __module__ __qualname____doc__rrr r r rrs  rc@r) scanning_producerz:like simple_producer, but more efficient for large stringsrcC||_||_d|_dSNr)r r posr r r rr# zscanning_producer.__init__cCsV|jt|jkr)|j}tt|j|j|j}|j||}|jt|7_|SdSr)r rr minr )r lprprr r rr(s zscanning_producer.moreNrrr r r rr!s  rc@ eZdZdZddZddZdS)lines_producerzproducer for a list of linescC ||_dSr)linesr r(r r rr8 zlines_producer.__init__cCs6|jr|jdd}|jdd|_d|dSdS)N2 )r(join)r chunkr r rr;s zlines_producer.moreNrr r r rr&5s r&c@r%)buffer_list_producerzproducer for a list of stringscCd|_||_dSr)indexbuffers)r r3r r rrHrzbuffer_list_producer.__init__cCs2|jt|jkr dS|j|j}|jd7_|SNr)r2rr3r r r r rrLs  zbuffer_list_producer.moreNrr r r rr0Cs r0c@s$eZdZdZdZddZddZdS) file_producerz(producer wrapper for file[-like] objectscCr1r)donefile)r r:r r rrZrzfile_producer.__init__cCs8|jrdS|j|j}|s|j|`d|_dS|Sr4)r9r:readout_buffer_sizecloser6r r rr^s zfile_producer.moreN)rrrrr<rrr r r rr7Ts  r7c@sHeZdZdZddZddZddZdd Zd d Zd d Z ddZ dS)output_producerz;Acts like an output file; suitable for capturing sys.stdoutcCs d|_dSrr r r r rrtr*zoutput_producer.__init__cCs&|d}d|}|j|7_dS)N r,)splitr.r )r r r(r r rwritews  zoutput_producer.writecCs|j|d|_dSNr,r?)r liner r r writeline|szoutput_producer.writelinecCs|jd|d|_dSrD)r r.r)r r r writelinesszoutput_producer.writelinescCdSrr r@r r rflushzoutput_producer.flushcGrHrr )r argsr r r softspacerJzoutput_producer.softspacecCs,|jr|jdd}|jdd|_|SdS)Nir-r?rr r rrs zoutput_producer.moreN) rrrrrrCrFrGrIrLrr r r rr>rs r>c@r%)composite_producerz$combine a fifo of producers into onecCr'r) producers)r rNr r rrr*zcomposite_producer.__init__cCs>t|jr|jd}|}|r|S|jdt|jsdS)Nrr)rrNrpop)r pdr r rrs    zcomposite_producer.moreNrr r r rrMs rMc@r) 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] r8cCs||_d|_||_dSr)producerbufferr )r rSr r r rrr!zglobbing_producer.__init__cCsNt|j|jkr|j}|r|j||_nnt|j|jks|j}d|_|Sr)rrTr rSr)r r rr r rrs zglobbing_producer.moreN)r8rr r r rrRs  rRc@r%)hooked_producerz A producer that will call when it empties,. with an argument of the number of bytes produced. Useful for logging/instrumentation purposes. cCrr)rSfunctionbytes)r rSrWr r rrr!zhooked_producer.__init__cCsD|jr |j}|sd|_||j|S|jt|7_|SdS)Nr-)rSrrWrXrrr r rrs  zhooked_producer.moreNrr r r rrVs rVc@s"eZdZdZdddZddZdS)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() NcCrr)rSfooters)r rSrZr r rrrzchunked_producer.__init__cCs^|jr-|j}|rdt|}t|d|dSd|_|jr+ddg|jdSdSdS)Nz%xs 0s s0 r)rSrrrrZr.)r r sr r rrs  zchunked_producer.morerrr r r rrYs rYNc@r) compressed_producerz: Compress another producer on-the-fly, using ZLIB cCs||_t||_dSr)rSzlib compressobj compressor)r rSlevelr r rrszcompressed_producer.__init__cCsD|jr d}|s|j}|sd|_|jS|j|}|r|SdSr)rSrrarIcompress)r cdatar r r rr s   zcompressed_producer.moreN)r^rr r r rr]s r]c@s"eZdZdZd ddZddZdS) escaping_producerz0A producer that escapes a sequence of characters . ..cCs"||_||_||_d|_t|_dSr)rSesc_fromesc_torTr)r rSrhrir r rr s  zescaping_producer.__init__cCsh|j}|j}|j|j}|r2|||}|||}|r-|| d|_|d| Sd|_|S|Sr)rhrirTrSrreplacer)r rhrirTir r rr's  zescaping_producer.moreN)rfrgrr r r rres  re)RCS_IDsupervisor.medusa.asynchat_25rsupervisor.compatrrrr&r0r7r>rMrRrVrYr_ ImportErrorr]rer r r rs*