V.jP%dZddlZddlZddlZddlZddlZddlmZddlmZ ddl m Z  ddl m ZdZej*j-d Zed ZGd d ej2Zd ZGddZGddZGddZGddej>Z ere Z!yeZ!y#e$rB ddlmZn7#e$r/ ddlmZn$#e$r ddlmZn#e$r ddlmZYnwxYwYnwxYwYnwxYwYwxYw)z#Threading primitives and utilities.N)contextmanager) TIMEOUT_MAXProxy) getcurrent) get_ident)bgThreadLocal LocalStack LocalManagerrdefault_socket_timeoutUSE_FAST_LOCALSc#Ktj}tj|dtj|yw)z7Context temporarily setting the default socket timeout.N)socketgetdefaulttimeoutsetdefaulttimeout)timeoutprevs VC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\celery/utils/threads.pyr r #s5  # # %D W%  T"sAAcBeZdZdZdfd ZdZdZdZdZdZ xZ S) r zBackground service thread.c t|tj|_tj|_d|_|xs|jj|_ y)NT) super__init__ threadingEvent_bgThread__is_shutdown_bgThread__is_stoppeddaemon __class____name__name)selfr!kwargsrs rrzbgThread.__init__/sI &__.%OO- 3DNN33 ctN)NotImplementedErrorr"s rbodyz bgThread.body6s !##r$ct|j|tjt j dtjy)N)file)printformatsysstderr traceback print_exc)r"msgfmtr#s ron_crashzbgThread.on_crash9s/ jcjj#SZZ0D#**-r$c"|j}|jj} |s ||s|j y#t$r} |j d|j ||j tjjtjdn8#tjjtjdwxYwYd}~d}~wwxYw#|j wxYw)Nz{0!r} crashed: {1!r}) r)ris_set Exceptionr4r! _set_stoppedr.r/flushos_exit)r"r) shutdown_setexcs rrunz bgThread.run=syy))00  "n$F#n    !$$ &>> loc = Local() >>> loc.foo = 42 >>> release_local(loc) >>> hasattr(loc, 'foo') False N)__release_local__)locals r release_localrQ^s$ r$c>eZdZdZdZdZdZdZdZdZ dZ d Z y ) r z Local object.) __storage____ident_func__chtj|ditj|dty)NrSrT)object __setattr__rr(s rrzLocal.__init__xs'434!19=r$cHt|jjSr&)iterrSitemsr(s r__iter__zLocal.__iter__|sD$$**,--r$ct||S)zCreate a proxy for a name.r)r"proxys r__call__zLocal.__call__sT5!!r$cX|jj|jdyr&)rSpoprTr(s rrOzLocal.__release_local__s! T002D9r$ct |j|j|S#t$r t|wxYwr&rSrTKeyErrorAttributeErrorr"r!s r __getattr__zLocal.__getattr__s@ '##D$7$7$9:4@ @ ' & & 's"7cz|j}|j} ||||<y#t$r ||i||<YywxYwr&)rTrSrc)r"r!valueidentstorages rrWzLocal.__setattr__sJ##%"" +#(GEN4  +"E]GEN +s '::cr |j|j|=y#t$r t|wxYwr&rbres r __delattr__zLocal.__delattr__s= '  !4!4!67= ' & & 's!6N) r rIrJrK __slots__rr[r^rOrfrWrlr$rr r ss-1I>.":' +'r$r cveZdZdZdZdZdZdZeeeZ [[dZ dZ dZ d Z ed Zed Zy ) _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|_yr&)r _localr(s rrz_LocalStack.__init__s g r$c8|jjyr&)rrrOr(s rrOz_LocalStack.__release_local__s %%'r$c.|jjSr&)rrrTr(s r_get__ident_func__z_LocalStack._get__ident_func__s{{)))r$cFtj|jd|yNrT)rVrWrr)r"rhs r_set__ident_func__z_LocalStack._set__ident_func__s4;;(8%@r$c$fd}t|S)Nc:j}| td|S)Nzobject unbound)top RuntimeError)rvr"s r_lookupz%_LocalStack.__call__.._lookups"Bz"#344Ir$r)r"r~s` rr^z_LocalStack.__call__s  W~r$ct|jdd}|gx|j_}|j||S)zPush a new item to the stack.stackN)getattrrrrappend)r"objr}s rpushz_LocalStack.pushs< T[['4 0 :&( 'DKK  # r$ct|jdd}|yt|dk(rt|j|dS|j 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.popsK  Wd3 = Z1_ $++ &9 99; r$cNt|jdd}|r t|SdS)Nrr)rrrrrs r__len__z_LocalStack.__len__s% Wd3"s5z))r$c<t|jdd}||SgS)Nr)rrrrs rrz_LocalStack.stacks& Wd3  L r$c` |jjdS#ttf$rYywxYw)ztThe topmost item on the stack. Note: If the stack is empty, :const:`None` is returned. rN)rrrrd IndexErrorr(s rr{z_LocalStack.tops3 ;;$$R( ( +  s --N)r rIrJrKrrOrurxpropertyrTr^rr`rrr{rnr$rrprpsl4(*A02DEN. *  r$rpc*eZdZdZddZdZdZdZy)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|_n)t|tr |g|_nt||_|0||_|jD]}t j |d|yt|_yrw)locals isinstancer list ident_funcrVrWr)r"rrrPs rrzLocalManager.__init__ sc >DK  &!(DKv,DK  !(DO""5*:JG%(DOr$c"|jS)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  r$c<|jD] }t|y)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$s [[E % !r$ctdj|jjt|jS)Nz<{} storages: {}>)r-rr rrr(s r__repr__zLocalManager.__repr__,s-")) NN # #S%57 7r$)NN)r rIrJrKrrrrrnr$rr r s  (!!7r$r c4eZdZfdZedZdZxZS)_FastLocalStackcg|_|jj|_|jj|_t|yr&)rrrr`rr)r"rs rrz_FastLocalStack.__init__3s5 JJ%% ::>> r$cL |jdS#ttf$rYywxYw)Nr)rrdrr(s rr{z_FastLocalStack.top9s, ::b> ! +  s ##c,t|jSr&)rrr(s rrz_FastLocalStack.__len__@s4::r$)r rIrJrrr{rrLrMs@rrr1s!  r$r)"rKr;rr.rr0 contextlibrrrG celery.localrgreenletrr ImportError_threadthread _dummy_thread dummy_thread__all__environgetrr Threadr rQr rpr rPrr rnr$rrs) %7 30  **..!23##/*y/*d*%'%'PaaH/7/7dioo& J J{  3 3% 3 3 ( 3 33 32 3 33 3s}B((C/.B54C/5C);CC)C#CC# C C#C C# C)"C##C)&C/(C))C/.C/