| Server IP : 162.144.4.212 / Your IP : 216.73.216.108 Web Server : Apache System : Linux gator2125.hostgator.com 5.14.0-162.23.1.9991722448259.nf.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 31 18:11:45 UTC 2024 x86_64 User : cozeellc ( 2980) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/libexec/oracle-cloud-agent/plugins/osms/grpc/ |
Upload File : |
a
K��f�= � @ sx d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
m Z m Z m
Z
mZmZmZmZmZmZ ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd
lm Z dd lm Z dd lm Z dd
lm Z ddlm!Z! ddlm"Z" ddlm#Z# ddl$Ze�%e&�Z'd�(ej)�Z*dZ+e�,d�duZ-ej.j/ej.j0ej.j1ej.j2ej.j3ej.j4fZ5ej.j/ej.j0ej.j1ej.j2ej.j4fZ6ej.j/ej.j2ej.j3ej.j4fZ7ej.j/ej.j2ej.j4fZ8dZ9dZ:dZ;ee< ee< d�dd�Z=eej> ee? e?d�dd�Z@G d d � d eA�ZBeBej>e?dd �d d �ZCejDeBee ee d!�d"d#�ZEeBee e#d$�d%d&�ZFe
eBeejGejHf e"ee# dd'�d(d)�ZIe?eBe?d*�d+d,�ZJG d-d.� d.ejKejLejM�ZNG d/d0� d0ejKejO�ZPG d1d2� d2ePejLejM�ZQG d3d4� d4ePejLejM�ZRe
ee< e"eee< eeS eejK f d5�d6d7�ZTeBejHeUee< ee!ee!ejLf f d8�d9d:�ZVee eWeeejX d;�d<d=�ZYee eWeeeejX ee# f d;�d>d?�ZZee< ee< d@�dAdB�Z[G dCdD� dDej\�Z]G dEdF� dFej^�Z_G dGdH� dHej^�Z`G dIdJ� dJeja�ZbG dKdL� dLejc�ZdG dMdN� dNeW�ZeG dOdP� dPeA�ZfefddQ�dRdS�ZgefdT�dUdV�ZhG dWdX� dXeA�Zieiee ejjgdf dQ�dYdZ�Zkeiejjee ejjgdf dd[�d\d]�Zleiee ejjgdf dd^�d_d`�ZmeiejneUdda�dbdc�Zoeie ejjgdf eUddd�dedf�Zpeie ejjgdf ddg�dhdi�Zqee eejr ee dj�dkdl�Zsee eee ee f dm�dndo�ZtG dpdq� dqejn�ZndS )rz.Invocation-side implementation of gRPC Python.� N)
�Any�Callable�Dict�Iterator�List�Optional�Sequence�Set�Tuple�Union)�_common)� _compression)�_grpcio_metadata)�_observability)�cygrpc)�ChannelArgumentType)�DeserializingFunction)�IntegratedCallFactory)� MetadataType)�NullaryCallbackType)� ResponseType)�SerializingFunction)�UserTagzgrpc-python/{}�!GRPC_SINGLE_THREADED_UNARY_STREAMz0Exception calling channel subscription callback!z?<{} of RPC that terminated with:
status = {}
details = "{}"
>zZ<{} of RPC that terminated with:
status = {}
details = "{}"
debug_error_string = "{}"
>��timeout�returnc C s | d u r d S t � � | S �N)�time�r � r �q/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/_channel.py� _deadlinem s r" )�unknown_cygrpc_code�detailsr c C s d� | |�S )Nz,Server sent unknown code {} and details "{}")�format)r# r$ r r r! �_unknown_code_detailsq s �r& c @ s� e Zd ZU ejed< eej ed< e e
ed< e ed< e e
ed< e e j
ed< e e ed< e e ed< eed < ee ed
< e e ed < e e ed < e e ed
< e e ed< e e ed< eej e e
e e
e e j
e e d�dd�Zdd� ZdS )� _RPCState� condition�due�initial_metadata�response�trailing_metadata�coder$ �debug_error_string� cancelled� callbacks�
fork_epoch�rpc_start_time� rpc_end_time�method�target)r) r* r, r- r$ c C sj t �� | _t|�| _|| _d | _|| _|| _|| _ d | _
d | _ d | _ d | _
d | _d| _g | _t�� | _d S �NF)� threading� Conditionr( �setr) r* r+ r, r- r$ r. r2 r3 r4 r5 r/ r0 r �get_fork_epochr1 )�selfr) r* r, r- r$ r r r! �__init__� s
z_RPCState.__init__c C s t �� | _d S r )r7 r8 r( �r; r r r! �reset_postfork_child� s z _RPCState.reset_postfork_childN)�__name__�
__module__� __qualname__r7 r8 �__annotations__r r �
OperationTyper r r �grpc�
StatusCode�str�boolr r �int�floatr r< r> r r r r! r' y s,
� (r' )�stater- r$ r c C s0 | j d u r,|| _ || _| jd u r&d| _d| _d S �Nr )r- r$ r* r, )rJ r- r$ r r r! �_abort� s
rL )�eventrJ �response_deserializerr c
C s$ g }| j D �]}|�� }|j�|� |tjjkr<|�� |_q
|tjjkr�|� � }|d ur�t
� ||�}|d u r�d}t |t
jj|� n||_q
|tjjkr
|�� |_|jd u r�t
j�|�� �} | d u r�t
jj|_t| |�� �|_n| |_|�� |_|�� |_t� � |_ t � |� |� |j!� d |_!q
|S )Nz!Exception deserializing response!)"�batch_operations�typer) �remover rC �receive_initial_metadatar* �receive_message�messager � deserializerL rD rE �INTERNALr+ �receive_status_on_clientr, r- �!CYGRPC_STATUS_CODE_TO_STATUS_CODE�get�UNKNOWNr& r$ � error_stringr. r � perf_counterr3 r �maybe_record_rpc_latency�extendr0 )
rM rJ rN r0 �batch_operation�operation_type�serialized_responser+ r$ r- r r r! �
_handle_event� sF �
�
�
rb )rJ rN r c s � �fdd�}|S )Nc s� �j �. t| �� �}�j �� �j }W d � n1 s:0 Y |D ]L}z
|� W qH ty� } z$t�dt|j�t|�� W Y d }~qHd }~0 0 qH|o��j t
� � kS )Nz Exception in callback %s: %s) r( rb �
notify_allr) � Exception�logging�error�repr�funcr1 r r: )rM r0 �done�callback�e�rN rJ r r! � handle_event� s
&
� z$_event_handler.<locals>.handle_eventr )rJ rN rm r rl r! �_event_handler� s rn )�request_iteratorrJ �call�request_serializer�
event_handlerr c s6 � ����fdd�}t j|d�}|�d� |�� dS )z'Consume a request supplied by the user.c sn d} z�zt �� t��}W n� ty@ Y W | s8t �� �q�Y nb ty� t �� d} tjj}d}t �
|� � � t j
| |� t�||� Y W | s�t �� d S 0 W | s�t �� n| s�t �� 0 t �|��}�j�� �jd u �rƈj�s�|d u �r.tjj}d}� � t j
| |� t�||� W d � d S �j�t jj� t �|t�f}� �|��}|�s~�j�t jj� W d � d S �fdd�}t j �jj |t � t j ��d� �jd u�r�W d � d S nW d � d S W d � q 1 �s�0 Y q �j�Z �jd u �rJ�j�t jj � t �!t�f}� �|��}|�sJ�j�t jj � W d � n1 �s`0 Y d S )NFTz Exception iterating requests!� Exception serializing request!c s � j d uptjj� jvS r )r- r rC � send_messager) r �rJ r r! �_done= s
��zJ_consume_request_iterator.<locals>.consume_request_iterator.<locals>._done)�spin_cb)"r � enter_user_request_generator�next�
StopIteration�"return_from_user_request_generatorrd rD rE rZ �_LOGGER� exception�cancelr �!STATUS_CODE_TO_CYGRPC_STATUS_CODErL � serializer( r- r/ rV r) �addrC rt �SendMessageOperation� _EMPTY_FLAGS�operaterQ �wait� functools�partial�block_if_fork_in_progress�send_close_from_client� SendCloseFromClientOperation)�*return_from_user_request_generator_invoked�requestr- r$ �serialized_request�
operations� operatingrv �rp rr ro rq rJ r r! �consume_request_iterator s�
�
� �
�
� �� �� 2 � �z;_consume_request_iterator.<locals>.consume_request_iterator�r5 TN�r �ForkManagedThread� setDaemon�start)ro rJ rp rq rr r� �consumption_threadr r� r! �_consume_request_iterator s O�
r� )�
class_name� rpc_stater c C s� |j �� |jdu r*d�| �W d � S |jtjju rXt�| |j|j�W d � S t�| |j|j|j �W d � S W d � n1 s�0 Y dS )z Calculates error string for RPC.Nz <{} object>)
r( r- r% rD rE �OK�_OK_RENDEZVOUS_REPR_FORMATr$ � _NON_OK_RENDEZVOUS_REPR_FORMATr. )r� r� r r r! �_rpc_state_stringb s
��r� c @ sV e Zd ZU dZeed< ed�dd�Zee d�dd�Z ee d�d d
�Z
ee j d�d d �Z
ee d�d
d�Zee d�dd�Zed�dd�Zed�dd�Zed�dd�Zed�dd�Zed�dd�Zed�dd �Zed�d d �Zd*ee ed �d!d"�Zd+ee ee d �d#d$�Z d,ee ee j d �d%d&�Z d-e!e j"gd f ee d d'�d(d)�Z#d S ).�_InactiveRpcErrorz�An RPC error not tied to the execution of a particular RPC.
The RPC represented by the state object must not be in-progress or
cancelled.
Attributes:
_state: An instance of _RPCState.
�_stateru c C sv |j �\ tdt�|j�t�|j�|jt�|j��| _t�|j �| j_ t�|j
�| j_
W d � n1 sh0 Y d S rK ) r( r' �copy�deepcopyr* r, r- r$ r� r+ r. �r; rJ r r r! r< � s
�z_InactiveRpcError.__init__�r c C s | j jS r �r� r* r= r r r! r* � s z"_InactiveRpcError.initial_metadatac C s | j jS r �r� r, r= r r r! r, � s z#_InactiveRpcError.trailing_metadatac C s | j jS r �r� r- r= r r r! r- � s z_InactiveRpcError.codec C s t �| jj�S r )r �decoder� r$ r= r r r! r$ � s z_InactiveRpcError.detailsc C s t �| jj�S r )r r� r� r. r= r r r! r. � s z$_InactiveRpcError.debug_error_stringc C s t | jj| j�S r �r� � __class__r? r� r= r r r! �_repr� s z_InactiveRpcError._reprc C s | � � S r �r� r= r r r! �__repr__� s z_InactiveRpcError.__repr__c C s | � � S r r� r= r r r! �__str__� s z_InactiveRpcError.__str__c C s dS )zSee grpc.Future.cancel.Fr r= r r r! r~ � s z_InactiveRpcError.cancelc C s dS )zSee grpc.Future.cancelled.Fr r= r r r! r/ � s z_InactiveRpcError.cancelledc C s dS )zSee grpc.Future.running.Fr r= r r r! �running� s z_InactiveRpcError.runningc C s dS )zSee grpc.Future.done.Tr r= r r r! ri � s z_InactiveRpcError.doneNr c C s | �dS )zSee grpc.Future.result.Nr �r; r r r r! �result� s z_InactiveRpcError.resultc C s | S )zSee grpc.Future.exception.r r� r r r! r} � s z_InactiveRpcError.exceptionc C s. z| �W n t jy( t�� d Y S 0 dS )zSee grpc.Future.traceback.� N)rD �RpcError�sys�exc_infor� r r r! � traceback� s z_InactiveRpcError.traceback)�fnr r c C s || � dS )z"See grpc.Future.add_done_callback.Nr )r; r� r r r r! �add_done_callback� s z#_InactiveRpcError.add_done_callback)N)N)N)N)$r? r@ rA �__doc__r' rB r< r r r* r, rD rE r- rF r$ r. r� r� r� rG r~ r/ r� ri rI r r� rd r} �types�
TracebackTyper� r �Futurer� r r r r! r� t sH
�� �� �� ��r� c s e Zd ZU dZeed< eejej f ed< e
e ed< e
e ed< eeejej f e
e e
e d�� fdd� Z
ed �d
d �Ze
e d �d d
�Zed �dd�Zeed�dd�Zdd� Zdd� Zdd� Zdd� Ze
e d �dd �Zed �d d �Zed �d d �Zed �d!d"�Z d#d �d$d%�Z � Z S )&� _Rendezvousa� An RPC iterator.
Attributes:
_state: An instance of _RPCState.
_call: An instance of SegregatedCall or IntegratedCall.
In either case, the _call object is expected to have operate, cancel,
and next_event methods.
_response_deserializer: A callable taking bytes and return a Python
object.
_deadline: A float representing the deadline of the RPC in seconds. Or
possibly None, to represent an RPC with no deadline at all.
r� �_call�_response_deserializerr" )rJ rp rN �deadlinec s* t t| ��� || _|| _|| _|| _d S r )�superr� r< r� r� r� r" )r; rJ rp rN r� �r� r r! r< � s
z_Rendezvous.__init__r� c C s8 | j j� | j jdu W d � S 1 s*0 Y dS )z See grpc.RpcContext.is_activeN�r� r( r- r= r r r! � is_active� s
z_Rendezvous.is_activec C sh | j j�L | jdu r$W d � dS t| jt�� d�W d � S W d � n1 sZ0 Y dS )z"See grpc.RpcContext.time_remainingNr )r� r( r" �maxr r= r r r! �time_remaining� s
z_Rendezvous.time_remainingc C s� | j j�~ | j jdu rhtjj}d}| j�tj | |� d| j _
t | j ||� | j j� � W d � dS W d � dS W d � n1 s�0 Y dS )zSee grpc.RpcContext.cancelNz!Locally cancelled by application!TF)
r� r( r- rD rE � CANCELLEDr� r~ r r r/ rL rc )r; r- r$ r r r! r~ � s
� z_Rendezvous.cancel�rj r c C sf | j j�J | j jdu r&W d � dS | j j�|� W d � dS W d � n1 sX0 Y dS )z See grpc.RpcContext.add_callbackNFT)r� r( r0 �append�r; rj r r r! � add_callback s
z_Rendezvous.add_callbackc C s | S r r r= r r r! �__iter__ s z_Rendezvous.__iter__c C s | � � S r ��_nextr= r r r! ry s z_Rendezvous.nextc C s | � � S r r� r= r r r! �__next__ s z_Rendezvous.__next__c C s
t � �d S r ��NotImplementedErrorr= r r r! r� ! s z_Rendezvous._nextc C s
t � �d S r r� r= r r r! r. $ s z _Rendezvous.debug_error_stringc C s t | jj| j�S r r� r= r r r! r� ' s z_Rendezvous._reprc C s | � � S r r� r= r r r! r� * s z_Rendezvous.__repr__c C s | � � S r r� r= r r r! r� - s z_Rendezvous.__str__Nc C s| | j j�` | j jd u rZtjj| j _d| j _d| j _| j� t
j | j j | j j� | j j� � W d � n1 sn0 Y d S )Nz"Cancelled upon garbage collection!T)
r� r( r- rD rE r� r$ r/ r� r~ r r rc r= r r r! �__del__0 s
�z_Rendezvous.__del__) r? r@ rA r� r' rB r r �SegregatedCall�IntegratedCallr r rI r< rG r� r� r~ r r� r� ry r� r� rF r. r� r� r� r� �
__classcell__r r r� r! r� � s.
�
r� c @ sF e Zd ZU dZeed< ed�dd�Zed�dd�Zed�dd �Z ed�d
d �Z
d'e e e
d
�dd�Zd(e e e e d
�dd�Zd)e e e ej d
�dd�Zeejgd f d d�dd�Ze e d�dd�Ze e d�dd�Ze ej d�dd �Z e e d�d d �Z e e j d�d d �Z!e
d�d!d"�Z"e
d�d#d$�Z#e e d�d%d&�Z$d S )*�_SingleThreadedRendezvousaN An RPC iterator operating entirely on a single thread.
The __next__ method of _SingleThreadedRendezvous does not depend on the
existence of any other thread, including the "channel spin thread".
However, this means that its interface is entirely synchronous. So this
class cannot completely fulfill the grpc.Future interface. The result,
exception, and traceback methods will never block and will instead raise
an exception if calling the method would result in blocking.
This means that these methods are safe to call from add_done_callback
handlers.
r� r� c C s | j jd uS r r� r= r r r! � _is_completeO s z&_SingleThreadedRendezvous._is_completec C s4 | j j� | j jW d � S 1 s&0 Y d S r �r� r( r/ r= r r r! r/ R s
z#_SingleThreadedRendezvous.cancelledc C s8 | j j� | j jd u W d � S 1 s*0 Y d S r r� r= r r r! r� V s
z!_SingleThreadedRendezvous.runningc C s8 | j j� | j jd uW d � S 1 s*0 Y d S r r� r= r r r! ri Z s
z _SingleThreadedRendezvous.doneNr c C s~ ~| j j�` | �� s tj�d��| j jtjju rF| j j W d � S | j j
rXt� � �n| �W d � n1 sp0 Y dS )a9 Returns the result of the computation or raises its exception.
This method will never block. Instead, it will raise an exception
if calling this method would otherwise result in blocking.
Since this method will never block, any `timeout` argument passed will
be ignored.
zJ_SingleThreadedRendezvous only supports result() when the RPC is complete.N) r� r( r� rD � experimental�
UsageErrorr- rE r� r+ r/ �FutureCancelledErrorr� r r r! r� ^ s
�
z _SingleThreadedRendezvous.resultc C s� ~| j j�h | �� s tj�d��| j jtjju r@W d � dS | j j rRt�
� �n| W d � S W d � n1 sx0 Y dS )a* Return the exception raised by the computation.
This method will never block. Instead, it will raise an exception
if calling this method would otherwise result in blocking.
Since this method will never block, any `timeout` argument passed will
be ignored.
zM_SingleThreadedRendezvous only supports exception() when the RPC is complete.N) r� r( r� rD r� r� r- rE r� r/ r� r� r r r! r} u s
�
z#_SingleThreadedRendezvous.exceptionc C s� ~| j j�� | �� s tj�d��| j jtjju r@W d � dS | j j rRt�
� �n8z| �W n. tj y� t �
� d Y W d � S 0 W d � n1 s�0 Y dS )a; Access the traceback of the exception raised by the computation.
This method will never block. Instead, it will raise an exception
if calling this method would otherwise result in blocking.
Since this method will never block, any `timeout` argument passed will
be ignored.
zM_SingleThreadedRendezvous only supports traceback() when the RPC is complete.Nr� )r� r( r� rD r� r� r- rE r� r/ r� r� r� r� r� r r r! r� � s
�
z#_SingleThreadedRendezvous.traceback�r� r c C sf | j j�B | j jd u r<| j j�t�|| �� W d � d S W d � n1 sP0 Y || � d S r �r� r( r- r0 r� r� r� �r; r� r r r! r� � s
.z+_SingleThreadedRendezvous.add_done_callbackc C sJ | j j�. | j jdu r | �� q
| j jW d � S 1 s<0 Y dS )� See grpc.Call.initial_metadataN)r� r( r* �_consume_next_eventr= r r r! r* � s
z*_SingleThreadedRendezvous.initial_metadatac C sL | j j�0 | j jdu r"tj�d��| j jW d � S 1 s>0 Y dS )� See grpc.Call.trailing_metadataNz4Cannot get trailing metadata until RPC is completed.)r� r( r, rD r� r� r= r r r! r, � s
�z+_SingleThreadedRendezvous.trailing_metadatac C sL | j j�0 | j jdu r"tj�d��| j jW d � S 1 s>0 Y dS )�See grpc.Call.codeNz'Cannot get code until RPC is completed.)r� r( r- rD r� r� r= r r r! r- � s
�z _SingleThreadedRendezvous.codec C sR | j j�6 | j jdu r"tj�d��t�| j j�W d � S 1 sD0 Y dS )�See grpc.Call.detailsNz*Cannot get details until RPC is completed.)r� r( r$ rD r� r� r r� r= r r r! r$ � s
�z!_SingleThreadedRendezvous.detailsc C sV | j �� }| jj�0 t|| j| j�}|D ]
}|� q(W d � n1 sH0 Y |S r )r� �
next_eventr� r( rb r� )r; rM r0 rj r r r! r� � s
�&z-_SingleThreadedRendezvous._consume_next_eventc C s� | � � | jj�v | jjd ur@| jj}d | j_|W d � S tjj| jjvrx| jjt j
j u rht � �n| jjd urx| �W d � q 1 s�0 Y q d S r )
r� r� r( r+ r rC rS r) r- rD rE r� rz )r; r+ r r r! �_next_response� s
� z(_SingleThreadedRendezvous._next_responsec C s� | j j�x | j jd u rV| j j�tjj� | j� t�
t �fd �}|sr| j j� tjj� n | j jt
jju rnt� �n| �W d � n1 s�0 Y | �� S r )r� r( r- r) r� r rC rS r� r� �ReceiveMessageOperationr� rQ rD rE r� rz r� )r; r� r r r! r� � s
�"z _SingleThreadedRendezvous._nextc C sR | j j�6 | j jd u r"tj�d��t�| j j�W d � S 1 sD0 Y d S )Nz5Cannot get debug error string until RPC is completed.)r� r( r. rD r� r� r r� r= r r r! r.
s
�z,_SingleThreadedRendezvous.debug_error_string)N)N)N)%r? r@ rA r� r' rB rG r� r/ r� ri r rI r r� rd r} r� r� r� r rD r� r� r r* r, rE r- rF r$ r � BaseEventr� r� r� r. r r r r! r� = s,
�� r� c @ s$ e Zd ZU dZeed< ee d�dd�Zee d�dd�Z ee
j d�dd �Z ee
d�d
d �Zee
d�d d
�Zed�dd�Zed�dd�Zed�dd�Zed�dd�Zd#ee ed�dd�Zd$ee ee d�dd�Zd%ee eej d�d d �Z e e
j gdf dd �d d �Z ed�d!d"�Z dS )&�_MultiThreadedRendezvousa� An RPC iterator that depends on a channel spin thread.
This iterator relies upon a per-channel thread running in the background,
dequeueing events from the completion queue, and notifying threads waiting
on the threading.Condition object in the _RPCState object.
This extra thread allows _MultiThreadedRendezvous to fulfill the grpc.Future interface
and to mediate a bidirection streaming RPC.
r� r� c sR � j j�6 � fdd�}t�� j jj|� � j jW d � S 1 sD0 Y dS )r� c s � j jd uS r r� r r= r r! rv & s z8_MultiThreadedRendezvous.initial_metadata.<locals>._doneN)r� r( r r� r* �r; rv r r= r! r* " s
z)_MultiThreadedRendezvous.initial_metadatac sR � j j�6 � fdd�}t�� j jj|� � j jW d � S 1 sD0 Y dS )r� c s � j jd uS r r� r r= r r! rv 0 s z9_MultiThreadedRendezvous.trailing_metadata.<locals>._doneN)r� r( r r� r, r� r r= r! r, , s
z*_MultiThreadedRendezvous.trailing_metadatac sR � j j�6 � fdd�}t�� j jj|� � j jW d � S 1 sD0 Y dS )r� c s � j jd uS r r� r r= r r! rv : s z,_MultiThreadedRendezvous.code.<locals>._doneN)r� r( r r� r- r� r r= r! r- 6 s
z _MultiThreadedRendezvous.codec sX � j j�< � fdd�}t�� j jj|� t�� j j�W d � S 1 sJ0 Y dS )r� c s � j jd uS r )r� r$ r r= r r! rv D s z/_MultiThreadedRendezvous.details.<locals>._doneN)r� r( r r� r� r$ r� r r= r! r$ @ s
z _MultiThreadedRendezvous.detailsc sX � j j�< � fdd�}t�� j jj|� t�� j j�W d � S 1 sJ0 Y d S )Nc s � j jd uS r )r� r. r r= r r! rv M s z:_MultiThreadedRendezvous.debug_error_string.<locals>._done)r� r( r r� r� r. r� r r= r! r. J s
z+_MultiThreadedRendezvous.debug_error_stringc C s4 | j j� | j jW d � S 1 s&0 Y d S r r� r= r r r! r/ S s
z"_MultiThreadedRendezvous.cancelledc C s8 | j j� | j jd u W d � S 1 s*0 Y d S r r� r= r r r! r� W s
z _MultiThreadedRendezvous.runningc C s8 | j j� | j jd uW d � S 1 s*0 Y d S r r� r= r r r! ri [ s
z _MultiThreadedRendezvous.donec C s | j jd uS r r� r= r r r! r� _ s z%_MultiThreadedRendezvous._is_completeNr c C s� | j j�r tj| j jj| j|d�}|r0t�� �n<| j jtjj u rV| j j
W d � S | j j rht� � �n| �W d � n1 s�0 Y dS )z�Returns the result of the computation or raises its exception.
See grpc.Future.result for the full API contract.
r N)
r� r( r r� r� rD �FutureTimeoutErrorr- rE r� r+ r/ r� �r; r � timed_outr r r! r� b s
�
z _MultiThreadedRendezvous.resultc C s� | j j�z tj| j jj| j|d�}|r0t�� �nD| j jtjj u rPW d � dS | j j
rbt� � �n| W d � S W d � n1 s�0 Y dS )zvReturn the exception raised by the computation.
See grpc.Future.exception for the full API contract.
r N) r� r( r r� r� rD r� r- rE r� r/ r� r� r r r! r} u s
�
z"_MultiThreadedRendezvous.exceptionc C s� | j j�� tj| j jj| j|d�}|r0t�� �nj| j jtjj u rPW d � dS | j j
rbt� � �n8z| �W n. tj y� t
�� d Y W d � S 0 W d � n1 s�0 Y dS )z�Access the traceback of the exception raised by the computation.
See grpc.future.traceback for the full API contract.
r Nr� )r� r( r r� r� rD r� r- rE r� r/ r� r� r� r� r� r r r! r� � s
�
z"_MultiThreadedRendezvous.tracebackr� c C sf | j j�B | j jd u r<| j j�t�|| �� W d � d S W d � n1 sP0 Y || � d S r r� r� r r r! r� � s
.z*_MultiThreadedRendezvous.add_done_callbackc s. � j j�� � j jd u rft� j � j�}� j j�tjj � � j
� t� t
�f|�}|s�� j j�tjj � n � j jtjju r~t� �n� �� fdd�}t�� j jj|� � j jd urΈ j j}d � j _|W d � S tjj � j jv�r
� j jtjju r�t� �n� j jd u�r
� �W d � n1 �s 0 Y d S )Nc s( � j jd up&tjj� j jvo&� j jd uS r )r� r+ r rC rS r) r- r r= r r! �_response_ready� s
�z7_MultiThreadedRendezvous._next.<locals>._response_ready)r� r( r- rn r� r) r� r rC rS r� r� r� r� rQ rD rE r� rz r r� r+ )r; rr r� r� r+ r r= r! r� � s4 �
� z _MultiThreadedRendezvous._next)N)N)N)!r? r@ rA r� r' rB r r r* r, rD rE r- rF r$ r. rG r/ r� ri r� rI r r� rd r} r� r� r� r r� r� r� r r r r! r� s(
�� r� )r� r rq r c C sP t |�}t�| |�}|d u rBtdddtjjd�}t|�}|d |fS ||d fS d S )Nr rs )r" r r� r' rD rE rV r� )r� r rq r� r� rJ rf r r r! �_start_unary_request� s �
r� )rJ rp � with_callr� r c C s> | j tjju r2|r*t| |d |�}| j|fS | jS nt| ��d S r )r- rD rE r� r� r+ r� )rJ rp r� r� �
rendezvousr r r! � _end_unary_response_blocking� s
r� )�metadata�initial_metadata_flagsr c C s* t �| |�t �t�t �t�ft �t�ffS r )r � SendInitialMetadataOperationr� r� � ReceiveStatusOnClientOperation� ReceiveInitialMetadataOperation�r� r� r r r! �#_stream_unary_invocation_operations� s ��
�r� c C s t dd� t| |�D ��S )Nc s s | ]}|d fV qd S r r )�.0r� r r r! � <genexpr> s ��z?_stream_unary_invocation_operations_and_tags.<locals>.<genexpr>)�tupler� r� r r r! �,_stream_unary_invocation_operations_and_tags s
��r� )�
user_deadliner c C sR t �� }|d u r | d u r d S |d ur0| d u r0|S | d urD|d u rD| S t|| �S d S r )r �get_deadline_from_context�min)r� �parent_deadliner r r! �_determine_deadline s r c @ s� e Zd ZU ejed< eed< eed< eed< ee ed< ee
ed< e ed< ee ed< g d �Z
ejeeeee ee
ee d
�d d �Ze ee ee ee eej eee eeej ee eej f d
�dd�Zde ee ee eej ee eej eeejf d�dd�Z de ee ee eej ee eej e d�dd�Z d e ee ee eej ee eej ee ej f d�dd�Z d e ee ee eej ee eej e d�dd�Z!dS ) �_UnaryUnaryMultiCallable�_channel�
_managed_call�_method�_target�_request_serializerr� �_context�_registered_call_handle�r r r r r r� r ��channel� managed_callr4 r5 rq rN r c C s8 || _ || _|| _|| _|| _|| _t�� | _|| _ d S r �
r r r r r r� r �build_census_contextr r �r; r r
r4 r5 rq rN r r r r! r< / s
z!_UnaryUnaryMultiCallable.__init__)r� r r� �wait_for_ready� compressionr c
C s� t ||| j�\}}}t� �|�} t�||�}
|d u r@d d d |fS ttd d d d �} t� |
| �t�
|t �t� t �t�
t �t�t �t�t �f} | | |d fS d S r )r� r �_InitialMetadataFlags�with_wait_for_readyr
�augment_metadatar' �_UNARY_UNARY_INITIAL_DUEr r� r� r� r� r� r� r� )
r; r� r r� r r r� r� r� r� �augmented_metadatarJ r� r r r! �_prepareB s,
�
�� �
�
z!_UnaryUnaryMultiCallable._prepareN�r� r r� � credentialsr r r c
C s� | � |||||�\}}} }
|d u r(|
�n�t�� |_t�| j�|_t�| j�|_ | j
� t j
j| jd t| �||d u rtd n|j|d ff| j| j� } | �� } t| || j� || fS d S r )r r r\ r2 r r� r r4 r r5 r �segregated_callr �PropagationConstants�GRPC_PROPAGATE_DEFAULTSr � _credentialsr r r� rb r� )
r; r� r r� r r r rJ r� r� r� rp rM r r r! � _blockingh s2
�
���z"_UnaryUnaryMultiCallable._blockingc C s& | � ||||||�\}}t||dd �S r6 �r r� � r; r� r r� r r r rJ rp r r r! �__call__� s ��z!_UnaryUnaryMultiCallable.__call__c C s& | � ||||||�\}}t||dd �S �NTr r! r r r! r� � s ��z"_UnaryUnaryMultiCallable.with_callc
C s� | � |||||�\}}} }
|d u r(|
�nxt|| j�} t�� |_t�| j�|_ t�| j
�|_ | � t
jj| jd | ||d u rzd n|j|f| | j| j�
} t|| | j| �S d S r )r rn r� r r\ r2 r r� r r4 r r5 r r r r r r r r� )
r; r� r r� r r r rJ r� r� r� rr rp r r r! �future� s0
�
�
�z _UnaryUnaryMultiCallable.future)NNNNN)NNNNN)NNNNN)NNNNN)"r? r@ rA r �ChannelrB r �bytesr r r r rH � __slots__r< rI r rG rD � Compressionr
r' r � Operationr� r �CallCredentialsr� r r" �Callr� r� r$ r r r r! r s�
� ��� ) � � ) �� � � ��r c @ s� e Zd ZU ejed< eed< eed< ee ed< ee ed< e
ed< ee ed< g d�Z ejeeee ee d �d
d �Z
de
ee ee eej ee eej ed
�dd�Zd S )�'_SingleThreadedUnaryStreamMultiCallabler r r r r� r r )r r r r r� r )r r4 r5 rq rN r c C s2 || _ || _|| _|| _|| _t�� | _|| _d S r ) r r r r r� r r r r )r; r r4 r5 rq rN r r r r! r< � s
z0_SingleThreadedUnaryStreamMultiCallable.__init__Nr c C s t |�}t�|| j�}|d u r:tdddtjjd�} t| ��tt d d d d �} |d u rVd n|j
}
t � � |�} t
�||�} t�| | �t�|t�t�t�ft�t�ft�t�ff}
tdd� |
D ��}t�� | _t�| j�| _ t�| j �| _ | j � tj!j"| jd t#|�||
|| j$| j%� }t&| || j'|�S )Nr rs c s s | ]}|d fV qd S r r )r� �opsr r r! r� $ � zC_SingleThreadedUnaryStreamMultiCallable.__call__.<locals>.<genexpr>)(r" r r� r r' rD rE rV r� �_UNARY_STREAM_INITIAL_DUEr r r r
r r r� r� r� r� r� r� r� r r\ r2 r� r r4 r r5 r r r r r r r r� r� )r; r� r r� r r r r� r� rJ �call_credentialsr� r r� �operations_and_tagsrp r r r! r" � sb ������
�
�
�
�z0_SingleThreadedUnaryStreamMultiCallable.__call__)NNNNN)r? r@ rA r r% rB r& r r r r rH r' r< rI r rD r* rG r( r� r" r r r r! r, � s:
� ��r, c @ s� e Zd ZU ejed< eed< eed< eed< ee ed< ee
ed< e ed< ee ed< g d �Z
ejeeee e
ee d
�d d �Zde ee ee eej ee eej ed�dd�Zd
S )�_UnaryStreamMultiCallabler r r r r r� r r r
r c C s8 || _ || _|| _|| _|| _|| _t�� | _|| _ d S r r r r r r! r< M s
z"_UnaryStreamMultiCallable.__init__Nr c C s� t ||| j�\}}} t� �|�}
|d u r.| �n�t�||�} ttd d d d �} t� | |
�t�
|t �t� t �t�
t �ft�t �ff}
t�� | _t�| j�| _t�| j�| _| �tjj| jd t|�||d u r�d n|j |
t | | j �| j | j �
}t!| || j |�S d S r )"r� r r r r
r r' r/ r r� r� r� r� r� r� r r\ r2 r r� r r4 r r5 r r r r r rn r� r r r� )r; r� r r� r r r r� r� r� r� r rJ r� rp r r r! r" ` sR �
�����
�
�
�z"_UnaryStreamMultiCallable.__call__)NNNNN)r? r@ rA r r% rB r r& r r r r rH r' r< rI r rD r* rG r( r� r" r r r r! r2 8 s>
� ��r2 c
@ sn e Zd ZU ejed< eed< eed< eed< ee ed< ee
ed< e ed< ee ed< g d �Z
ejeeeee ee
ee d
�d d �Zeee ee eej ee eej eeejf d
�dd�Zdeee ee eej ee eej e d
�dd�Zdeee ee eej ee eej ee ejf d
�dd�Z deee ee eej ee eej e d
�dd�Z dS )�_StreamUnaryMultiCallabler r r r r r� r r r
r c C s8 || _ || _|| _|| _|| _|| _t�� | _|| _ d S r r r r r r! r< � s
z"_StreamUnaryMultiCallable.__init__�ro r r� r r r r c
C s t |�}ttd d d d �}t� �|�} t�||�}
t�� |_ t
� | j �|_
t
� | j�|_| j�tjj| j d t|�|
|d u r|d n|jt|
| �| j| j� } t||| | jd � | � � } |j �> t | || j � |j � � |j!s�W d � �qW d � q�1 s�0 Y q�|| fS r )"r" r' �_STREAM_UNARY_INITIAL_DUEr r r
r r r\ r2 r r� r r4 r r5 r r r r r r r r� r r r� r r� r( rb r� rc r) )
r; ro r r� r r r r� rJ r� r rp rM r r r! r � sD ��
��
�
0z#_StreamUnaryMultiCallable._blockingNc C s& | � ||||||�\}}t||dd �S r6 r � r; ro r r� r r r rJ rp r r r! r" � s �� z"_StreamUnaryMultiCallable.__call__c C s& | � ||||||�\}}t||dd �S r# r r6 r r r! r� s �� z#_StreamUnaryMultiCallable.with_callc
C s� t |�}ttd d d d �}t|| j�} t� �|�}
t�||�} t �
� |_ t �
| j�|_t �
| j�|_| �tjj| jd || |d u r�d n|jt||
�| | j| j�
} t||| | j| � t || | j|�S r ) r" r' r5 rn r� r r r
r r r\ r2 r r� r r4 r r5 r r r r r r� r r r� r r� )
r; ro r r� r r r r� rJ rr r� r rp r r r! r$ sH ��
���
�z _StreamUnaryMultiCallable.future)NNNNN)NNNNN)NNNNN) r? r@ rA r r% rB r r& r r r r rH r' r< r rI r rD r* rG r( r
r' r� r r" r+ r� r� r$ r r r r! r3 � s�
� � 0 �� � � ��r3 c @ s� e Zd ZU ejed< eed< eed< eed< ee ed< ee
ed< e ed< ee ed< g d �Z
ejeeeee ee
ee d
�d d �Zdeee ee eej ee eej ed�dd�Zd
S )�_StreamStreamMultiCallabler r r r r r� r r r
r c C s8 || _ || _|| _|| _|| _|| _t�� | _|| _ d S r r r r r r! r< \ s
z#_StreamStreamMultiCallable.__init__Nr4 c C s� t |�}ttd d d d �}t� �|�} t�||�}
t�|
| �t� t
�ft� t
�ff} t || j
�} t�� |_t�| j�|_t�| j�|_| �tjj| jd t|�|
|d u r�d n|j| | | j | j �
}
t |||
| j | � t ||
| j
|�S r )!r" r' �_STREAM_STREAM_INITIAL_DUEr r r
r r r� r� r� r� rn r� r r\ r2 r r� r r4 r r5 r r r r r r r r� r r� )r; ro r r� r r r r� rJ r� r r� rr rp r r r! r" o sR ����
�
� �
�z#_StreamStreamMultiCallable.__call__)NNNNN)r? r@ rA r r% rB r r& r r r r rH r' r< r rI r rD r* rG r( r� r" r r r r! r7 G s>
� ��r7 c s> e Zd ZdZefed�� fdd�
Zee ed�dd�Z � Z
S )r z'Stores immutable initial metadata flags)�valuec s |t jjM }tt| ��| |�S r )r �InitialMetadataFlags� used_maskr� r �__new__)�clsr9 r� r r! r< � s z _InitialMetadataFlags.__new__)r r c C sJ |d urF|r&| � | tjjB tjjB �S |sF| � | tjj @ tjjB �S | S r )r� r r: r � wait_for_ready_explicitly_set)r; r r r r! r � s ��� ��z)_InitialMetadataFlags.with_wait_for_ready) r? r@ rA r� r� rH r< r rG r r� r r r� r! r � s r c @ sN e Zd ZU ejed< eed< eed< ejd�dd�Zdd�d d
�Z d d � Z
dS )
�_ChannelCallStater �
managed_callsr7 �r c C s t �� | _|| _d| _d| _ d S )Nr F)r7 �Lock�lockr r@ �r; r r r r! r< � s
z_ChannelCallState.__init__Nr� c C s
d| _ d S )Nr )r@ r= r r r! r> � s z&_ChannelCallState.reset_postfork_childc C s2 z| j �tjjd� W n ttfy, Y n0 d S )NzChannel deallocated!)r �closer rE r/ � TypeError�AttributeErrorr= r r r! r� � s �z_ChannelCallState.__del__) r? r@ rA r r% rB rH rG r< r> r� r r r r! r? � s
r? )rJ r c s. � fdd�}t j|d�}|�d� |�� d S )Nc s� t �� � � j�� } | jt jjkr$q | �| �}|r � j�8 � j d8 _ � j dkrbW d � d S W d � q 1 sv0 Y q d S )N� r )
r r� r �next_call_event�completion_type�CompletionType�
queue_timeout�tagrC r@ )rM �call_completedru r r! � channel_spin� s
z._run_channel_spin_thread.<locals>.channel_spinr� Tr� )rJ rO �channel_spin_threadr ru r! �_run_channel_spin_thread� s
rQ ru c sL t ttt tt tt ttj tttj t
t tt tj d� � fdd� }|S )N) �flagsr4 �hostr� r� r r� rr �contextr r c
s� t � fdd�|D ��}
�j�X �j�| ||||||
|| � } �jdkrTd�_t�� n� jd7 _| W d � S 1 sz0 Y dS )a� Creates a cygrpc.IntegratedCall.
Args:
flags: An integer bitfield of call flags.
method: The RPC method.
host: A host string for the created call.
deadline: A float to be the deadline of the created call or None if
the call is to have an infinite deadline.
metadata: The metadata for the call or None.
credentials: A cygrpc.CallCredentials or None.
operations: A sequence of sequences of cygrpc.Operations to be
started on the call.
event_handler: A behavior to call to handle the events resultant from
the operations on the call.
context: Context object for distributed tracing.
_registered_call_handle: An int representing the call handle of the
method, or None if the method is not registered.
Returns:
A cygrpc.IntegratedCall with which to conduct an RPC.
c 3 s | ]}|� fV qd S r r )r� � operation�rr r r! r� s ��zC_channel_managed_call_management.<locals>.create.<locals>.<genexpr>r rH N)r� rC r �integrated_callr@ rQ ) rR r4 rS r� r� r r� rr rT r r1 rp ru rV r! �create� s( ��
z0_channel_managed_call_management.<locals>.create)
rH r& r rF rI r r r* r r) r r r� )rJ rX r ru r! � _channel_managed_call_management� s �:rY c @ s� e Zd ZU ejed< ejed< eed< ej ed< eed< e
e e e
ej gdf eej f ed< eed< ejd �d
d �Zdd �d
d�ZdS )�_ChannelConnectivityStaterC r �polling� connectivity�try_to_connectN� callbacks_and_connectivities�
deliveringrA c C s2 t �� | _|| _d| _d | _d| _g | _d| _d S r6 ) r7 �RLockrC r r[ r\ r] r^ r_ rD r r r! r< 6 s
z"_ChannelConnectivityState.__init__r� c C s" d| _ d | _d| _g | _d| _d S r6 )r[ r\ r] r^ r_ r= r r r! r> ? s
z._ChannelConnectivityState.reset_postfork_child)r? r@ rA r7 r` rB rD r% rG �ChannelConnectivityr r r r r r< r> r r r r! rZ % s"
���� rZ c C s: g }| j D ]*}|\}}|| jur
|�|� | j|d< q
|S )NrH )r^ r\ r� )rJ �callbacks_needing_update�callback_and_connectivityrj �callback_connectivityr r r! � _deliveriesG s
�
re )rJ �initial_connectivity�initial_callbacksr c C s� |}|}|D ]8}t �| � z ||� W q tyB t�t� Y q 0 q | j�: t| �}|rb| j}nd| _ W d � d S W d � q1 s�0 Y qd S r6 )
r r� rd r| r} �0_CHANNEL_SUBSCRIPTION_CALLBACK_ERROR_LOG_MESSAGErC re r\ r_ )rJ rf rg r\ r0 rj r r r! �_deliverV s
� ri )rJ r0 r c C s2 t jt| | j|fd�}|�d� |�� d| _d S �N)r5 �argsT)r r� ri r\ r� r� r_ )rJ r0 �delivering_threadr r r! �_spawn_deliveryo s ��
rm )rJ r �initial_try_to_connectr c C s^ |}|� |�}| j�T tj| | _tdd� | jD ��}| jD ]}| j|d< q<|rZt| |� W d � n1 sn0 Y |�|t � � d �}t
� | � | j�D | js�| j s�d| _
d | _W d � �qZ| j }d| _ W d � n1 s�0 Y |js�|rx|� |�}| j�< tj| | _| j�s8t| �}|�r8t| |� W d � qx1 �sN0 Y qxd S )Nc s s | ]\}}|V qd S r r )r� rj �_r r r! r� � s z%_poll_connectivity.<locals>.<genexpr>rH g�������?F)�check_connectivity_staterC r �1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITYr\ r� r^ rm �watch_connectivity_stater r r� r] r[ �successr_ re )rJ r rn r] r\ r0 rc rM r r r! �_poll_connectivity� sN
���
( �
��$
��rt )rJ rj r] r c C s� | j �� | jsX| jsXtjt| | jt|�fd�}|�d� |� � d| _| j�
|d g� nd| j s�| j d ur�t
| |f� | jt|�O _| j�
|| j g� n"| jt|�O _| j�
|d g� W d � n1 s�0 Y d S rj )rC r^ r[ r r� rt r rG r� r� r� r_ r\ rm r] )rJ rj r] �polling_threadr r r! �
_subscribe� s$ �
�rv )rJ rj r c C sZ | j �@ t| j�D ]$\}\}}||kr| j�|� q8qW d � n1 sL0 Y d S r )rC � enumerater^ �pop)rJ rj �index�subscribed_callback�unused_connectivityr r r! � _unsubscribe� s � r| )� base_optionsr r c C s$ t �|�}t| �| tjjtff S r )r
�create_channel_optionr� r �
ChannelArgKey�primary_user_agent_string� _USER_AGENT)r} r �compression_optionr r r! �_augment_options� s
�����r� )�optionsr c C sB g }g }| D ],}|d t jjjkr.|�|� q |�|� q ||fS )z;Separates core channel options from Python channel options.r )rD r� �ChannelOptions�SingleThreadedUnaryStreamr� )r� � core_options�python_options�pairr r r! �_separate_channel_options� s �� r� c @ s� e Zd ZU dZeed< ejed< eed< e ed< e
ed< e e
e f ed< e
e
e eej eej d�d d
�Ze
e d �d d
�Ze
e dd�dd�Zd1eejgdf ee dd�dd�Zeejgdf dd�dd�Zd2e
ee ee ee ej d�dd�Z d3e
ee ee ee ej d�d d �Z d4e
ee ee ee ej d�d d �Z!d5e
ee ee ee ej"d�d d!�Z#dd"�d#d$�Z$dd"�d%d&�Z%dd"�d'd(�Z&d)d*� Z'd+d,� Z(dd"�d-d.�Z)d/d0� Z*dS )6r% z7A cygrpc.Channel-backed implementation of grpc.Channel.� _single_threaded_unary_streamr � _call_state�_connectivity_stater �_registered_call_handles)r5 r� r r c C sr t |�\}}t| _| �|� t�t�|�t||�|�| _ || _
t | j �| _ t
| j �| _t�| � tjrnt�� dS )aP Constructor.
Args:
target: The target to which to connect.
options: Configuration options for the channel.
credentials: A cygrpc.ChannelCredentials or None.
compression: An optional value indicating the compression method to be
used over the lifetime of the channel.
N)r� �%_DEFAULT_SINGLE_THREADED_UNARY_STREAMr� �_process_python_optionsr r% r �encoder� r r r? r� rZ r� �fork_register_channel�g_gevent_activated� gevent_increment_channel_count)r; r5 r� r r r� r� r r r! r< s �
�
zChannel.__init__)r4 r c C s | j �t�|��S )ah
Get the registered call handle for a method.
This is a semi-private method. It is intended for use only by gRPC generated code.
This method is not thread-safe.
Args:
method: Required, the method name for the RPC.
Returns:
The registered call handle pointer in the form of a Python Long.
)r �get_registered_call_handler r� )r; r4 r r r! �_get_registered_call_handle& s z#Channel._get_registered_call_handleN)r� r c C s& |D ] }|d t jjjkrd| _qdS )zASets channel attributes according to python-only channel options.r TN)rD r� r� r� r� )r; r� r� r r r! r� 6 s ��z Channel._process_python_options)rj r] r c C s t | j||� d S r )rv r� )r; rj r] r r r! � subscribeA s zChannel.subscriber� c C s t | j|� d S r )r| r� r� r r r! � unsubscribeH s zChannel.unsubscribeF)r4 rq rN �_registered_methodr c C s< d }|r| � |�}t| jt| j�t�|�t�| j�|||�S r )r� r r rY r� r r� r �r; r4 rq rN r� r r r r! � unary_unaryN s
�zChannel.unary_unaryc C sh d }|r| � |�}| jr:t| jt�|�t�| j�|||�S t| jt| j �t�|�t�| j�|||�S d S r )
r� r� r, r r r� r r2 rY r� r� r r r! � unary_streamc s*
�
�zChannel.unary_streamc C s< d }|r| � |�}t| jt| j�t�|�t�| j�|||�S r )r� r3 r rY r� r r� r r� r r r! � stream_unary� s
�zChannel.stream_unaryc C s< d }|r| � |�}t| jt| j�t�|�t�| j�|||�S r )r� r7 r rY r� r r� r r� r r r! �
stream_stream� s
�zChannel.stream_streamr� c C s@ | j }|r<|j� |jd d �= W d � n1 s20 Y d S r )r� rC r^ r� r r r! �_unsubscribe_all� s zChannel._unsubscribe_allc C s6 | � � | j�tjjd� t�| � tjr2t�� d S )NzChannel closed!) r� r rE r rE r/ �fork_unregister_channelr� � gevent_decrement_channel_countr= r r r! �_close� s
zChannel._closec C s | � � | j�tjjd� d S )NzChannel closed due to fork)r� r �
close_on_forkr rE r/ r= r r r! �_close_on_fork� s �zChannel._close_on_forkc C s | S r r r= r r r! � __enter__� s zChannel.__enter__c C s | � � dS r6 �r� )r; �exc_type�exc_val�exc_tbr r r! �__exit__� s zChannel.__exit__c C s | � � d S r r� r= r r r! rE � s z
Channel.closec C s z | � � W n Y n0 d S r )r� r= r r r! r� � s
zChannel.__del__)N)NNF)NNF)NNF)NNF)+r? r@ rA r� rG rB r r% r? rZ rF r rH r r r rD �ChannelCredentialsr( r< r� r� r ra r� r� r r �UnaryUnaryMultiCallabler� �UnaryStreamMultiCallabler� �StreamUnaryMultiCallabler� �StreamStreamMultiCallabler� r� r� r� r� r� rE r� r r r r! r% � s�
� !� �� � �� �� & �� �� r% )ur� r� r� re �osr� r7 r r� �typingr r r r r r r r r
r rD r r
r r � grpc._cythonr � grpc._typingr r r r r r r r �grpc.experimental� getLoggerr? r| r% � __version__r� r� �getenvr� rC �send_initial_metadatart r� rR rS rW r r/ r5 r8 rh r� r� rI r" rE rF r& �objectr' rL r� rb rn r� r� r� r� r� r+ r� r� �
RpcContextr� r� r� r& r� rG r� rH r) r� r� r r� r r� r, r2 r� r3 r� r7 r r? rQ rY rZ ra re ri rm r% rt rv r| r( r� r� r r r r! �<module> s2 0
�� ������ � =
� -� � _^k
� W
� ;� � � � ;d_ 1^?#� � � � 2� � � �