o
    7?e                     @   s   d Z ddlZddlZddlZddlZddlmZmZmZm	Z	 ddl
Z
ddl
mZ ddlmZ eeZdZG dd ded	d
e
jZG dd de
jZG dd de
jZde
jdefddZdS )z#Internal utilities for gRPC Python.    N)CallableDictOptionalSequence)_common)DoneCallbackTypez6Exception calling connectivity future "done" callback!c                   @   s   e Zd ZdS )RpcMethodHandlerN)__name__
__module____qualname__ r   r   P/home/www/facesmatcher.com/pyenv/lib/python3.10/site-packages/grpc/_utilities.pyr   !   s    r   Z_RpcMethodHandler)Zrequest_streamingZresponse_streamingZrequest_deserializerZresponse_serializerZunary_unaryZunary_streamZstream_unaryZstream_streamc                   @   sl   e Zd ZU eed< eeejf ed< dedeeejf fddZdefdd	Z	d
ej
deej fddZdS )DictionaryGenericHandler_name_method_handlersservicemethod_handlersc                    s"    | _  fdd| D | _d S )Nc                    s   i | ]\}}t  ||qS r   )r   Zfully_qualified_method).0methodZmethod_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_detailsc                 C   s   |j }| j|S r   )r   r   get)r   r   Zdetails_methodr   r   r   r   D   s   z DictionaryGenericHandler.serviceN)r	   r
   r   str__annotations__r   grpcr   r   r   ZHandlerCallDetailsr   r   r   r   r   r   r   4   s   
 
	r   c                   @   s  e Zd ZU ejed< ejed< eed< eed< e	e
 ed< dejfddZd	ee d
dfddZdeej d
dfddZd
efddZd
efddZd
efddZd
efddZd&d	ee d
dfddZd&d	ee d
dfddZd&d	ee d
dfddZdefd d!Zd"d# Zd$d% Zd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__timeoutr   Nc                 C   s   |d u rd nt   | }| j5 	 | jrt | jr$	 W d    d S |d u r.| j  n|t    }|dk r<t | jj|d q1 sGw   Y  d S )NTr   )r,   )timer$   r'   r"   ZFutureCancelledErrorr&   waitZFutureTimeoutError)r   r,   Zuntil	remainingr   r   r   _block\   s    z_ChannelReadyFuture._blockconnectivityc              	   C   s   | j 2 | js%|tjju r%d| _| j| j | j 	  t
| j}d | _n		 W d    d S W d    n1 s8w   Y  |D ]}z||  W q? tyU   tt Y q?w d S )NT)r$   r'   r"   ChannelConnectivityZREADYr&   r%   unsubscribe_update
notify_alltupler(   	Exception_LOGGER	exception$_DONE_CALLBACK_EXCEPTION_LOG_MESSAGE)r   r1   done_callbacksdone_callbackr   r   r   r4   n   s*   


	z_ChannelReadyFuture._updatec              	   C   s   | j , | jsd| _| j| j | j   t| j}d | _n		 W d    dS W d    n1 s2w   Y  |D ]}z||  W q9 t	yO   t
t Y q9w dS )NTF)r$   r&   r'   r%   r3   r4   r5   r6   r(   r7   r8   r9   r:   )r   r;   r<   r   r   r   cancel   s$   


z_ChannelReadyFuture.cancelc                 C   s0   | j  | jW  d    S 1 sw   Y  d S r   )r$   r'   r   r   r   r   	cancelled   s   $z_ChannelReadyFuture.cancelledc                 C   s:   | j  | j o| j W  d    S 1 sw   Y  d S r   r$   r'   r&   r   r   r   r   running   s   $z_ChannelReadyFuture.runningc                 C   s6   | j  | jp	| jW  d    S 1 sw   Y  d S r   r?   r   r   r   r   done   s   
$z_ChannelReadyFuture.donec                 C      |  | d S r   r0   r   r,   r   r   r   result      z_ChannelReadyFuture.resultc                 C   rB   r   rC   rD   r   r   r   r9      rF   z_ChannelReadyFuture.exceptionc                 C   rB   r   rC   rD   r   r   r   	traceback   rF   z_ChannelReadyFuture.tracebackfnc                 C   s\   | j  | js| js| j| 	 W d    d S W d    n1 s#w   Y  ||  d S r   )r$   r'   r&   r(   append)r   rH   r   r   r   add_done_callback   s    z%_ChannelReadyFuture.add_done_callbackc                 C   s>   | j  | jj| jdd W d    d S 1 sw   Y  d S )NT)Ztry_to_connect)r$   r%   	subscriber4   r   r   r   r   start   s   "z_ChannelReadyFuture.startc                 C   sf   | j & | js| js!| j| j W d    d S W d    d S W d    d S 1 s,w   Y  d S r   )r$   r'   r&   r%   r3   r4   r   r   r   r   __del__   s   "z_ChannelReadyFuture.__del__r   )r	   r
   r   r*   r+   r!   r"   Channelboolr   r   r   r   floatr0   r2   r4   r=   r>   r@   rA   rE   r9   rG   r   rJ   rL   rM   r   r   r   r   r#   M   s&   
 

r#   r)   r   c                 C   s   t | }|  |S r   )r#   rL   )r)   Zready_futurer   r   r   channel_ready_future   s   rQ   )__doc__collectionsloggingr*   r-   typingr   r   r   r   r"   r   Zgrpc._typingr   	getLoggerr	   r8   r:   
namedtupler   ZServiceRpcHandlerr   Futurer#   rN   rQ   r   r   r   r   <module>   s,   

o