`fP%dZddlZddlZddlZddlZddlZddlmZddlmZ ddl m Z  ddl m ZnJ#e$rB ddlmZn7#e$r/ ddlmZn$#e$r ddlmZn#e$r ddlmZYnwxYwYnwxYwYnwxYwYnwxYwdZejd Zed ZGd d ejZd ZGddZGddZGddZGddejZ ere Z!dSeZ!dS)z#Threading primitives and utilities.N)contextmanager) TIMEOUT_MAXProxy) getcurrent) get_ident)bgThreadLocal LocalStack LocalManagerrdefault_socket_timeoutUSE_FAST_LOCALSc#Ktj}tj|dVtj|dS)z7Context temporarily setting the default socket timeout.N)socketgetdefaulttimeoutsetdefaulttimeout)timeoutprevs F/var/www/html/env/lib/python3.11/site-packages/celery/utils/threads.pyr r #sG  # % %D W%%% EEE T"""""cBeZdZdZd fd ZdZdZdZdZdZ xZ S) r zBackground service thread.Nc ttj|_tj|_d|_|p |jj|_ dS)NT) super__init__ threadingEvent_bgThread__is_shutdown_bgThread__is_stoppeddaemon __class____name__name)selfr"kwargsr s rrzbgThread.__init__/sU &_..%O-- 3DN3 rctN)NotImplementedErrorr#s rbodyz bgThread.body6s!###rct|j|tjt jdtjdS)N)file)printformatsysstderr traceback print_exc)r#msgfmtr$s ron_crashzbgThread.on_crash9s; jcj#SZ0000D#*-----rc,|j}|jj} |s |n#t$r} |d|j||tj tj dn7#tj tj dwxYwYd}~nd}~wwxYw||dS#|wxYw)Nz{0!r} crashed: {1!r}) r)ris_set Exceptionr4r" _set_stoppedr.r/flushos_exit)r#r) shutdown_setexcs rrunz bgThread.run=s y)0  "lnn $$DFFFF $$$$ &>> loc = Local() >>> loc.foo = 42 >>> release_local(loc) >>> hasattr(loc, 'foo') False N)__release_local__)locals r release_localrQ^s$ rc@eZdZdZdZdZdZdZdZdZ dZ d Z d S) r z Local object.) __storage____ident_func__ct|dit|dtdS)NrSrT)object __setattr__rr(s rrzLocal.__init__xs943334!19=====rcNt|jSr&)iterrSitemsr(s r__iter__zLocal.__iter__|sD$**,,---rc"t||S)zCreate a proxy for a name.r)r#proxys r__call__zLocal.__call__sT5!!!rc`|j|ddSr&)rSpoprTr(s rrOzLocal.__release_local__s- T0022D99999rc |j||S#t$rt|wxYwr&rSrTKeyErrorAttributeErrorr#r"s r __getattr__zLocal.__getattr__sO '#D$7$7$9$9:4@ @ ' ' ' && & 's $'Ac|}|j} ||||<dS#t$r ||i||<YdSwxYwr&)rTrSrc)r#r"valueidentstorages rrWzLocal.__setattr__sb##%%" +#(GEN4  + + +"E]GENNNN +s *??c |j||=dS#t$rt|wxYwr&rbres r __delattr__zLocal.__delattr__sR ' !4!4!6!67=== ' ' ' && & 's $>N) r!rIrJrK __slots__rr[r^rOrfrWrlrrr r ss1I>>>...""":::''' +++'''''rr ceZdZdZdZdZdZdZeeeZ [[dZ dZ dZ d Z ed Zed Zd S) _LocalStackaLocal stack. This class works similar to a :class:`Local` but keeps a stack of objects instead. This is best explained with an example:: >>> ls = LocalStack() >>> ls.push(42) >>> ls.top 42 >>> ls.push(23) >>> ls.top 23 >>> ls.pop() 23 >>> ls.top 42 They can be force released by using a :class:`LocalManager` or with the :func:`release_local` function but the correct way is to pop the item from the stack after using. When the stack is empty it will no longer be bound to the current context (and as such released). By calling the stack without arguments it will return a proxy that resolves to the topmost item on the stack. c,t|_dSr&)r _localr(s rrz_LocalStack.__init__sgg rc8|jdSr&)rrrOr(s rrOz_LocalStack.__release_local__s %%'''''rc|jjSr&)rrrTr(s r_get__ident_func__z_LocalStack._get__ident_func__s {))rcHt|jd|dSNrT)rVrWrr)r#rhs r_set__ident_func__z_LocalStack._set__ident_func__s#4;(8%@@@@@rc,fd}t|S)Nc8j}|td|S)Nzobject unbound)top RuntimeError)rvr#s r_lookupz%_LocalStack.__call__.._lookups#Bz"#3444Irr)r#r~s` rr^z_LocalStack.__call__s*      W~~rc|t|jdd}|gx|j_}|||S)zPush a new item to the stack.stackN)getattrrrrappend)r#objr}s rpushz_LocalStack.pushs? T['4 0 0 :&( 'DK  # rct|jdd}|dSt|dkrt|j|dS|S)zRemove the topmost item from the stack. Note: Will return the old value or `None` if the stack was already empty. rNr6)rrrlenrQr`r#rs rr`z_LocalStack.popsX  Wd33 =4 ZZ1__ $+ & & &9 99;; rcTt|jdd}|rt|ndS)Nrr)rrrrrs r__len__z_LocalStack.__len__s* Wd33")s5zzz)rc:t|jdd}||SgS)Nr)rrrrs rrz_LocalStack.stacks' Wd33  L rcX |jjdS#ttf$rYdSwxYw)ztThe topmost item on the stack. Note: If the stack is empty, :const:`None` is returned. rN)rrrrd IndexErrorr(s rr{z_LocalStack.tops> ;$R( ( +   44 s ))N)r!rIrJrKrrOrurxpropertyrTr^rr`rrr{rnrrrprps4(((***AAAX02DEEN.   ***X  X   rrpc,eZdZdZddZdZdZdZdS)r aLocal objects cannot manage themselves. For that you need a local manager. You can pass a local manager multiple locals or add them later by appending them to ``manager.locals``. Every time the manager cleans up, it will clean up all the data left in the locals for this context. The ``ident_func`` parameter can be added to override the default ident function for the wrapped locals. Nc|g|_n2t|tr |g|_nt||_|/||_|jD]}t |d|dSt|_dSrw)locals isinstancer list ident_funcrVrWr)r#rrrPs rrzLocalManager.__init__ s >DKK  & & '!(DKKv,,DK  !(DO H H""5*:JGGGG H H(DOOOrc*|S)a4Return context identifier. This is the identifier the local objects use internally for this context. You cannot override this method to change the behavior but use it to link other context local objects (such as SQLAlchemy's scoped sessions) to the Werkzeug locals. )rr(s rrzLocalManager.get_idents   rc8|jD]}t|dS)zManually clean up the data in the locals for this context. Call this at the end of the request or use ``make_middleware()``. N)rrQ)r#rPs rcleanupzLocalManager.cleanup$s0 [ ! !E %  ! !rcfd|jjt|jS)Nz<{} storages: {}>)r-r r!rrr(s r__repr__zLocalManager.__repr__,s.")) N #S%5%577 7r)NN)r!rIrJrKrrrrrnrrr r s_   ( ( ( (!!!!!!77777rr c:eZdZfdZedZdZxZS)_FastLocalStackcg|_|jj|_|jj|_t dSr&)rrrr`rr)r#r s rrz_FastLocalStack.__init__3s= J% :> rcN |jdS#ttf$rYdSwxYw)Nr)rrdrr(s rr{z_FastLocalStack.top9s: :b> ! +   44 s $$c*t|jSr&)rrr(s rrz_FastLocalStack.__len__@s4:r)r!rIrJrrr{rrLrMs@rrr1sb X rr)"rKr;rr.rr0 contextlibrrrG celery.localrgreenletrr ImportError_threadthread _dummy_thread dummy_thread__all__environgetrr Threadr rQr rpr rPrr rnrrrs)) %%%%%%777777 30000000 3 3 3 3%%%%%%% 333 3 ( ( ( ( ( ( ( 3 3 3 33333333 3 3 322222222 3 33 3  *..!233###/*/*/*/*/*y/*/*/*d*%'%'%'%'%'%'%'%'PaaaaaaaaH/7/7/7/7/7/7/7/7dio& JJJ JJJsw1A8>A8A2A  A2 A,AA, A& #A,%A& &A,)A2+A,,A2/A81A22A87A8