| 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/aio/ |
Upload File : |
a
K��fSU � @ s� d Z ddlZddlZddlmZmZmZmZmZ ddl Z ddl m
Z
ddl m Z ddl m Z ddl
mZ dd lmZ dd
lmZ dd lmZ dd lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddlm Z ddl!m"Z" ddl#m$Z$ ddl#m%Z% ddl#m&Z& dd l#m'Z' dd l#m(Z( dd l#m)Z) dd l#m*Z* dd l+m,Z, d!�-e j.�Z/ej0d d"k �r�eej1 d#�d$d%�Z2neej1 d#�d&d%�Z2e$ee j3 d'�d(d)�Z4G d*d+� d+�Z5G d,d-� d-e5ej6�Z6G d.d/� d/e5ej7�Z7G d0d1� d1e5ej8�Z8G d2d3� d3e5ej9�Z9G d4d5� d5ej:�Z:d<e;ee$ ee j3 eee d6�d7d8�Z<d=e;e j=ee$ ee j3 eee d9�d:d;�Z>dS )>z6Invocation-side implementation of gRPC Asyncio Python.� N)�Any�Iterable�List�Optional�Sequence)�_common)� _compression)�_grpcio_metadata)�cygrpc� )�
_base_call)�
_base_channel)�StreamStreamCall)�StreamUnaryCall)�UnaryStreamCall)�UnaryUnaryCall)�ClientInterceptor)�InterceptedStreamStreamCall)�InterceptedStreamUnaryCall)�InterceptedUnaryStreamCall)�InterceptedUnaryUnaryCall)� StreamStreamClientInterceptor)� StreamUnaryClientInterceptor)� UnaryStreamClientInterceptor)�UnaryUnaryClientInterceptor)�Metadata)�ChannelArgumentType)�DeserializingFunction)� MetadataType)�RequestIterableType)� RequestType)� ResponseType)�SerializingFunction)�_timeout_to_deadlinezgrpc-python-asyncio/{}� ��returnc C s
t j�� S �N)�asyncio�Task� all_tasks� r+ r+ �u/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/aio/_channel.py�
_all_tasks7 s r- c C s t �� S r' )r( r* r+ r+ r+ r, r- < s )� base_options� compressionc C s( t �|�}tjjtff}t| �| | S r' )r �create_channel_optionr
�
ChannelArgKey�primary_user_agent_string� _USER_AGENT�tuple)r. r/ � compression_channel_argument�user_agent_channel_argumentr+ r+ r, �_augment_channel_arguments@ s ������r7 c @ s� e Zd ZU dZejed< ejed< e ed< e
ed< e ed< e e
e ed< ee ed< ejed< eje e
e e e
e ee ejd d
�d d �Zede e e ej ed
�dd��Zd S )�_BaseMultiCallablezrBase class of all multi callable objects.
Handles the initialization logic and stores common attributes.
�_loop�_channel�_method�_request_serializer�_response_deserializer�
_interceptors� _referencesN)�channel�method�request_serializer�response_deserializer� interceptors�
references�loopr& c C s. || _ || _|| _|| _|| _|| _|| _d S r' )r9 r: r; r< r= r> r? )�selfr@ rA rB rC rD rE rF r+ r+ r, �__init__c s
z_BaseMultiCallable.__init__)�metadatar/ r& c C s@ | pt � } t| t �s(t| t�r(t �| �} |r<t t�| |�� } | S )z�Based on the provided values for <metadata> or <compression> initialise the final
metadata, as it should be used for the current call.
)r �
isinstancer4 �
from_tupler �augment_metadata)rI r/ r+ r+ r, �_init_metadatau s
�z!_BaseMultiCallable._init_metadata)NN)�__name__�
__module__� __qualname__�__doc__r( �AbstractEventLoop�__annotations__r
�
AioChannel�bytesr" r r r r r r rH � staticmethodr �grpc� Compressionr rM r+ r+ r+ r, r8 S s4
� ��r8 c
@ sV e Zd Zdddddd�eee ee eej ee eej
e j ee
f d�dd�ZdS )�UnaryUnaryMultiCallableN��timeoutrI � credentials�wait_for_readyr/ ��requestr[ rI r\ r] r/ r& c C sh | � ||�}| js<t|t|�|||| j| j| j| j| j�
}n(t | j|||||| j| j| j| j| j� }|S r' )
rM r> r r# r: r; r< r= r9 r �rG r_ r[ rI r\ r] r/ �callr+ r+ r, �__call__� s8
�
�z UnaryUnaryMultiCallable.__call__)rN rO rP r r �floatr rW �CallCredentials�boolrX r r r! rb r+ r+ r+ r, rY � s � �rY c
@ sV e Zd Zdddddd�eee ee eej ee eej
e j ee
f d�dd�ZdS )�UnaryStreamMultiCallableNrZ r^ c C sh | � ||�}| js<t|t|�|||| j| j| j| j| j�
}n(t | j|||||| j| j| j| j| j� }|S r' )
rM r> r r# r: r; r< r= r9 r r` r+ r+ r, rb � s8
�
�z!UnaryStreamMultiCallable.__call__)rN rO rP r r rc r rW rd re rX r r r! rb r+ r+ r+ r, rf � s � �rf c @ sF e Zd Zdee ee ee eej ee eej
e j d�dd�Z
dS )�StreamUnaryMultiCallableN��request_iteratorr[ rI r\ r] r/ r& c C sh | � ||�}| js<t|t|�|||| j| j| j| j| j�
}n(t | j|||||| j| j| j| j| j� }|S r' )
rM r> r r# r: r; r< r= r9 r �rG ri r[ rI r\ r] r/ ra r+ r+ r, rb � s8 �
�z!StreamUnaryMultiCallable.__call__)NNNNNN)rN rO rP r r rc r rW rd re rX r r rb r+ r+ r+ r, rg � s ��rg c @ sF e Zd Zdee ee ee eej ee eej
e j d�dd�Z
dS )�StreamStreamMultiCallableNrh c C sh | � ||�}| js<t|t|�|||| j| j| j| j| j�
}n(t | j|||||| j| j| j| j| j� }|S r' )
rM r> r r# r: r; r< r= r9 r rj r+ r+ r, rb s8 �
�z"StreamStreamMultiCallable.__call__)NNNNNN)rN rO rP r r rc r rW rd re rX r r rb r+ r+ r+ r, rk s ��rk c @ s� e Zd ZU ejed< ejed< ee ed< ee
ed< ee ed< ee ed< e
eeej eej eee d�dd �Zd
d � Zd d
� Zdd� Zd,ee d�dd�Zdd� Zd-e ej d�dd�Z ej dd�dd �Z dd �d d �Z e
e!d �d!d"�Z"d.e
ee# ee$ ee e%d#�d$d%�Z&d/e
ee# ee$ ee e'd#�d&d'�Z(d0e
ee# ee$ ee e)d#�d(d)�Z*d1e
ee# ee$ ee e+d#�d*d+�Z,dS )2�Channelr9 r: �_unary_unary_interceptors�_unary_stream_interceptors�_stream_unary_interceptors�_stream_stream_interceptors)�target�optionsr\ r/ rD c C s� g | _ g | _g | _g | _|dur�|D ]�}t|t�r@| j �|� q$t|t�rX| j�|� q$t|t�rp| j�|� q$t|t �r�| j�|� q$t
d� |�d� tj � d� tj � d� tj � d� t j � ��q$t
�� | _t
�t�|�t||�|| j�| _dS )a� 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.
interceptors: An optional list of interceptors that would be used for
intercepting any RPC executed with that channel.
NzInterceptor {} must be z{} or z{}. )rm rn ro rp rJ r �appendr r r �
ValueError�formatrN r
�get_working_loopr9 rT r �encoder7 r: )rG rq rr r\ r/ rD � interceptorr+ r+ r, rH D s@
�
�
�
��
�zChannel.__init__c � s | S r' r+ �rG r+ r+ r, �
__aenter__w s zChannel.__aenter__c � s | � d �I d H d S r' ��_close)rG �exc_type�exc_val�exc_tbr+ r+ r, � __aexit__z s zChannel.__aexit__c � sH | j �� rd S | j �� t� }g }g }|D ]�}z|jdd�}W n@ ty~ } z(dt|�v rhW Y d }~q*n� W Y d }~n
d }~0 0 |s�q*|d }|j�d�} | r*t | t
j �r*t | d�r�| j | j ur�q*n,t | d�r�| j
j | j ur�q*nt�d| � ���|�| � |�|� q*|�r&|�r&tj||d �I d H |D ]}
|
�� �q*| j �� d S )
Nr )�limit�framer rG r: � _cython_callzUnrecognized call object: )r[ )r: �closed�closingr- � get_stack�AttributeError�str�f_locals�getrJ r �Call�hasattrr� r
�
InternalErrorrs r( �wait�cancel�close) rG �grace�tasks�calls�
call_tasks�task�stack�attribute_errorr� � candidatera r+ r+ r, r| } sF
�
zChannel._closeN)r� c � s | � |�I d H d S r' r{ )rG r� r+ r+ r, r� � s z
Channel.closec C s" t | d�r | j�� s | j�� d S )Nr: )r� r: r� r� ry r+ r+ r, �__del__� s
zChannel.__del__F)�try_to_connectr& c C s | j �|�}tj| S r' )r: �check_connectivity_stater �1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY)rG r� �resultr+ r+ r, � get_state� s zChannel.get_state)�last_observed_stater& c � s" | j �|jd d �I d H s J �d S )Nr )r: �watch_connectivity_state�value)rG r� r+ r+ r, �wait_for_state_change� s
�z Channel.wait_for_state_changer% c � s: | j dd�}|tjjkr6| �|�I d H | j dd�}q d S )NT)r� )r� rW �ChannelConnectivity�READYr� )rG �stater+ r+ r, �
channel_ready� s zChannel.channel_ready)rA r& c C s d S r' r+ )rG rA r+ r+ r, �_get_registered_call_handle� s z#Channel._get_registered_call_handle)rA rB rC �_registered_methodr& c C s" t | jt�|�||| j| g| j�S r' )rY r: r rw rm r9 �rG rA rB rC r� r+ r+ r, � unary_unary� s �zChannel.unary_unaryc C s" t | jt�|�||| j| g| j�S r' )rf r: r rw rn r9 r� r+ r+ r, � unary_stream� s �zChannel.unary_streamc C s" t | jt�|�||| j| g| j�S r' )rg r: r rw ro r9 r� r+ r+ r, � stream_unary s �zChannel.stream_unaryc C s" t | jt�|�||| j| g| j�S r' )rk r: r rw rp r9 r� r+ r+ r, �
stream_stream% s �zChannel.stream_stream)N)F)NNF)NNF)NNF)NNF)-rN rO rP r( rR rS r
rT r r r r r r� r r rW �ChannelCredentialsrX r r rH rz r� r| rc r� r� re r� r� r� r� �intr� r" r rY r� rf r� rg r� rk r� r+ r+ r+ r, rl < s�
� 3H �� � �� �� �� ��rl �rq rr r/ rD c C s t | |du rdn|d||�S )a Creates an insecure asynchronous Channel to a server.
Args:
target: The server address
options: An optional list of key-value pairs (:term:`channel_arguments`
in gRPC Core runtime) to configure the channel.
compression: An optional value indicating the compression method to be
used over the lifetime of the channel.
interceptors: An optional sequence of interceptors that will be executed for
any call executed with this channel.
Returns:
A Channel.
Nr+ )rl r� r+ r+ r, �insecure_channel7 s �r� �rq r\ rr r/ rD c C s t | |du rdn||j||�S )a< Creates a secure asynchronous Channel to a server.
Args:
target: The server address.
credentials: A ChannelCredentials instance.
options: An optional list of key-value pairs (:term:`channel_arguments`
in gRPC Core runtime) to configure the channel.
compression: An optional value indicating the compression method to be
used over the lifetime of the channel.
interceptors: An optional sequence of interceptors that will be executed for
any call executed with this channel.
Returns:
An aio.Channel.
Nr+ )rl � _credentialsr� r+ r+ r, �secure_channelT s �r� )NNN)NNN)?rQ r( �sys�typingr r r r r rW r r r � grpc._cythonr
� r r
�_callr r r r � _interceptorr r r r r r r r r � _metadatar �_typingr r r r r r! r" �_utilsr# ru � __version__r3 � version_infor) r- rX r7 r8 rY rf rg rk rl r� r� r� r� r+ r+ r+ r, �<module> s�
� 4
�-
�.
�-
�- ~ �
� �
�