\dW"dZddlmZddlmZmZdZdZGddZGdd Z dd l Z dd l Z dd l Z dd l Z eeGd d eZd ZeeGddeZd S)z Implements a simple polling interface for file descriptors that don't work with select() - this is pretty much only useful on Windows. ) implementer) IConsumer IPushProducerg& .>g?ceZdZdZdZdZdS)_PollableResourceTcd|_dSNTactiveselfs =lib/python3.11/site-packages/twisted/internet/_pollingfile.pyactivatez_PollableResource.activates  cd|_dSNFr r s r deactivatez_PollableResource.deactivates  rN)__name__ __module__ __qualname__r rrrrrrs7 FrrcDeZdZdZdZdZdZdZdZdZ dZ d Z d S) _PollingTimercV||_g|_d|_t|_d|_dSr)reactor _resources _pollTimer MAX_TIMEOUT_currentTimeout_paused)r rs r__init__z_PollingTimer.__init__ s* * rcb|j||dSN)rappend_checkPollingState)r ress r_addPollableResourcez"_PollingTimer._addPollableResource's0 s### !!!!!rc~|jD] }|jr|dS!|dSr#)rr _startPolling _stopPolling)r resources rr%z _PollingTimer._checkPollingState+sU  H ""$$$         rcJ|j||_dSdSr#)r _rescheduler s rr)z_PollingTimer._startPolling3s) ? ""..00DOOO # "rcX|j"|jd|_dSdSr#)rcancelr s rr*z_PollingTimer._stopPolling7s1 ? & O " " $ $ $"DOOO ' &rcd|_dSr )r r s r_pausez_PollingTimer._pause<s  rc<d|_|dSr)r r%r s r_unpausez_PollingTimer._unpause?s!  !!!!!rc^|js%|j|j|jSdSr#)r r callLaterr _pollEventr s rr-z_PollingTimer._rescheduleCs6| Q<))$*>PP P Q Qrchd}g}|jD]<}|jr3||z }|jr||=|j}|r |j|dzz }|t krt }n|jdz}|t krt }||_|r||_dSdS)Ngg?g@) rr checkWorkr$r MIN_TIMEOUTrr-r)r workUnits anyActiver+ newTimeouts rr6z_PollingTimer._pollEventGs   / /H /X//111 ?/$$X...)  )-SAJK''( -3JK''( )  1"..00DOOO 1 1rN) rrrr!r'r%r)r*r1r3r-r6rrrrrs"""   111### """QQQ11111rrNc8eZdZdZdZdZdZdZdZdZ dS) _PollableReadPipec0||_||_||_dSr#)pipereceivedCallback lostCallback)r r@rArBs rr!z_PollableReadPipe.__init__js 0(rcd}g} tj|jd\}}}|snLtj|j|d\}}||n#t j$rd}YnwxYwnd|}|r| ||r| t|S)Nrr) win32pipe PeekNamedPiper@ win32fileReadFiler$win32apierrorjoinrAcleanuplen) r finished fullDataReadbuffer bytesToReadresulthrdatadataBufs rr8z_PollableReadPipe.checkWorkps   .7.EdiQR.S.S+ V"$-didKKD##D))))>     ((<((  +  ! !' * * *   LLNNN7||s A3AA0/A0cV||dSr#)rrBr s rrLz_PollableReadPipe.cleanups*  rcf tj|jdS#tj$rYdSwxYwr#)rI CloseHandler@ pywintypesrJr s rclosez_PollableReadPipe.closesE    + + + + +    DD s 00c.|dSr#)rZr s r stopProducingz_PollableReadPipe.stopProducings rc.|dSr#)rr s rpauseProducingz _PollableReadPipe.pauseProducings rc.|dSr#)rr s rresumeProducingz!_PollableReadPipe.resumeProducings rN) rrrr!r8rLrZr\r^r`rrrr>r>hs}))) .rr>icJeZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) _PollableWritePipecd|_d|_d|_d|_g|_||_||_ tj|tj dddS#tj $rYdSwxYw)NFr) disconnectingproducerproducerPausedstreamingProduceroutQueue writePiperBrESetNamedPipeHandleState PIPE_NOWAITrYrJ)r rirBs rr!z_PollableWritePipe.__init__s" #!" "(   -90$         DD s!AA)(A)cd|_dSr )rdr s rrZz_PollableWritePipe.closes!rcX|j"d|_|jdSdSr )rerfr^r s r bufferFullz_PollableWritePipe.bufferFulls4 = $"&D  M ( ( * * * * * % $rc~|j5|jr|jr'd|j_|jdSdS)NFT)rergrfr`r s r bufferEmptyz_PollableWritePipe.bufferEmptysJ = $' %,0,? %,1DM ( M ) ) + + +4urc|jtd|d|jd|js|dS||_||_|s|dSdS)awRegister to receive data from a producer. This sets this selectable to be a consumer for a producer. When this selectable runs out of data on a write() call, it will ask the producer to resumeProducing(). A producer should implement the IProducer interface. FileDescriptor provides some infrastructure for producer methods. NzCannot register producer z, because producer z was never unregistered.)re RuntimeErrorr r\rgr`)r re streamings rregisterProducerz#_PollableWritePipe.registerProducers = $,#+88T]]]< { +  " " $ $ $ $ $$DM%.D " +((***** + +rcd|_dS)z;Stop consuming data from a producer, without disconnecting.N)rer s runregisterProducerz%_PollableWritePipe.unregisterProducers  rc| tj|jn#tj$rYnwxYw|dSr#)rrIrXrirYrJrBr s rwriteConnectionLostz&_PollableWritePipe.writeConnectionLostsj     0 0 0 0    D  s0AActtt|vrtd|j|dS)z Append a C{list} or C{tuple} of bytes to the output buffer. @param seq: C{list} or C{tuple} of C{str} instances to be appended to the output buffer. @raise TypeError: If C{seq} contains C{unicode}. %Unicode not allowed in output buffer.N)strmaptype TypeErrorrhextend)r seqs r writeSequencez _PollableWritePipe.writeSequencesB #dC.. CDD D S!!!!!rc t|trtd|jrdS|j|t tt|jtkr| dSdS)z Append some bytes to the output buffer. @param data: C{str} to be appended to the output buffer. @type data: C{str}. @raise TypeError: If C{data} is C{unicode} instead of C{str}. rzN) isinstancer{r~rdrhr$sumr|rMFULL_BUFFER_SIZErn)r rTs rwritez_PollableWritePipe.writes dC  ECDD D    F T""" s3 && ' '*: : : OO      ; :rcd}|jse|jr|dS tj|jddn+#t j$r||cYSwxYw|jr|jd}d} tj|j|d\}}||z }t||kr$|j d||dnbn)#tj$r|Yn>>># ' ' '((***&&&& 'm +=$$Q''DG )2)   ((***  m +&&((G +t1 +((***s#A%A,+A,C..#DDN) rrrr!rZrnrprtrvrxrrr8rrrrbrbs """+++ +++. " " ""rrb)__doc__zope.interfacertwisted.internet.interfacesrrr9rrrrYrIrGrEr>rrbrrrrsf  '&&&&&@@@@@@@@  ?1?1?1?1?1?1?1?1J ]00000)000f YCCCCC*CCCCCr