o åÅe*(ã@sddlZddlZddlZddlZddlZddlZddlZejdkr'ddl m Z zddl Z Wn e y8dZ Ynwz ddl mZdd„ZWn dZdd„ZYzddlmZWndZYej d¡Zd Zd Zd Zd Zd ZGdd„deƒZeZGdd„deƒZdd„ZdS)éNÚwin32)ÚpatchercCs t t¡S©N)Úeventlet_patcherÚis_monkey_patchedÚselect©rrú,/usr/lib/python3/dist-packages/ovs/poller.pyÚ_using_eventlet_green_select$s r cCsdS)NFrrrrr r )s)ÚmonkeyÚpollerééééé c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú _SelectSelectzh select.poll emulation by using select.select. Only register and poll are needed at the moment. cCsg|_g|_g|_dSr)ÚrlistÚwlistÚxlist©Úselfrrr Ú__init__Ds z_SelectSelect.__init__cCs˜t|tjƒr | ¡}trt|tjƒr| ¡}tjdkr"t|tƒs"J‚|t@r1|j   |¡|tM}|t @r@|j   |¡|t M}|rJ|j   |¡dSdS)Nr)Ú isinstanceÚsocketÚfilenoÚsslÚ SSLSocketÚsysÚplatformÚintÚPOLLINrÚappendÚPOLLOUTrr©rÚfdÚeventsrrr ÚregisterIs      ÿz_SelectSelect.registerc CsŒ|dkr tƒr d}tjdkrr|j|j|j}|sgSt|ƒtjj kr't dƒ‚|dkr.d}nt |ƒ}z tj  |d|¡}Wntj jyLdtfgYSw|tjjkrUgS|||jvr_t}n |||jvrit}nt}|||fgS|dkryd}nt|ƒd}t |j|j|j|¡\}}}i}|D] } | | d¡tB|| <q‘|D] } | | d¡tB|| <q |D]} | | d¡ttBtBB|| <q¯t| ¡ƒS) Nrgš™™™™™¹?rz,Cannot handle more than maximum waitobjects édFéÿÿÿÿiè)r rrrrrÚlenÚwinutilsÚ win32eventÚMAXIMUM_WAIT_OBJECTSÚ WindowsErrorr ÚWaitForMultipleObjectsÚ pywintypesÚerrorÚPOLLERRÚwinerrorÚ WAIT_TIMEOUTr!r#ÚfloatrÚgetÚPOLLHUPÚPOLLNVALÚlistÚitems) rÚtimeoutr&ÚretvalÚreventrrrÚ events_dictr%rrr Úpoll[s` ýÿ   ý ÿ þ z_SelectSelect.pollN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr'r?rrrr r@s  rc@sXeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dS)ÚPollera=High-level wrapper around the "poll" system call. Intended usage is for the program's main loop to go about its business servicing whatever events it needs to. Then, when it runs out of immediate tasks, it calls each subordinate module or object's "wait" function, which in turn calls one (or more) of the functions Poller.fd_wait(), Poller.immediate_wake(), and Poller.timer_wait() to register to be awakened when the appropriate event occurs. Then the main loop calls Poller.block(), which blocks until one of the registered events happens.cCs | ¡dSr)Ú_Poller__resetrrrr rªs zPoller.__init__cCs|j ||¡dS)aWRegisters 'fd' as waiting for the specified 'events' (which should be select.POLLIN or select.POLLOUT or their bitwise-OR). The following call to self.block() will wake up when 'fd' becomes ready for one or more of the requested events. The event registration is one-shot: only the following call to self.block() is affected. The event will need to be re-registered after self.block() is called if it is to persist. 'fd' may be an integer file descriptor or an object with a fileno() method that returns an integer file descriptor.N)r?r'r$rrr Úfd_wait­s zPoller.fd_waitcCs"|jdks ||jkr||_dSdS)Nr©r;©rÚmsecrrr Ú __timer_wait»s ÿzPoller.__timer_waitcCs"|dkr | ¡dS| |¡dS)aŠCauses the following call to self.block() to block for no more than 'msec' milliseconds. If 'msec' is nonpositive, the following call to self.block() will not block at all. The timer registration is one-shot: only the following call to self.block() is affected. The timer will need to be re-registered after self.block() is called if it is to persist.rN)Úimmediate_wakeÚ_Poller__timer_waitrHrrr Ú timer_wait¿s zPoller.timer_waitcCs0tj ¡}||kr| ¡dS| ||¡dS)aÓCauses the following call to self.block() to wake up when the current time, as returned by ovs.timeval.msec(), reaches 'msec' or later. If 'msec' is earlier than the current time, the following call to self.block() will not block at all. The timer registration is one-shot: only the following call to self.block() is affected. The timer will need to be re-registered after self.block() is called if it is to persist.N)ÚovsÚtimevalrIrKrL)rrIÚnowrrr Útimer_wait_untilÌs  zPoller.timer_wait_untilcCs d|_dS)z[Causes the following call to self.block() to wake up immediately, without blocking.rNrGrrrr rKÛs zPoller.immediate_wakec Csäzlz|j |j¡}| |¡WnHty3}z |jtjkr)t dt  |j¡¡WYd}~n0d}~wt j yW}z|\}}|tjkrMt d|d¡WYd}~nd}~wwW|  ¡dSW|  ¡dSW|  ¡dS|  ¡w)zæBlocks until one or more of the events registered with self.fd_wait() occurs, or until the minimum duration registered with self.timer_wait() elapses, or not at all if self.immediate_wake() has been called.zpoll: %sNr ) r?r;Ú_Poller__log_wakeupÚOSErrorÚerrnoÚEINTRÚvlogÚerrÚosÚstrerrorrr1rE)rr&Úer1Úmsgrrr Úblockàs* € €üú € €z Poller.blockcCs˜|s t d|j¡dS|D];\}}|dkrId}|t@r |d7}|t@r(|d7}|t@r0|d7}|t@r8|d7}|t@r@|d7}t d ||f¡qdS) Nz %d-ms timeoutrÚz[POLLIN]z [POLLOUT]z [POLLERR]z [POLLHUP]z [POLLNVAL]z %s on fd %d)rVÚdbgr;r!r#r2r7r8)rr&r%ÚreventsÚsrrr Ú __log_wakeupös$ €ózPoller.__log_wakeupcCstƒ|_d|_dS)Nr))Ú SelectPollr?r;rrrr Ú__reset s zPoller.__resetN) r@rArBrCrrFrLrMrQrKr\rRrErrrr rDŸs   rDcCs`z&tƒrt d¡j}W|ƒStr t dd¡r t dd¡}W|ƒStj}W|ƒSt}Y|ƒS)a[Returns the original select.poll() object. If select.poll is monkey patched by eventlet or gevent library, it gets the original select.poll and returns an object of it using the eventlet.patcher.original/gevent.monkey.get_original functions. As a last resort, if there is any exception it returns the SelectPoll() object. rr?) r rÚoriginalr?Ú gevent_monkeyÚis_object_patchedÚ get_originalrrb)Ú _system_pollrrr Úget_system_polls  øÿüýri) rTrXrrrÚ ovs.timevalrNÚovs.vlogrÚ ovs.winutilsr+rÚ ImportErrorÚeventletrrr Úgeventr rerVÚVlogr!r#r2r7r8ÚobjectrrbrDrirrrr ÚsD    ÿ    Y o