a ƹDfr@sdZGdddeZdS)zq This module implements a selector class, which can be used to dispatch events and for event handler wrangling. c@seZdZdZdddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddlmZedddZ[dZdS)Selectorz: Selector object for watching and event notification. NcCs`|r ||_|dSz |Wn8|ddl}|dd\}}||Yn0dS)z*dispatch events to the registered hanldersN)_timeout_watch_cleanupsysexc_info)selftimeoutrtypevaluer \/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/pathos/selector.pywatchs zSelector.watchcCs|j|g|dS)zEadd to the list of routines to call when is read readyN)_input setdefaultappendr fdhandlerr r rnotifyOnReadReady=szSelector.notifyOnReadReadycCs|j|g|dS)zFadd to the list of routines to call when is write readyN)_outputrrrr r rnotifyOnWriteReadyCszSelector.notifyOnWriteReadycCs|j|g|dS)zKadd to the list of routines to call when raises an exceptionN) _exceptionrrrr r rnotifyOnExceptionIszSelector.notifyOnExceptioncCs|j|dS)zCadd to the list of routines to call when a signal arrivesN) _interruptrr rr r rnotifyOnInterruptOs zSelector.notifyOnInterruptcCs|j|dS)zCadd to the list of routines to call when a timeout occursN)_idlerrr r rnotifyWhenIdleUs zSelector.notifyWhenIdlecCs0d|_|j|_i|_i|_i|_g|_g|_dS)z! Takes no initial input. TN)state_TIMEOUTrrrrrr)r r r r__init__[szSelector.__init__c Csddl}|jr|jdt|j}t|j}t|j}|jd||jd||jd||jd|s|s|s|j s|j ddS|jdz|||||j \}}}WnR|j y}z6|j \} } |j d | | fWYd}~qWYd}~n d}~00|jd |sp|sp|sp|j d |j D]} | |sP|j | qPq|j d ||j||j d ||j||j d||j|qdS)Nrzconstructing list of watchersz input: %sz output: %sz exception: %szchecking for indefinite blockz$no registered handlers left; exitingzcalling selectzsignal received: %d: %szreturned from selectz)no activity; dispatching to idle handlersz!dispatching to exception handlerszdispatching to output handlerszdispatching to input handlers)selectr _debugdebuglistrkeysrrrinforerrorargsremove _dispatch) r r#ZiwtdZowtdZewtdZreadsZwritesZexceptsr)errnomsgrr r rrnsB     "       zSelector._watchcCsB|D]8}||D]}|||s|||q||s||=qdS)N)r+)r handlersentitiesrrr r rr,s  zSelector._dispatchcCs`|jd|jD] }|q|jD] }|q&|jD] }|q:|jD] }||qNdS)Nz cleaning up)r$r(rcloserrrrr r rrs         zSelector._cleanupr)loggerzpathos.selector)namelevelg?)N)__name__ __module__ __qualname____doc__rrrrrrr"rr,rZpathosr2r$r!r r r rrs 3   rN)r9objectrr r r rs