o
0ik7 @ s d Z ddlZddlZddlZddlZddlmZ ddlm Z ddlm
Z
ddlm Z ddlm Z e j
Z
e jZe jZe jZejd ZG d d
d
ZeZd d Zd
d Zdd Zdd Zdd Zdd ZddddZzddl Z W n
e yz Y dS w e j ZZ dS ))Future wrap_futureisfuture N) GenericAlias ) base_futures)events)
exceptions)format_helpersc @ s e Zd Z eZdZdZdZdZdZ dZ
dZ dZ ddddZ
ejZdd Zdd ZeeZed
d Zejd d Zd
d Zdd Zd(ddZdd Z dd Z dd Z dd Z dd Z dd d d Z!d d! Z"d"d# Z#d$d% Z$d&d' Z%e%Z&dS ))r NFloopc C sF |d u r t | _n|| _g | _| j r!ttd| _ d S d S )Nr )
r _get_event_loop_loop
_callbacksZ get_debugr
extract_stacksys _getframe_source_tracebackselfr r 6/opt/alt/python310/lib64/python3.10/asyncio/futures.py__init__H s
zFuture.__init__c C s d | jjd| S )Nz<{} {}> )format __class____name__join
_repr_infor r r r __repr__Z s
zFuture.__repr__c C sF | j sd S | j}| jj d|| d}| jr| j|d< | j| d S )Nz exception was never retrieved)message exceptionfutureZsource_traceback)_Future__log_traceback
_exceptionr r r r Zcall_exception_handler)r exccontextr r r __del__^ s
zFuture.__del__c C s | j S N)r$ r r r r _log_tracebackp s zFuture._log_tracebackc C s |rt dd| _d S )Nz'_log_traceback can only be set to FalseF)
ValueErrorr$ )r valr r r r* t s
c C s | j }|d u r td|S )Nz!Future object is not initialized.)r RuntimeErrorr r r r get_loopz s
zFuture.get_loopc C s4 | j d u r t }nt| j }| j|_d | _|S r) )_cancel_messager CancelledError_cancelled_exc __context__r r& r r r _make_cancelled_error s
z Future._make_cancelled_errorc C s. d| _ | jtkr dS t| _|| _| dS )NFT)r$ _state_PENDING
_CANCELLEDr/ _Future__schedule_callbacks)r msgr r r cancel s
z
Future.cancelc C sJ | j d d }|s d S g | j d d < |D ]
\}}| jj|| |d qd S Nr' )r r call_soon)r Z callbackscallbackctxr r r Z__schedule_callbacks s zFuture.__schedule_callbacksc C s | j tkS r) )r5 r7 r r r r cancelled s
zFuture.cancelledc C s | j tkS r) )r5 r6 r r r r done s
z Future.donec C sP | j tkr | }|| j tkrtdd| _| jd ur%| j| j | j
S )NzResult is not ready.F) r5 r7 r4 _FINISHEDr InvalidStateErrorr$ r% with_traceback
_exception_tb_resultr3 r r r result s
z
Future.resultc C s8 | j tkr | }|| j tkrtdd| _| jS )NzException is not set.F)r5 r7 r4 rB r rC r$ r% r3 r r r r" s
zFuture.exceptionr< c C sF | j tkr| jj|| |d d S |d u rt }| j||f d S r; )r5 r6 r r= contextvarsZ copy_contextr append)r fnr' r r r add_done_callback s
zFuture.add_done_callbackc s> fdd| j D }t| j t| }|r || j d d < |S )Nc s g | ] \}}| kr||fqS r r ).0fr? rJ r r
s
z/Future.remove_done_callback..)r len)r rJ Zfiltered_callbacksZ
removed_countr rN r remove_done_callback s
zFuture.remove_done_callbackc C s: | j tkrt| j d| || _t| _ | d S )N: )r5 r6 r rC rF rB r8 )r rG r r r
set_result s
zFuture.set_resultc C sl | j tkrt| j d| t|tr| }t|tu r#td|| _|j | _
t | _ | d| _
d S )NrR zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r5 r6 r rC
isinstancetype
StopIteration TypeErrorr%
__traceback__rE rB r8 r$ )r r" r r r
set_exception s
zFuture.set_exceptionc c s. | s d| _| V | std| S )NTz await wasn't used with future)rA _asyncio_future_blockingr- rG r r r r __await__ s zFuture.__await__r) )'r
__module__ __qualname__r6 r5 rF r% r r r/ r1 rZ r$ r r Z_future_repr_infor r r( classmethodr __class_getitem__propertyr* setterr. r4 r: r8 r@ rA rG r" rK rQ rS rY r[ __iter__r r r r r sD
r c C s& z| j }W | S ty Y | jS w r) )r. AttributeErrorr )futr. r r r _get_loop) s re c C s | rd S | | d S r) )r@ rS )rd rG r r r _set_result_unless_cancelled5 s rf c C sT t | }|tjju rtj| j S |tjju r tj| j S |tjju r(tj| j S | S r) )rU
concurrentfuturesr0 r args TimeoutErrorrC )r& Z exc_classr r r _convert_future_exc< s rk c C sV | r | | sd S | }|d ur | t| d S | }| | d S r) )r@ r: Z set_running_or_notify_cancelr" rY rk rG rS )rg sourcer" rG r r r _set_concurrent_future_stateH s rm c C sZ | rd S | r| d S | }|d ur"|t| d S | }|| d S r) )r@ r: r" rY rk rG rS )rl destr" rG r r r _copy_future_stateW s ro c s t sttjjstdt s ttjjs tdt r'tnd t r1tnd dd fdd} fdd}| | d S ) Nz(A future is required for source argumentz-A future is required for destination argumentc S s$ t | r t|| d S t| | d S r) )r ro rm )r# otherr r r
_set_state{ s z!_chain_future.._set_statec s8 | rd u s u r d S j d S d S r) )r@ r: call_soon_threadsafe) destination) dest_looprl source_loopr r _call_check_cancel s
z)_chain_future.._call_check_cancelc sX rd ur rd S d u su r | d S r#d S | d S r) )r@ Z is_closedrr )rl )rq rt rs ru r r _call_set_state s z&_chain_future.._call_set_state)r rT rg rh r rW re rK )rl rs rv rw r )rq rt rs rl ru r
_chain_futurek s
rx r c C s4 t | r| S |d u rt }| }t| | |S r) )r r r
Z
create_futurerx )r# r Z
new_futurer r r r s
r ) __all__Zconcurrent.futuresrg rH Zloggingr typesr r r r r
r r6 r7 rB DEBUGZ STACK_DEBUGr Z _PyFuturere rf rk rm ro rx r Z_asyncio ImportErrorZ_CFuturer r r r sB
,