o bW"@sdZddlmZddlmZmZdZdZGdddZGdd d Z dd l Z dd l Z dd l Z dd l Z eeGd d d eZd ZeeGdddeZd 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?c@s eZdZdZddZddZdS)_PollableResourceTcC d|_dSNTactiveselfr ?/usr/lib/python3/dist-packages/twisted/internet/_pollingfile.pyactivate z_PollableResource.activatecCrNFrr r r r deactivaterz_PollableResource.deactivateN)__name__ __module__ __qualname__r rrr r r r rs rc@sTeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ dS) _PollingTimercCs"||_g|_d|_t|_d|_dSr)reactor _resources _pollTimer MAX_TIMEOUT_currentTimeout_paused)r rr r r __init__ s  z_PollingTimer.__init__cCs|j||dSN)rappend_checkPollingState)r resr r r _addPollableResource's  z"_PollingTimer._addPollableResourcecCs,|jD] }|jr|dSq|dSr)rr _startPolling _stopPolling)r resourcer r r r+s  z _PollingTimer._checkPollingStatecCs|jdur ||_dSdSr)r _rescheduler r r r r"3s z_PollingTimer._startPollingcCs"|jdur|jd|_dSdSr)rcancelr r r r r#7s   z_PollingTimer._stopPollingcCrr)rr r r r _pause<rz_PollingTimer._pausecCsd|_|dSr)rrr r r r _unpause?s z_PollingTimer._unpausecCs|js |j|j|jSdSr)rr callLaterr _pollEventr r r r r%Csz_PollingTimer._reschedulecCsd}g}|jD]}|jr||7}|jr||q|j}|r.|j|d}|tkr-t}n |jd}|tkr9t}||_|rE||_dSdS)Ngg?g@) rr checkWorkrr MIN_TIMEOUTrr%r)r workUnits anyActiver$ newTimeoutr r r r*Gs*    z_PollingTimer._pollEventN) rrrrr!rr"r#r'r(r%r*r r r r rs rNc@sDeZdZddZddZddZddZd d Zd d Zd dZ dS)_PollableReadPipecCs||_||_||_dSr)pipereceivedCallback lostCallback)r r1r2r3r r r rjs z_PollableReadPipe.__init__c Csd}g} zt|jd\}}}|sWnt|j|d\}}||Wn tjy0d}Ynwqd|}|r>| ||rD| t |S)Nr) win32pipe PeekNamedPiper1 win32fileReadFilerwin32apierrorjoinr2cleanuplen) r finished fullDataReadbuffer bytesToReadresulthrdatadataBufr r r r+ps(  z_PollableReadPipe.checkWorkcCs||dSr)rr3r r r r r=s z_PollableReadPipe.cleanupcCs*z t|jWdStjyYdSwr)r: CloseHandler1 pywintypesr;r r r r closes z_PollableReadPipe.closecC |dSr)rIr r r r stopProducing z_PollableReadPipe.stopProducingcCrJr)rr r r r pauseProducingrLz _PollableReadPipe.pauseProducingcCrJr)rr r r r resumeProducingrLz!_PollableReadPipe.resumeProducingN) rrrrr+r=rIrKrMrNr r r r r0hs r0ic@s\eZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ dS)_PollableWritePipecCsZd|_d|_d|_d|_g|_||_||_z t|tj ddWdSt j y,YdSw)NFr) disconnectingproducerproducerPausedstreamingProduceroutQueue writePiper3r6SetNamedPipeHandleState PIPE_NOWAITrHr;)r rUr3r r r rs  z_PollableWritePipe.__init__cCrr)rPr r r r rIrz_PollableWritePipe.closecCs"|jdurd|_|jdSdSr)rQrRrMr r r r bufferFulls z_PollableWritePipe.bufferFullcCs0|jdur|jr |jrd|j_|jdSdS)NFT)rQrSrRrNr r r r bufferEmptys  z_PollableWritePipe.bufferEmptycCsN|jdurtd||jf|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. NzHCannot register producer %s, because producer %s was never unregistered.)rQ RuntimeErrorr rKrSrN)r rQ streamingr r r registerProducers   z#_PollableWritePipe.registerProducercCs d|_dS)z;Stop consuming data from a producer, without disconnecting.N)rQr r r r unregisterProducers z%_PollableWritePipe.unregisterProducercCs:|zt|jWn tjyYnw|dSr)rr:rGrUrHr;r3r r r r writeConnectionLosts z&_PollableWritePipe.writeConnectionLostcCs&ttt|vr td|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 TypeErrorrTextend)r seqr r r writeSequences z _PollableWritePipe.writeSequencecCsLt|tr td|jrdS|j|ttt|jt kr$| 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}. r_N) isinstancer`rcrPrTrsumrar>FULL_BUFFER_SIZErX)r rEr r r writes   z_PollableWritePipe.writecCsd}|js)|jr|dSz t|jddWntjy(||YSw|jrk|jd}d}z t|j|d\}}Wnt jyO|Y|Sw||7}t ||krh|j d||d |S|js,| }|sx|jrx||S)Nrr5) rTrPr^r8 WriteFilerUrHr;popr:r>insertrY)r numBytesWrittenrEerrCode nBytesWrittenresumedr r r r+s>    z_PollableWritePipe.checkWorkN) rrrrrIrXrYr\r]r^rfrjr+r r r r rOs   rO)__doc__zope.interfacertwisted.internet.interfacesrrr,rrrrHr:r8r6r0rirOr r r r s   E3