
    kCi8                        S r SSKrSSK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r " S S\R$                  5      r " S S\R(                  5      rS rS r " S S\R0                  5      rS rS rS rS rS r " S S\R>                  " SS5      \R@                  5      r!S r"S r# " S  S!\RH                  5      r% " S" S#\RL                  5      r'S$ r(g)%zCTranslates gRPC's server-side API into gRPC's server-side Beta API.    N)_common)	_metadata)
interfaces)cardinality)style)abandonment)logging_pool)stream)face   c                   &    \ rS rSrS rS rS rSrg)_ServerProtocolContext#   c                     Xl         g N_servicer_contextselfservicer_contexts     Y/var/www/html/land-ocr/venv/lib/python3.13/site-packages/grpc/beta/_server_adaptations.py__init___ServerProtocolContext.__init__$       !1    c                 6    U R                   R                  5       $ r   )r   peerr   s    r   r   _ServerProtocolContext.peer'   s    %%**,,r   c                     g r    r   s    r   !disable_next_response_compression8_ServerProtocolContext.disable_next_response_compression*   s    r   r   N)__name__
__module____qualname____firstlineno__r   r   r"   __static_attributes__r!   r   r   r   r   #   s    2-r   r   c                   V    \ rS rSrS rS rS rS rS rS r	S r
S	 rS
 rS rS rSrg)_FaceServicerContext.   c                     Xl         g r   r   r   s     r   r   _FaceServicerContext.__init__/   r   r   c                 6    U R                   R                  5       $ r   )r   	is_activer   s    r   r/   _FaceServicerContext.is_active2   s    %%//11r   c                 6    U R                   R                  5       $ r   )r   time_remainingr   s    r   r2   #_FaceServicerContext.time_remaining5   s    %%4466r   c                     Sn[        U5      e)Nz6add_abortion_callback no longer supported server-side!)NotImplementedError)r   abortion_callback	error_msgs      r   add_abortion_callback*_FaceServicerContext.add_abortion_callback8   s    L	!),,r   c                 8    U R                   R                  5         g r   )r   cancelr   s    r   r;   _FaceServicerContext.cancel<   s    %%'r   c                 ,    [        U R                  5      $ r   )r   r   r   s    r   protocol_context%_FaceServicerContext.protocol_context?   s    %d&<&<==r   c                 ^    [         R                  " U R                  R                  5       5      $ r   )r   betar   invocation_metadatar   s    r   rB   (_FaceServicerContext.invocation_metadataB   s     ~~d44HHJKKr   c                 b    U R                   R                  [        R                  " U5      5        g r   )r   send_initial_metadatar   unbeta)r   initial_metadatas     r   rG   %_FaceServicerContext.initial_metadataE   s%    44-.	
r   c                 b    U R                   R                  [        R                  " U5      5        g r   )r   set_terminal_metadatar   rF   )r   terminal_metadatas     r   rK   &_FaceServicerContext.terminal_metadataJ   s%    44./	
r   c                 :    U R                   R                  U5        g r   )r   set_code)r   codes     r   rO   _FaceServicerContext.codeO   s    ''-r   c                 :    U R                   R                  U5        g r   )r   set_details)r   detailss     r   rS   _FaceServicerContext.detailsR   s    **73r   r   N)r$   r%   r&   r'   r   r/   r2   r8   r;   r>   rB   rG   rK   rO   rS   r(   r!   r   r   r*   r*   .   s:    227-(>L



.4r   r*   c                    ^  U 4S jnU$ )Nc                 (   > T" U [        U5      5      $ r   r*   )requestr   unary_request_inlines     r   
adaptation/_adapt_unary_request_inline.<locals>.adaptationW   s    #)*:;
 	
r   r!   )rY   rZ   s   ` r   _adapt_unary_request_inliner\   V       

 r   c                    ^  U 4S jnU$ )Nc                 (   > T" U [        U5      5      $ r   rW   )request_iteratorr   stream_request_inlines     r   rZ   0_adapt_stream_request_inline.<locals>.adaptation`   s    $23CD
 	
r   r!   )ra   rZ   s   ` r   _adapt_stream_request_inlinerc   _   r]   r   c                   >    \ rS rSrS rS rS rS rS rS r	S r
S	rg
)	_Callbackh   c                 b    [         R                  " 5       U l        / U l        SU l        SU l        g NF)	threading	Condition
_condition_values_terminated
_cancelledr   s    r   r   _Callback.__init__i   s(    #--/ r   c                     U R                      U R                  R                  U5        U R                   R                  5         S S S 5        g ! , (       d  f       g = fr   )rk   rl   append
notify_allr   values     r   consume_Callback.consumeo   s5    __LL&OO&&( __s   6A
Ac                     U R                      SU l        U R                   R                  5         S S S 5        g ! , (       d  f       g = fNT)rk   rm   rr   r   s    r   	terminate_Callback.terminatet   s+    __#DOO&&( __	   "8
Ac                     U R                      U R                  R                  U5        SU l        U R                   R	                  5         S S S 5        g ! , (       d  f       g = frx   )rk   rl   rq   rm   rr   rs   s     r   consume_and_terminate_Callback.consume_and_terminatey   s=    __LL&#DOO&&( __s   =A
A!c                     U R                      SU l        U R                   R                  5         S S S 5        g ! , (       d  f       g = frx   )rk   rn   rr   r   s    r   r;   _Callback.cancel   s*    __"DOOO&&( __r{   c                 d   U R                       U R                  (       a  [        R                  " 5       eU R                  (       a$  U R                  R                  S5      sS S S 5        $ U R                  (       a
   S S S 5        g U R                   R                  5         M  ! , (       d  f       g = fNr   )rk   rn   r   	Abandonedrl   poprm   waitr   s    r   draw_one_value_Callback.draw_one_value   sv    __??%//11\\<<++A. _ %% _ OO((*  _s   AB!*B!B!!
B/c                 4   U R                       U R                  (       a  [        R                  " 5       eU R                  (       a'  [        U R                  5      nS U l        UsS S S 5        $ U R                   R                  5         Mz  ! , (       d  f       g = fr   )rk   rn   r   r   rm   tuplerl   r   )r   
all_valuess     r   draw_all_values_Callback.draw_all_values   si    __??%//11%%!&t||!4J#'DL% _ OO((*  _s   AB	-B		
B)rn   rk   rm   rl   N)r$   r%   r&   r'   r   ru   ry   r}   r;   r   r   r(   r!   r   r   re   re   h   s%     )
)
))

+
+r   re   c                    ^ ^^^ [         R                  " 5       mUU UU4S jn[         R                  " US9nSUl        UR	                  5         g )Nc                  
  > T Hl  n TR                  5       (       a  TR                  5       (       a    g TR                  U 5        TR                  5       (       a  TR                  5       (       d  Ml    g    TR                  5         g r   )r/   is_setru   ry   )rX   request_consumerr`   r   thread_joineds    r   pipe_requests/_run_request_pipe_thread.<locals>.pipe_requests   si    'G#--//=3G3G3I3I$$W-#--//=3G3G3I3I ( 	""$r   )targetT)ri   EventThreaddaemonstart)r`   r   r   r   request_pipe_threadr   s   ```  @r   _run_request_pipe_threadr      sC     OO%M% % $**-@!%r   c                    ^  U 4S jnU$ )Nc                    > [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" U UR
                  [        U5      5        UR                  5       S   $ r   )re   add_callbackr;   r   r   r}   r*   r   )rX   r   callbackunary_unary_events      r   rZ   ,_adapt_unary_unary_event.<locals>.adaptation   sa    ;,,X__==''))** !12	

 '')!,,r   r!   )r   rZ   s   ` r   _adapt_unary_unary_eventr      s    	- r   c                    ^  U 4S jnU$ )Nc              3      >#    [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" X[        U5      5         UR                  5       nUc  g Uv   M  7fr   )re   r   r;   r   r   r*   r   )rX   r   r   responseunary_stream_events       r   rZ   -_adapt_unary_stream_event.<locals>.adaptation   sk     ;,,X__==''))34DE	
 ..0H s   A-A0r!   )r   rZ   s   ` r   _adapt_unary_stream_eventr      s     r   c                    ^  U 4S jnU$ )Nc                    > [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" UR
                  [        U5      5      n[        XU5        UR                  5       S   $ r   )	re   r   r;   r   r   r}   r*   r   r   )r`   r   r   r   stream_unary_events       r   rZ   -_adapt_stream_unary_event.<locals>.adaptation   sq    ;,,X__==''))-** !12
 	!0@	
 '')!,,r   r!   )r   rZ   s   ` r   _adapt_stream_unary_eventr      s    - r   c                    ^  U 4S jnU$ )Nc              3      >#    [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" U[        U5      5      n[        XU5         UR                  5       nUc  g Uv   M  7fr   )re   r   r;   r   r   r*   r   r   )r`   r   r   r   r   stream_stream_events        r   rZ   ._adapt_stream_stream_event.<locals>.adaptation   s~     ;,,X__=='')).*+;<
 	!0@	
 ..0H s   A9A<r!   )r   rZ   s   ` r   _adapt_stream_stream_eventr      s    " r   c                       \ rS rSrSrg)_SimpleMethodHandler   r!   N)r$   r%   r&   r'   r(   r!   r   r   r   r      s      	r   r   _MethodHandler)request_streamingresponse_streamingrequest_deserializerresponse_serializerunary_unaryunary_streamstream_unarystream_streamc                    U R                   [         R                  R                  L Ga;  U R                  [        R                  R
                  L a%  [        SSUU[        U R                  5      S S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS [        U R                  5      S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S [        U R                  5      S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S S [        U R                  5      5      $  [3        5       eU R                   [         R                  R                   L Ga0  U R                  [        R                  R
                  L a%  [        SSUU[#        U R$                  5      S S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS ['        U R(                  5      S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S [+        U R,                  5      S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S S [/        U R0                  5      5      $ [3        5       e)NFT)r   ServiceINLINEr   CardinalityUNARY_UNARYr   r\   unary_unary_inlineUNARY_STREAMunary_stream_inlineSTREAM_UNARYrc   stream_unary_inlineSTREAM_STREAMstream_stream_inlineEVENTr   r   r   r   r   r   r   r   
ValueError)implementationr   r   s      r   _simple_method_handlerr   
  s    u}}333%%)@)@)L)LL'$#+N,M,MN	 	 %%)@)@)M)MM'$#+N,N,NO	 	 %%)@)@)M)MM'$#,"66   %%)@)@)N)NN'$#,"77  Ot ,[ 
		!4!4	4%%)@)@)L)LL'$#()I)IJ	 	 %%)@)@)M)MM'$#).*K*KL	 	 %%)@)@)M)MM'$#).*K*KL	 	 %%)@)@)N)NN'$#*>+M+MN	 	 ,r   c                 x    U =(       d    0 n 0 nU  H&  n[         R                  " US   US   5      nX   X'   M(     U$ )Nr      )r   fully_qualified_method)method_pair_mapflat_mapmethod_pairmethods       r   _flatten_method_pair_mapr   n  sG    %+OH&//AAO*7 ' Or   c                        \ rS rSrS rS rSrg)_GenericRpcHandleriw  c                 p    [        U5      U l        [        U5      U l        [        U5      U l        X l        g r   )r   _method_implementations_request_deserializers_response_serializers_multi_method_implementation)r   method_implementationsmulti_method_implementationrequest_deserializersresponse_serializerss        r   r   _GenericRpcHandler.__init__x  sB     (@"(
$ '?!'
# &> &
" -H)r   c                 L   U R                   R                  UR                  5      nUbS  [        UU R                  R                  UR                  5      U R
                  R                  UR                  5      5      $ U R                  c  g  g ! [        R                   a     g f = fr   )	r   getr   r   r   r   r   r   NoSuchMethodError)r   handler_call_detailsmethod_implementations      r   service_GenericRpcHandler.service  s     $ < < @ @ ''!
 !,)%++//0D0K0KL**../C/J/JK 
 ,,4	%% 		s   B#"B#)r   r   r   r   N)r$   r%   r&   r'   r   r   r(   r!   r   r   r   r   w  s    H$r   r   c                   >    \ rS rSrS rS rS rS rS rS r	S r
S	rg
)_Serveri  c                     Xl         g r   _grpc_server)r   grpc_servers     r   r   _Server.__init__  s    'r   c                 8    U R                   R                  U5      $ r   )r   add_insecure_port)r   addresss     r   r   _Server.add_insecure_port  s      227;;r   c                 8    U R                   R                  X5      $ r   )r   add_secure_port)r   r   server_credentialss      r   r   _Server.add_secure_port  s      00MMr   c                 8    U R                   R                  5         g r   r   r   r   s    r   r   _Server.start  s    !r   c                 8    U R                   R                  U5      $ r   r   stop)r   graces     r   r   _Server.stop  s      %%e,,r   c                 :    U R                   R                  5         U $ r   r   r   s    r   	__enter___Server.__enter__  s    !r   c                 :    U R                   R                  S 5        grh   r   )r   exc_typeexc_valexc_tbs       r   __exit___Server.__exit__  s    t$r   r   N)r$   r%   r&   r'   r   r   r   r   r   r  r  r(   r!   r   r   r   r     s&    (<N"-r   r   c                     [        U UUU5      nUc   [        R                  " Uc  [        OU5      nOUn[	        [
        R                  " Xv4S95      $ )N)handlers)r   r	   pool_DEFAULT_POOL_SIZEr   grpcserver)service_implementationsr   r   r   thread_poolthread_pool_sizegeneric_rpc_handlereffective_thread_pools           r   r  r    se     -#	  , 1 1"2":@P!
 !,)4JK r   ))__doc__collectionsri   r  r   	grpc.betar   r   grpc.framework.commonr   r   grpc.framework.foundationr   r	   r
   grpc.framework.interfaces.facer   r  GRPCServicerContextr   ServicerContextr*   r\   rc   Consumerre   r   r   r   r   r   
namedtupleRpcMethodHandlerr   r   r   GenericRpcHandlerr   Serverr   r  r!   r   r   <module>r!     s    J        - ' 1 2 , /  Z;; %44// %4P2+ 2+j &$"*			
 		&aH"// "Jj 2r   