| 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� � @ 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�Zeeed�dd�Z dS )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 �s/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/_utilities.pyr ! s r �_RpcMethodHandler)�request_streaming�response_streaming�request_deserializer�response_serializer� unary_unary� unary_stream� stream_unary�
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 �fully_qualified_method)�.0�method�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_detailsr& c C s |j }| j�|�S r' )r r �get)r# r* �details_methodr r r
r D s �z DictionaryGenericHandler.serviceN)
r r
r �str�__annotations__r �grpcr r$ r) �HandlerCallDetailsr 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� Conditionr2 r3 r4 r5 r6 )r# r7 r r r
r$ T s
z _ChannelReadyFuture.__init__N)�timeoutr& c C s� |d u r d n
t � � | }| j�x | jr0t�� �q | jrFW d � d S |d u rZ| j�� q |t � � }|dk rxt�� �q | jj|d� q W d � n1 s�0 Y d S )Nr )r: )�timer2 r5 r/ �FutureCancelledErrorr4 �wait�FutureTimeoutError)r# r: �until� remainingr r r
�_block\ s
z_ChannelReadyFuture._block)� connectivityr& c C s� | j �b | jsJ|tjju rJd| _| j�| j� | j � � t
| j �}d | _ nW d � d S W d � n1 sn0 Y |D ].}z || � W q| t y� t
�t� Y q|0 q|d S )NT)r2 r5 r/ �ChannelConnectivity�READYr4 r3 � unsubscribe�_update�
notify_all�tupler6 � Exception�_LOGGER� exception�$_DONE_CALLBACK_EXCEPTION_LOG_MESSAGE)r# rB �done_callbacks�
done_callbackr r r
rF n s �
�
. z_ChannelReadyFuture._updater% c C s� | j �V | js>d| _| j�| j� | j �� t| j�}d | _nW d � dS W d � n1 sb0 Y |D ].}z || � W qp t y� t
� t � Y qp0 qpdS )NTF)
r2 r4 r5 r3 rE rF rG rH r6 rI rJ rK rL )r# rM rN r r r
�cancel� s
. z_ChannelReadyFuture.cancelc C s0 | j � | jW d � S 1 s"0 Y d S r' )r2 r5 r( r r r
� cancelled� s z _ChannelReadyFuture.cancelledc C s: | j � | j o| j W d � S 1 s,0 Y d S r' �r2 r5 r4 r( r r r
�running� s z_ChannelReadyFuture.runningc C s6 | j � | jp| jW d � S 1 s(0 Y d S r' rQ r( r r r
�done� s z_ChannelReadyFuture.donec C s | � |� d S r' �rA �r# r: r r r
�result� s z_ChannelReadyFuture.resultc C s | � |� d S r' rT rU r r r
rK � s z _ChannelReadyFuture.exceptionc C s | � |� d S r' rT rU r r r
� traceback� s z _ChannelReadyFuture.traceback)�fnc C sZ | j �8 | js0| js0| j�|� W d � d S W d � n1 sD0 Y || � d S r' )r2 r5 r4 r6 �append)r# rX r r r
�add_done_callback� s
.z%_ChannelReadyFuture.add_done_callbackc C s< | j �" | jj| jdd� W d � n1 s.0 Y d S )NT)�try_to_connect)r2 r3 � subscriberF r( r r r
�start� s z_ChannelReadyFuture.startc C sD | j �* | js"| js"| j�| j� W d � n1 s60 Y d S r' )r2 r5 r4 r3 rE rF r( r r r
�__del__� s z_ChannelReadyFuture.__del__)N)N)N) r r
r r8 r9 r. r/ �Channel�boolr r r$ r �floatrA rC rF rO rP rR rS rV rK rW r rZ r] r^ r r r r
r1 M s$
r1 )r7 r& c C s t | �}|�� |S r' )r1 r] )r7 � ready_futurer r r
�channel_ready_future� s rc )�version1�version2r& c C s� | � d�}|� d�}zRtd�D ]D}t|| �t|| �k rB W dS t|| �t|| �kr W dS q W n tyz Y dS 0 t|�t|�k S )a�
Compares two versions in the format '1.60.1' or '1.60.1.dev0'.
This method will be used in all stubs generated by grpcio-tools to check whether
the stub version is compatible with the runtime grpcio.
Args:
version1: The first version string.
version2: The second version string.
Returns:
True if version1 is lower, False otherwise.
�.� TF)�split�range�int�
ValueError�len)rd re �
version1_list�
version2_list�ir r r
�first_version_is_lower� s
rp ) �__doc__� collections�loggingr8 r; �typingr r r r r/ r � grpc._typingr � getLoggerr rJ rL �
namedtupler �ServiceRpcHandlerr �Futurer1 r_ rc r- r` rp r r r r
�<module> s,
�
�
�o