ó [³XMc@sèdZddlZddlZddlmZmZddlmZmZm Z m Z m Z ddl m Z ddlmZddlmZmZmZddlmZe e Be BZd ejfd „ƒ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(tmaint posixbaseR(t IReactorFDSett PollReactorcBsŠeZdZeeƒd„Zd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z e Zd „Zd „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.pyR9s     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_updateRegistrationEs    cCs}y|jƒ}||Wn;x5|jjƒD]\}}||kr.Pq.q.WdSnX||kry||=|j|ƒndS(N(tfilenoRtitemsR(Rt selectabletmdictRtfdes((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pyt _dictRemoveWs    cCsI|jƒ}||jkrE||j|tselectRR*RRRRRRtzope.interfaceRttwisted.pythonRttwisted.internetR R ttwisted.internet.interfacesR R6RR RLt__all__(((s@/usr/lib/python2.7/dist-packages/twisted/internet/pollreactor.pyt s(¯