| 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��f c � @ s� d Z ddlZddlZddlmZ ddlZddlZddlZddlm Z m
Z
m Z m Z m
Z
mZmZ ddlZddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ dd lmZ dd
lm Z ddlm Z ddlm Z ddlm Z ddlm Z dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(e�)e*�Z+G dd� dej,�Z-eej.e-d �d d �Z/G d d � d �Z0G d!d"� d"ej1�Z2G d#d$� d$e0e e �Z3G d%d&� d&e0�Z4G d'd(� d(e0�Z5G d)d*� d*e3e0ej6�Z6G d+d,� d,e4e0ej7�Z7G d-d.� d.e5e3e0ej8�Z8G d/d0� d0e5e4e0ej9�Z9dS )1z6Invocation-side implementation of gRPC Asyncio Python.� N)�partial)�Any�
AsyncIterator� Generator�Generic�Optional�Tuple�Union)�_common)�cygrpc� )�
_base_call)�Metadata)�DeserializingFunction)�DoneCallbackType)�EOFType)�
MetadatumType)�RequestIterableType)� RequestType)� ResponseType)�SerializingFunction)� AioRpcError�Call�UnaryUnaryCall�UnaryStreamCallz!Locally cancelled by application!z"Cancelled upon garbage collection!zRPC already finished.z0RPC is half closed after calling "done_writing".zBThe iterator and read/write APIs may not be mixed on a single RPC.z?<{} of RPC that terminated with:
status = {}
details = "{}"
>zZ<{} of RPC that terminated with:
status = {}
details = "{}"
debug_error_string = "{}"
>c s� e Zd ZU dZejed< ee ed< ee ed< ee ed< ee ed< d eje e ee ee dd�� fd d
�
Z
ejd �d d
�Z ee d �dd�Z e d �dd�Z
e d �dd�Zed �dd�Zed �dd�Zed �dd�Zed �dd�Zd d � Z� ZS ) r z�An implementation of RpcError to be used by the asynchronous API.
Raised RpcError is a snapshot of the final status of the RPC, values are
determined. Hence, its methods no longer needs to be coroutines.
�_code�_details�_initial_metadata�_trailing_metadata�_debug_error_stringN)�code�initial_metadata�trailing_metadata�details�debug_error_string�returnc s, t � �� || _|| _|| _|| _|| _dS )ah Constructor.
Args:
code: The status code with which the RPC has been finalized.
details: Optional details explaining the reason of the error.
initial_metadata: Optional initial metadata that could be sent by the
Server.
trailing_metadata: Optional metadata that could be sent by the Server.
N)�super�__init__r r r r r )�selfr r! r" r# r$ �� __class__� �r/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/aio/_call.pyr' U s
zAioRpcError.__init__�r% c C s | j S )ztAccesses the status code sent by the server.
Returns:
The `grpc.StatusCode` status code.
)r �r( r+ r+ r, r n s zAioRpcError.codec C s | j S )zkAccesses the details sent by the server.
Returns:
The description of the error.
)r r. r+ r+ r, r# v s zAioRpcError.detailsc C s | j S )zuAccesses the initial metadata sent by the server.
Returns:
The initial metadata received.
)r r. r+ r+ r, r! ~ s z AioRpcError.initial_metadatac C s | j S )zwAccesses the trailing metadata sent by the server.
Returns:
The trailing metadata received.
)r r. r+ r+ r, r" � s z AioRpcError.trailing_metadatac C s | j S )zyAccesses the debug error string sent by the server.
Returns:
The debug error string received.
)r r. r+ r+ r, r$ � s z AioRpcError.debug_error_stringc C s t �| jj| j| j| j�S )z-Assembles the error string for the RPC error.)�_NON_OK_CALL_REPRESENTATION�formatr* �__name__r r r r. r+ r+ r, �_repr� s �zAioRpcError._reprc C s | � � S �N�r2 r. r+ r+ r, �__repr__� s zAioRpcError.__repr__c C s | � � S r3 r4 r. r+ r+ r, �__str__� s zAioRpcError.__str__c C s t | �| j| j| j| j| jffS r3 )�typer r r r r r. r+ r+ r, �
__reduce__� s ��zAioRpcError.__reduce__)NN)r1 �
__module__� __qualname__�__doc__�grpc�
StatusCode�__annotations__r �strr r' r r# r! r" r$ r2 r5 r6 r8 �
__classcell__r+ r+ r) r, r H s2
�� r )r! �statusr% c C s4 t tj|�� t�| �t�|�� �|�� |�� d�S )N)r# r$ ) r r
�!CYGRPC_STATUS_CODE_TO_STATUS_CODEr r �
from_tupler" r# r$ )r! rA r+ r+ r, �_create_rpc_error� s �rD c @ sV e Zd ZU dZejed< ejed< e j
ed< e e df ed< e
ed< eed< e j
ee
eejd d
�d d �Zd d
�dd�Zed
�dd�Zeed�dd�Zed
�dd�Zed
�dd�Zed d�dd�Zee d
�d d �Z ed
�d d �Z ed
�d d!�Z ejd
�d"d#�Z ed
�d$d%�Z ed
�d&d'�Z!d d
�d(d)�Z"ed
�d*d+�Z#ed
�d,d-�Z$ed
�d.d/�Z%d S )0r zyBase implementation of client RPC Call object.
Implements logic around final status, metadata and cancellation.
�_loopr � _cython_call.� _metadata�_request_serializer�_response_deserializerN)� cython_call�metadata�request_serializer�response_deserializer�loopr% c C s& || _ || _t|�| _|| _|| _d S r3 )rE rF �tuplerG rH rI )r( rJ rK rL rM rN r+ r+ r, r' � s
z
Call.__init__r- c C s" t | d�r | j�� s | �t� d S )NrF )�hasattrrF �done�_cancel�_GC_CANCELLATION_DETAILSr. r+ r+ r, �__del__� s
z Call.__del__c C s
| j �� S r3 )rF � cancelledr. r+ r+ r, rU � s zCall.cancelled)r# r% c C s" | j �� s| j �|� dS dS dS )z0Forwards the application cancellation reasoning.TFN)rF rQ �cancel)r( r# r+ r+ r, rR � s
z Call._cancelc C s
| � t�S r3 )rR �_LOCAL_CANCELLATION_DETAILSr. r+ r+ r, rV � s z Call.cancelc C s
| j �� S r3 )rF rQ r. r+ r+ r, rQ � s z Call.done)�callbackr% c C s t || �}| j�|� d S r3 )r rF �add_done_callback)r( rX �cbr+ r+ r, rY � s
zCall.add_done_callbackc C s
| j �� S r3 )rF �time_remainingr. r+ r+ r, r[ � s zCall.time_remainingc � s | j �� I d H }t�|�S r3 )rF r! r rC �r( �raw_metadata_tupler+ r+ r, r! � s zCall.initial_metadatac � s | j �� I d H �� }t�|�S r3 )rF rA r" r rC r\ r+ r+ r, r" � s �zCall.trailing_metadatac � s | j �� I d H �� }tj| S r3 )rF rA r r
rB )r( � cygrpc_coder+ r+ r, r s z Call.codec � s | j �� I d H �� S r3 )rF rA r# r. r+ r+ r, r# s z Call.detailsc � s | j �� I d H �� S r3 )rF rA r$ r. r+ r+ r, r$ s zCall.debug_error_stringc � sP | j �� rt�� �| �� I d H }|tjjkrLt| � � I d H | j �
� I d H ��d S r3 ) rF �is_locally_cancelled�asyncio�CancelledErrorr r< r= �OKrD r! rA )r( r r+ r+ r, �_raise_for_status s
�zCall._raise_for_statusc C s
t | j�S r3 )�reprrF r. r+ r+ r, r2 s z
Call._reprc C s | � � S r3 r4 r. r+ r+ r, r5 s z
Call.__repr__c C s | � � S r3 r4 r. r+ r+ r, r6 s z Call.__str__)&r1 r9 r: r; r` �AbstractEventLoopr> r< r= r �_AioCallr r r r r r' rT �boolrU r? rR rV rQ r rY r �floatr[ r! r" r r# r$ rc r2 r5 r6 r+ r+ r+ r, r � s<
� r c @ s e Zd ZdZdZdZdS )� _APIStyler r � N)r1 r9 r: �UNKNOWN�ASYNC_GENERATOR�
READER_WRITERr+ r+ r+ r, ri s ri c sV e Zd ZU ejed< ejd�dd�Zed�� fdd� Ze e
de f d�d d
�Z � Z
S ) �_UnaryResponseMixin�_call_response)�
response_taskc C s
|| _ d S r3 )ro )r( rp r+ r+ r, �_init_unary_response_mixin' s z._UnaryResponseMixin._init_unary_response_mixinr- c s t � �� r| j�� dS dS d S �NTF)r& rV ro r. r) r+ r, rV * s
z_UnaryResponseMixin.cancelNc c sr z| j E dH }W n& tjy6 | �� s0| �� � Y n0 |tju rj| j�� rVt�� �qnt | jj
| jj ��n|S dS )z+Wait till the ongoing RPC request finishes.N) ro r` ra rU rV r �EOFrF r_ rD r �_status)r( �responser+ r+ r, � __await__1 s
�z _UnaryResponseMixin.__await__)r1 r9 r: r` �Taskr> rq rg rV r r r rv r@ r+ r+ r) r, rn $ s
rn c s� e Zd ZU ee ed< ejed< eed< ejd�dd�Z ed�dd �Z
e d
�� fd d � Z ed
�d
d�Z
ee d
�dd�Zed
�dd�Zeeef d
�dd�Z� ZS )�_StreamResponseMixin�_message_aiter� _preparation�_response_style)� preparationc C s d | _ || _tj| _d S r3 )ry rz ri rk r{ )r( r| r+ r+ r, �_init_stream_response_mixinT s z0_StreamResponseMixin._init_stream_response_mixin��stylec C s, | j tju r|| _ n| j |ur(t�t��d S r3 )r{ ri rk r �
UsageError�_API_STYLE_ERROR�r( r r+ r+ r, �_update_response_styleY s
z+_StreamResponseMixin._update_response_styler- c s t � �� r| j�� dS dS d S rr )r& rV rz r. r) r+ r, rV _ s
z_StreamResponseMixin.cancelc C s@ | � � I d H }|tjur.|V | � � I d H }q| �� I d H d S r3 )�_readr rs rc )r( �messager+ r+ r, �_fetch_stream_responsesf s
z,_StreamResponseMixin._fetch_stream_responsesc C s& | � tj� | jd u r | �� | _| jS r3 )r� ri rl ry r� r. r+ r+ r, � __aiter__o s
z _StreamResponseMixin.__aiter__c � sj | j I d H z| j�� I d H }W n& tjyF | �� s@| �� � Y n0 |tju rXtjS t �
|| j �S d S r3 ) rz rF �receive_serialized_messager` ra rU rV r rs r
� deserializerI )r( � raw_responser+ r+ r, r� u s
�z_StreamResponseMixin._readc � sR | � � r | �� I d H tjS | �tj� | �� I d H }|tju rN| �� I d H |S r3 )rQ rc r rs r� ri rm r� )r( �response_messager+ r+ r, �read� s
z_StreamResponseMixin.read)r1 r9 r: r r r> r` rw ri r} r� rg rV r� r� r� r r r� r@ r+ r+ r) r, rx O s
rx c s� e Zd ZU ejed< eed< eej ed< e ed< ee
d�dd�Z e d�d d
�Z ed �� fd d
� Z
dd� Ze
dd�dd�Zedd�dd�Zdd �dd�Zedd�dd�Zdd �dd �Zdd �d d �Z� ZS ) �_StreamRequestMixin�_metadata_sent�_done_writing_flag�_async_request_poller�_request_style)�request_iteratorc C sH t �� | _d| _|d ur6| j�| �|��| _tj | _
nd | _tj | _
d S )NF) r` �Eventr� r� rE � create_task�_consume_request_iteratorr� ri rl r� rm )r( r� r+ r+ r, �_init_stream_request_mixin� s
�
z._StreamRequestMixin._init_stream_request_mixinr~ c C s | j |urt�t��d S r3 )r� r r� r� r� r+ r+ r, �_raise_for_different_style� s
z._StreamRequestMixin._raise_for_different_styler- c s* t � �� r"| jd ur | j�� dS dS d S rr )r& rV r� r. r) r+ r, rV � s
z_StreamRequestMixin.cancelc C s | j �� d S r3 )r� �setr. r+ r+ r, �_metadata_sent_observer� s z+_StreamRequestMixin._metadata_sent_observerN)r� r% c � s z�t �|�st|d�rx|2 zX3 d H W }z| �|�I d H W q typ } z t�d|� W Y d }~ W d S d }~0 0 q6 nV|D ]P}z| �|�I d H W q| ty� } z t�d|� W Y d }~ W d S d }~0 0 q|| �� I d H W n$ t�dt� � � | �
� Y n0 d S )Nr� z2Exception while consuming the request_iterator: %sz,Client request_iterator raised exception:
%s) �inspect�
isasyncgenrP �_writer �_LOGGER�debug�
_done_writing� traceback�
format_excrV )r( r� �request� rpc_errorr+ r+ r, r� � s: ��"� �z-_StreamRequestMixin._consume_request_iterator)r� r% c
� s� | � � rt�t��| jr"t�t��| j�� sR| j�� I d H | � � rR| � � I d H t
� || j �}z| j
�|�I d H W nh tjy� } z*| j
�t|�� | � � I d H W Y d }~n.d }~0 tjy� | �� s�| �� � Y n0 d S r3 )rQ r` �InvalidStateError� _RPC_ALREADY_FINISHED_DETAILSr� �_RPC_HALF_CLOSED_DETAILSr� �is_set�waitrc r
� serializerH rF �send_serialized_messager �
InternalError�set_internal_errorr? ra rU rV )r( r� �serialized_request�errr+ r+ r, r� � s(
�"z_StreamRequestMixin._writec � sX | � � r d S | jsTd| _z| j�� I d H W n& tjyR | �� sL| �� � Y n0 d S )NT)rQ r� rF �send_receive_closer` ra rU rV r. r+ r+ r, r� � s z!_StreamRequestMixin._done_writingc � s | � tj� | �|�I d H d S r3 )r� ri rm r� )r( r� r+ r+ r, �write s z_StreamRequestMixin.writec � s | � tj� | �� I dH dS )zUSignal peer that client is done writing.
This method is idempotent.
N)r� ri rm r� r. r+ r+ r, � done_writing s z _StreamRequestMixin.done_writingc � s* | j �� I d H | �� r&| �� I d H d S r3 )r� r� rQ rc r. r+ r+ r, �wait_for_connection s z'_StreamRequestMixin.wait_for_connection)r1 r9 r: r` r� r> rg r rw ri r r� r� rV r� r� r r� r� r� r� r� r@ r+ r+ r) r, r� � s"
� � ,r� c s| e Zd ZU dZeed< ejed< eee e
ee j ee
ejeeeejdd� � fdd� Zed�d d
�Zdd�d d �Z� ZS )
r z}Object for managing unary-unary RPC calls.
Returned when an instance of `UnaryUnaryMultiCallable` object is called.
�_request�_invocation_taskN� r� �deadlinerK � credentials�wait_for_ready�channel�methodrL rM rN r% c sP t � �|�||||�||| |
� || _t�� | _|
�| �� �| _ | �
| j � d S r3 ) r& r' �callr� r �build_census_context�_contextr� �_invoker� rq � r( r� r� rK r� r� r� r� rL rM rN r) r+ r, r' ( s
�
zUnaryUnaryCall.__init__r- c � sv t �| j| j�}z | j�|| j| j�I d H }W n$ tj yR | �
� sN| � � Y n0 | j� � rlt �
|| j�S tjS d S r3 )r
r� r� rH rF � unary_unaryrG r� r` ra rU rV �is_okr� rI r rs )r( r� �serialized_responser+ r+ r, r� A s �
�
�zUnaryUnaryCall._invokec � s& | j I d H | �� r"| �� I d H d S r3 )r� rQ rc r. r+ r+ r, r� X s z"UnaryUnaryCall.wait_for_connection)r1 r9 r: r; r r> r` rw r rh r r< �CallCredentialsrg r �
AioChannel�bytesr r re r' r r� r� r@ r+ r+ r) r, r s"
�r c s| e Zd ZU dZeed< ejed< eee e
ee j ee
ejeeeejdd� � fdd� Zed�d d
�Zdd�d d �Z� ZS )
r zObject for managing unary-stream RPC calls.
Returned when an instance of `UnaryStreamMultiCallable` object is called.
r� �_send_unary_request_taskNr� c sP t � �|�||||�||| |
� || _t�� | _|
�| �� �| _ | �
| j � d S r3 ) r& r' r� r� r r� r� r� �_send_unary_requestr� r} r� r) r+ r, r' h s
�
�zUnaryStreamCall.__init__r- c � sZ t �| j| j�}z | j�|| j| j�I d H W n& tj yT | �
� sN| � � � Y n0 d S r3 ) r
r� r� rH rF �initiate_unary_streamrG r� r` ra rU rV )r( r� r+ r+ r, r� � s �
�z#UnaryStreamCall._send_unary_requestc � s& | j I d H | �� r"| �� I d H d S r3 )r� rQ rc r. r+ r+ r, r� � s z#UnaryStreamCall.wait_for_connection)r1 r9 r: r; r r> r` rw r rh r r< r� rg r r� r� r r re r' r r� r� r@ r+ r+ r) r, r ^ s"
�
r c s^ e Zd ZdZee ee eeej ee
e j e
eeejdd� � fdd� Zed�dd�Z� ZS ) �StreamUnaryCallzObject for managing stream-unary RPC calls.
Returned when an instance of `StreamUnaryMultiCallable` object is called.
N� r� r� rK r� r� r� r� rL rM rN r% c sL t � �|�||||�||| |
� t�� | _| �|� | �|
�| � � �� d S r3 )
r& r' r� r r� r� r� rq r� � _conduct_rpc� r( r� r� rK r� r� r� r� rL rM rN r) r+ r, r' � s
�
zStreamUnaryCall.__init__r- c � sj z | j �| j| j| j�I d H }W n& tjyF | �� s@| �� � Y n0 | j � � r`t
� || j �S t
jS d S r3 )rF � stream_unaryrG r� r� r` ra rU rV r� r
r� rI r rs )r( r� r+ r+ r, r� � s �
�z StreamUnaryCall._conduct_rpc)r1 r9 r: r; r r rh r r< r� rg r r� r� r r r` re r' r r� r@ r+ r+ r) r, r� � s �r� c sd e Zd ZU dZejed< ee ee e
ee j ee
ejeeeejdd� � fdd� Zdd� Z� ZS ) �StreamStreamCallz�Object for managing stream-stream RPC calls.
Returned when an instance of `StreamStreamMultiCallable` object is called.
� _initializerNr� c sV t � �|�||||�||| |
� t�� | _| j�| �� �| _ | �
|� | � | j � d S r3 ) r& r' r� r r� r� rE r� � _prepare_rpcr� r� r} r� r) r+ r, r' � s
�
zStreamStreamCall.__init__c � sJ z | j �| j| j| j�I dH W n$ tjyD | �� s@| �� Y n0 dS )z�This method prepares the RPC for receiving/sending messages.
All other operations around the stream should only happen after the
completion of this method.
N) rF �initiate_stream_streamrG r� r� r` ra rU rV r. r+ r+ r, r� � s �z StreamStreamCall._prepare_rpc)r1 r9 r: r; r` rw r> r r rh r r< r� rg r r� r� r r re r' r� r@ r+ r+ r) r, r� � s
�r� ):r; r` �enum� functoolsr r� �loggingr� �typingr r r r r r r r< r
� grpc._cythonr � r
rG r �_typingr r r r r r r r �__all__rW rS r� r� r� �_OK_CALL_REPRESENTATIONr/ � getLoggerr1 r� �RpcErrorr � AioRpcStatusrD r �IntEnumri rn rx r� r r r� r� r+ r+ r+ r, �<module> sd $
���
k� `+G @9
�4
�