h!SrSSKJr SSKJrJr SrSr"SS5r"SS 5r SS K r SS K r SS K r SS K r \"\5"S S \55rS r\"\5"SS\55rg )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$\rSrSrSrSrSrSrg)_PollableResourceTcSUlgNTactiveselfs d/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/_pollingfile.pyactivate_PollableResource.activates  cSUlgNFr r s r deactivate_PollableResource.deactivates  rr N)__name__ __module__ __qualname____firstlineno__r rr__static_attributes__rrrrs FrrcJ\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) _PollingTimercPXl/UlSUl[UlSUlgr)reactor _resources _pollTimer MAX_TIMEOUT_currentTimeout_paused)rr!s r__init___PollingTimer.__init__ s$ * rcZURRU5 UR5 gN)r"append_checkPollingState)rress r_addPollableResource"_PollingTimer._addPollableResource's  s# !rcURH&nUR(dMUR5 g UR5 gr*)r"r _startPolling _stopPolling)rresources rr, _PollingTimer._checkPollingState+s6H""$(    rcJURcUR5Ulggr*)r# _rescheduler s rr1_PollingTimer._startPolling3s! ?? ""..0DO #rcbURb"URR5 SUlggr*)r#cancelr s rr2_PollingTimer._stopPolling7s( ?? & OO " " $"DO 'rcSUlgr )r&r s r_pause_PollingTimer._pause<s  rc2SUlUR5 gr)r&r,r s r_unpause_PollingTimer._unpause?s  !rcUR(d0URRURUR5$gr*)r&r! callLaterr% _pollEventr s rr6_PollingTimer._rescheduleCs/||<<))$*>*>P PrcSn/nURHLnUR(dMXR5- nUR(dM;URU5 MN URnU(a#URUS-- nU[ :a[ nOURS-nU[ :a[ nX@lU(aUR5Ulgg)Ngg?g@) r"r checkWorkr+r% MIN_TIMEOUTr$r6r#)r workUnits anyActiver3 newTimeouts rrC_PollingTimer._pollEventGs  H//11 ???$$X. ()) --SAJK'( --3JK'( ) "..0DO r)r%r&r#r"r!N)rrrrr'r.r,r1r2r<r?r6rCrrrrrrs0" 1# "Q1rrNc>\rSrSrSrSrSrSrSrSr Sr S r g ) _PollableReadPipehc(XlX lX0lgr*)pipereceivedCallback lostCallback)rrPrQrRs rr'_PollableReadPipe.__init__js 0(rcSn/n[R"URS5up4nU(dO7[R"URUS5upgUR U5 MdSRU5nU(aURU5 U(aUR5 [U5$![ Ra SnMdf=f)Nrr) win32pipe PeekNamedPiperP win32fileReadFiler+win32apierrorjoinrQcleanuplen) rfinished fullDataReadbuffer bytesToReadresulthrdatadataBufs rrF_PollableReadPipe.checkWorkps  .7.E.EdiiQR.S+V"$--diidK##D)((<(   ! !' *  LLN7|>>  s+B55B55CCcDUR5 UR5 gr*)rrRr s rr]_PollableReadPipe.cleanups  rcz[R"UR5 g![Ra gf=fr*)rZ CloseHandlerP pywintypesr[r s rclose_PollableReadPipe.closes1    +   s #::c$UR5 gr*)rmr s r stopProducing_PollableReadPipe.stopProducings  rc$UR5 gr*)rr s rpauseProducing _PollableReadPipe.pauseProducings  rc$UR5 gr*)rr s rresumeProducing!_PollableReadPipe.resumeProducings  r)rRrPrQN) rrrrr'rFr]rmrprsrvrrrrrMrMhs%) .rrMicP\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )_PollableWritePipecSUlSUlSUlSUl/UlXlX l[R"U[RSS5 g![Ra gf=f)NFr) disconnectingproducerproducerPausedstreamingProduceroutQueue writePiperRrVSetNamedPipeHandleState PIPE_NOWAITrlr[)rrrRs rr'_PollableWritePipe.__init__so" #!" "(   - -900$    s'AA0/A0cSUlgr )r|r s rrm_PollableWritePipe.closes !rcbURb"SUlURR5 ggr )r}r~rsr s r bufferFull_PollableWritePipe.bufferFulls) == $"&D  MM ( ( * %rcURbNUR(aUR(a,SURlURR5 gg)NFT)r}rr~rvr s r bufferEmpty_PollableWritePipe.bufferEmptys? == $''D,?,?+0DMM ( MM ) ) +rcURb[SU<SUR<S35eUR(dUR5 gXlX lU(dUR 5 gg)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.)r} RuntimeErrorr rprrv)rr} streamings rregisterProducer#_PollableWritePipe.registerProducers] == $#+T]]< {{  " " $$M%. "((*rcSUlg)z;Stop consuming data from a producer, without disconnecting.N)r}r s runregisterProducer%_PollableWritePipe.unregisterProducers  rcUR5 [R"UR5 UR 5 g![R a N'f=fr*)rrZrkrrlr[rRr s rwriteConnectionLost&_PollableWritePipe.writeConnectionLostsK     0    s AAAc[[[U5;a [S5eURR U5 g)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 TypeErrorrextend)rseqs r writeSequence _PollableWritePipe.writeSequences0 #dC. CD D S!rc[U[5(a [S5eUR(agURR U5 [ [[UR55[:aUR5 gg)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) isinstancerrr|rr+sumrr^FULL_BUFFER_SIZEr)rres rwrite_PollableWritePipe.writesc dC CD D     T" s3 & '*: : OO  ;rc SnUR(dEUR(aUR5 g[R"UR SS5 UR(aURRS5nSn[R"UR US5up4X- n[U5U:a!URRSX$S5 U$UR(aMUR5nU(d!UR(aUR5 U$![ Ra UR5 Us$f=f![Ra UR5 U$f=f)Nrr) rr|rrX WriteFilerrlr[popr^insertrZr)rnumBytesWrittenreerrCode nBytesWrittenresumeds rrF_PollableWritePipe.checkWorksO}}!!((* '##DNNC>mm==$$Q'DG )2)<)> ((* s#"D.$E.&EE$FF)r|rRrr}r~rrN)rrrrr'rmrrrrrrrrFrrrrryrys4 "+ +. ""rry)__doc__zope.interfacertwisted.internet.interfacesrrrGr$rrrlrZrXrVrMrryrrrrs  '@  ?1?1J ]0)00f YC*CCr