bQj_ PdZddlZddlZddlmZmZmZmZmZm Z ddl Z ddl Z ddl m Z ddl m Z ddl mZddlmZddlmZd d lmZd d lmZd d lmZd d lmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlm Z d dlm!Z!d dlm"Z"d dlm#Z#d dlm$Z$d dl%m&Z&d dl'm(Z(d dl'm)Z)d dl'm*Z*d dl'm+Z+d dl'm,Z,d dl'm-Z-d d l'm.Z.d d!l/m0Z0e d"e#Z1d$jeejfZ4d%e(d&ee jjd'e(fd(Z6Gd)d*ee,e-e1fZ7Gd+d,e7e,e-e$fejpe,e-fZ8Gd-d.e7e,e-e#fejre,e-fZ9Gd/d0e7e,e-e"fejte,e-fZ:Gd1d2e7e,e-e!fejve,e-fZ;Gd3d4ejxZ< d;d5e=d6ee(d&ee jjd7eeed'ejxf d8Z> d;d5e=d9e j~d6ee(d&ee jjd7eeed'ejxf d:Z@y)r?r@rArB ValueError isinstanceChannel TypeError_python_channel) selfrCrDrErFrGrHrIrB error_msgs r6__init__z_BaseMultiCallable.__init__`s   #5 &;#)%'>$( Y' '$**1-w7 I& &#//2r8metadatar*c|xs t}t|ts.t|trtjt |}|r t j ||}|t|}|S)zBased on the provided values for or initialise the final metadata, as it should be used for the current call. )rrLr from_tupler3r augment_metadata)rSr*augmented_metadatas r6_init_metadataz!_BaseMultiCallable._init_metadatasq)xz h  h  **5?;H !-!>!>+" "-#%78r8)r)NN)__name__ __module__ __qualname____doc__asyncioAbstractEventLoop__annotations__r AioChannelbytesrr%r#r r$rr'rrintrR staticmethodr!grpc CompressionrrXr8r6r:r:NsA  $ $$ N!"5k"BCC$%:<%HIIH%7899c  ()!3""!3!3%%8%EF !3 ((=l(KL !3 x(:;< !3I!3''!3"%!3 !3F+/26<(d../ r8r:ceZdZdddddddedeedeedeejdee deejd e jee ffd Zy) UnaryUnaryMultiCallableNtimeoutrS credentialswait_for_readyr*requestrjrSrkrlr*r+c|j||}|js[t|t|||||j|j |j |j|j|j }n\t|j||||||j|j |j |j|j|j }|jj||Sr-) rXr@rr&r<r=r>r?r;rBrrO_register_callrPrmrjrSrkrlr*calls r6__call__z UnaryUnaryMultiCallable.__call__s&&x=!!!$W-  ((++ ,, D-""  ((++ ,, D ++D1 r8)rYrZr[r#rfloatr!rdCallCredentialsboolrerrr$rrrfr8r6rhrhs$(+/6:)-26++% + <( + d223 +!+d../+  " "; #< =+r8rhceZdZdddddddedeedeedeejdee deejd e jee ffd Zy) UnaryStreamMultiCallableNrirmrjrSrkrlr*r+c|j||}|js[t|t|||||j|j |j |j|j|j }n\t|j||||||j|j |j |j|j|j }|jj||Sr-) rXr@rr&r<r=r>r?r;rBrrOrorps r6rrz!UnaryStreamMultiCallable.__call__s&&x=!!"$W-  ((++ ,, D.""  ((++ ,, D ++D1 r8)rYrZr[r#rrsr!rdrtrurerrr$rrrfr8r6rwrws$(+/6:)-26,,% , <( , d223 ,!,d../,  # #K$= >,r8rwceZdZ d deeedeedeedeejdee deejde jeeffd Zy) StreamUnaryMultiCallableNrequest_iteratorrjrSrkrlr*r+c|j||}|js[t|t|||||j|j |j |j|j|j }n\t|j||||||j|j |j |j|j|j }|jj||Sr-) rXr@rr&r<r=r>r?r;rBrrOrorPr{rjrSrkrlr*rqs r6rrz!StreamUnaryMultiCallable.__call__s&&x=!!" $W-  ((++ ,, D.""   ((++ ,, D ++D1 r8NNNNNN)rYrZr[rr"r#rsr!rdrtrurerrr$rrrfr8r6rzrzs HL#'+/6:)-26+"#6{#CD+%+<( + d223 + ! +d../+  # #K$= >+r8rzceZdZ d deeedeedeedeejdee deejde jeeffd Zy) StreamStreamMultiCallableNr{rjrSrkrlr*r+c|j||}|js[t|t|||||j|j |j |j|j|j }n\t|j||||||j|j |j |j|j|j }|jj||Sr-) rXr@rr&r<r=r>r?r;rBrrOror}s r6rrz"StreamStreamMultiCallable.__call__8s&&x=!!# $W-  ((++ ,, D/""   ((++ ,, D ++D1 r8r~)rYrZr[rr"r#rsr!rdrtrurerrr$rrrfr8r6rr2sHL#'+/6:)-26+"#6{#CD+%+<( + d223 + ! +d../+  $ $[,%> ?+r8rc jeZdZUejed<ejed<ee ed<ee ed<ee ed<ee ed<e jej ed<ded ed eej(d eej,d eeef d Zdej ddfdZdefdZdeeedeedeej@dee!fdZ"dee#ddfdZ$d)dee#ddfdZ%dZ& d*de!dejNfdZ(dejNddfdZ)d+dZ*d ed!ee!de+fd"Z, d,d ed#ee-e.d$ee/e0d!ee!de1e.e0ff d%Z2 d,d ed#ee-e.d$ee/e0d!ee!de3e.e0ff d&Z4 d,d ed#ee-e.d$ee/e0d!ee!de5e.e0ff d'Z6 d,d ed#ee-e.d$ee/e0d!ee!de7e.e0ff d(Z8y)-rMr;r<_unary_unary_interceptors_unary_stream_interceptors_stream_unary_interceptors_stream_stream_interceptors _active_callstargetoptionsrkr*rGcg|_g|_g|_g|_|Q|D]K}t |t r|jj |0t |tr|jj |\t |tr|jj |t |tr|jj |tdj|djt jzdjtjzdjtjzdjtjztj|_tj t#j$|t'||||j|_t+j,|_y)aConstructor. 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{}. )rrrrrLrappendrrrrKformatrYr get_working_loopr;r`r encoder7r<weakrefWeakSetr)rPrrrkr*rG interceptors r6rRzChannel.__init__os&*,&*,'*,'+-(  #+  k+FG2299+F -IJ33::;G -IJ33::;G -JK44;;KH$188E"//*E*N*NOP"//*F*O*OPQ#//*F*O*OPQ!--(E(N(NO P $,,. )) NN6 " &w <  JJ   %__.r8rqr+Nc|jj||j|jjy)z-Register a call to be tracked by the channel.N)raddadd_done_callbackdiscard)rPrqs r6rozChannel._register_calls0 t$ t1199:r8cK|Swr-rfrPs r6 __aenter__zChannel.__aenter__s  sexc_typeexc_valexc_tbcBK|jdd{y7wr-_close)rPrrrs r6 __aexit__zChannel.__aexit__s kk$ gracecK|jjry|r|dkrd|d}t||jjdtj ddfd}t |j}|r_|Dcgc]3}|js!|jj||5}}|rtj||d{|D]}|j|j|jj|jjycc}w7ew)Nrz grace must be non-negative, got .rqr+c`K |jd{y7#t$rYywxYwwr-)code Exception)rqs r6_wait_for_call_to_completez2Channel._close.._wait_for_call_to_completes- iik!!   s(.. +.+.)rj)r<closedrKclosingrCalllistrdoner; create_taskr]waitcancelclearclose)rPrrQrcallsrq call_taskss r6rzChannel._closes$ ==   !  UQY:5'CIY' '  :?? t T''( "yy{ &&'A$'GHJ ll:u=== D KKM      " ! >sA?D?8D89D?D=A&D?cBK|j|d{y7wr-r)rPrs r6rz Channel.closeskk%   rct|dr6|jjs|jjyyy)Nr<)hasattrr<rrrs r6__del__zChannel.__del__s4 4 $T]]-A-A-C MM   !.D $r8try_to_connectc^|jj|}tj|Sr-)r<check_connectivity_stater 1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY)rPrresults r6 get_statezChannel.get_states)77GHHPPr8last_observed_statecK|jj|jddd{}|s d}t|y7w)Nrz:gRPC channel connectivity state watch failed unexpectedly.)r<watch_connectivity_statevalue RuntimeError)rPrresolvedrQs r6wait_for_state_changezChannel.wait_for_state_changesU??  % %a ($  L y) )  s-AAAcK|jd}|tjjk7rJ|j |d{|jd}|tjjk7rIyy76w)NT)r)rrdChannelConnectivityREADYr)rPstates r6 channel_readyzChannel.channel_readysgd3t//555,,U3 3 3NN$N7Et//555 3sAA?A=3A?;A?rD_registered_methodcd|sy|jjtj|S)a; Get the registered call handle for a registered method or None. This is a semi-private method. It is intended for use only by gRPC generated code. This method is not thread-safe. It is acceptable since method is only called during multicallable construction, not during RPC exeution. Moreover there are no `await` suspension points, which can interleave. Args: method: Required, the method name for the RPC. Returns: The registered call handle pointer in the form of a Python Long. r)r<get_registered_call_handler r)rPrDrs r6_get_registered_call_handlez#Channel._get_registered_call_handle s($"}}77v8NOOr8rErFc t|jtj||||j|g|j |j ||Sr-)rhr<r rrr;rrPrDrErFrs r6 unary_unaryzChannel.unary_unary!sP' MM NN6 "  !  * * F JJ  , ,V5G H  r8c t|jtj||||j|g|j |j ||Sr-)rwr<r rrr;rrs r6 unary_streamzChannel.unary_stream6P( MM NN6 "  !  + + F JJ  , ,V5G H  r8c t|jtj||||j|g|j |j ||Sr-)rzr<r rrr;rrs r6 stream_unaryzChannel.stream_unaryKrr8c t|jtj||||j|g|j |j ||Sr-)rr<r rrr;rrs r6 stream_streamzChannel.stream_stream`sP) MM NN6 "  !  , , F JJ  , ,V5G H  r8r-)F)r+N)NNF)9rYrZr[r]r^r_r r`rrrrrrrrrstrrrChannelCredentialsrdrerrrRror rtype BaseExceptiontypes TracebackTyperurrsrrrrrrrrbrr%r#r r$rhrrwrrzrrrrfr8r6rMrMfsh  $ $$#$?@@ $%A BB $%A BB!%&C!DD??:??332/2/%2/f778 2/ d../ 2/ x(9:; 2/h;:??;t; $ 4 ./ -( ,,-  $  )e_) )V!%!D!" &+Q"Q ! !Q *!55* *08 PP/7~P P6JN -2  %%8%EF  ( !, /  %TN  !l!: ; 0JN -2  %%8%EF  ( !, /  %TN  "+|"; < 0JN -2  %%8%EF  ( !, /  %TN  "+|"; < 0JN -2  %%8%EF  ( !, /  %TN  #; #< = r8rMrrrGc(t||dn|d||S)aCreates 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. Nrf)rM)rrr*rGs r6insecure_channelrus&( o7   r8rkc<t||dn||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. rf)rM _credentials)rrkrr*rGs r6secure_channelrs,, o7    r8)NNN)Ar\r]rtypingrrrrrrrrdr r r grpc._cythonr typing_extensionsr rr_callrrrr _interceptorrrrrrrrrr _metadatar_typingrr r!r"r#r$r%_utilsr&r'r __version__r2rer7r:rhrwrzrrMrrrrrfr8r6rs= BB !"#""!+54437665(*!( !((19JK&--.>.J.JK %4   ) *$**+8$567   @.2.2:>  (() *$**+  8$567   r8