ÿØÿà JFIF      ÿÛ „ 	 ( %!1!%)+//.383,7(-.+



-%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ               ÿÄ J  	     ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ              ÿÄ *        !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú
"SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5
ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍÑ¶¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e
ríV
..............................................................................................................................................................................
.............................................................................                                                  
                                                                                                                                                                                     ÿØÿà JFIF      ÿÛ „ 	 ( %!1!%)+//.383,7(-.+



-%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ               ÿÄ J  	     ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ              ÿÄ *        !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú
"SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5
ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍÑ¶¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e
ríV
..............................................................................................................................................................................
.............................................................................                                                  
                                                                                                                                                                                     3

  \>                 @   s  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mZ dd
lmZ ddlm	Z	 ej
Z
ejZejZejZejZejZejZejd ZG dd dZG dd dZeZdd Zdd Zdd Zdd ZddddZyddlZW n ek
r   Y nX ej ZZdS )CancelledErrorTimeoutErrorInvalidStateErrorFuturewrap_futureisfuture    N   )base_futures)compat)eventsc               @   s0   e Zd ZdZdd Zdd Zd	d
 Zdd ZdS )_TracebackLoggerloopsource_tracebackexctbc             C   s    |j | _|j| _|| _d | _d S )N)_loopr   _source_tracebackr   r   r   )selffuturer    r   '/usr/lib64/python3.6/asyncio/futures.py__init__R   s    z_TracebackLogger.__init__c             C   s,   | j }|d k	r(d | _ tj|j||j| _d S )N)r   	tracebackformat_exception	__class____traceback__r   )r   r   r   r   r   activateX   s
    
z_TracebackLogger.activatec             C   s   d | _ d | _d S )N)r   r   )r   r   r   r   clear_   s    z_TracebackLogger.clearc             C   sb   | j r^d}| jr: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_listrstripr   call_exception_handler)r   msgsrcr   r   r   __del__c   s    z_TracebackLogger.__del__N)r   r   r   r   )__name__
__module____qualname__	__slots__r   r   r   r&   r   r   r   r   r      s
   2r   c               @   s   e Zd ZeZdZdZdZdZdZ	dZ
ddddZejZdd ZejrNd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   NF)r   c            C   s@   |d krt j | _n|| _g | _| jj r<t jtjd| _d S )Nr   )	r   get_event_loopr   
_callbacksZ	get_debugextract_stacksys	_getframer   )r   r   r   r   r   r      s    
zFuture.__init__c             C   s   d| j jdj| j f S )Nz<%s %s> )r   r'   r    
_repr_info)r   r   r   r   __repr__   s    zFuture.__repr__c             C   sD   | j s
d S | j}d| jj || d}| jr4| j|d< | jj| d S )Nz %s exception was never retrieved)r   	exceptionr   r   )_log_traceback
_exceptionr   r'   r   r   r#   )r   r   contextr   r   r   r&      s    
zFuture.__del__c             C   s&   d| _ | jtkrdS t| _| j  dS )NFT)r4   _state_PENDING
_CANCELLED_schedule_callbacks)r   r   r   r   cancel   s    
zFuture.cancelc             C   sD   | j d d  }|sd S g | j d d < x|D ]}| jj||  q*W d S )N)r,   r   	call_soon)r   Z	callbackscallbackr   r   r   r:      s    
zFuture._schedule_callbacksc             C   s
   | j tkS )N)r7   r9   )r   r   r   r   	cancelled   s    zFuture.cancelledc             C   s
   | j tkS )N)r7   r8   )r   r   r   r   done   s    zFuture.donec             C   s<   | j tkrt| j tkr tdd| _| jd k	r6| j| jS )NzResult is not ready.F)r7   r9   r   	_FINISHEDr   r4   r5   _result)r   r   r   r   result   s    


zFuture.resultc             C   s,   | j tkrt| j tkr tdd| _| jS )NzException is not set.F)r7   r9   r   r@   r   r4   r5   )r   r   r   r   r3      s    

zFuture.exceptionc             C   s*   | j tkr| jj||  n| jj| d S )N)r7   r8   r   r<   r,   append)r   fnr   r   r   add_done_callback  s    
zFuture.add_done_callbackc                s<    fdd| j D }t| j t| }|r8|| j d d < |S )Nc                s   g | ]}| kr|qS r   r   ).0f)rD   r   r   
<listcomp>  s    z/Future.remove_done_callback.<locals>.<listcomp>)r,   len)r   rD   Zfiltered_callbacksZremoved_countr   )rD   r   remove_done_callback  s
    zFuture.remove_done_callbackc             C   s4   | j tkrtdj| j | || _t| _ | j  d S )Nz{}: {!r})r7   r8   r   formatrA   r@   r:   )r   rB   r   r   r   
set_result   s
    
zFuture.set_resultc             C   s   | j tkrtdj| j | t|tr,| }t|tkr@td|| _t	| _ | j
  tjrbd| _nt| || _| jj| jj d S )Nz{}: {!r}zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r7   r8   r   rK   
isinstancetypeStopIteration	TypeErrorr5   r@   r:   r
   PY34r4   r   Z
_tb_loggerr   r<   r   )r   r3   r   r   r   set_exception,  s    

zFuture.set_exceptionc             c   s   | j  sd| _| V  | j S )NT)r?   _asyncio_future_blockingrB   )r   r   r   r   __iter__D  s    zFuture.__iter__) r'   r(   r)   r8   r7   rA   r5   r   r   rS   r4   r   r	   Z_future_repr_infor1   r2   r
   rQ   r&   r;   r:   r>   r?   rB   r3   rE   rJ   rL   rR   rT   ZPY35	__await__r   r   r   r   r   n   s2   
c             C   s   | j  rd S | j| d S )N)r>   rL   )ZfutrB   r   r   r   _set_result_unless_cancelledS  s    rV   c             C   sN   |j  r| j  | j sd S |j }|d k	r8| j| n|j }| j| d S )N)r>   r;   Zset_running_or_notify_cancelr3   rR   rB   rL   )
concurrentsourcer3   rB   r   r   r   _set_concurrent_future_stateZ  s    rY   c             C   sP   |j  rd S | j  r|j  n.| j }|d k	r:|j| n| j }|j| d S )N)r>   r;   r3   rR   rB   rL   )rX   destr3   rB   r   r   r   _copy_future_statei  s    
r[   c                s   t  r"ttjj r"tdt  rDttjj rDtdt rRjnd t rd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   r[   rY   )r   otherr   r   r   
_set_state  s    z!_chain_future.<locals>._set_statec                s2   | j  r.d ks kr"j  njj d S )N)r>   r;   call_soon_threadsafe)destination)	dest_looprX   source_loopr   r   _call_check_cancel  s    
z)_chain_future.<locals>._call_check_cancelc                sJ   j  rd k	rj rd S d ks,kr8 |  nj |  d S )N)r>   Z	is_closedr^   )rX   )r]   r`   r_   ra   r   r   _call_set_state  s    z&_chain_future.<locals>._call_set_state)r   rM   rW   Zfuturesr   rP   r   rE   )rX   r_   rb   rc   r   )r]   r`   r_   rX   ra   r   _chain_future}  s    	
rd   )r   c            C   s2   t | r| S |d krtj }|j }t| | |S )N)r   r   r+   Zcreate_futurerd   )r   r   Z
new_futurer   r   r   r     s    
)__all__Zconcurrent.futuresrW   Zloggingr.   r   r   r	   r
   r   r   r   r   r   r8   r9   r@   DEBUGZSTACK_DEBUGr   r   Z	_PyFuturerV   rY   r[   rd   r   Z_asyncioImportErrorZ_CFuturer   r   r   r   <module>   s<   

P c*