\edZddlZddlZddlmZddlmZej dZej dZe eefZ e gdZ dZ dd Zd ZGd d eZd Zy)z6 Eventlet utils helper module. .. versionadded:: 1.3 N) importutils) timeutilseventletzeventlet.patcher) __builtin__MySQLdbospsycopgselectsocketthreadtimectstjStj d}|rt j StjS)zGet the current thread. If eventlet is used to monkey-patch the threading module, return the current eventlet greenthread. Otherwise, return the current Python thread. .. versionadded:: 1.5 r )EVENTLET_AVAILABLE threadingcurrent_thread_patcheris_monkey_patched _eventlet getcurrent)green_threadeds :/usr/lib/python3/dist-packages/oslo_utils/eventletutils.pyfetch_current_thread_functorr-s> '''!33H= '' '++ +c|stj}nSt}|D]D}|dk(r|jt|tvrt d|z|j |Ft r} ttj}|r`g}t|D])}tj|r|j|+|r$tjd|d|dt dy y y y #t$rd}YqwxYw) aWarns if eventlet is being used without patching provided modules. :param expected_patched_modules: list of modules to check to ensure that they are patched (and to warn if they are not); these names should correspond to the names passed into the eventlet monkey_patch() routine. If not provided then *all* the modules that could be patched are checked. The currently valid selection is one or multiple of ['MySQLdb', '__builtin__', 'all', 'os', 'psycopg', 'select', 'socket', 'thread', 'time'] (where 'all' has an inherent special meaning). :type expected_patched_modules: list/tuple/iterable :param what: string to merge into the warnings message to identify what is being checked (used in forming the emitted warnings message). :type what: string allz1Unknown module '%s' requested to check if patchedTz=It is highly recommended that when eventlet is used that the z' modules are monkey patched when using z8 (to avoid spurious or unexpected lock-ups and/or hangs)) stacklevelN) _ALL_PATCHcopysetupdate ValueErroraddrboolralready_patchedAttributeErrorsortedrappendwarningswarnRuntimeWarning)expected_patched_moduleswhatexpanded_patched_modulesm maybe_patched not_patcheds rwarn_eventlet_not_patchedr2Es, $#-??#4 #&5 ) 4AEz(// ;J&$&356&788-003 4 !!!9!9:M K45 *11!4&&q) * 3>t E - < ! !!M  !s2C// C=<C=c:tytj|S)zDetermines safely is eventlet patching for module enabled or not :param module: String, module name :return Bool: True if module is patched, False otherwise F)rr)modules rrrs   % %f --rc@eZdZdZfdZdZdZeZdZddZ xZ S) EventletEventzA class that provides consistent eventlet/threading Event API. This wraps the eventlet.event.Event class to have the same API as the standard threading.Event object. cJtt| |jyN)superr6__init__clear)selfargskwargs __class__s rr:zEventletEvent.__init__s mT+- rctt|ddr+d|_tjj |_yy)N_setTF)getattrrAreventEvent_eventr<s rr;zEventletEvent.clears. 4 &DI#////1DK 'rc|jSr8)rArFs ris_setzEventletEvent.is_sets yyrcb|js#d|_|jjdyy)NT)rArEsendrFs rr zEventletEvent.sets'yyDI KK  T "rcntj|5} |j}tjj |j dd5|j||jur dddf ddd|jcdddS#1swY"xYw#1swYyxYw)NT) return_noneF) r StopWatchrErtimeoutTimeoutleftoverwaitrH)r<rNswrCs rrQzEventletEvent.waits   ) %R &&..r{{t{/L/46!JJLDKK/ !!0! {{} % %!! % %s)>B+ B4 B+>B+B( $B++B4r8) __name__ __module__ __qualname____doc__r:r;rHisSetr rQ __classcell__)r?s@rr6r6s( 2  E# %rr6cTtdr tStjS)Nr )rr6rrDrrrDrDs"  r)Nz this library)rVrr) oslo_utilsrr try_importrrrr frozensetrrr2robjectr6rDrZrrr_s" "  #K " ": . !; ! !"4 5 )X./IJ ,08<#1>