ó H!¯Nc@sÈdZddlZddlmZmZddlmZmZmZm Z m Z ddl m Z ddl mZddlmZddlmZd ejejfd „ƒYZd „Zd d gZdS( sñ A poll() based implementation of the twisted main loop. To install the event loop (and you should do this before any connections, listeners or connectors are added):: from twisted.internet import pollreactor pollreactor.install() iÿÿÿÿN(terrortpoll(tPOLLINtPOLLOUTtPOLLHUPtPOLLERRtPOLLNVAL(t implements(tlog(t posixbase(t IReactorFDSett PollReactorcBs›eZdZeeƒeeBeBZe Z e Z d„Z d„Zd„Zd„Zd„Zd„Zd„Zd„Zd „ZeZd „Zd „ZRS( sW A reactor that uses poll(2). @ivar _poller: A L{poll} which will be used to check for I/O readiness. @ivar _selectables: A dictionary mapping integer file descriptors to instances of L{FileDescriptor} which have been registered with the reactor. All L{FileDescriptors} which are currently receiving read or write readiness notifications will be present as values in this dictionary. @ivar _reads: A dictionary mapping integer file descriptors to arbitrary values (this is essentially a set). Keys in this dictionary will be registered with C{_poller} for read readiness notifications which will be dispatched to the corresponding L{FileDescriptor} instances in C{_selectables}. @ivar _writes: A dictionary mapping integer file descriptors to arbitrary values (this is essentially a set). Keys in this dictionary will be registered with C{_poller} for write readiness notifications which will be dispatched to the corresponding L{FileDescriptor} instances in C{_selectables}. cCs;tƒ|_i|_i|_i|_tjj|ƒdS(so Initialize polling object, file descriptor tracking dictionaries, and the base class. N(Rt_pollert _selectablest_readst_writesR tPosixReactorBaset__init__(tself((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pyR;s     cCs¨y|jj|ƒWntk r'nXd}||jkrJ|tB}n||jkrf|tB}n|dkrˆ|jj||ƒn||jkr¤|j|=ndS(s*Register/unregister an fd with the poller.iN( R t unregistertKeyErrorRRRRtregisterR (Rtfdtmask((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pyt_updateRegistrationGs    cCs}y|jƒ}||Wn;x5|jjƒD]\}}||kr.Pq.q.WdSnX||kry||=|j|ƒndS(N(tfilenoR titemsR(Rt selectabletmdictRtfdes((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pyt _dictRemoveYs    cCsI|jƒ}||jkrE||j|(tpR>((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pytinstall´s RA(R9R+tselectRR)RRRRRRtzope.interfaceRttwisted.pythonRttwisted.internetR ttwisted.internet.interfacesR Rt_PollLikeMixinR RAt__all__(((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pyt s (˜