
    (phSV                        S r SSKrSSKrSSKJrJrJrJrJr  SSK	r	SSK	J
r
  SSK	Jr  SSK	Jr  SSKJr  SS	KJr  SS
KJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJ r   SSK!J"r"  SSK#J$r$  SSK#J%r%  SSK#J&r&  SSK#J'r'  SSK#J(r(  SSK#J)r)  SSK#J*r*  SS K+J,r,  S!R[                  \R\                  5      r/\R`                  S   S":  a  S#\\Rb                     4S$ jr2OS#\\Rb                     4S% jr2S&\$S'\\	Rf                     4S( jr4 " S) S*5      r5 " S+ S,\5\Rl                  5      r6 " S- S.\5\Rn                  5      r7 " S/ S0\5\Rp                  5      r8 " S1 S2\5\Rr                  5      r9 " S3 S4\Rt                  5      r:   S;S5\;S6\\$   S'\\	Rf                     S7\\\      4S8 jjr<   S;S5\;S9\	Rz                  S6\\$   S'\\	Rf                     S7\\\      4
S: jjr>g)<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_deadlinezgrpc-python-asyncio/{}   returnc                  >    [         R                  R                  5       $ N)asyncioTask	all_tasks     D/var/www/html/venv/lib/python3.13/site-packages/grpc/aio/_channel.py
_all_tasksr/   7   s    ||%%''r-   c                  ,    [         R                  " 5       $ r(   )r)   r+   r,   r-   r.   r/   r/   <   s      ""r-   base_optionscompressionc                     [         R                  " U5      n[        R                  R                  [
        44n[        U 5      U-   U-   $ r(   )r	   create_channel_optionr   ChannelArgKeyprimary_user_agent_string_USER_AGENTtuple)r1   r2   compression_channel_argumentuser_agent_channel_arguments       r.   _augment_channel_argumentsr;   @   sX     $0#E#E$ 
   ::	
# 	l
&	'
%	&r-   c                   d   \ rS rSr% Sr\R                  \S'   \R                  \S'   \
\S'   \\S'   \\S'   \\\      \S'   \\   \S	'   \R                  \S'   S
\R                  S\
S\S\S\\\      S\\   S\R                  SS4S jr\  SS\\   S\\R,                     S\4S jj5       rSrg)_BaseMultiCallableS   zjBase class of all multi callable objects.

Handles the initialization logic and stores common attributes.
_loop_channel_method_request_serializer_response_deserializer_interceptors_referenceschannelmethodrequest_serializerresponse_deserializerinterceptors
referencesloopr&   Nc                 X    Xpl         Xl        X l        X0l        X@l        XPl        X`l        g r(   )r?   r@   rA   rB   rC   rD   rE   )selfrF   rG   rH   rI   rJ   rK   rL   s           r.   __init___BaseMultiCallable.__init__c   s+     
#5 &;#)%r-   metadatar2   c                     U =(       d
    [        5       n [        U [         5      (       d+  [        U [        5      (       a  [         R                  " U 5      n U(       a  [        [        R
                  " X5      6 n U $ )zBased on the provided values for <metadata> or <compression> initialise the final
metadata, as it should be used for the current call.
)r   
isinstancer8   
from_tupler	   augment_metadata)rQ   r2   s     r.   _init_metadata!_BaseMultiCallable._init_metadatau   s[     )xz(H--*Xu2M2M**84H..xEH r-   )r@   rD   r?   rA   rE   rB   rC   )NN)__name__
__module____qualname____firstlineno____doc__r)   AbstractEventLoop__annotations__r   
AioChannelbytesr#   r   r   r   r   r   r   rO   staticmethodr   grpcCompressionr   rV   __static_attributes__r,   r-   r.   r=   r=   S   s   
 $$$N,,11H%6788c$$$&""& & 0	&
  5& x(9:;& I& ''& 
&$ +/26<(d../ 
 r-   r=   c                       \ rS rSrSSSSSS.S\S\\   S\\   S\\R                     S\\
   S	\\R                     S
\R                  \\4   4S jjrSrg)UnaryUnaryMultiCallable   NtimeoutrQ   credentialswait_for_readyr2   requestri   rQ   rj   rk   r2   r&   c                   U R                  X65      nU R                  (       dQ  [        U[        U5      UUUU R                  U R
                  U R                  U R                  U R                  5
      nU$ [        U R                  UUUUUU R                  U R
                  U R                  U R                  U R                  5      nU$ r(   )
rV   rD   r   r$   r@   rA   rB   rC   r?   r   rN   rl   ri   rQ   rj   rk   r2   calls           r.   __call__ UnaryUnaryMultiCallable.__call__   s     &&x=!!!$W-((++

D6  -""((++

D r-   r,   )rX   rY   rZ   r[   r!   r   floatr   rb   CallCredentialsboolrc   r   r   r"   rp   rd   r,   r-   r.   rf   rf      s     $(+/6:)-26'' %	'
 <(' d223' !' d../' 
	"	";#<	=' 'r-   rf   c                       \ rS rSrSSSSSS.S\S\\   S\\   S\\R                     S\\
   S	\\R                     S
\R                  \\4   4S jjrSrg)UnaryStreamMultiCallable   Nrh   rl   ri   rQ   rj   rk   r2   r&   c                   U R                  X65      nU R                  (       dQ  [        U[        U5      UUUU R                  U R
                  U R                  U R                  U R                  5
      nU$ [        U R                  UUUUUU R                  U R
                  U R                  U R                  U R                  5      nU$ r(   )
rV   rD   r   r$   r@   rA   rB   rC   r?   r   rn   s           r.   rp   !UnaryStreamMultiCallable.__call__   s     &&x=!!"$W-((++

D6  .""((++

D r-   r,   )rX   rY   rZ   r[   r!   r   rr   r   rb   rs   rt   rc   r   r   r"   rp   rd   r,   r-   r.   rv   rv      s     $(+/6:)-26(( %	(
 <(( d223( !( d../( 
	#	#K$=	>( (r-   rv   c                       \ rS rSr      SS\\   S\\   S\\   S\\R                     S\\
   S\\R                     S	\R                  4S
 jjrSrg)StreamUnaryMultiCallable   Nrequest_iteratorri   rQ   rj   rk   r2   r&   c                    U R                  X65      nU R                  (       dQ  [        U[        U5      UUUU R                  U R
                  U R                  U R                  U R                  5
      nU$ [        U R                  UUUUUU R                  U R
                  U R                  U R                  U R                  5      nU$ r(   )
rV   rD   r   r$   r@   rA   rB   rC   r?   r   rN   r}   ri   rQ   rj   rk   r2   ro   s           r.   rp   !StreamUnaryMultiCallable.__call__   s     &&x=!!" $W-((++

D6  ."" ((++

D r-   r,   NNNNNN)rX   rY   rZ   r[   r   r    rr   r   rb   rs   rt   rc   r   r   rp   rd   r,   r-   r.   r{   r{      s    
 ;?#'+/6:)-26'"#67' %' <(	'
 d223' !' d../' 
	#	#' 'r-   r{   c                       \ rS rSr      SS\\   S\\   S\\   S\\R                     S\\
   S\\R                     S	\R                  4S
 jjrSrg)StreamStreamMultiCallablei  Nr}   ri   rQ   rj   rk   r2   r&   c                    U R                  X65      nU R                  (       dQ  [        U[        U5      UUUU R                  U R
                  U R                  U R                  U R                  5
      nU$ [        U R                  UUUUUU R                  U R
                  U R                  U R                  U R                  5      nU$ r(   )
rV   rD   r   r$   r@   rA   rB   rC   r?   r   r   s           r.   rp   "StreamStreamMultiCallable.__call__  s     &&x=!!# $W-((++

D6  /"" ((++

D r-   r,   r   )rX   rY   rZ   r[   r   r    rr   r   rb   rs   rt   rc   r   r   rp   rd   r,   r-   r.   r   r     s    
 ;?#'+/6:)-26'"#67' %' <(	'
 d223' !' d../' 
	$	$' 'r-   r   c                   v   \ rS rSr% \R
                  \S'   \R                  \S'   \	\
   \S'   \	\   \S'   \	\   \S'   \	\   \S'   S\S	\S
\\R$                     S\\R&                     S\\\      4
S jrS rS rS rS%S\\   4S jjrS r S&S\S\R<                  4S jjrS\R<                  SS4S jr S'S jr!S\S\"4S jr#   S(S\S\\$   S\\%   S\\   S\&4
S  jjr'   S(S\S\\$   S\\%   S\\   S\(4
S! jjr)   S(S\S\\$   S\\%   S\\   S\*4
S" jjr+   S(S\S\\$   S\\%   S\\   S\,4
S# jjr-S$r.g))Channeli<  r?   r@   _unary_unary_interceptors_unary_stream_interceptors_stream_unary_interceptors_stream_stream_interceptorstargetoptionsrj   r2   rJ   c                    / U l         / U l        / U l        / U l        UGbj  U GHc  n[	        U[
        5      (       a  U R                   R                  U5        M6  [	        U[        5      (       a  U R                  R                  U5        Mh  [	        U[        5      (       a  U R                  R                  U5        M  [	        U[        5      (       a  U R                  R                  U5        M  [        SR                  U5      SR                  [
        R                  5      -   SR                  [        R                  5      -   SR                  [        R                  5      -   SR                  [        R                  5      -   5      e   [        R                  " 5       U l        [        R                   " ["        R$                  " U5      ['        X$5      UU R                  5      U l        g)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.
NzInterceptor {} must be z{} or z{}. )r   r   r   r   rS   r   appendr   r   r   
ValueErrorformatrX   r   get_working_loopr?   r_   r   encoder;   r@   )rN   r   r   rj   r2   rJ   interceptors          r.   rO   Channel.__init__D  s   & *,&*,'*,'+-(#+k+FGG2299+F-IJJ33::;G-IJJ33::;G-JKK44;;KH$188E"//*E*N*NOP"//*F*O*OPQ #//*F*O*OPQ !--(E(N(NO	P   ,$ ,,.
))NN6"&w<JJ	
r-   c                    #    U $ 7fr(   r,   rN   s    r.   
__aenter__Channel.__aenter__w  s
     s   c                 B   #    U R                  S 5      I S h  vN   g  N7fr(   _close)rN   exc_typeexc_valexc_tbs       r.   	__aexit__Channel.__aexit__z  s     kk$   c                   #    U R                   R                  5       (       a  g U R                   R                  5         [        5       n/ n/ nU GH  n UR	                  SS9nU(       d  M  US   nUR                  R                  S5      n	U	c  MB  [        U	[        R                  5      (       d  Mc  [        U	S5      (       a  U	R                   U R                   La  M  OP[        U	S5      (       a&  U	R                  R                   U R                   La  M  O[        R                  " SU	 35      eUR!                  U	5        UR!                  U5        GM     U(       a#  U(       a  ["        R$                  " XAS	9I S h  vN   U H  n
U
R'                  5         M     U R                   R)                  5         g ! [
         a  nS[        U5      ;   a   S nAGM  e S nAff = f Na7f)
Nr   )limitframer   rN   r@   _cython_callzUnrecognized call object: )ri   )r@   closedclosingr/   	get_stackAttributeErrorstrf_localsgetrS   r   Callhasattrr   r   InternalErrorr   r)   waitcancelclose)rN   gracetaskscalls
call_taskstaskstackattribute_errorr   	candidatero   s              r.   r   Channel._close}  s    ==!! 	 
DQ/,  !HE**62I $i99y*55$--T]]B$ C N;;$11::$--O$ P %228D  LL+%%d+e l Z,,z999 DKKM  	w "  c/22%h :sO   AGF2!*GG0C	G9G:8G2
G<GGGGGNr   c                 B   #    U R                  U5      I S h  vN   g  N7fr(   r   )rN   r   s     r.   r   Channel.close  s     kk%   r   c                     [        U S5      (       a;  U R                  R                  5       (       d  U R                  R                  5         g g g )Nr@   )r   r@   r   r   r   s    r.   __del__Channel.__del__  s<    4$$==''))##% * %r-   try_to_connectr&   c                 ^    U R                   R                  U5      n[        R                  U   $ r(   )r@   check_connectivity_stater   1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY)rN   r   results      r.   	get_stateChannel.get_state  s)     77GHHPPr-   last_observed_statec                    #    U R                   R                  UR                  S   S 5      I S h  vN (       d   eg  N7f)Nr   )r@   watch_connectivity_statevalue)rN   r   s     r.   wait_for_state_changeChannel.wait_for_state_change  s=      ]];;%%a($
 
 
 	
 
s   -><>c                    #    U R                  SS9nU[        R                  R                  :w  aI  U R	                  U5      I S h  vN   U R                  SS9nU[        R                  R                  :w  a  MH  g g  N57f)NT)r   )r   rb   ChannelConnectivityREADYr   )rN   states     r.   channel_readyChannel.channel_ready  sf     d3t//555,,U333NN$N7E t//5553s   AA<A:1A<8A<rG   c                     g r(   r,   )rN   rG   s     r.   _get_registered_call_handle#Channel._get_registered_call_handle  s    r-   rH   rI   _registered_methodc           	          [        U R                  [        R                  " U5      UUU R                  U /U R
                  5      $ r(   )rf   r@   r   r   r   r?   rN   rG   rH   rI   r   s        r.   unary_unaryChannel.unary_unary  s?     'MMNN6"!**FJJ
 	
r-   c           	          [        U R                  [        R                  " U5      UUU R                  U /U R
                  5      $ r(   )rv   r@   r   r   r   r?   r   s        r.   unary_streamChannel.unary_stream   ?     (MMNN6"!++FJJ
 	
r-   c           	          [        U R                  [        R                  " U5      UUU R                  U /U R
                  5      $ r(   )r{   r@   r   r   r   r?   r   s        r.   stream_unaryChannel.stream_unary  r   r-   c           	          [        U R                  [        R                  " U5      UUU R                  U /U R
                  5      $ r(   )r   r@   r   r   r   r?   r   s        r.   stream_streamChannel.stream_stream(  s?     )MMNN6"!,,FJJ
 	
r-   )r@   r?   r   r   r   r   r(   )F)r&   N)NNF)/rX   rY   rZ   r[   r)   r]   r^   r   r_   r   r   r   r   r   r   r   r   rb   ChannelCredentialsrc   r   r   rO   r   r   r   rr   r   r   rt   r   r   r   r   intr   r#   r   rf   r   rv   r   r{   r   r   r   rd   r,   r-   r.   r   r   <  sh   $$$#$?@@ $%A BB $%A BB!%&C!DD1
1
 %1
 d556	1

 d../1
 x(9:;1
f IV!% !& &+Q"Q		!	!Q
!55
 

8# #  =AAE-2

 %%89
  ((=>	

 %TN
 
!
. =AAE-2

 %%89
  ((=>	

 %TN
 
"
. =AAE-2

 %%89
  ((=>	

 %TN
 
"
. =AAE-2

 %%89
  ((=>	

 %TN
 
#
 
r-   r   r   r   rJ   c                 *    [        U Uc  SOUSUU5      $ )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,   )r   )r   r   r2   rJ   s       r.   insecure_channelr   :  s&    ( o7 r-   rj   c                 >    [        U Uc  SOUUR                  UU5      $ )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.
r,   )r   _credentials)r   rj   r   r2   rJ   s        r.   secure_channelr   W  s,    , o7   r-   )NNN)?r\   r)   systypingr   r   r   r   r   rb   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$   r   __version__r7   version_infor*   r/   rc   r;   r=   rf   rv   r{   r   r   r   r   r   r   r,   r-   r.   <module>r      s
   =  
 : :    !    # " " ! + 5 4 4 3 7 6 6 5  ( * ! (   ! ( (&--.>.J.JKA(. (
#. #%4<T=M=M4N&1 1h*==*Z+>>+\*>>*Z*??*Z{
m## {
@ .2.2:>	)* $**+ 8$567	@ .2.2:>(( )* $**+	
 8$567r-   