آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \+م@s®dddgZddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlmZdd lmZdd l mZejdZejjo eejjdƒƒZyejZejZWnek rخdZdZYnXy ejZWnek rِd d„ZYnXyddlmZ m!Z"Wne#k گr*dZ Z"YnXdd„Z$e$ƒZ%[$dd„Z&Gdd„dƒZ'dd„Ze(ƒZ)dd„Zej*e'fZ+e dk گr†e+e f7Z+edk گrڑefe+Z+dd„Z,dd„Z-dS)ع coroutineعiscoroutinefunctionعiscoroutineéNé)عcompat)ع constants)عevents)عbase_futures)عloggerZ YIELD_FROMZPYTHONASYNCIODEBUGcCsdS)NF©)عfuncrrْ*/usr/lib64/python3.6/asyncio/coroutines.pyع/sr)ع Coroutineع AwaitablecCsFGdd„dƒ}dd„}d}|ƒ}||ƒ}t|ƒ|j|ƒ|j|fkS) Nc@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) z!has_yield_from_bug..MyGencSs d|_dS)N)ع send_args)عselfrrr ع__init__;sz*has_yield_from_bug..MyGen.__init__cSs|S)Nr)rrrr ع__iter__=sz*has_yield_from_bug..MyGen.__iter__cSsdS)Né*r)rrrr ع__next__?sz*has_yield_from_bug..MyGen.__next__cWs ||_dS)N)r)rZwhatrrr عsendAsz&has_yield_from_bug..MyGen.sendN)ع__name__ع __module__ع__qualname__rrrrrrrr عMyGen:srcss|EdHdS)Nr)عgenrrr عyield_from_genDsz*has_yield_from_bug..yield_from_genréé)rrr)عnextrr)rrعvaluerعcororrr عhas_yield_from_bug9s r#cCs t|dƒS)N)عCoroWrapper)rrrr ع debug_wrapperPsr%c@sجeZdZd%dd„Zdd„Zdd„Zdd „Zer8d d„Zndd„Zd&d d„Z dd„Z edd„ƒZedd„ƒZ edd„ƒZejrہdd„Zedd„ƒZedd„ƒZedd„ƒZedd „ƒZed!d"„ƒZd#d$„ZdS)'r$NcCs>||_||_tjtjdƒƒ|_t|ddƒ|_t|ddƒ|_ dS)Nrrr) rrrع extract_stackعsysع _getframeع_source_tracebackعgetattrrr)rrrrrr r[s zCoroWrapper.__init__cCs@t|ƒ}|jr0|jd}|d|d|df7}d|jj|fS)Nrz, created at %s:%srz<%s %s>éےےےے)ع_format_coroutiner)ع __class__r)rع coro_reprعframerrr ع__repr__cs zCoroWrapper.__repr__cCs|S)Nr)rrrr rjszCoroWrapper.__iter__cCs|jjdƒS)N)rr)rrrr rmszCoroWrapper.__next__cGs4tjƒ}|j}|jj|jtkr(|d}|jj|ƒS)Nr) r'r(عf_backعf_codeعco_codeعf_lastiع_YIELD_FROMrr)rr!r/Zcallerrrr rus zCoroWrapper.sendcCs|jj|ƒS)N)rr)rr!rrr r}scCs|jj|||ƒS)N)rعthrow)rعtyper!ع tracebackrrr r6€szCoroWrapper.throwcCs |jjƒS)N)rعclose)rrrr r9ƒszCoroWrapper.closecCs|jjS)N)rعgi_frame)rrrr r:†szCoroWrapper.gi_framecCs|jjS)N)rع gi_running)rrrr r;ٹszCoroWrapper.gi_runningcCs|jjS)N)rعgi_code)rrrr r<ژszCoroWrapper.gi_codecCs,t|jddƒ}|dk r(tdj|j|ƒƒ‚|S)Nعcr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r*rعRuntimeErrorعformat)rr=rrr ع __await__”szCoroWrapper.__await__cCs|jjS)N)rعgi_yieldfrom)rrrr rAœszCoroWrapper.gi_yieldfromcCs|jjS)N)rr=)rrrr r= szCoroWrapper.cr_awaitcCs|jjS)N)rع cr_running)rrrr rB¤szCoroWrapper.cr_runningcCs|jjS)N)rعcr_code)rrrr rC¨szCoroWrapper.cr_codecCs|jjS)N)rعcr_frame)rrrr rD¬szCoroWrapper.cr_framecCs’t|ddƒ}t|ddƒ}|dkr,t|ddƒ}|dk rژ|jd krژd|}t|dfƒ}|r„djtj|ƒƒ}|dtj›d ‌7}||jƒ7}tj |ƒdS)Nrr:rDrz%r was never yielded fromr)عzB Coroutine object created at (most recent call last, truncated to z last lines): r+) r*r4عjoinr8عformat_listrZDEBUG_STACK_DEPTHعrstripr عerror)rrr/عmsgعtbrrr ع__del__°szCoroWrapper.__del__)N)NN)rrrrr0rrع_YIELD_FROM_BUGrr6r9عpropertyr:r;r<rZPY35r@rAr=rBrCrDrLrrrr r$Xs( r$csptˆƒrˆStjˆƒrˆ‰ntjˆƒ‡fdd„ƒ‰tsNtdkrDˆ}qftˆƒ}ntjˆƒ‡‡fdd„ƒ}t|_|S)z„Decorator to mark coroutines. If the coroutine is not yielded from before it is destroyed, an error message is logged. c?svˆ||ژ}tj|ƒs(tj|ƒs(t|tƒr4|EdH}n>tdk rry |j}Wntk rZYnXt|tƒrr|ƒEdH}|S)N) r ZisfutureعinspectZisgeneratorع isinstancer$ع _AwaitableABCr@عAttributeError)عargsعkwعresZ await_meth)rrr r"زs zcoroutine..coroNcs@tˆ||ژˆdچ}|jr |jd=tˆddƒ|_tˆddƒ|_|S)N)rrrrr+)r$r)r*rr)rSعkwdsعw)r"rrr عwrapperêszcoroutine..wrapper)ع_inspect_iscoroutinefunctionrOعisgeneratorfunctionع functoolsعwrapsع_DEBUGع_types_coroutineع _is_coroutine)rrXr)r"rr rآs cCst|ddƒtkpt|ƒS)z6Return True if func is a decorated coroutine function.r_N)r*r_rY)rrrr rےscCs t|tƒS)z)Return True if obj is a coroutine object.)rPع_COROUTINE_TYPES)عobjrrr rsc Cst|dƒr’t|dƒr’t|dt|dt|ƒjƒƒ}dj|ƒ}d}y |j}Wn4tk r~y |j}Wntk rxYnXYnX|rژdj|ƒS|Sd}t|t ƒrہ|j }|j}|dk rؤdj|ƒ}n|}|dkrعtj |fiƒ}d}t|dƒrِ|jrِ|j}nt|dƒگr|jگr|j}d}t|dƒگr0|jگr0|j}nt|d ƒگrJ|jگrJ|j}d }|گrb|jگrb|j}d}|}t|t ƒگrعtj|j ƒگrع|j dk گrعtj|j ƒ} | dk گr°| \}}|dkگrتd|||f}nd |||f}n:|dk گrْ|j}d|||f}n|گr|j}d|||f}|S)NrCr<rrz{}()Fz {} runningrDr:zrz%s done, defined at %s:%sz%s running, defined at %s:%sz%s running at %s:%s)عhasattrr*r7rr?rBrRr;rPr$rrrZ_format_callbackrCr<rDr:عco_filenamerOrZZ_get_function_sourceعf_linenoعco_firstlineno) r"Z coro_nameZrunningrZ coro_codeZ coro_frameعfilenameعlinenor.عsourcerrr r,sx r,).ع__all__r[rOZopcodeعosr'r8عtypesrErrrr عlogr Zopmapr5عflagsعignore_environmentعboolعenvironعgetr]rr^ع CoroutineTypeZ_types_CoroutineTyperRrrYعcollections.abcrZ _CoroutineABCrrQعImportErrorr#rMr%r$عobjectr_ع GeneratorTyper`rr,rrrr عsZ j: