o 0׾g<#@sddlmZmZddlZddlZddlmZddlmZddlmZddl m Z ddd d d d d ddddddddZ e ZdZddZGdddeZddddfddZGd d!d!eZdS)")absolute_importprint_functionN) iteritems)imp_acquire_lock)imp_release_lock) __import___threading_localsocketselect selectorsssl_thread subprocessos threadingbuiltinssignaltimequeue contextvars)z gevent.localz gevent.socketz gevent.selectzgevent.selectorsz gevent.sslz gevent.threadzgevent.subprocessz gevent.oszgevent.threadingzgevent.builtinsz gevent.signalz gevent.timez gevent.queuezgevent.contextvars__g_patched_module_c CsHi}ttD]\}}z t|||<Wqty!|tvr Yqw|S)z Return a map from standard library name to imported gevent module that provides the same API. Optional modules are skipped if they cannot be imported. )rMAPPING importlib import_module ImportErrorOPTIONAL_STDLIB_MODULES)result gevent_name stdlib_namerY/var/www/html/backend_erp/backend_erp_env/lib/python3.10/site-packages/gevent/_patcher.py_collect_stdlib_gevent_modules,s r!c@sXeZdZddfddZddZddZd d Zd d Zd ZddZ ddZ ddZ d S)_SysModulesPatchercCdSNrrmod_namerrr Az_SysModulesPatcher.cCs||_||_t|_i|_dSN) extra_all importingr!_green_modules_t_modules_to_restore)selfr+r*rrr __init__As z_SysModulesPatcher.__init__cCs~i|_|jD] }tj|d|j|<qtttjD]\}}||jr-||j|<tj|=qt|jD] \}}|tj|<q3dSr)) r-r,sysmodulesgetlistr startswithr+)r.modnamemodnamerrr _saveNs    z_SysModulesPatcher._savec CstttjD]\}}||jr||j|<tj|=qt|jD]\}}|dur.|tj|<q ztj|=Wq ty=Yq wdSr)) r3rr0r1r4r+r,r-KeyError)r.r5r6rrr _restorecs     z_SysModulesPatcher._restorecCs*z |Wtd|_dStd|_wr))r:rr-)r.tvtbrrr __exit__ws   z_SysModulesPatcher.__exit__cCst||Sr))rr8r.rrr __enter__sz_SysModulesPatcher.__enter__NcCs^|jdur-|||j||_||j_|jtjt|j<Wd|S1s(wY|Sr))module import_oner+__gevent_patcher__r0r1 _PATCH_PREFIX)r.after_import_hookrrr __call__s  z_SysModulesPatcher.__call__cCstt|}|tjvrtj|S||jsJtj|dt|ii|ddd}||_| |g|||S)N.) rDr0r1r4r+popg_importsplitrA _import_all)r. module_namerE patched_namerArrr rBs   z_SysModulesPatcher.import_onec Cs|rI|d}|j}tt|dd||}|D]+}zt||WqtyD|jd|}t|ii|}t|||||Yqw|sdSdS)Nr__all__rrG) rI__name__tuplegetattrr*AttributeErrorrJsetattrappend)r.rrAr7mod_all attr_namerM new_modulerrr rLs    z_SysModulesPatcher._import_all) rP __module__ __qualname__r/r8r:r>r@rArFrBrLrrrr r"?s  r"cCr#r$rr%rrr r'r(r'cCsdSr)r)rArrr r'r(cCs>tt||}||Wd|S1swY|S)a Import *module_name* with gevent monkey-patches active, and return an object holding the greened module as *module*. Any sub-modules that were imported by the package are also saved. .. versionchanged:: 1.5a4 If the module defines ``__all__``, then each of those attributes/modules is also imported as part of the same transaction, recursively. The order of ``__all__`` is respected. Anything passed in *extra_all* (which must be in the same namespace tree) is also imported. .. versionchanged:: 1.5a4 You must now do all patching for a given module tree with one call to this method, or at least by using the returned object. N)cached_platform_architecturer")rMr*rEpatcherrrr import_patcheds   r]c@s,eZdZdZdZdZdZddZddZdS)r[a  Context manager that caches ``platform.architecture``. Some things that load shared libraries (like Cryptodome, via dnspython) invoke ``platform.architecture()`` for each one. That in turn wants to fork and run commands , which in turn wants to call ``threading._after_fork`` if the GIL has been initialized. All of that means that certain imports done early may wind up wanting to have the hub initialized potentially much earlier than before. Part of the fix is to observe when that happens and delay initializing parts of gevent until as late as possible (e.g., we delay importing and creating the resolver until the hub needs it, unless explicitly configured). The rest of the fix is to avoid the ``_after_fork`` issues by first caching the results of platform.architecture before doing patched imports. (See events.py for similar issues with platform, and test__threading_2.py for notes about threading._after_fork if the GIL has been initialized) Ncs6ddl}|_|_|j_fdd}||_S)Nrcs|s|sjSj|i|Sr)) _arch_result _orig_arch)argskwargsr?rr archsz4cached_platform_architecture.__enter__..arch)platform _platform architecturer^r_)r.rcrbrr?r r@s  z&cached_platform_architecture.__enter__cGs|j|j_d|_dSr))r_rdre)r._argsrrr r>s  z%cached_platform_architecture.__exit__) rPrYrZ__doc__r^r_rdr@r>rrrr r[s r[) __future__rrrr0gevent._compatrrrgevent.builtinsrrJr frozensetrrDr!objectr"r]r[rrrr s<     t