File: //opt/alt/python37/lib64/python3.7/site-packages/grpc/__pycache__/_utilities.cpython-37.pyc
B
��f� � @ s� d Z ddlZddlZddlZddlZddlmZmZmZm Z ddl
Z
ddl
m Z ddl m
Z
e�e�ZdZG dd� de�d d
�e
j�ZG d d � d e
j�ZG d
d� de
j�Ze
jed�dd�ZdS )z#Internal utilities for gRPC Python.� N)�Callable�Dict�Optional�Sequence)�_common)�DoneCallbackTypez6Exception calling connectivity future "done" callback!c @ s e Zd ZdS )�RpcMethodHandlerN)�__name__�
__module__� __qualname__� r r �B/opt/alt/python37/lib64/python3.7/site-packages/grpc/_utilities.pyr ! s r Z_RpcMethodHandler)Zrequest_streamingZresponse_streamingZrequest_deserializerZresponse_serializerZ unary_unaryZ unary_streamZ stream_unaryZ
stream_streamc @ sh e Zd ZU eed< eeejf ed< eeeejf d�dd�Zed�dd�Z ej
e ej d �d
d �Z d S )
�DictionaryGenericHandler�_name�_method_handlers)�service�method_handlersc s" � | _ � fdd�|�� D �| _d S )Nc s i | ]\}}|t �� |��qS r )r Zfully_qualified_method)�.0�methodZmethod_handler)r r r
�
<dictcomp>< s z5DictionaryGenericHandler.__init__.<locals>.<dictcomp>)r �itemsr )�selfr r r )r r
�__init__8 s
z!DictionaryGenericHandler.__init__)�returnc C s | j S )N)r )r r r r
� service_nameA s z%DictionaryGenericHandler.service_name)�handler_call_detailsr c C s |j }| j�|�S )N)r r �get)r r Zdetails_methodr r r
r D s z DictionaryGenericHandler.serviceN)
r r
r �str�__annotations__r �grpcr r r ZHandlerCallDetailsr r r r r r
r 4 s
r c @ s e Zd ZU ejed< ejed< eed< eed< e e
ed< ejd�dd�Z e e
d d
�d d �Ze ej d d
�dd�Zed�dd�Zed�dd�Zed�dd�Zed�dd�Zd&e e
d d
�dd�Zd'e e
d d
�dd �Zd(e e
d d
�d d �Zed �d d!�Zd"d#� Zd$d%� Zd S ))�_ChannelReadyFuture�
_condition�_channel�_matured�
_cancelled�_done_callbacks)�channelc C s& t �� | _|| _d| _d| _g | _d S )NF)� threading� Conditionr! r" r# r$ r% )r r& r r r
r T s
z _ChannelReadyFuture.__init__N)�timeoutr c C s� |d kr d n
t � � | }| j�f x^| jr2t�� �q"| jr<d S |d krP| j�� q"|t � � }|dk rnt�� �q"| jj|d� q"W W d Q R X d S )Nr )r) )�timer! r$ r ZFutureCancelledErrorr# �waitZFutureTimeoutError)r r) Zuntil� remainingr r r
�_block\ s
z_ChannelReadyFuture._block)� connectivityr c C s� | j �L | jsJ|tjjkrJd| _| j�| j� | j � � t
| j �}d | _ nd S W d Q R X x8|D ]0}y || � W q^ t k
r� t
�t� Y q^X q^W d S )NT)r! r$ r �ChannelConnectivityZREADYr# r" � unsubscribe�_update�
notify_all�tupler% � Exception�_LOGGER� exception�$_DONE_CALLBACK_EXCEPTION_LOG_MESSAGE)r r. �done_callbacks�
done_callbackr r r
r1 n s
z_ChannelReadyFuture._update)r c C s� | j �@ | js>d| _| j�| j� | j �� t| j�}d | _ndS W d Q R X x8|D ]0}y || � W qR t k
r� t
� t � Y qRX qRW dS )NTF)
r! r# r$ r" r0 r1 r2 r3 r% r4 r5 r6 r7 )r r8 r9 r r r
�cancel� s
z_ChannelReadyFuture.cancelc C s | j � | jS Q R X d S )N)r! r$ )r r r r
� cancelled� s z _ChannelReadyFuture.cancelledc C s" | j � | j o| j S Q R X d S )N)r! r$ r# )r r r r
�running� s z_ChannelReadyFuture.runningc C s | j � | jp| jS Q R X d S )N)r! r$ r# )r r r r
�done� s z_ChannelReadyFuture.donec C s | � |� d S )N)r- )r r) r r r
�result� s z_ChannelReadyFuture.resultc C s | � |� d S )N)r- )r r) r r r
r6 � s z _ChannelReadyFuture.exceptionc C s | � |� d S )N)r- )r r) r r r
� traceback� s z _ChannelReadyFuture.traceback)�fnc C s: | j �" | js$| js$| j�|� d S W d Q R X || � d S )N)r! r$ r# r% �append)r r@ r r r
�add_done_callback� s
z%_ChannelReadyFuture.add_done_callbackc C s( | j � | jj| jdd� W d Q R X d S )NT)Ztry_to_connect)r! r" � subscriber1 )r r r r
�start� s z_ChannelReadyFuture.startc C s0 | j � | js"| js"| j�| j� W d Q R X d S )N)r! r$ r# r" r0 r1 )r r r r
�__del__� s z_ChannelReadyFuture.__del__)N)N)N) r r
r r' r( r r �Channel�boolr r r r �floatr- r/ r1 r: r; r< r= r> r6 r? r rB rD rE r r r r
r M s$
r )r& r c C s t | �}|�� |S )N)r rD )r& Z ready_futurer r r
�channel_ready_future� s rI )�__doc__� collections�loggingr' r* �typingr r r r r r Z grpc._typingr � getLoggerr r5 r7 �
namedtupler ZServiceRpcHandlerr ZFuturer rF rI r r r r
�<module> s$
o