f76 dZddlZddlZddlZddlZddlmZddlm Z ddlm Z ddlm Z ddlm Z e j Z e jZe jZe jZejdz ZGd d ZeZd Zd Zd ZdZdZdZdddZ ddlZejxZZdS#e$rYdSwxYw))Future wrap_futureisfutureN) GenericAlias) base_futures)events) exceptions)format_helpersceZdZ eZdZdZdZdZdZ dZ dZ dZ dddZ dZdZeeZedZejdZd Zd Zdd Zd Zd ZdZdZdZdddZdZdZ dZ!dZ"e"Z#dS)rNFloopc |tj|_n||_g|_|jr-t jtjd|_ dSdS)Nr) r _get_event_loop_loop _callbacks get_debugr extract_stacksys _getframe_source_tracebackselfrs 6/opt/alt/python311/lib64/python3.11/asyncio/futures.py__init__zFuture.__init__Hsv </11DJJDJ :   ! ! "%3%A a  &"&"D " " " " "c*tj|SN)r _future_reprrs r__repr__zFuture.__repr__Xs(...rc|jsdS|j}|jjd||d}|jr |j|d<|j|dS)Nz exception was never retrieved)message exceptionfuturesource_traceback)_Future__log_traceback _exception __class____name__rrcall_exception_handler)rexccontexts r__del__zFuture.__del__[sx#  Fo>*JJJ     ! A*.*@G& ' ))'22222rc|jSr)r'r s r_log_tracebackzFuture._log_tracebackms ##rc6|rtdd|_dS)Nz'_log_traceback can only be set to FalseF) ValueErrorr')rvals rr0zFuture._log_tracebackqs(  HFGG G$rc8 |j}|td|S)Nz!Future object is not initialized.)r RuntimeErrorrs rget_loopzFuture.get_loopws%;z <BCC C rc |j|j}d|_|S|jtj}ntj|j}|j|_d|_|Sr)_cancelled_exc_cancel_messager CancelledError __context__rr,s r_make_cancelled_errorzFuture._make_cancelled_error~sj   *%C"&D J   '+--CC+D,@AAC-" rc d|_|jtkrdSt|_||_|dS)NFT)r'_state_PENDING _CANCELLEDr9_Future__schedule_callbacks)rmsgs rcancelz Future.cancelsI % ;( " "5  " !!###trc |jdd}|sdSg|jdd<|D]"\}}|j|||#dSNr-)rr call_soon)r callbackscallbackctxs r__schedule_callbackszFuture.__schedule_callbacksss OAAA&   F& > >MHc J 4 = = = = > >rc$ |jtkSr)r?rAr s r cancelledzFuture.cancelleds6{j((rc$ |jtkSr)r?r@r s rdonez Future.dones {h&&rc |jtkr|}||jtkrt jdd|_|j|j|j |j S)NzResult is not ready.F) r?rAr= _FINISHEDr InvalidStateErrorr'r(with_traceback _exception_tb_resultr<s rresultz Future.results| ;* $ $,,..CI ;) # #./EFF F$ ? &/001CDD D|rc |jtkr|}||jtkrt jdd|_|jS)NzException is not set.F)r?rAr=rRr rSr'r(r<s rr$zFuture.exceptions[  ;* $ $,,..CI ;) # #./FGG G$rrGc |jtkr|j|||dS|t j}|j||fdSrF)r?r@rrH contextvars copy_contextrappend)rfnr-s radd_done_callbackzFuture.add_done_callbacksl ;( " " J T7 ; ; ; ; ;%244 O " "B= 1 1 1 1 1rc fd|jD}t|jt|z }|r ||jdd<|S)Nc*g|]\}}|k ||fSra).0frKr]s r z/Future.remove_done_callback..s2***"*1c!"b !#h!(r)rlen)rr]filtered_callbacks removed_counts ` rremove_done_callbackzFuture.remove_done_callbacksp ****.2o***DO,,s3E/F/FF  4!3DOAAA rc |jtkrtj|jd|||_t |_|dS)N: )r?r@r rSrVrRrB)rrWs r set_resultzFuture.set_results] ;( " ".$+/I/I/I/IJJ J   !!#####rc` |jtkrtj|jd|t |t r |}t |t urtd||_|j |_ t|_| d|_ dS)NrjzPStopIteration interacts badly with generators and cannot be raised into a FutureT)r?r@r rS isinstancetype StopIteration TypeErrorr( __traceback__rUrRrBr')rr$s r set_exceptionzFuture.set_exception s ;( " ".$+/I/I/I/IJJ J i & & $! I  ??m + +ABB B#&4  !!####rc#K|s d|_|V|std|S)NTzawait wasn't used with future)rP_asyncio_future_blockingr5rWr s r __await__zFuture.__await__sUyy{{ ,0D )JJJyy{{ @>?? ?{{}}rr)$r* __module__ __qualname__r@r?rVr(rrr9r8rtr'rr!r. classmethodr__class_getitem__propertyr0setterr6r=rDrBrNrPrWr$r^rhrkrrru__iter__rarrrrs&FGJ EON %O#""""" ///333 $ L11 $$X$%%% (     > > >))) '''" 04 2 2 2 2 2    $ $ $$$$&HHHrrcT |j}|S#t$rYnwxYw|jSr)r6AttributeErrorr)futr6s r _get_loopr+sH<xzz       9s   c^ |rdS||dSr)rNrk)rrWs r_set_result_unless_cancelledr7s2I }}NN6rct|}|tjjurt j|jS|tjjurt j|jS|tjjurt j|jS|Sr)rn concurrentfuturesr:r args TimeoutErrorrS)r, exc_classs r_convert_future_excr>suS IJ&555(#(33 j(5 5 5&11 j(: : :+SX66 rc" |r|j|jsdS|}||jt |dS|}|j|dSr)rNrDset_running_or_notify_cancelr$rrrrWrk)rsourcer$rWs r_set_concurrent_future_staterJsB   2: 2 4 4  ""I  !4Y!?!?@@@@@ f%%%%%rcN |rdS|r|dS|}|$|t |dS|}||dSr)rNrDr$rrrrWrk)rdestr$rWs r_copy_future_staterYs  ~~ $ $$&&    29== > > > > >]]__F OOF # # # # #rc ts.ttjjst dts.ttjjst dtrt ndtrt nddfd}fd}||dS)Nz(A future is required for source argumentz-A future is required for destination argumentcht|rt||dSt||dSr)rrr)r%others r _set_statez!_chain_future.._set_state}s> F   8 uf - - - - - ( 7 7 7 7 7rc|r8urdSjdSdSr)rNrDcall_soon_threadsafe) destination dest_loopr source_loops r_call_check_cancelz)_chain_future.._call_check_cancelsa  " " @"kY&>&> 00?????  @ @rcrrdSur|dSrdS|dSr)rN is_closedr)rrrrrs r_call_set_statez&_chain_future.._call_set_states  ! ! # # %)*=*=*?*?% F   [ 8 8 J{F + + + + +""$$   * *:{F K K K K Kr)rrmrrrrprr^)rrrrrrrs`` @@@r _chain_futurermsd F  DJv/9/A/H%J%JDBCCC K IK4>4F4M*O*OIGHHH'/'7'7A)F###TK*2;*?*?I +&&&TI888 @@@@@@@ L L L L L L L L!!"4555 _-----rr c t|r|S|tj}|}t |||Sr)rr r create_futurer)r%r new_futures rrrsV0  |%''##%%J&*%%% r)__all__concurrent.futuresrrZloggingrtypesrrr r r rr@rArRDEBUG STACK_DEBUGr _PyFuturerrrrrrr_asyncio_CFuture ImportErrorrarrrs4        $  " ma FFFFFFFFT         & & &$$$().).).X!%     (OOO !'FXXX    DD sBBB