]D @ sH d d d d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d
l m Z d Z
d Z d
Z e j
j j Z e j
j Z e j
j Z e j d Z Gd d d e Z Gd d d Z d d Z Gd d d Z d d Z d d Z d d Z d d Z d d d d Z d S) CancelledError TimeoutErrorInvalidStateErrorFuture wrap_futureisfuture N )compat)eventsPENDING CANCELLEDFINISHEDc @ s e Z d Z d S)r N)__name__
__module__ __qualname__ r r ,/opt/alt/python35/lib64/python3.5/futures.pyr s c @ sF e Z d Z d Z d d Z d d Z d d
Z d d Z d
S)_TracebackLoggerloopsource_tracebackexctbc C s. | j | _ | j | _ | | _ d | _ d S)N)_loopr _source_tracebackr r r )selffuturer r r r __init__U s z_TracebackLogger.__init__c C s@ | j } | d k r< d | _ t j | j | | j | _ d S)N)r tracebackformat_exception __class__
__traceback__r )r r r r r activate[ s
z_TracebackLogger.activatec C s d | _ d | _ d S)N)r r )r r r r clearb s z_TracebackLogger.clearc C s | j r d } | j rQ d j t j | j } | d 7} | d | j 7} | d j | j j 7} | j j d | i d S)Nz*Future/Task exception was never retrieved
z0Future/Task created at (most recent call last):
z%s
message)r r joinr format_listrstripr call_exception_handler)r msgsrcr r r __del__f s
z_TracebackLogger.__del__N)r r r r )r r r __slots__r r! r" r+ r r r r r ! s
2 r c C s t | j d o | j d k S)N_asyncio_future_blocking)hasattrr r- )objr r r r q s c @ s e Z d Z e Z d Z d Z d Z d Z d Z d Z
d Z d d d d Z d d Z
d d Z d
d Z e j r d d
Z d d Z d d Z d d Z d d Z d d Z d d Z d d Z d d Z d d Z d d! Z d" d# Z e j re Z d S)$r NFr c C s^ | d k r t j | _ n | | _ g | _ | j j rZ t j t j d | _ d S)Nr )
r
get_event_loopr
_callbacksZ get_debugr
extract_stacksys _getframer )r r r r r r s zFuture.__init__c C s | j } t | } | s! d } d d } | d k rL | | d } nn | d k r d j | | d | | d } n9 | d k r d j | | d | d | | d
} d | S) Nr# c S s t j | f S)N)r
Z_format_callback_source)callbackr r r format_cb s z,Future.__format_callbacks.<locals>.format_cbr r z{}, {}z{}, <{} more>, {}zcb=[%s])r1 lenformat)r cbsizer6 r r r Z__format_callbacks s ) zFuture.__format_callbacksc C s | j j g } | j t k rt | j d k rL | j d j | j n( t j | j } | j d j | | j r | j | j
| j r | j d } | j d | d | d f | S)Nzexception={!r}z result={}r zcreated at %s:%sr r8 ) _statelower _FINISHED
_exceptionappendr: reprlibrepr_resultr1 _Future__format_callbacksr )r inforesultframer r r
_repr_info s
zFuture._repr_infoc C s) | j } d | j j d j | f S)Nz<%s %s> )rI r r r% )r rF r r r __repr__ s zFuture.__repr__c C sb | j s
d S| j } d d | j j d | d | i } | j rN | j | d <| j j | d S)Nr$ z %s exception was never retrieved exceptionr r )_log_tracebackr@ r r r r r( )r r contextr r r r+ s
zFuture.__del__c C s3 d | _ | j t k r d St | _ | j d S)NFT)rM r= _PENDING
_CANCELLED_schedule_callbacks)r r r r cancel s
z
Future.cancelc C sX | j d d } | s d Sg | j d d <x! | D] } | j j | | q7 Wd S)N)r1 r call_soon)r Z callbacksr5 r r r rQ s
zFuture._schedule_callbacksc C s
| j t k S)N)r= rP )r r r r cancelled s zFuture.cancelledc C s
| j t k S)N)r= rO )r r r r done s z Future.donec C s} | j t k r t | j t k r0 t d d | _ | j d k r^ | j j d | _ | j d k rv | j | j S)NzResult is not ready.F)
r= rP r r? r rM
_tb_loggerr" r@ rD )r r r r rG s
z
Future.resultc C se | j t k r t | j t k r0 t d d | _ | j d k r^ | j j d | _ | j S)NzException is not set.F) r= rP r r? r rM rV r" r@ )r r r r rL ) s
zFuture.exceptionc C s9 | j t k r% | j j | | n | j j | d S)N)r= rO r rS r1 rA )r fnr r r add_done_callback; s zFuture.add_done_callbackc sR f d d | j D } t | j t | } | rN | | j d d <| S)Nc s" g | ] } | k r | q Sr r ).0f)rW r r
<listcomp>N s z/Future.remove_done_callback.<locals>.<listcomp>)r1 r9 )r rW Zfiltered_callbacksZ
removed_countr )rW r remove_done_callbackI s
zFuture.remove_done_callbackc C sJ | j t k r* t d j | j | | | _ t | _ | j d S)Nz{}: {!r})r= rO r r: rD r? rQ )r rG r r r
set_resultV s
zFuture.set_resultc C s | j t k r* t d j | j | t | t rB | } t | t k r` t d | | _ t | _ | j
t j r d | _
n( t | | | _ | j j | j j d S)Nz{}: {!r}zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r= rO r r:
isinstancetype
StopIteration TypeErrorr@ r? rQ r PY34rM r rV r rS r! )r rL r r r
set_exceptionb s
zFuture.set_exceptionc c s$ | j s d | _ | V| j S)NT)rU r- rG )r r r r __iter__z s zFuture.__iter__) r r r rO r= rD r@ r r r- rM rV r rE rI rK r rb r+ rR rQ rT rU rG rL rX r\ r] rc rd ZPY35 __await__r r r r r | s6
c C s! | j r d S| j | d S)N)rT r] )ZfutrG r r r _set_result_unless_cancelled s rf c C sk | j r | j | j s& d S| j } | d k rN | j | n | j } | j | d S)N)rT rR set_running_or_notify_cancelrL rc rG r] )
concurrentsourcerL rG r r r _set_concurrent_future_state s
rj c C sn | j r d S| j r) | j nA | j } | d k rQ | j | n | j } | j | d S)N)rT rR rL rc rG r] )ri destrL rG r r r _copy_future_state s
rl c s t r/ t t j j r/ t d t r^ t t j j r^ t d t rs j n d t r j n d d d f d d } f d d } j | j | d S) Nz(A future is required for source argumentz-A future is required for destination argumentc S s- t | r t | | n
t | | d S)N)r rl rj )r otherr r r
_set_state s z!_chain_future.<locals>._set_statec sE | j rA d k s$ k r1 j n j j d S)N)rT rR call_soon_threadsafe) destination) dest_loopri source_loopr r _call_check_cancel s
z)_chain_future.<locals>._call_check_cancelc s? d k s k r( | n j | d S)N)ro )ri )rn rq rp rr r r _call_set_state s z&_chain_future.<locals>._call_set_state)r r^ rh futuresr ra r rX )ri rp rs rt r )rn rq rp ri rr r
_chain_future s
rv r c C sE t | r | S| d k r( t j } | j } t | | | S)N)r r
r0 Z
create_futurerv )r r Z
new_futurer r r r s
) __all__concurrent.futures._baserh loggingrB r3 r r# r r
rO rP r? ru _baseErrorr r DEBUGZ STACK_DEBUGr r r r rf rj rl rv r r r r r <module> s4
P
'