U  W[#ã@s¸dZddlmZmZddlmZddlmZmZddl m Z dZ dZ Gdd „d ƒZ Gd d „d ƒZdd lZdd lZdd lZdd lZeeƒGd d„de ƒƒZdZeeƒ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. é)Úabsolute_importÚdivision)Ú implementer)Ú IConsumerÚ IPushProducer)Úunicodeg•Ö&è .>gš™™™™™¹?c@s eZdZdZdd„Zdd„ZdS)Ú_PollableResourceTcCs d|_dS©NT©Úactive©Úself©rú?/usr/lib/python3/dist-packages/twisted/internet/_pollingfile.pyÚactivatesz_PollableResource.activatecCs d|_dS©NFr r rrrÚ deactivatesz_PollableResource.deactivateN)Ú__name__Ú __module__Ú __qualname__r rrrrrrrsrc@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 rrrrÚ__init__%s z_PollingTimer.__init__cCs|j |¡| ¡dS©N)rÚappendÚ_checkPollingState)r ÚresrrrÚ_addPollableResource,s z"_PollingTimer._addPollableResourcecCs*|jD]}|jr| ¡q&q| ¡dSr)rr Ú _startPollingÚ _stopPolling)r Úresourcerrrr 0s  z _PollingTimer._checkPollingStatecCs|jdkr| ¡|_dSr)rÚ _rescheduler rrrr#8s z_PollingTimer._startPollingcCs|jdk r|j ¡d|_dSr)rZcancelr rrrr$<s  z_PollingTimer._stopPollingcCs d|_dSr )rr rrrÚ_pauseAsz_PollingTimer._pausecCsd|_| ¡dSr)rr r rrrÚ_unpauseDsz_PollingTimer._unpausecCs|js|j |j|j¡SdSr)rrZ callLaterrÚ _pollEventr rrrr&Hsz_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 newTimeoutrrrr)Ls$    z_PollingTimer._pollEventN) rrrrr"r r#r$r'r(r&r)rrrrr"srNc@sDeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dS)Ú_PollableReadPipecCs||_||_||_dSr)ÚpipeÚreceivedCallbackÚ lostCallback)r r-r.r/rrrrosz_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 ZfinishedZ fullDataReadÚbufferZ bytesToReadÚresultZhrÚdataZdataBufrrrr*us"   z_PollableReadPipe.checkWorkcCs| ¡| ¡dSr)rr/r rrrr7Œsz_PollableReadPipe.cleanupcCs,zt |j¡Wntjk r&YnXdSr)r4Ú CloseHandler-Ú pywintypesr5r rrrÚclosesz_PollableReadPipe.closecCs | ¡dSr)r>r rrrÚ stopProducing—sz_PollableReadPipe.stopProducingcCs | ¡dSr)rr rrrÚpauseProducingšsz _PollableReadPipe.pauseProducingcCs | ¡dSr)rr rrrÚresumeProducingsz!_PollableReadPipe.resumeProducingN) rrrrr*r7r>r?r@rArrrrr,lsr,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/r2ZSetNamedPipeHandleStateZ PIPE_NOWAITr=r5)r rHr/rrrr¦sýz_PollableWritePipe.__init__cCs d|_dSr )rCr rrrr>·sz_PollableWritePipe.closecCs|jdk rd|_|j ¡dSr )rDrEr@r rrrÚ bufferFullºs z_PollableWritePipe.bufferFullcCs0|jdk r,|jr|jr,d|j_|j ¡dSdS)NFT)rDrFrErAr rrrÚ 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.)rDÚ RuntimeErrorr r?rFrA)r rDZ streamingrrrÚregisterProducerÉs ÿÿ z#_PollableWritePipe.registerProducercCs d|_dS)zDStop consuming data from a producer, without disconnecting. N)rDr rrrÚunregisterProducerßsz%_PollableWritePipe.unregisterProducercCs<| ¡zt |j¡Wntjk r.YnX| ¡dSr)rr4r<rHr=r5r/r rrrÚ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)rÚmapÚtypeÚ TypeErrorrGÚextend)r ÚseqrrrÚ 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}. rON) Ú isinstancerrRrCrGrÚsumrPr8ÚFULL_BUFFER_SIZErI)r r;rrrÚ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)Nrr1) rGrCrNr3Z WriteFilerHr=r5Úpopr4r8ÚinsertrJ)r ZnumBytesWrittenr;ZerrCodeZ nBytesWrittenZresumedrrrr*s:  ÿ    z_PollableWritePipe.checkWorkN) rrrrr>rIrJrLrMrNrUrYr*rrrrrB£s  rB)Ú__doc__Z __future__rrZzope.interfacerZtwisted.internet.interfacesrrZtwisted.python.compatrr+rrrr2r3r4r=r,rXrBrrrrÚs"   E4