Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/asyncio/__pycache__/futures.cpython-39.opt-2.pyc
Ðазад
a b�h�6 � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm Z ej Z ej Z ej Z ejZejd ZG dd � d �ZeZd d � Zd d � Zdd� Zdd� Zdd� Zdd� Zdd�dd�Zz ddlZW n ey� Y n 0 ej ZZ dS ))�Future� wrap_future�isfuture� N� )� base_futures)�events)� exceptions)�format_helpersc @ s� e Zd ZeZdZdZdZdZdZ dZ dZ dZ dd�dd�Z ejZdd� Zdd � Zd d � Zed d � �Zejdd � �Zdd� Zdd� Zd*dd�Zdd� Zdd� Zdd� Z dd � Z d d � Z dd �d d!�Z d"d#� Z d$d%� Z!d&d'� Z"d(d)� Z#e#Z$dS )+r NF��loopc C s@ |d u rt �� | _n|| _g | _| j�� r<t�t�d��| _ d S )Nr ) r �get_event_loop�_loop� _callbacksZ get_debugr � extract_stack�sys� _getframe�_source_traceback��selfr � r �0/opt/imh-python/lib/python3.9/asyncio/futures.py�__init__G s �zFuture.__init__c C s d� | jjd�| �� ��S )Nz<{} {}>� )�format� __class__�__name__�join� _repr_info�r r r r �__repr__Y s �zFuture.__repr__c C sF | j s d S | j}| jj� d�|| d�}| jr6| j|d< | j�|� d S )Nz exception was never retrieved)�message� exception�futureZsource_traceback)�_Future__log_traceback� _exceptionr r r r Zcall_exception_handler)r �exc�contextr r r �__del__] s � zFuture.__del__c C s | S �Nr )�cls�typer r r �__class_getitem__m s zFuture.__class_getitem__c C s | j S r( )r# r r r r �_log_tracebackp s zFuture._log_tracebackc C s t |�rtd��d| _d S )Nz'_log_traceback can only be set to FalseF)�bool� ValueErrorr# )r �valr r r r, t s c C s | j }|d u rtd��|S )Nz!Future object is not initialized.)r � RuntimeErrorr r r r �get_loopz s zFuture.get_loopc C s2 | j d u rt�� }n t�| 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| _ | jtkrdS t| _|| _| �� dS )NFT)r# �_state�_PENDING� _CANCELLEDr2 �_Future__schedule_callbacks)r �msgr r r �cancel� s z Future.cancelc C sH | j d d � }|sd S g | j d d �< |D ]\}}| jj|| |d� q(d S �N�r& )r r � call_soon)r Z callbacks�callback�ctxr r r Z__schedule_callbacks� s zFuture.__schedule_callbacksc C s | j tkS r( )r8 r: r r r r � cancelled� s zFuture.cancelledc C s | j tkS r( )r8 r9 r r r r �done� s z Future.donec C sF | j tkr| �� }|�| j tkr*t�d��d| _| jd ur@| j�| jS )NzResult is not ready.F) r8 r: r7 � _FINISHEDr �InvalidStateErrorr# r$ �_resultr6 r r r �result� s z Future.resultc C s6 | j tkr| �� }|�| j tkr*t�d��d| _| jS )NzException is not set.F)r8 r: r7 rE r rF r# r$ r6 r r r r! � s zFuture.exceptionr? c C sB | j tkr | jj|| |d� n |d u r.t�� }| j�||f� d S r> )r8 r9 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|� }|r8|| j d d �< |S )Nc s g | ]\}}|� kr||f�qS r r )�.0�frB �rK r r � <listcomp>� s �z/Future.remove_done_callback.<locals>.<listcomp>)r �len)r rK Zfiltered_callbacksZ removed_countr rO r �remove_done_callback� s �zFuture.remove_done_callbackc C s8 | j tkr t�| j � d| ����|| _t| _ | �� d S )N�: )r8 r9 r rF rG rE r; )r rH r r r � set_result� s zFuture.set_resultc C sb | j tkr t�| j � d| ����t|t�r0|� }t|�tu rDtd��|| _t | _ | � � d| _ d S )NrS zPStopIteration interacts badly with generators and cannot be raised into a FutureT) r8 r9 r rF � isinstancer* � StopIteration� TypeErrorr$ rE r; r# )r r! r r r � set_exception s zFuture.set_exceptionc c s, | � � sd| _| V | � � s$td��| �� S )NTz await wasn't used with future)rD �_asyncio_future_blockingr0 rH r r r r � __await__ s zFuture.__await__)N)%r � __module__� __qualname__r9 r8 rG r$ r r r2 r4 rY r# r r Z_future_repr_infor r r' r+ �propertyr, �setterr1 r7 r= r; rC rD rH r! rL rR rT rX rZ �__iter__r r r r r s@ r c C s* z | j }W n ty Y n0 |� S | jS r( )r1 �AttributeErrorr )�futr1 r r r � _get_loop( s rb c C s | � � r d S | �|� d S r( )rC rT )ra rH r r r � _set_result_unless_cancelled4 s rc c C sX t | �}|tjju r tj| j� S |tjju r8tj| j� S |tjju rPtj| j� S | S d S r( )r* � concurrent�futuresr3 r �args� TimeoutErrorrF )r% Z exc_classr r r �_convert_future_exc; s rh c C sR |� � r| �� | �� s d S |�� }|d ur<| �t|�� n|�� }| �|� d S r( )rC r= � set_running_or_notify_cancelr! rX rh rH rT )rd �sourcer! rH r r r � _set_concurrent_future_stateG s rk c C sT |� � r d S | � � r |�� n2| �� }|d ur>|�t|�� n| �� }|�|� d S r( )rC r= r! rX rh rH rT )rj �destr! rH r r r �_copy_future_stateV s rm c s� t ��s t�tjj�s td��t ��s<t�tjj�s<td��t ��rLt��nd �t ��r`t��nd �dd� � ���fdd�}� ���fdd�}��|� ��|� d S ) Nz(A future is required for source argumentz-A future is required for destination argumentc S s" t | �rt|| � n t| |� d S r( )r rm rk )r" �otherr r r � _set_statez s z!_chain_future.<locals>._set_statec s2 | � � r.�d u s�� u r"��� n ���j� d S r( )rC r= �call_soon_threadsafe)� destination)� dest_looprj � source_loopr r �_call_check_cancel� s z)_chain_future.<locals>._call_check_cancelc sJ �� � r �d ur ��� r d S �d u s,��u r8� �| � n��� �| � d S r( )rC Z is_closedrp )rj )ro rr rq rs r r �_call_set_state� s �� z&_chain_future.<locals>._call_set_state)r rU rd re r rW rb rL )rj rq rt ru r )ro rr rq rj rs r � _chain_futurej s � � rv r c C s2 t | �r | S |d u r t�� }|�� }t| |� |S r( )r r r Z create_futurerv )r" r Z new_futurer r r r � s r ) �__all__�concurrent.futuresrd rI �loggingr � r r r r r r9 r: rE �DEBUGZ STACK_DEBUGr Z _PyFuturerb rc rh rk rm rv r Z_asyncio� ImportErrorZ_CFuturer r r r �<module> s: *
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка