U @f}@sddlZddlZddlZddlZddlmZddlmZddddgZ e dZ e Z d Zed d eDZGd d d eZddZdddZddZddlmZdddejdfddZddZddZGdddeZdS)N)patcher) greenletsuse_hubget_hubget_default_hub trampoline threading)ZepollsZkqueuepollZselectsccs|]}td|VqdS)eventlet.hubs.N) importlib import_module).0namerP/var/www/html/chatgpt/venv/lib/python3.8/site-packages/eventlet/hubs/__init__.py src@s eZdZdS)HubErrorN__name__ __module__ __qualname__rrrrrsrcCs,tD]}|r|SqtdtdS)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: {}N)builtin_hub_modules is_availablerformatmodrrrrs  cCs|dkrtjdd}|dkr$t}ttdr2t`d}t|tr| dkrTt dd|ksdd|krz| d\}}}nd|}t |}t|d r|std |nd j|d }tj|td d|}t|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 NZ EVENTLET_HUBhubzNeed to specify a hub.:r rz3selected 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 partitionr r r ExceptionrwarningswarnDeprecationWarninginspectisclassgetattrr")r classname modulename_msgZhubclassrrrr,s2      c CsXz tj}WnHtk rRz tjWntk r>tYnXt}t_YnX|S)zKGet the current event hub singleton object. .. note :: |internal| )r'rAttributeErrorr"r)rrrrrbs   )timeoutc sd}t}t|jkr$td|r4|r4tdz |}Wntk rX|}YnX|dk r|fdd} ||| |}z\|r||j |j j |} n|r||j |j j |} z| WWS| | XW5|dk r|XdS)a<Suspend the current coroutine until the given socket object or file descriptor is ready to *read*, ready to *write*, or the specified *timeout* elapses, depending on arguments specified. To wait for *fd* to be ready to read, pass *read* ``=True``; ready to write, pass *write* ``=True``. To specify a timeout, pass the *timeout* argument in seconds. If the specified *timeout* elapses before the socket is ready to read or write, *timeout_exc* will be raised instead of ``trampoline()`` returning normally. .. note :: |internal| Nz0do not call blocking functions from the mainloopz1not allowed to trampoline for reading and writingcs|dS)N)throw)exccurrentrr_timeoutsztrampoline.._timeout)rgreenletZ getcurrentr+filenor8Zschedule_call_globalcanceladdREADswitchr:WRITEremove) fdreadwriter9Z timeout_excZmark_as_closedtrr@r>Zlistenerrr<rrvs0    cCst}||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_closerGrrrrrKsrKcCst}||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)rZmark_as_reopenedrLrrr notify_openeds rMc@s eZdZdS)IOClosedNrrrrrrNsrN)N)r r1r#r.ZeventletrZeventlet.supportrr?__all__originalrlocalr'Zbuiltin_hub_namestuplerr-rrrrr9TimeoutrrKrMIOErrorrNrrrrs,     6  /