VHϽC 6 d Z ddlZddlZddlZddlZddlmZ ddlm Z ddlm
Z
ddlm Z ddlm Z e j
Z
e j Ze j Ze j Zej dz
Z G d d
ZeZd Zd Zd
Zd Zd Zd ZdddZ ddl Z e j xZZ dS # e $ r Y dS w xY w))Future wrap_futureisfuture N) GenericAlias ) base_futures)events)
exceptions)format_helpersc e Zd Z eZdZdZdZdZdZ dZ
dZ dZ dddZ
d Zd Z ee Zed Zej d Zd Zd
Zdd Zd Zd
Zd Zd Z d Z dddZ d Z d Z d Z!d Z"e"Z#dS )r NFloopc |t j | _ n|| _ g | _ | j r-t j t j d | _ d S d S )Nr )
r _get_event_loop_loop
_callbacks get_debugr
extract_stacksys _getframe_source_tracebackselfr s *JJJ
! A*.*@G& '
))'22222r c | j S r )r' r s r _log_tracebackzFuture._log_tracebackm s ##r c 6 |rt d d| _ d S )Nz'_log_traceback can only be set to FalseF)
ValueErrorr' )r vals r r0 zFuture._log_tracebackq s( H FGG G $ r c 8 | j }|t d |S )Nz!Future object is not initialized.)r RuntimeErrorr s r get_loopzFuture.get_loopw s% ;z < BCC C r c | j | j }d | _ |S | j t j }nt j | j }| j |_ d | _ |S r )_cancelled_exc_cancel_messager
CancelledError __context__r r, s r _make_cancelled_errorz Future._make_cancelled_error~ sj
*%C"&D J ' +--CC +D,@AAC - "
r c d| _ | j t k rdS t | _ || _ | dS )NFT)r' _state_PENDING
_CANCELLEDr9 _Future__schedule_callbacks)r msgs r cancelz
Future.cancel sI % ;( " "5 " !!###tr c | j d d }|sd S g | j d d < |D ]"\ }}| j || | #d S Nr- )r r call_soon)r callbackscallbackctxs r __schedule_callbackszFuture.__schedule_callbacks ss
OAAA& F & > >MHc J 4 = = = = > >r c $ | j t k S r )r? rA r s r cancelledzFuture.cancelled s 6{j((r c $ | j t k S r )r? r@ r s r donez Future.done s
{h&&r c | j t k r| }|| j t k rt j d d| _ | j | j | j | j
S )NzResult is not ready.F) r? rA r= _FINISHEDr
InvalidStateErrorr' r( with_traceback
_exception_tb_resultr< s r resultz
Future.result s| ;* $ $,,..CI ;) # # ./EFF F $ ? &/001CDD D|r c | j t k r| }|| j t k rt j d d| _ | j S )NzException is not set.F)r? rA r= rR r
rS r' r( r< s r r$ zFuture.exception s[ ;* $ $,,..CI ;) # # ./FGG G $ r rG c | j t k r | j || | d S |t j }| j ||f d S rF )r? r@ r rH contextvars copy_contextr append)r fnr- s r add_done_callbackzFuture.add_done_callback sl ;( " " J T7 ; ; ; ; ;%244 O " "B= 1 1 1 1 1r c fd| j D }t | j t | z
}|r || j d d < |S )Nc * g | ]\ }}|k ||fS ra ).0frK r] s r
z/Future.remove_done_callback.. s2 * * *"*1c!"b !#h!(r )r len)r r] filtered_callbacks
removed_counts ` r remove_done_callbackzFuture.remove_done_callback sp * * * *.2o * * * DO,,s3E/F/FF
4!3DOAAA r c | j t k r t j | j d| || _ t
| _ | d S )N: )r? r@ r
rS rV rR rB )r rW s r
set_resultzFuture.set_result s]
;( " " .$+/I/I/I/IJJ J !!#####r c ` | j t k r t j | j d| t |t
r
| }t | t u rt d || _ |j | _
t | _ | d| _
d S )Nrj zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r? r@ r
rS
isinstancetype
StopIteration TypeErrorr(
__traceback__rU rR rB r' )r r$ s r
set_exceptionzFuture.set_exception s
;( " " .$+/I/I/I/IJJ J i & & $! I ??m + + A B B
B# & 4 !!### # r c # K | s d| _ | V | st d | S )NTz await wasn't used with future)rP _asyncio_future_blockingr5 rW r s r __await__zFuture.__await__ sU yy{{ ,0D )JJJyy{{ @ >?? ?{{}} r r )$r*
__module__ __qualname__r@ r? rV r( r r r9 r8 rt r' r r! r. classmethodr __class_getitem__propertyr0 setterr6 r= rD rB rN rP rW r$ r^ rh rk rr ru __iter__ra r r r r s & FGJ E ON % O # " " " " " / / /3 3 3 $ L11
$ $ X$ % % %
(
> > > ) ) ) ' ' ' " 04 2 2 2 2 2
$
$
$$ $ $& HHHr r c T | j } | S # t $ r Y nw xY w| j S r )r6 AttributeErrorr )futr6 s r _get_loopr + sH < xzz
9s
c ^ | rd S | | d S r )rN rk )r rW s r _set_result_unless_cancelledr 7 s2 I
}} NN6r c t | }|t j j u rt j | j S |t j j u rt j | j S |t j j u rt j | j S | S r )rn
concurrentfuturesr: r
args TimeoutErrorrS )r, exc_classs r _convert_future_excr > su S IJ&555(#(33 j(5 5 5&11 j(: : :+SX66
r c " | r | j | j sd S | }| | j t | d S | } | j | d S r )rN rD set_running_or_notify_cancelr$ rr r rW rk )r sourcer$ rW s r _set_concurrent_future_stater J s B
2: 2 4 4 ""I
!4Y!?!?@@@@@
f%%%%%r c N | rd S | r| d S | }|$| t | d S | }| | d S r )rN rD r$ rr r rW rk )r destr$ rW s r _copy_future_stater Y s
~~
$
$$&& 29 = = > > > > >]]__F OOF # # # # #r c t s.t t j j st d t s.t t j j st d t rt
nd t rt
nd d fd}fd} | | d S )Nz(A future is required for source argumentz-A future is required for destination argumentc h t | rt || d S t | | d S r )r r r )r% others r
_set_statez!_chain_future.._set_state} s> F 8 uf - - - - - ( 7 7 7 7 7r c | r8u r d S j d S d S r )rN rD call_soon_threadsafe) destination dest_loopr source_loops r _call_check_cancelz)_chain_future.._call_check_cancel sa " " @"kY&>&>
00 ????? @ @r c r rd S u r | d S rd S | d S r )rN is_closedr )r r r r r s r _call_set_statez&_chain_future.._call_set_state s ! ! # # %)*=*=*?*?% F [ 8 8 J{F + + + + +""$$
* *:{F K K K K Kr )r rm r r r rp r r^ )r r r r r r r s `` @@@r
_chain_futurer m sd F DJv/9/A/H%J %J DBCCC K IK4>4F4M*O *O IGHHH'/'7'7A)F###TK*2;*?*?I +&&&TI8 8 8 @ @ @ @ @ @ @ L L L L L L L L !!"4555
_-----r r
c t | r| S |t j }| }t | | |S r )r r r
create_futurer )r% r
new_futures r r r sV 0
|%''##%%J&*%%% r ) __all__concurrent.futuresr rZ loggingr typesr r r r
r r r@ rA rR DEBUG STACK_DEBUGr _PyFuturer r r r r r r _asyncio_CFuture ImportErrorra r r r s 4
$
" ma F F F F F F F FT
& & & $ $ $(). ). ).X !%
(OOO
!'FXXX DD s B BB