B H/\ @sdZddlmZddlmZddlmZddlmZdddgZGd d d eej Z e Z d a d d Z ddZddZddZddZddZddZddZddlmZeedd S)z" Maintains the thread local hub. )absolute_import)division)print_function)thread_mod_nameget_hubget_hub_noargsget_hub_if_existscseZdZfddZZS) _Threadlocalcs$tt|d|_d|_d|_dS)N)superr __init__Hubloophub)self) __class__0lib/python3.7/site-packages/gevent/_hub_local.pyr sz_Threadlocal.__init__)__name__ __module__ __qualname__r __classcell__rr)rrr sr NcCstj}|dkrt}t_|S)zReturn the type of hub to use for the current thread. If there's no type of hub for the current thread yet, 'gevent.hub.Hub' is used. N) _threadlocalr )hubtyperrr get_hub_class(s rcCs|adS)N)r )rrrrset_default_hub_class2srcOs(tj}|dkr$t}|||}t_|S)a Return the hub for the current thread. If a hub does not exist in the current thread, a new one is created of the type returned by :func:`get_hub_class`. .. deprecated:: 1.3b1 The ``*args`` and ``**kwargs`` arguments are deprecated. They were only used when the hub was created, and so were non-deterministic---to be sure they were used, *all* callers had to pass them, or they were order-dependent. Use ``set_hub`` instead. N)rrr)argskwargsrrrrrr6s cCs$tj}|dkr t}|}t_|S)N)rrr)rrrrrrIs  cCstjS)z`Return the hub for the current thread. Return ``None`` if no hub has been created yet. )rrrrrrrSscCs |t_dS)N)rr)rrrrset_hub[srcCstjS)N)rr rrrrget_loop^srcCs |t_dS)N)rr )r rrrset_loopasr)import_c_accelzgevent.__hub_local)__doc__Z __future__rrrZgevent._compatr__all__ __import___localr rr rrrrrrrrZ gevent._utilr globalsrrrrs(