!ni i$ddlmZ ddlZddlZddlZ ddlmZddl Z gdZ hdZ GddZ dZ d Zd Zd Zd ZiZd ZdZdZdZdZddZdZdZdZdZdZdZdZdZ dZ!gdfdZ"e#dk(rnejHjKdee&ejHd5Z'e(e'jSejHddZ*e+e*dddyy#e$rddlZYwxYw#e$rdZYwxYw#1swYyxYw) ) annotationsN)register_at_fork)injectimport_patched monkey_patchis_monkey_patched>__file____name__ __builtins__c$eZdZdZddZdZdZy)SysModulesSaverzClass that captures some subset of the current state of sys.modules. Pass in an iterator of module names to the constructor.cXi|_tj|j|yN)_savedimp acquire_locksave)self module_namess P/home/homepc/tiktok-worker/venv/lib/python3.12/site-packages/eventlet/patcher.py__init__zSysModulesSaver.__init__s#   < cl|D]/}tjj|d|j|<1y)z&Saves the named modules to the object.N)sysmodulesgetr)rrmodnames rrzSysModulesSaver.save#s0# BG#&;;??7D#ADKK  Brc |jjD]-\}}||tj|< tj|=/ t j y#t$rYQwxYw#t j wxYw)zRRestores the modules that the saver knows about into sys.modules. N)ritemsrrKeyErrorr release_lock)rrmods rrestorezSysModulesSaver.restore(s|  $ 1 1 3  ?+.CKK(KK0      $    s.6A1A" A1" A.+A1-A..A11BN))r __module__ __qualname____doc__rrr#r$rrr r s! B rr cvd|z}|tjvrtj|S|s6ttzt zt zt z}t|Dcgc]\}}| c}}}|j||D]\}}|tj|<tjj|dttjjD]7}|j|dzstjj|d9 t|ii|jddd} |(t| D]}|t vs t#| |||<| tj|<|j%| Scc}}w#|j%wxYw)aBase method for "injecting" greened modules into an imported module. It imports the module specified in *module_name*, arranging things so that the already-imported modules in *additional_modules* are used when *module_name* makes its imports. **Note:** This function does not create or change any sys.modules item, so if your greened module use code like 'sys.modules["your_module_name"]', you need to update sys.modules by yourself. *new_globals* is either None or a globals dictionary that gets populated with the contents of the *module_name* module. This is useful when creating a "green" version of some other module. *additional_modules* should be a collection of two-element tuples, of the form (, ). If it's not specified, a default selection of name/module pairs is used, which should cover all use cases but may be slower because there are inevitably redundant or unnecessary imports. __patched_module_N.)rr_green_os_modules_green_select_modules_green_socket_modules_green_thread_modules_green_time_modulesr rpoplistkeys startswith __import__splitdir __excludegetattrr#) module_name new_globalsadditional_modules patched_namenamemsaverr"imported_module_namemodules rrr9s&'4Ls{{"{{<((   #% &#% &$% &"#  $  1CDgdATD EE JJ{( c D KKOOK&!%S[[%5%5%7 88  * *;+< = KKOO0$ 78 KR1B1B31G1LM  "F  >y((/(=K% > %+ L!  M?E:  s- F 18F&*$F&&F8cPt|dg|t|jzS)zImports a module in a way that ensures that the module uses "green" versions of the standard library modules, so that everything works nonblockingly. The only required argument is the name of the module to be imported. N)rtupler)r:r<kw_additional_moduless rrrs2 T .7L7R7R7T1UU rcs6ttztztzt zfd}|S)a Decorator that returns a version of the function that patches some modules for the duration of the function call. This is deeply gross and should only be used for functions that import network libraries within their function bodies that there is no way of getting around.ct}D])\}}|j||tj|<+ |i||j S#|j wxYwr)r rrrr#)argskwr@r>r"r<funcs rpatchedzpatch_function..patcheds]!+ $ID# JJt  #CKK  $ $$ MMOEMMOs AA%)r,r-r.r/r0)rJr<rKs`` rpatch_functionrLsQ   #% &#% &$% &"#  $  Nrcfd}|S)auKind of the contrapositive of patch_function: decorates a function such that when it's called, sys.modules is populated only with the unpatched versions of the specified modules. Unlike patch_function, only the names of the modules need be supplied, and there are no defaults. This is a gross hack; tell your kids not to import inside function bodies!ct}D]}t|tj|<  |i||j S#|j wxYwr)r originalrrr#)rHrIr@r>rJrs rrKz)_original_patch_function..patchedsS -  /D (CKK  / $$ MMOEMMOs A Ar$)rJrrKs`` r_original_patch_functionrPs Nrcd|z}|tjvrtjj|St|f}tjj |dddd}||vr2||}|j |t |tj|< t|ii|jddd}|dvr;t|d s/t|jjd|j_ |tj|<|jtj|S#|jwxYw) zcThis returns an unpatched version of a module; this is useful for Eventlet itself (i.e. tpool).__original_module_N_thread threadingrTqueuer*r+)QueuerV _threading)rrrr r1rrOr5r6hasattrrPrWrr#)r original_namer@deps dependencyreal_mods rrOrOs)72M #{{}-- WJ 'EKKOOGT"#[ 9D$']  :"*:"6 J gr2w}}S/A#2/FG ( (<1P'?'''HNN #&. M"  ;;} %%  s A2D44Ec|}t|}|dk(r+ddl}t|jdr|j|_|dvrF ddl}|dk(r||j j_|dk(r||j j_ dD]F} tj|}t||dtj |us:t#|||Hy#t$rYWwxYw#t$rYdwxYw) z When using asyncio hub, we want the asyncio modules to use the original, blocking APIs. So un-monkeypatch references to the given module name, e.g. "select". rSrN get_identrUrTrV)zasyncio.base_eventszasyncio.base_futureszasyncio.base_subprocesszasyncio.base_taskszasyncio.constantszasyncio.coroutineszasyncio.eventszasyncio.exceptionszasyncio.format_helperszasyncio.futuresasyncioz asyncio.locksz asyncio.logzasyncio.mixinszasyncio.protocolszasyncio.queueszasyncio.runnerszasyncio.selector_eventszasyncio.sslprotozasyncio.staggeredzasyncio.streamszasyncio.subprocesszasyncio.taskgroupsz asyncio.taskszasyncio.threadszasyncio.timeoutszasyncio.transportszasyncio.trsockzasyncio.unix_events)rOasyncio.base_futuresrY base_futuresr_concurrent.futures.threadfuturesthreadrTrV RuntimeError importlib import_module ImportErrorr9rrsetattr)!unmonkeypatch_refs_to_this_module to_unpatchoriginal_moduler` concurrentr:rBs r_unmonkey_patch_asyncioros 3Jz*OY# 7'' 5#2#<# ,,[9F 6:t , J0G G FJ 8M&9   X   s$CC# C C # C/.C/c ttttt t t tggD]\}}t|tdtd_ y)z< Unmonkey-patch all referred-to modules in asyncio. select selectorsN) sumr,r-r.r/r0_green_builtins_green_subprocess_modulesrorOrq)r:_s r_unmonkey_patch_asyncio_allrw5sn!#  - Q , -$,H#5H[ rc tjjhd}d|vrd|vrJ |jd}||d<|jdd}|j D]}||vst d|z|d|jv}|D]B}|dk(r|j|d |dk(r|j|d |j||Dd dl }t|j}g}d tfd tfd tfdtfdt fdt"fdt$fdt&ffD]4\} } || s t(j+| r"|| z }dt(| <6|dr5t(j+ds d dlm} | j1dt(d<t5d} t7j8 |D]\} } t:j<j+| }| t?| }| j@D]}tC| |d}|tE|||!tC| dg}|D]}tG||stI||| dk(stJsd}|jL|jN_&|jLtQdijN_& t7jRd dl*}t5d}||jV_,d dl }|jZ|_ d dl.}|j^|_0|D]\} }| dk(s tc|y#t$rYwxYw#t2$rYwxYw#t7jRwxYw)aGlobally patches certain system modules to be greenthread-friendly. The keyword arguments afford some control over which modules are patched. If no keyword arguments are supplied, all possible modules are patched. If keywords are set to True, only the specified modules are patched. E.g., ``monkey_patch(socket=True, select=True)`` patches only the select and socket modules. Most arguments patch the single module of the same name (os, time, select). The exceptions are socket, which also patches the ssl module if present; and thread, which patches thread, threading, and Queue. It's safe to call monkey_patch multiple times. > ostimerqsocketreMySQLdbpsycopgbuiltins subprocess __builtin__r~allNz4monkey_patch() got an unexpected keyword argument %rTr|Frryrqr{rerzrr})psycopg2_patcherrT __deleted__cyrr$r$rrnoopzmonkey_patch..noopsrrS)2eventlethubsget_hubr1r r3 TypeErrorvalues setdefaultrTtypeRLockr,r-r.r/r0_green_MySQLdbrtrualready_patchedreventlet.supportrmake_psycopg_greenrirOrrrrr5 __patched__r9rjrYdelattrr__code__ _after_forkrr!importlib._bootstrap _bootstraprS_PyRLockrV_PySimpleQueue SimpleQueue_green_existing_locks)on accepted_argsb default_onkrrToriginal_rlock_typemodules_to_patchr>modules_functionrrXr"orig_mod attr_name patched_attrdeletedrrgrerVrvs rrrFsv* MM M# b(89 9 FF= !:t$J WWY M !IAM  ,  + i  MM'5 ) j MM'5 ) gz* +y01  ! () () () $% N# _% 01 # ) d8O//5  0 2 2 $(OD ! ) )}_00;  9  / / 1)-OI &+&J) MID#{{t,H%d+ __ ? &sIt< +Hi> ?c="5G$ 1 8Y/Hi0 1{"'704 $$-?C}}{B'33<7 M:  i F#)I ((IO,,E$7a ;  !"5 67_    ^    P sILL.AL>-L>L>L>AL> L+*L+. L;:L;>Mc<|tvxst|ddtvS)a[Returns True if the given module is monkeypatched currently, False if not. *module* can be either the module itself or its name. Based entirely off the name of the module, so if you import a module some other way than with the import keyword (including import_patched), this might not be correct about that particular module.r N)rr9)rBs rrrs( /! @ 6:t , ?rct ddl}ddl}ddl}|jjj fd}t tj||d|jvry|jd}|jD]} t||r|dz }|r[ ddl} |jD]B} t||s | j.t1t$|j3|vr|dz}~D |r.upgrades!(C00rPYTEST_CURRENT_TESTrz/Not increase rlock count, an exception of type zoccurred with the message 'z'. Traceback details: z.No decrease rlock count, an exception of type z{} RLock(s) were not greened,z= to fix this error make sure you run eventlet.monkey_patch() z#before importing any other modules.)gcryeventlet.green.threadgreenrer__upgrade_instancesrrenvironcollect get_objects isinstanceReferenceErrorlogging tracebackLoggererrorrr str format_exc_frozen_importlib _ModuleLockmap get_referrersriformat) rlock_typerryrrremaining_rlocksoexcrrloggerrrs @rrrsP   ..   ) ) +C1s{{J8  * JJL ^^  !Z( A%   $^^% %a4 5%00Cb>N>Nq>Q4RR$)$) , + + 2 23C DM N3 4 O   ^^J/F LLAs)$$%'DEc(56&&()   .& "$$^^J7FLLHs),,-/LMc(#%=>$..01     sDD6H*5 F06 F-?A#F((F-0 H'9A#H""H'* H76H7c8ii|t|<fd}t|tr1t|j D]\}}||}||||<t|tr#t |D]\} }||}|||| < t |} t| j D]\}}||}|t|||y#ddl} | jd} | jddYyxYw#t$rYywxYw)a| Starting with a Python object, find all instances of ``klass``, following references in ``dict`` values, ``list`` items, and attributes. Once an object is found, replace all instances with ``upgrade(found_object)``, again limited to the criteria above. In practice this is used only for ``threading.RLock``, so we can assume instances are hashable. Nct|vryt|r|vr|S|}||<|St|yr)idrr)objnewklass old_to_newrvisiteds rupgrade_or_traversez/_upgrade_instances..upgrade_or_traverseWsX c7g  c5 !j !#&cl"% 3 sE7GZ HrrrzAn exception was thrown while monkey_patching for eventlet. to fix this error make sure you run eventlet.monkey_patch() before importing any other modules.T)exc_info) rrdictr2r enumeratevarsrjrr exceptionr) containerrrrrrrvricontainer_varsrrs ```` rrrDsE 'GByM )T"*+ #DAq%a(C" !  #)T"i( #DAq%a(C" !  #i ^1134 /1)!,?Iq#. /  ^^J/F   6      s$ D $)CC*D  DDcxddl}ddlm}|j}t |dr t |ds t d||_d}|jr3|j|jd}|jr3|jr|jd}|r||_ |S) z Convert a normal RLock to one implemented in Python. This is necessary to make RLocks work with eventlet, but also introduces bugs, e.g. https://bugs.python.org/issue13697. So more of a downgrade, really. rN) allocate_lock_block_ownerzINTERNAL BUG. Perhaps you are using a major version of Python that is unsupported by eventlet? Please file a bug at https://github.com/eventlet/eventlet/issues/newFT) rTrrrrYrfr _is_ownedreleaseacquirer)oldrrTrracquireds rrrs3    C 3 !h)? C  CJH --/   --/ }}  Jrcddlm}d|fgS)Nrryry)eventlet.greenryrs rr,r,s! 2J<rcNddlm}d|fg}ddlm}|jd|f|S)Nr)rqrq)rrrr)rrqrrappend)rqrrrs rr-r-s+%&!"G( NNK+, NrcTddlm} ddlm}d|fd|fgS#t$rd|fgcYSwxYw)Nr)r{)sslr{r)rr{rri)r{rs rr.r.s>%$&6"UCL11 $6"##$s ''cddlm}d|fgS)Nrrr)rrrs rrurus) : & ''rc<ddlm}ddlm}ddlm}d|fd|fd|fgS)Nr)rW)re)rTrVrSrT)rrWrerT)rWrerTs rr/r/s'$%( e y&1K3K LLrcddlm}d|fgS)Nrrzrz)rrzrs rr0r0s# TN rc< ddlm}d|fgS#t$rgcYSwxYw)Nrr|r|)rr|rirs rrrs,*G$%%   c< ddlm}d|fgS#t$rgcYSwxYw)Nrbuiltinr~)rrrirs rrtrts,*W%&&  rc | |j}|j|Dcic]$}|jds||vs |t||&c}ycc}w)aCopy properties from *source* (assumed to be a module) to *destination* (assumed to be a dict). *ignore* lists properties that should not be thusly copied. *srckeys* is a list of keys to copy, if the source's __all__ is untrustworthy. N__)__all__updater4r9)source destinationignoresrckeysr>s rslurp_propertiesrs[..  OOD)TV^ '&$' '  s)A__main__exec)NN), __future__r_imprrirgrryrrrr8r rrrLrPrOrrorwrrrrrr,r-r.rur/r0rrtrr argvr1openfcompilereadcoderr$rrr sa" $ L 4 @EP :(%&PI9X6"W7t S lAHD $( M 24T& zHHLLON chhqk aqvvx!f5 T wjs.C*C92.D* C65C69DDD