Hi}<ddlZddlZddlZddlZddlmZddlmZgdZ ej dZ e Z dZedeDZGdd eZd Zdd Zd Zdd lmZdddejdfdZdZdZGddeZdS)N)patcher) greenlets)use_hubget_hubget_default_hub trampoline threading)epollskqueuepollselectsc#DK|]}tjd|zVdS)eventlet.hubs.N) importlib import_module).0names [/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/eventlet/hubs/__init__.py rs4kkQUI34Dt4KLLkkkkkkceZdZdS)HubErrorN__name__ __module__ __qualname__rrrrDrrctD]}|r|cStdt)aSelect the default hub implementation based on what multiplexing libraries are installed. The order that the hubs are tried is: * epoll * kqueue * poll * select .. include:: ../../doc/source/common.txt .. note :: |internal| z"no built-in hubs are available: {})builtin_hub_modules is_availablerformatmods rrrsU#      JJJ  7>>?RSS T TTrc| tjdd}|t}t t drt `d}t|trt| dkrtdd|vsd|vr,| d\}}}nd|z}tj |}t |d r7|s"td |n2d | }t#j|t&d |}t)j|st-||pd}|t _dS)aUse the module *mod*, containing a class called Hub, as the event hub. Usually not required; the default hub is usually fine. `mod` can be an actual hub class, a module, a string, or None. If `mod` is a class, use it directly. If `mod` is a module, use `module.Hub` class If `mod` is a string and contains either '.' or ':' then `use_hub` uses 'package.subpackage.module:Class' convention, otherwise imports `eventlet.hubs.mod`. If `mod` is None, `use_hub` uses the default hub. Only call use_hub during application initialization, because it resets the hub's state and any existing timers or listeners will never be resumed. These two threadlocal attributes are not part of Eventlet public API: - `threadlocal.Hub` (capital H) is hub constructor, used when no hub is currently active - `threadlocal.hub` (lowercase h) is active hub instance N EVENTLET_HUBhubzNeed to specify a hub.:rr!z3selected hub is not available on this system mod={}zPlease provide `is_available()` function in your custom Eventlet hub {mod}. It must return bool: whether hub supports current platform. See eventlet/hubs/{{epoll,kqueue}} for example. r#) stacklevelHub)osenvirongetrhasattr _threadlocalr' isinstancestrstrip RuntimeError partitionrrr! Exceptionr"warningswarnDeprecationWarninginspectisclassgetattrr-)r$ classname modulename_msghubclasss rrr,s* {jnn^T22 {|U##  I#s2 99;;"  677 7 #::'*yy{{'<'._timeouts MM#     r)rgreenlet getcurrentr6filenorEschedule_call_globaladdREADswitchrJWRITEremovecancel) fdreadwriterF timeout_excmark_as_closedtr'rPrMlistenerrLs @rrrvs" A ))C!##G |wMNNN PPNOOO        $ $Wh D D   awwsxP^__HH  awwsy&'.'-Q_``H !::<< JJx = HHJJJJ  JJx = HHJJJJ s7A&& A54A5AE-D-E-EEE cLt}||dS)z A particular file descriptor has been explicitly closed. Register for any waiting listeners to be notified on the next run loop. N)r notify_closerXr's rr`r`s' ))CRrcLt}||dS)a Some file descriptors may be closed 'silently' - that is, by the garbage collector, by an external library, etc. When the OS returns a file descriptor from an open call (or something similar), this may be the only indication we have that the FD has been closed and then recycled. We let the hub know that the old file descriptor is dead; any stuck listeners will be disabled and notified in turn. N)rmark_as_reopenedras r notify_openedrds' ))CrceZdZdS)IOClosedNrrrrrfrfrrrfrI)rr<r.r9eventletreventlet.supportrrN__all__originalr localr2builtin_hub_namestupler r8rrrrrFTimeoutrr`rdIOErrorrfrrrrps 222222 B A A G [ ) )   <ekkYjkkkkk     y   UUU&3 3 3 3 l   "D$"?",,,,^        w     r