֦i8 h 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 y# e $ r Y yw 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#y)r NFloopc |t j | _ n|| _ g | _ | j j r.t j t j d | _ y y )Nr )
r get_event_loop_loop
_callbacks get_debugr
extract_stacksys _getframe_source_tracebackselfr s (/usr/lib64/python3.12/asyncio/futures.py__init__zFuture.__init__H s` < ..0DJ DJ :: !%3%A%A
a &"D " " c , t j | S N)r _future_reprr s r __repr__zFuture.__repr__X s ((..r c | j sy | j }| j j d|| d}| j r| j |d< | j
j
| y )Nz exception was never retrieved)message exceptionfuturesource_traceback)_Future__log_traceback
_exception __class____name__r r call_exception_handler)r exccontexts r __del__zFuture.__del__[ sl ##
oo >>**++IJ
! !*.*@*@G& '
))'2r c | j S r )r' r s r _log_tracebackzFuture._log_tracebackm s ###r c , |r t d d| _ y )Nz'_log_traceback can only be set to FalseF)
ValueErrorr' )r vals r r0 zFuture._log_tracebackq s FG G $ r c : | j }| t d |S )Nz!Future object is not initialized.)r RuntimeErrorr s r get_loopzFuture.get_loopw s$ ;zz < BC C r c | j | j }d | _ |S | j t j }n t j | j }| j |_ d | _ |S r )_cancelled_exc_cancel_messager
CancelledError __context__)r r, s r _make_cancelled_errorz Future._make_cancelled_error~ sw
*%%C"&D J ' ++-C ++D,@,@AC -- "
r c d| _ | j t k7 ryt | _ || _ | j y)NFT)r' _state_PENDING
_CANCELLEDr9 _Future__schedule_callbacks)r msgs r cancelz
Future.cancel s> % ;;( " " !!#r c | j d d }|sy g | j d d |D ]# \ }}| j j || | % y Nr- )r r call_soon)r callbackscallbackctxs r __schedule_callbackszFuture.__schedule_callbacks sR
OOA& &MHc JJ 4 = 'r c * | j t k( S r )r> r@ r s r cancelledzFuture.cancelled s 6{{j((r c * | j t k7 S r )r> r? r s r donez Future.done s
{{h&&r c " | j t k( r| j | j t k7 rt j
d d| _ | j %| j j | j | j S )NzResult is not ready.F) r> r@ r< _FINISHEDr
InvalidStateErrorr' r( with_traceback
_exception_tb_resultr s r resultz
Future.result sy ;;* $,,. . ;;) # ../EF F $ ?? &//001C1CD D||r c | j t k( r| j | j t k7 rt j
d d| _ | j S )NzException is not set.F)r> r@ r< rQ r
rR r' r( r s r r$ zFuture.exception sT ;;* $,,. . ;;) # ../FG G $ r rF c | j t k7 r | j j || | y |t j
}| j j ||f y rE )r> r? r rG contextvars copy_contextr append)r fnr- s r add_done_callbackzFuture.add_done_callback sW ;;( " JJ T7 ;%224 OO " "B= 1r c | j D cg c] \ }}||k7 r||f }}}t | j t | z
}|r|| j d d |S c c}}w r )r len)r r\ frJ filtered_callbacks
removed_counts r remove_done_callbackzFuture.remove_done_callback ss
/3oo *.=(1c!"b !#h.= * DOO,s3E/FF
!3DOOA
*s Ac | j t k7 r$t j | j d| || _ t
| _ | j
y )N: )r> r? r
rR rU rQ rA )r rV s r
set_resultzFuture.set_result sO
;;( " ..$++ b/IJ J !!#r c l | j t k7 r$t j | j d| t |t
r | }t |t rt d }||_ ||_ |}|| _
|j | _ t | _ | j d| _ y )Nre zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r> r? r
rR
isinstancetype
StopIterationr5 __cause__r; r(
__traceback__rT rQ rA r' )r r$ new_excs r
set_exceptionzFuture.set_exception s
;;( " ..$++ b/IJ J i &! I i /" $, -G !*G "+G I# & 4 4 !!# # r c # K | j s d| _ | | j s t d | j S w)NTz await wasn't used with future)rO _asyncio_future_blockingr5 rV r s r __await__zFuture.__await__ s= yy{,0D )Jyy{ >? ?{{} s AA r )$r*
__module__ __qualname__r? r> rU r( r r r9 r8 rp r' r r! r. classmethodr __class_getitem__propertyr0 setterr6 r< rC rA rM rO rV r$ r] rc rf rn rq __iter__ r r r r s & FGJ E ON % O # " /3 $L1
$ $ % %
(
> ) '
04 2
$$. Hr r c ^ | j } | S # t $ r Y | j S w xY wr )r6 AttributeErrorr )futr6 s r _get_loopr} - s: << z
99
s ,,c J | j ry | j | y r )rM rf )r| rV s r _set_result_unless_cancelledr 9 s I
}}NN6r c l t | }|t j j u r t j | j
S |t j j u r t j | j
S |t j j u r t j | j
S | S r )ri
concurrentfuturesr: r
args TimeoutErrorrR )r, exc_classs r _convert_future_excr @ s S IJ&&555((#((33 j((55 5&&11 j((:: :++SXX66
r c |j r | j | j sy |j }| | j t | y |j
} | j | y r )rM rC set_running_or_notify_cancelr$ rn r rV rf )r sourcer$ rV s r _set_concurrent_future_stater L su B
2: 2 2 4 "I
!4Y!?@
f%r c |j ry | j r|j y | j }||j t | y | j }|j
| y r )rM rC r$ rn r rV rf )r destr$ rV s r _copy_future_stater [ sj
~~
$$& 29 = >]]_F OOF #r c t s/t t j j s t d t s/t t j j s t d t r t
nd t r t
nd d fd}fd}j | j | y )Nz(A future is required for source argumentz-A future is required for destination argumentc L t | r
t || y t | | y r )r r r )r% others r
_set_statez!_chain_future.._set_state s F uf - ( 7r c | j r3u rj y j j y y r )rM rC call_soon_threadsafe) destination dest_loopr source_loops r _call_check_cancelz)_chain_future.._call_check_cancel s< ""kY&>
00 ? #r c j rj ry u r
| y j ry j | y r )rM is_closedr )r r r r r s r _call_set_statez&_chain_future.._call_set_state s[ ! ! #%)*=*=*? [ 8 {F +""$ * *:{F Kr )r rh r r r TypeErrorr} r] )r r r r r r r s `` @@@r
_chain_futurer o s F Jv/9/A/A/H/H%JBCC K K4>4F4F4M4M*OGHH'/'7)F#TK*2;*? +&TI8 @ L !!"45
_-r r
c t | r| S |t j }|j }t | | |S r )r r r
create_futurer )r% r
new_futures r r r sE 0
|$$&##%J&*% r ) __all__concurrent.futuresr rY loggingr typesr r r r
r r r? r@ rQ DEBUG STACK_DEBUGr _PyFuturer} r r r r r r _asyncio_CFuture ImportErrorry r r r s 4
$
$
" " mma H HX
& $().X !%
(
!'FX s B) )B10B1