a xd.@sddlmZddlZddlZddlZddlZddlmZmZddl Z ddl Z ddl Z ddl mZddlZejdkrddlZeZededZeedZnd d Zd d Zd dZGdddZddZddZGdddZGdddeZe dZ!GdddeZ"ddZ#dS))ABCMetaN)wrapsupdate_wrapper) isasyncgenntzint raise(int);z!api-ms-win-crt-runtime-l1-1-0.dllraisecCstt|dSN)signal pthread_kill threading get_ident)signumrB/var/www/html/Ranjet/env/lib/python3.9/site-packages/trio/_util.py signal_raise@srcCs6zttjttjWdSty0YdS0dS)z7Attempt to reliably check if we are in the main thread.TFN)r SIGINT getsignal ValueErrorrrrris_main_threadLs  rcGsdd}z ||}WnTtyht|tjjrJ|tdj|dd||rbtd|dYn0t|tjjs||rtd|t|rtd|tdt|d ||S) NcSs:t|tjjrdSt|dddur&dS|jjdvr6dSdS)NTZ_asyncio_future_blocking)ZFutureZDeferredF) isinstance collectionsabc Generatorgetattr __class____name__)valuerrr&_return_value_looks_like_wrong_libraryZs zBcoroutine_or_error.._return_value_looks_like_wrong_libraryaTrio was expecting an async function, but instead it got a coroutine object {async_fn!r} Probably you did something like: trio.run({async_fn.__name__}(...)) # incorrect! nursery.start_soon({async_fn.__name__}(...)) # incorrect! Instead, you want (notice the parentheses!): trio.run({async_fn.__name__}, ...) # correct! nursery.start_soon({async_fn.__name__}, ...) # correct!)async_fnuTrio was expecting an async function, but instead it got {!r} – are you trying to use a library written for asyncio/twisted/tornado or similar? That won't work without some sort of compatibility shim.uTrio got unexpected {!r} – are you trying to use a library written for asyncio/twisted/tornado or similar? That won't work without some sort of compatibility shim.zEstart_soon expected an async function but got an async generator {!r}zCTrio expected an async function, but {!r} appears to be synchronous __qualname__) TypeErrorrrr Coroutinecloseformatrr)rargsrcororrrcoroutine_or_errorYsR    r&c@s(eZdZdZddZddZddZdS) ConflictDetectoraDetect when two tasks are about to perform operations that would conflict. Use as a synchronous context manager; if two tasks enter it at the same time then the second one raises an error. You can use it when there are two pieces of code that *would* collide and need a lock if they ever were called at the same time, but that should never happen. We use this in particular for things like, making sure that two different tasks don't call sendall simultaneously on the same stream. cCs||_d|_dSNF)_msg_held)selfmsgrrr__init__szConflictDetector.__init__cCs|jrt|jnd|_dS)NT)r*trioZBusyResourceErrorr))r+rrr __enter__szConflictDetector.__enter__cGs d|_dSr()r*)r+r$rrr__exit__szConflictDetector.__exit__N)r __module__r__doc__r-r/r0rrrrr's r'csfdd}|S)z@Similar to wraps, but for async wrappers of non-async functions.cs0|_djf|_djj|_|S)N.z,Like :meth:`~{}.{}.{}`, but async. )rjoinrr#r1r2)func attr_namecls wrapped_clsrr decorators  zasync_wraps..decoratorr)r8r9r7r:rr6r async_wrapss r;csDtfdd|D]\}ds |q dS)Ncst|vrdSt|t|dd}|dur|dr|_t|drbd|jvrb||_||_t|t r|j D]\}}d|||qvdS)Nr1ztrio.rr3) idaddr startswithr1hasattrrrrtype__dict__items)qualnamenameobjmodr7 attr_valuefix_one module_nameZobjnameZseen_idsrrrIs   z&fixup_module_metadata..fix_one_)setrBr>)rJ namespacerErrHrfixup_module_metadatas  rNc@s(eZdZdZddZddZddZdS) generic_functiona;Decorator that makes a function indexable, to communicate non-inferrable generic type parameters to a static type checker. If you write:: @generic_function def open_memory_channel(max_buffer_size: int) -> Tuple[ SendChannel[T], ReceiveChannel[T] ]: ... it is valid at runtime to say ``open_memory_channel[bytes](5)``. This behaves identically to ``open_memory_channel(5)`` at runtime, and currently won't type-check without a mypy plugin or clever stubs, but at least it becomes possible to write those. cCst||||_dSr)r_fn)r+fnrrrr-s zgeneric_function.__init__cOs|j|i|Sr)rP)r+r$kwargsrrr__call__ szgeneric_function.__call__cCs|Srr)r+rKrrr __getitem__ szgeneric_function.__getitem__N)rr1rr2r-rSrTrrrrrOsrOcs eZdZdZfddZZS)Finala<Metaclass that enforces a class to be final (i.e., subclass not allowed). If a class uses this metaclass like this:: class SomeClass(metaclass=Final): pass The metaclass will ensure that no sub class can be created. Raises ------ - TypeError if a sub class is created cs>|D]&}t|trt|jd|jdqt||||S)Nr3z does not support subclassing)rrUr r1rsuper__new__)r8rDbasesZ cls_namespacebaserrrrWs  z Final.__new__)rr1rr2rW __classcell__rrrZrrUsrUTcs>eZdZdZddZejeejejedfdd Z Z S)NoPublicConstructoraMetaclass that enforces a class to be final (i.e., subclass not allowed) and ensures a private constructor. If a class uses this metaclass like this:: class SomeClass(metaclass=NoPublicConstructor): pass The metaclass will ensure that no sub class can be created, and that no instance can be initialized. If you try to instantiate your class (SomeClass()), a TypeError will be thrown. Raises ------ - TypeError if a sub class or an instance is created. cOst|jd|jddS)Nr3z has no public constructor)r r1rr8r$rRrrrrS>szNoPublicConstructor.__call__)r8r$rRreturncstj|i|Sr)rVrSr^rZrr_createCszNoPublicConstructor._create) rr1rr2rStTyper\Anyr`r[rrrZrr]+sr]c Cs|t|dst|Sz|jjd}Wn$ttfyFd|jj}Yn0z |j }Wntyl|jj }Yn0|d|S)z{Return the fully-qualified name of the async generator function that produced the async generator iterator *agen*. ag_coderz<{}>r3) r?reprag_frame f_globalsAttributeErrorKeyErrorr#rd co_filenamerco_name)ZagenmodulerCrrr name_asyncgenGs   rm)$rrosr syspathlib functoolsrrtypingrar rasync_generatorrr.rDZcffiZFFIZ_ffiZcdefdlopenZ_librrrr&r'r;rNrOrUTypeVarr\r]rmrrrrs6   $     Q