| 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 ddlZddlZddlmZmZmZmZmZ ddl Z ddl
m Z ddl m
Z
ddl mZ e�e�Ze jje jje jje jje jje jje jje jje jj e jj iZ e j j e j j!e j j"e j j#e j j$e j j%e j j&e j j'e j j(e j j)e j j*e j j+e j j,e j j-e j j.e j j/e j j0e j j1e j j2e j j3e j j4e j j5e j j6e j j7e j j8e j j9e j j:e j j;e j j<e j j=e j j>e j j?e j j@e j jAiZBdd� eB�C� D �ZDd ZEd
ZFeeGd �d d
�ZHeeId�dd�ZJeeee
df eIed�dd�ZKeee eGd�dd�ZLeGee
ed�dd�ZMeIeIeId�dd �ZNed eOf ePeeg df d �d d �ZQd'ed eOf eg eOf eeP eeg df eOd!�d"d#�ZReIeSeSd$�d%d&�ZTdS )(zShared implementation.� N)�Any�AnyStr�Callable�Optional�Union)�cygrpc)�DeserializingFunction)�SerializingFunctionc C s i | ]\}}||�qS � r
)�.0� cygrpc_code� grpc_coder
r
�p/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/_common.py�
<dictcomp>6 s �r g�������?zjFailed to bind to address %s; set GRPC_VERBOSITY=debug environment variable to see detailed error message.)�s�returnc C s t | t�r| S | �d�S d S )N�utf8)�
isinstance�bytes�encode)r r
r
r r C s
r )�br c C s t | t�r| �dd�S | S )Nzutf-8�replace)r r �decode)r r
r
r r J s
r )�message� transformer�exception_messager c C s: |d u r | S z
|| �W S t y4 t�|� Y d S 0 d S )N)� Exception�_LOGGER� exception)r r r r
r
r �
_transformP s
r )r �
serializerr c C s t | |d�S )Nz Exception serializing message!�r )r r r
r
r � serialize_ s r" )�serialized_message� deserializerr c C s t | |d�S )Nz Exception deserializing message!r! )r# r$ r
r
r � deserializec s �r% )�group�methodr c C s d� | |�S )Nz/{}/{})�format)r& r' r
r
r �fully_qualified_methodk s r) .��wait_fn�timeout�spin_cbc C s | |d� |d ur|� d S )N)r, r
r* r
r
r �
_wait_onceo s
r. )r+ �wait_complete_fnr, r- r c C s` |du r |� s\t | t|� qn>t�� | }|� s\t|t�� t�}|dk rNdS t | ||� q*dS )ad Blocks waiting for an event without blocking the thread indefinitely.
See https://github.com/grpc/grpc/issues/19464 for full context. CPython's
`threading.Event.wait` and `threading.Condition.wait` methods, if invoked
without a timeout kwarg, may block the calling thread indefinitely. If the
call is made from the main thread, this means that signal handlers may not
run for an arbitrarily long period of time.
This wrapper calls the supplied wait function with an arbitrary short
timeout to ensure that no signal handler has to wait longer than
MAXIMUM_WAIT_TIMEOUT before executing.
Args:
wait_fn: A callable acceptable a single float-valued kwarg named
`timeout`. This function is expected to be one of `threading.Event.wait`
or `threading.Condition.wait`.
wait_complete_fn: A callable taking no arguments and returning a bool.
When this function returns true, it indicates that waiting should cease.
timeout: An optional float-valued number of seconds after which the wait
should cease.
spin_cb: An optional Callable taking no arguments and returning nothing.
This callback will be called on each iteration of the spin. This may be
used for, e.g. work related to forking.
Returns:
True if a timeout was supplied and it was reached. False otherwise.
Nr TF)r. �MAXIMUM_WAIT_TIMEOUT�time�min)r+ r/ r, r- �end� remainingr
r
r �waity s ! r5 )�address�portr c C s |dkrt t| ��n|S dS )ak Validates if the port binding succeed.
If the port returned by Core is 0, the binding is failed. However, in that
case, the Core API doesn't return a detailed failing reason. The best we
can do is raising an exception to prevent further confusion.
Args:
address: The address string to be bound.
port: An int returned by core
r N)� RuntimeError�"_ERROR_MESSAGE_PORT_BINDING_FAILED)r6 r7 r
r
r � validate_port_binding_result� s r: )NN)U�__doc__�loggingr1 �typingr r r r r �grpc� grpc._cythonr � grpc._typingr r � getLogger�__name__r �ConnectivityState�idle�ChannelConnectivity�IDLE�
connecting�
CONNECTING�ready�READY�transient_failure�TRANSIENT_FAILURE�shutdown�SHUTDOWN�1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY�
StatusCode�ok�OK� cancelled� CANCELLED�unknown�UNKNOWN�invalid_argument�INVALID_ARGUMENT�deadline_exceeded�DEADLINE_EXCEEDED� not_found� NOT_FOUND�already_exists�ALREADY_EXISTS�permission_denied�PERMISSION_DENIED�unauthenticated�UNAUTHENTICATED�resource_exhausted�RESOURCE_EXHAUSTED�failed_precondition�FAILED_PRECONDITION�aborted�ABORTED� out_of_range� OUT_OF_RANGE�
unimplemented�
UNIMPLEMENTED�internal�INTERNAL� unavailable� UNAVAILABLE� data_loss� DATA_LOSS�!CYGRPC_STATUS_CODE_TO_STATUS_CODE�items�!STATUS_CODE_TO_CYGRPC_STATUS_CODEr0 r9 r r �strr r r" r% r) �bool�floatr. r5 �intr: r
r
r
r �<module> s�
� ��� � �
�
�
� .