hB*tSrSSKrSSKrSSKJrJrJrJr SSKJ r J r SSK J r J r SSKJrJr \"\S5r\"\S5r\"\S 5r\"\S 5r\"\S 5r"S S \5r\R6"\\5 \"\ \ 5"SS\ R855rSrSS/rg!\a r\"\5eSrCff=f)am A kqueue()/kevent() based implementation of the Twisted main loop. To use this reactor, start your application specifying the kqueue reactor:: twistd --reactor kqueue ... To install the event loop from code (and you should do this before any connections, listeners or connectors are added):: from twisted.internet import kqreactor kqreactor.install() N) Attribute Interface declarations implementer)main posixbase)IReactorDaemonize IReactorFDSet)failurelog KQ_EV_ADD KQ_EV_DELETE KQ_EV_EOFKQ_FILTER_READKQ_FILTER_WRITEc8\rSrSrSr\"S5r\"S5rSrg)_IKQueue*z* An interface for KQueue implementations. zAn implementation of kqueue(2).zAn implementation of kevent(2).N) __name__ __module__ __qualname____firstlineno____doc__rkqueuekevent__static_attributes__ra/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/kqreactor.pyrr*s8 9F 8 9Frrcp\rSrSrSr\4SjrSrSrSr Sr Sr S r S r S rS rS rSrSr\rSrg) KQueueReactor6a% A reactor that uses kqueue(2)/kevent(2) and relies on Python 2.6 or higher which has built in support for kqueue in the select module. @ivar _kq: A C{kqueue} which will be used to check for I/O readiness. @ivar _impl: The implementation of L{_IKQueue} to use. @ivar _selectables: A dictionary mapping integer file descriptors to instances of L{FileDescriptor} which have been registered with the reactor. All L{FileDescriptor}s which are currently receiving read or write readiness notifications will be present as values in this dictionary. @ivar _reads: A set containing integer file descriptors. Values in this set will be registered with C{_kq} for read readiness notifications which will be dispatched to the corresponding L{FileDescriptor} instances in C{_selectables}. @ivar _writes: A set containing integer file descriptors. Values in this set will be registered with C{_kq} for write readiness notifications which will be dispatched to the corresponding L{FileDescriptor} instances in C{_selectables}. cXlURR5Ul[5Ul[5Ul0Ul[RRU5 g)aF Initialize kqueue object, file descriptor tracking dictionaries, and the base class. See: - http://docs.python.org/library/select.html - www.freebsd.org/cgi/man.cgi?query=kqueue - people.freebsd.org/~jlemon/papers/kqueue.pdf @param _kqueueImpl: The implementation of L{_IKQueue} to use. A hook for testing. N) _implr_kqset_reads_writes _selectablesrPosixReactorBase__init__)self _kqueueImpls rr+KQueueReactor.__init__QsK! ::$$&e u ""++D1rctURRURRXU5/SS5 g)z Private method for changing kqueue registration on a given FD filtering for events given filter/op. This will never block and returns nothing. rN)r%controlr$r)r,fdfilterops r_updateRegistration!KQueueReactor._updateRegistrationes. $**++B;"G6    KK  r "%%%b),,RN  B  #B2C2 CC CCcSnUR5nUS:Xa,URR5H up4XLdM Sn O gX0R;a\URR U5 X0R ;a URU U(dURU[[5 ggg![a SnNf=f![a gf=f)z* Implement L{IReactorFDSet.removeWriter}. FrKTN) r?rLr)rMr(rNr'r4rrr@)r,rGrOr1rPs r removeWriterKQueueReactor.removeWriters B 8 --335>"G6    LL   #$%%b),,R,O  B  rScURURVs/sHoRUPM snURVs/sHoRUPM sn5$s snfs snf)z' Implement L{IReactorFDSet.removeAll}. ) _removeAllr'r)r(r;s r removeAllKQueueReactor.removeAllsY-1[[ 9[r  r "[ 9-1\\ :\r  r "\ :  9 :s A!A& c^URVs/sHoRUPM sn$s snf)z( Implement L{IReactorFDSet.getReaders}. )r'r)r;s r getReadersKQueueReactor.getReaderss)15 < "!!"% <<<*c^URVs/sHoRUPM sn$s snf)z( Implement L{IReactorFDSet.getWriters}. )r(r)r;s r getWritersKQueueReactor.getWriterss)15 = "!!"% ===r^cUcSnURR/[UR5U5nURnUH7nURnURUn[R"XtXvU5 M9 g![a)nUR [ R :XaSnAgeSnAff=f![a Mf=f)z! Poll the kqueue for new events. N) r%r0lenr)r@errnoEINTR_doWriteOrReadidentr callWithLoggerKeyError)r,timeouteventse_drdweventr1 selectables rdoKEventKQueueReactor.doKEvents ?G XX%%b#d.?.?*@'JF##EB M!..r2 "":jeL ww%++%   s/0BB7 B4 B/.B//B47 CCc4SnSnURURURUR4upgpU[-(aU(aU (a[ R nO`UR5S:XaSn[RnO8U[:XaSnUR5nU[:XaSnUR5nU(aUR'XU5 gg![a/ [R "5n["R$"US5 NSf=f)zz Private method called when a FD is ready for reading, writing or was lost. Do the work and raise errors where necessary. NFrKTzSAn exception was raised from application code while processing a reactor selectable)r2flagsdatafflagsrrCONNECTION_LOSTr?r _NO_FILEDESCrdoReadrdoWriterLr Failurer err_disconnectSelectable) r,rpr1rowhyinReadr2rtrurvs rrgKQueueReactor._doWriteOrReads  LL KK JJ LL ) % 9 &&&C $$&","F#00C/!%(//10!&(002   & &z ? ! oo'=  s$&C 8C6DD)r$r%r'r)r(N)rrrrrselectr+r4r8r<rCrHrQrUrYr\r`rqrg doIterationrrrrr!r!6sY2$*2(D E $ %44 = > M<'@RKrr!c4[5nSSKJn U"U5 g)z Install the kqueue() reactor. r)installReactorN)r!twisted.internet.mainr)prs rinstallr:s A41rr) rrerzope.interfacerrrrtwisted.internetrrtwisted.internet.interfacesr r twisted.pythonr r getattrr rrrrAttributeErrorrm ImportErrorrdirectlyProvidesr*r!r__all__rrrrs  JJ,H'   ,I6>2L ,IV%56Nf&78O :y: fh/ ]-.@I..@/@F I &} a.s-B$$B7*B22B7