+ j!Rt^RIHt^RIHtHtRtRt!RR4t!RR4t ^R I t ^R I t ^R I t ^R I t ]!]4!R R ]44tRt]!]4!R R ]44tR #)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?c0a]tRt^toRtRtRtRtVtR#)_PollableResourceTcRVnR#TNactiveselfs&?/usr/lib/python3/dist-packages/twisted/internet/_pollingfile.pyactivate_PollableResource.activates  cRVnR#FNr r s&r deactivate_PollableResource.deactivates  rr N) __name__ __module__ __qualname____firstlineno__r rr__static_attributes____classdictcell__ __classdict__s@r rrs FrrcVa]tRt^toRtRtRtRtRtRt Rt Rt R t R t VtR #) _PollingTimercRWn.VnRVn\VnRVnR#)NF)reactor _resources _pollTimer MAX_TIMEOUT_currentTimeout_paused)r r s&&r __init___PollingTimer.__init__ s$ * rc\VPPV4VP4R#N)r!append_checkPollingState)r ress&&r _addPollableResource"_PollingTimer._addPollableResource's  s# !rcVPF(pVP'gKVP4R# VP4R#r))r!r _startPolling _stopPolling)r resources& r r+ _PollingTimer._checkPollingState+s6H""$(    rcPVPfVP4VnR#R#r))r" _rescheduler s&r r0_PollingTimer._startPolling3s! ?? ""..0DO #rchVPe$VPP4RVnR#R#r))r"cancelr s&r r1_PollingTimer._stopPolling7s( ?? & OO " " $"DO 'rcRVnR#r)r%r s&r _pause_PollingTimer._pause<s  rc4RVnVP4R#r)r%r+r s&r _unpause_PollingTimer._unpause?s  !rcVP'g1VPPVPVP4#R#r))r%r callLaterr$ _pollEventr s&r r5_PollingTimer._rescheduleCs1|||<<))$*>*>P PrcRp.pVPFRpVP'gKWP4, pVP'gKAVPV4KT VPpV'd-VPVR,, pV\ 8d\ pM$VPR,pV\ 8d\ pW@nV'dVP4VnR#R#)gg?g@N) r!r checkWorkr*r$ MIN_TIMEOUTr#r5r")r workUnits anyActiver2 newTimeouts& r rB_PollingTimer._pollEventGs  H//11 ???$$X. ()) --SAJK'( --3JK'( ) "..0DO r)r$r%r"r!r N)rrrrr&r-r+r0r1r;r>r5rBrrrs@r rrs8" 1# "Q11rrNcJa]tRt^htoRtRtRtRtRtRt Rt Rt Vt R #) _PollableReadPipec*WnW nW0nR#r))pipereceivedCallback lostCallback)r rNrOrPs&&&&r r&_PollableReadPipe.__init__js 0(rc^p.p\P!VP^4wr4pV'gM7\P!VPVR4wrgVP V4KfRPV4pV'dVPV4V'dVP4\V4# \ Pd^pKgi;i)Nr) win32pipe PeekNamedPiperN win32fileReadFiler*win32apierrorjoinrOcleanuplen) r finished fullDataReadbuffer bytesToReadresulthrdatadataBufs & r rE_PollableReadPipe.checkWorkps  .7.E.EdiiQR.S+V"$--diidK##D) ((<(   ! !' *  LLN7|>>  s,B85B88CCcFVP4VP4R#r))rrPr s&r r[_PollableReadPipe.cleanups  rc\P!VP4R# \PdR#i;ir))rX CloseHandlerN pywintypesrYr s&r close_PollableReadPipe.closes1    +   s $==c&VP4R#r))rkr s&r stopProducing_PollableReadPipe.stopProducings  rc&VP4R#r))rr s&r pauseProducing _PollableReadPipe.pauseProducings  rc&VP4R#r))rr s&r resumeProducing!_PollableReadPipe.resumeProducings  r)rPrNrON) rrrrr&rEr[rkrnrqrtrrrs@r rLrLhs-) .rrLc\a]tRt^toRtRtRtRtRtRt Rt Rt R t R t R tVtR #) _PollableWritePipecRVnRVnRVn^Vn.VnWnW n\P!V\PRR4R# \PdR#i;ir) disconnectingproducerproducerPausedstreamingProduceroutQueue writePiperPrTSetNamedPipeHandleState PIPE_NOWAITrjrY)r r~rPs&&&r r&_PollableWritePipe.__init__so" #!" "(   - -900$    s'AA32A3cRVnR#r)ryr s&r rk_PollableWritePipe.closes !rchVPe$RVnVPP4R#R#)NT)rzr{rqr s&r bufferFull_PollableWritePipe.bufferFulls) == $"&D  MM ( ( * %rcVPeRVP'dVP'd.RVPnVPP4R#R#)NFT)rzr|r{rtr s&r bufferEmpty_PollableWritePipe.bufferEmptysE == $'''D,?,?,?+0DMM ( MM ) ) +rc VPe\RV: RVP: R24hVP'gVP4R#WnW nV'gVP 4R#R#)aGRegister 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.)rz RuntimeErrorr rnr|rt)r rz streamings&&&r registerProducer#_PollableWritePipe.registerProducers_ == $#+T]]< {{{  " " $$M%. "((*rc RVnR#)z;Stop consuming data from a producer, without disconnecting.N)rzr s&r unregisterProducer%_PollableWritePipe.unregisterProducers  rcVP4\P!VP4VP 4R# \P dL)i;ir))rrXrir~rjrYrPr s&r writeConnectionLost&_PollableWritePipe.writeConnectionLostsK     0    s AAAc \\\V49d \R4hVPP V4R#)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 TypeErrorr}extend)r seqs&&r writeSequence _PollableWritePipe.writeSequences0 #dC. CD D S!rc "\V\4'd \R4hVP'dR#VPP V4\ \\VP44\8dVP4R#R#)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}. rN) isinstancerrryr}r*sumrr\FULL_BUFFER_SIZEr)r rcs&&r write_PollableWritePipe.writesf dC CD D      T" s3 & '*: : OO  ;rc^pVP'gHVP'dVP4^#\P!VP RR4VP'd~VPP^4p^p\P!VP VR4wr4W, p\V4V8d"VPP^W$R4V#KVP4pV'g#VP'dVP4V# \ PdTP4Tu#i;i \PdTP4T#i;i)rSrN) r}ryrrV WriteFiler~rjrYpopr\insertrXr)r numBytesWrittenrcerrCode nBytesWrittenresumeds& r rE_PollableWritePipe.checkWorksN}}}!!!((* '##DNNC>mmm==$$Q'DG )2)<)> ((* s#"D' $E''EE%E=<E=)ryrPr}rzr{r|r~N)rrrrr&rkrrrrrrrrErrrs@r rwrws< "+ +. ""rrwi)__doc__zope.interfacertwisted.internet.interfacesrrrFr#rrrjrXrVrTrLrrwrr rs  '@  ?1?1J ]0)00f YC*CCr