+ j(TRt^RIHt^RIt^RIt^RIHt^RIHtH t ^RI H t H t H t ^RIHt^RIHtHtHtHtHtHtHtHtHtHtHt^RIHtHt^R IH t ^R I!H"t"H#t#^R I$H%t%H&t&^R I'H(t(H)t)H*t*H+t+H,t,] PZ!R 4t.^RI/H0t1]1t0^RI H3t4]4t3]&R8Ht5Rt6]5'd ^RI H7t7H8t8Rt6]%Pr!4'd^RI:t:Rt6!RR4t;] !]]]4!RR];]44t<!RR4t=] !]4!RR]=];44t>]0f]3e ]!]<]4]5'd ]!]<]]4]6'd ]!]<]4]?!]RR4e ]!]<]4R.t@R# ]2dRt0Li;i ]2dRt3Li;i ]2dRt:Li;i)z Posix reactor base class ) annotationsN)Sequence)classImplements implementer)errortcpudp) ReactorBase) IConnectorIHalfCloseableDescriptor IReactorFDSetIReactorMulticastIReactorProcessIReactorSocket IReactorSSL IReactorTCP IReactorUDP IReactorUNIXIReactorUNIXDatagram)CONNECTION_DONECONNECTION_LOST) ClientFactory)failurelog)platform platformType)SignalHandling_ChildSignalHandling_IWaker_MultiSignalHandling_WakerzFile descriptor lost)tls)sslposixF)processunixTc]tRt^PtRt]P ]P!]P !44]P]P!]P!44/3Rlt Rt R#)_DisconnectSelectableMixinz6 Mixin providing the C{_disconnectSelectable} method. c VPV4VPVP4pV'd{V'dOVP\P8Xd0\ P !V4'dVPV4R#VPV4VPV4R#VPV4VP\P!V44R#)z Utility function for disconnecting a selectable. Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead(). N) removeReaderget __class__rConnectionDoner providedByreadConnectionLost removeWriterconnectionLostrFailure)self selectablewhyisReadfaildictfs&&&&& {999{  & & }K  r;zSequence[socket.AddressFamily]_supportedAddressFamiliesc 6W P9d\P!V4h\'d7V\P 8Xd"\ PPWV4pM \PPWW#4pVP4V#)a Create a new L{IListeningPort} from an already-initialized socket. This just dispatches to a suitable port implementation (eg from L{IReactorTCP}, etc) based on the specified C{addressFamily}. @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamPort} ) rrUnsupportedAddressFamilyrsocketAF_UNIXr%rt_fromListeningDescriptorrru)r2fileDescriptor addressFamilyrrzs&&&& r8adoptStreamPort PosixReactorBase.adoptStreamPort:ss  > > >00? ? ;=FNN: 224QA11mA r;c W P9d\P!V4h\'d6V\P 8Xd!\ PPWV4#\PPWW04#)zO @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} ) rrrrrrr%Server_fromConnectedSocketr)r2rrrs&&&&r8adoptStreamConnection&PosixReactorBase.adoptStreamConnectionOsd  > > >00? ? ;=FNN:;;33NTR R::22w r;c V\P\P39d\P!V4h\ P PWW#VR7pVP4V#))ry) rAF_INETAF_INET6rrrrtrru)r2rrrwryrzs&&&&& r8adoptDatagramPort"PosixReactorBase.adoptDatagramPort^s]  A A00? ? HH - - - .  r;c V\P!WW4V4pVP4V#rM)rrtru)r2rvrrrxrzs&&&&& r8 listenTCPPosixReactorBase.listenTCPls% HHTG = r;c 0V^8dQhRRRRRRRRR R R R /#) rGhoststrrvintrz'ClientFactory'rfloatrztuple[str, int] | NonerHr r<)rIs"r8rJrKqsF    !    ,   r;c V\P!WW4WP4pVP4V#rM)rrr)r2rrvrrrrs&&&&&& r8 connectTCPPosixReactorBase.connectTCPqs$ MM$g J r;c  \e+\PVRV4pVPWWuV4#\e+\P WW4WVV4pVP 4V#QR4h)NTSSL support is not present)r!TLSMemoryBIOFactoryrr"rr) r2rrvrcontextFactoryrr tlsFactoryrs &&&&&&& r8 connectSSLPosixReactorBase.connectSSLsg ?00wOJ??4zKP P _ GW4A IIKH 66 65r;c \e3\PVRV4pVPWWE4pRVnV#\e*\P WW4WP4pVP 4V#QR4h)NFTLSr)r!rr_typer"rtru)r2rvrrrrxrrzs&&&&&& r8 listenSSLPosixReactorBase.listenSSLsj ?00PJ>>$GGDDJK _QA   H 66 65r;c \V4VP, pVFpVPV4K \V4pVFpVPV4K \ W5,4#)a/ Remove all readers and writers, and list of removed L{IReadDescriptor}s and L{IWriteDescriptor}s. Meant for calling from subclasses, to implement removeAll, like:: def removeAll(self): return self._removeAll(self._reads, self._writes) where C{self._reads} and C{self._writes} are iterables. )setrSr)r/list)r2readerswritersremovedReadersreaderremovedWriterswriters&&& r8 _removeAllPosixReactorBase._removeAllscW(=(==$F   f %%W$F   f %%N344r;)rRr<) )rrF))2r)rr)rrN)r)rr)g>@N)rN)!r=r>r?r@rA _childWakerrOrVr[rqr{rrrrrrrrrrr__annotations__rrrrrrrrrC __classcell__)r+__conditional_annotations__s@@r8rErEvsK '<    6t "   " NN OO NNE !#A  NN OO% ! *    7 755r;rEc ]tRtRtRtRtRtR#)_PollLikeMixinia Mixin for poll-like reactors. Subclasses must define the following attributes:: - _POLL_DISCONNECTED - Bitmask for events indicating a connection was lost. - _POLL_IN - Bitmask for events indicating there is input to read. - _POLL_OUT - Bitmask for events indicating output can be written. Must be mixed in to a subclass of PosixReactorBase (for _disconnectSelectable). c \RpRpW0P,'d9W0P,'g!W P9d Rp\pM\pMyVP 4R8Xd\ pM\W0P,'dVP4pRpV'g+W0P,'dVP4pRpV'dVPWV4R#R# \d5\P!4^,p\P!4L\i;i)zO fd is available for read or write, do the work and raise errors if necessary. NFT)_POLL_DISCONNECTED_POLL_IN_readsrrfileno _NO_FILEDESCdoRead _POLL_OUTdoWrite BaseExceptionsysexc_inforerrr9)r2r3fdeventr4inReads&&&& r8_doReadOrWrite_PollLikeMixin._doReadOrWrites  ** * *EMM4I4I[[ %& $$&",'C}},,(//1!%5>>#9#9)002!&   & &z ?  ! llnQ'  sC,21C,$*C,,r?r@rArrCr<r;r8rrs  7@r;rcn]tRtRtRt^t^t^tRtRt Rt Rt Rt Rt R tR tR tR tR tRtRtR#)_ContinuousPollingiao Schedule reads and writes based on the passage of time, rather than notification. This is useful for supporting polling filesystem files, which C{epoll(7)} does not support. The implementation uses L{_PollLikeMixin}, which is a bit hacky, but re-implementing and testing the relevant code yet again is unappealing. @ivar _reactor: The L{EPollReactor} that is using this instance. @ivar _loop: A C{LoopingCall} that drives the polling, or L{None}. @ivar _readers: A C{set} of C{FileDescriptor} objects that should be read from. @ivar _writers: A C{set} of C{FileDescriptor} objects that should be written to. c \WnRVn\4Vn\4VnR#rM)_reactor_loopr_readers_writers)r2reactors&&r8__init___ContinuousPolling.__init__s     r;c VP'gVP'djVPfZ^RIHpHpV!VP 4VnVPVPnVPPVRR7R#R#VP'd$VPP4RVnR#R#)zP Start or stop a C{LoopingCall} based on whether there are readers and writers. N)_EPSILON LoopingCallF)now) rrrtwisted.internet.taskrriteraterclockstartstop)r2rrs& r8 _checkLoop_ContinuousPolling._checkLoops ===DMMMzz!G(6 #'==     u 5"ZZZ JJOO DJr;c \VP4FpVPWVP4K! \VP4FpVPW"VP 4K! R#)zH Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r2rrs& r8r_ContinuousPolling.iterate/sR4==)F    >*4==)F    ?*r;c \VPPV4VP4R#)zE Add a C{FileDescriptor} for notification of data available to read. N)rrTrr2rs&&r8rU_ContinuousPolling.addReader8  &! r;c \VPPV4VP4R#)zF Add a C{FileDescriptor} for notification of data available to write. N)rrTrr2rs&&r8 addWriter_ContinuousPolling.addWriter?r r;c VPPV4TP4R# \dR#i;i)zI Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrr s&&r8r)_ContinuousPolling.removeReaderFs9  MM  (     / >>c VPPV4TP4R# \dR#i;i)zJ Remove a C{FileDescriptor} from notification of data available to write. N)rrrrrs&&r8r/_ContinuousPolling.removeWriterPs9   MM  (    rc \VPVP,4pVPP4VPP4V#)z! Remove all readers and writers. )rrrclear)r2results& r8 removeAll_ContinuousPolling.removeAll[sBdmmdmm34   r;c ,\VP4#)z Return a list of the readers. )rrrNs&r8 getReaders_ContinuousPolling.getReadersfDMM""r;c ,\VP4#)z Return a list of the writers. )rrrNs&r8 getWriters_ContinuousPolling.getWriterslr!r;c WP9#)a* Checks if the file descriptor is currently being observed for read readiness. @param fd: The file descriptor being checked. @type fd: L{twisted.internet.abstract.FileDescriptor} @return: C{True} if the file descriptor is being observed for read readiness, C{False} otherwise. @rtype: C{bool} )rr2rs&&r8 isReading_ContinuousPolling.isReadingr]]""r;c WP9#)a, Checks if the file descriptor is currently being observed for write readiness. @param fd: The file descriptor being checked. @type fd: L{twisted.internet.abstract.FileDescriptor} @return: C{True} if the file descriptor is being observed for write readiness, C{False} otherwise. @rtype: C{bool} )rr&s&&r8 isWriting_ContinuousPolling.isWritingr)r;)rrrrN)r=r>r?r@rArrrrrrrUrr)r/rrr#r'r+rCr<r;r8rrsV,HI $@  # # # #r;rfromfd)ArA __future__rrrtypingrzope.interfacerrtwisted.internetrrrtwisted.internet.baser twisted.internet.interfacesr r r r rrrrrrrtwisted.internet.mainrrtwisted.internet.protocolrtwisted.pythonrrtwisted.python.runtimerr_signalsrrrrr ConnectionFdescWentAwayrtwisted.protocolsr!_tls ImportErrorr"_sslrprocessEnabledr$r% isWindowsrer'rErrgetattr__all__r<r;r8rBs # 7,,-    C3'9,,-CD - C, Cg% .N  #<#