U T‚g÷!ã@sœdZddlmZddlmZmZdZdZGdd„dƒZGdd „d ƒZ dd l Z dd l Z dd l Z dd l Z eeƒGd d „d eƒƒZd ZeeƒGdd„deƒƒZd 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 eZdZdZdd„Zdd„ZdS)Ú_PollableResourceTcCs d|_dS©NT©Úactive©Úself©r úA/tmp/pip-unpacked-wheel-1_7di8ic/twisted/internet/_pollingfile.pyÚactivatesz_PollableResource.activatecCs d|_dS©NFrr r r r Ú deactivatesz_PollableResource.deactivateN)Ú__name__Ú __module__Ú __qualname__rr rr r r r rsrc@sTeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z 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 |¡| ¡dS©N)rÚappendÚ_checkPollingState)r Úresr r r Ú_addPollableResource's z"_PollingTimer._addPollableResourcecCs*|jD]}|jr| ¡q&q| ¡dSr)rrÚ _startPollingÚ _stopPolling)r Úresourcer r r r+s  z _PollingTimer._checkPollingStatecCs|jdkr| ¡|_dSr)rÚ _rescheduler r r r r 3s z_PollingTimer._startPollingcCs|jdk r|j ¡d|_dSr)rÚcancelr r r r r!7s  z_PollingTimer._stopPollingcCs d|_dSr)rr r r r Ú_pause<sz_PollingTimer._pausecCsd|_| ¡dSr)rrr r r r Ú_unpause?sz_PollingTimer._unpausecCs|js|j |j|j¡SdSr)rrZ callLaterrÚ _pollEventr r r r r#Csz_PollingTimer._reschedulecCsŠd}g}|jD]&}|jr|| ¡7}|jr| |¡q|j}|r\|j|d}|tkrrt}n|jd}|tkrrt}||_|r†| ¡|_dS)Nggð?g@) rrÚ checkWorkrrÚ MIN_TIMEOUTrr#r)r Z workUnitsZ anyActiver"Z newTimeoutr r r r'Gs$    z_PollingTimer._pollEventN) rrrrrrr r!r%r&r#r'r r r r rsrNc@sDeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dS)Ú_PollableReadPipecCs||_||_||_dSr)ÚpipeÚreceivedCallbackÚ lostCallback)r r+r,r-r r r rjsz_PollableReadPipe.__init__c Cs”d}g}z>t |jd¡\}}}|s&Wqht |j|d¡\}}| |¡Wqtjk rdd}YqhYqXqd |¡}|r€|  |¡|rŒ|  ¡t |ƒS)Nréó) Ú win32pipeZ PeekNamedPiper+Ú win32fileZReadFilerÚwin32apiÚerrorÚjoinr,ÚcleanupÚlen) r ÚfinishedZ fullDataReadÚbufferÚ bytesToReadÚresultÚhrÚdataZdataBufr r r r(ps"   z_PollableReadPipe.checkWorkcCs| ¡| ¡dSr)rr-r r r r r5‡sz_PollableReadPipe.cleanupcCs,zt |j¡Wntjk r&YnXdSr)r2Ú CloseHandler+Ú pywintypesr3r r r r Úclose‹sz_PollableReadPipe.closecCs | ¡dSr)r?r r r r Ú stopProducing’sz_PollableReadPipe.stopProducingcCs | ¡dSr)rr r r r ÚpauseProducing•sz _PollableReadPipe.pauseProducingcCs | ¡dSr)r r r r r ÚresumeProducing˜sz!_PollableReadPipe.resumeProducingN) rrrrr(r5r?r@rArBr r r r r*hsr*ic@s\eZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dS)Ú_PollableWritePipecCs\d|_d|_d|_d|_g|_||_||_zt |tj dd¡Wnt j k rVYnXdS)NFr) Ú disconnectingÚproducerÚproducerPausedÚstreamingProducerÚoutQueueÚ writePiper-r0ZSetNamedPipeHandleStateZ PIPE_NOWAITr>r3)r rIr-r r r r¡s ÿz_PollableWritePipe.__init__cCs d|_dSr)rDr r r r r?±sz_PollableWritePipe.closecCs|jdk rd|_|j ¡dSr)rErFrAr r r r Ú bufferFull´s z_PollableWritePipe.bufferFullcCs0|jdk r,|jr|jr,d|j_|j ¡dSdS)NFT)rErGrFrBr r r r Ú bufferEmpty¹s ÿÿ z_PollableWritePipe.bufferEmptycCsH|jdk rtd||jfƒ‚|js,| ¡n||_||_|sD| ¡dS)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.)rEÚ RuntimeErrorrr@rGrB)r rEZ streamingr r r ÚregisterProducerÄs ÿÿ z#_PollableWritePipe.registerProducercCs d|_dS)z;Stop consuming data from a producer, without disconnecting.N)rEr r r r ÚunregisterProducerÛsz%_PollableWritePipe.unregisterProducercCs<| ¡zt |j¡Wntjk r.YnX| ¡dSr)rr2r=rIr>r3r-r r r r ÚwriteConnectionLostßs z&_PollableWritePipe.writeConnectionLostcCs&ttt|ƒkrtdƒ‚|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)ÚstrÚmapÚtypeÚ TypeErrorrHÚextend)r Úseqr r r Ú writeSequenceès z _PollableWritePipe.writeSequencecCsHt|tƒrtdƒ‚|jrdS|j |¡ttt|jƒƒt krD|  ¡dS)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}. rPN) Ú isinstancerQrTrDrHrÚsumrRr6ÚFULL_BUFFER_SIZErJ)r r<r r r Úwriteõs  z_PollableWritePipe.writecCsòd}|jsT|jr| ¡dSzt |jdd¡Wn"tjk rR| ¡|YSX|jrÔ|j d¡}d}zt |j|d¡\}}Wn"t jk r¤| ¡YqîYqTX||7}t |ƒ|krT|j  d||d…¡qîqT|  ¡}|sî|jrî| ¡|S)Nrr/) rHrDrOr1Z WriteFilerIr>r3Úpopr2r6ÚinsertrK)r ZnumBytesWrittenr<ZerrCodeZ nBytesWrittenZresumedr r r r(s4     z_PollableWritePipe.checkWorkN) rrrrr?rJrKrMrNrOrWr[r(r r r r rCŸs   rC)Ú__doc__Zzope.interfacerZtwisted.internet.interfacesrrr)rrrr>r2r1r0r*rZrCr r r r Ús  E3