Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
_server.cpython-313.pyc321 linesDownload Raw Back to __pycache__
1�

2��j����t�SrSSKJr SSKrSSKrSSKJr SSKrSSKrSSK	r	SSK3r4SSKrSSKrSSK
JrJrJrJrJrJrJrJrJrJrJrJr SSKrSSKJr SSKJr SSKJr SS	KJr SS5KJ r  SSK!J"r" SSK!J#r# SS
K!J$r$ SSK!J%r% SSK!J&r& SSK!J'r' SSK!J(r( SSK!J)r) SSK!J*r* SSK+J,r, \	RZ"\.5r/Sr0Sr1Sr2Sr3Sr4Sr5Sr6Sr7Sr8Sr9Sr:S r;Sr<S!r=S"r>SlS#jr?SmS$jr@SnS&jrASoS'jrBSpS(jrC"S)S*\R�"S*S+5\R�5rF"S,S-\R�5rH"S.S/\H5rI"S0S1\H5rJ"S2S%\K5rLSqS3jrMSrS4jrNSsS5jrOStS6jrPSuS7jrQSvS8jrRSwS9jrSSxS:jrTSwS;jrUSsS<jrV"S=S>\R�5rX"S?S@\K5rYSySAjrZSzS{SBjjr[S|SCjr\S}SDjr]S~SEjr^SqSFjr_SSGjr`S�SHjraS�SIjrbS�SJjrcS�SKjrdS�SLjreS�SMjrfS�SNjrgS�SOjrhS�SPjriS�SQjrjS�SRjrkS�SSjrlS�STjrmS�SUjrn\R�"SVSW\R�55rq"SXSY\K5rrS�SZjrsS�S[jrtS�S\jruS�S]jrvS�S^jrwS�S_jrxS�S`jryS�SajrzS�Sbjr{S�Scjr|S�Sdjr}S�Sejr~S�SfjrS�Sgjr�S�Shjr�"SiSj\GR5r�S�Skjr�g)�z+Service-side implementation of gRPC Python.�)�annotationsN)�futures)�Any�Callable�Dict�Iterable�Iterator�List�Mapping�Optional�Sequence�Set�Tuple�Union)�_common)�_compression)�_interceptor)�_observability)�cygrpc)�ArityAgnosticMethodHandler)�ChannelArgumentType)�DeserializingFunction)�MetadataType)�NullaryCallbackType)�ResponseType)�SerializingFunction)�ServerCallbackTag)�ServerTagCallbackType)�override�shutdown�request_call�receive_close_on_server�send_initial_metadata�receive_message�send_messagez$send_initial_metadata * send_message�send_status_from_serverz/send_initial_metadata * send_status_from_server�open�closed�	cancelledg�?ge��Ac�<�URSR5$�Nr)�batch_operations�message)�
request_events �RD:\code\apps\devtools\python\user_packages\Python313\site-packages\grpc/_server.py�_serialized_requestr0Vs���)�)�!�,�4�4�6�6�c�~�[RRU5nUc[RR6$U$�N)r�!STATUS_CODE_TO_CYGRPC_STATUS_CODE�getr�7StatusCode�unknown)�code�cygrpc_codes  r/�_application_coder:Zs4���;�;�?�?��E�K�(3�(;�6���$�$�L��Lr1�	_RPCStatec�z�URc[RR$[	UR5$r3)r8rr6�okr:��states r/�_completion_coder@_s-���z�z��� � �#�#�#��U�Z�Z�(�(r1c�J�URcU$[UR5$r3)r8r:)r?r8s  r/�_abortion_coderBes"��
�z�z�����U�Z�Z�(�(r1c�8�URcS$UR$)Nr1)�detailsr>s r/�_detailsrEms���-�-�'�3�:�U�]�]�:r1c��\rSrSrSrg)�_HandlerCallDetails�q�N)�__name__�8__module__�__qualname__�__firstlineno__�__static_attributes__rIr1r/rGrGqs��	r1rG)�method�invocation_metadatac�l�\rSrSr\R9SSj5r\R10SSj5rSrg)�_Method�~c��[5er3��NotImplementedError��selfs r/�name�_Method.names��!�#�#r1c��[5er3rU�rX�handler_call_detailss  r/�handler�_Method.handler�s
��"�#�#r1rIN��returnz
Optional[str]�r]rGra�Optional[grpc.RpcMethodHandler])	rJrKrLrM�abc�abstractmethodrYr^rNrIr1r/rRrR~sD�����$��$�	���$�$7�$�	(�$��$r1rRc�V�\rSrSrSSjr\SSj5r\S	Sj5rSrg)11�_RegisteredMethod�c��XlX lgr3��_name�_registered_handler)rXrY�registered_handlers   r/�__init__�_RegisteredMethod.__init__�s��12�13�#5� r1c��UR$r3)rkrWs r/rY�_RegisteredMethod.name�s���z�z�r1c��UR$r3)rlr\s  r/r^�_RegisteredMethod.handler�s���'�'�'r1rjN)rY�strrmrcr`rb�	rJrKrLrMrnrrYr^rNrIr1r/rgrg�sQ��6��6�<�6������(�$7�(�	(�(��(r1rgc�R�\rSrSrSSjr\SSj5r\S	Sj5rSrg)14�_GenericMethod�c��Xlgr3��_generic_handlers)rX�generic_handlerss  r/rn�_GenericMethod.__init__�s15��"2�r1c��gr3rIrWs r/rY�_GenericMethod.name�s��r1c�Z�URHnURU5nUcMUs $ gr3)r{�service)rXr]�generic_handler�method_handlers    r/r^�_GenericMethod.handler�s6�� $�5�5�O�,�4�4�5I�J�N��)�%�%� 6�r1rzN)r|�List[grpc.GenericRpcHandler]r`rbrurIr1r/rwrw�sG��2�6�2������	�$7�	�	(�	��	r1rwc��\rSrSr%S\S'S\S'\\rS\S'S\S	'S16\S'S\S
'S17\S'S\S'S\S'S\S'S18\S'S\S'S\S'S19\S'SrSr	g)r;�zcontextvars.Context�contextzthreading.Condition�	conditionr�requestrt�client�bool�initial_metadata_allowed�Optional[grpc.Compression]�compression_algorithm�disable_next_compression�Optional[MetadataType]�trailing_metadatazOptional[grpc.StatusCode]r8�Optional[bytes]rD�statusedzList[Exception]�20rpc_errorsz#Optional[List[NullaryCallbackType]]�	callbacks�abortedc�:�[R"5Ul[R"5Ul[
5UlSUl[Ul21SUlSUlSUl
SUlSUlSUlSUl/Ul/UlSUlg�NTF)�contextvars�Contextr��	threading�	Conditionr��set�duer��_OPENr�r�r�r�r�r8rDr�r�r�r�rWs r/rn�_RPCState.__init__�s���"�*�*�,���"�,�,�.����5���������(,��%�%)��"�(-��%�!%�����	������
���������r1)r�r�r�r8r�r�r�rDr�r�r�r�r�r�r�N)22rJrKrLrM�__annotations__rrtr�rnrNrIr1r/r;r;�s`��
 � �"�"�23
�c�(�C�
�L��K�"�"�5�5�"�"�-�-�24#�#�
���N���2�2�
�M�r1c�f�[R"5nURRU5 Uer3)�grpc�RpcErrorr��append)r?�	rpc_errors  r/�_raise_rpc_errorr��s&���
�
��I�	�����I�&�25�Or1c��URRU5 [U5(d'UR(dURnSUlX4$g)N�NrI)r��remove�_is_rpc_state_activer�)r?�tokenr�s   r/�_possibly_finish_callr��sC��26�I�I���U����&�&�u�y�y��O�O�	�������r1c�^^�UU4SjnU$)Nc�j>�TR [TT5sSSS5 $!,(df   g=fr3)r�r�)�$unused_send_status_from_server_eventr?r�s ��r/r&�9_send_status_from_server.<locals>.send_status_from_server�s���
�_�_�(���6��_�_�s�$�272rI)r?r�r&s`` r/�_send_status_from_serverr��s���7�#�"r1c��UR UR(aF[R"UR54nUcUsSSS5 $U[	U5-sSSS5 $UsSSS5 $!,(df   g=fr3)r�r�r�!compression_algorithm_to_metadata�tuple)r?�metadata�compression_metadatas   r/�_get_initial_metadatar��si��28����&�&��>�>��/�/��$� �29��+�30��(�%��/�9�31���32���s�7A0�
A0�%A0�033A>c�N�[R"[X5[5nU$r3)r�SendInitialMetadataOperationr��_EMPTY_FLAGS)r?r��	operations   r/�_get_initial_metadata_operationr�s&���3�3��e�.���I��r1c���UR[La�[X5nURcUOURnUR(a:[US5[R"URUU[54n[nO.[R"URUU[54n[nURU[X55 SUlURR!U5 gg�NT)r��34_CANCELLEDrBrDr�r�r�SendStatusFromServerOperationr�r��8_SEND_INITIAL_METADATA_AND_SEND_STATUS_FROM_SERVER_TOKEN�_SEND_STATUS_FROM_SERVER_TOKEN�start_server_batchr�r�r��add)r?�callr8rD�effective_code�effective_details�35operationsr�s        r/�_abortr�s���
�|�|�:�%�'��4��',�}�}�'<�G�%�-�-���)�)�/��t�<��4�4��+�+�"�%� �	��J�M�E��4�4��+�+�"�%� �	��J�3�E�����0��>�	36����
�	�	�
�
�e��9&r1c�^�U4SjnU$)Nc�>>�TR URSR5(a[TlOTR[37La[TlTRR5 [T[5sSSS5 $!,(df   g=fr+)38r�r,r)r�r�r��_CLOSED�39notify_allr��_RECEIVE_CLOSE_ON_SERVER_TOKEN)�receive_close_on_server_eventr?s �r/r"�9_receive_close_on_server.<locals>.receive_close_on_server.sc���
�_�_�,�=�=�a�@�J�J�L�L�)�������&�&����O�O�&�&�(�(��0N�O�
�_�_�s�A6B�40BrI)r?r"s` r/�_receive_close_on_serverr�-s���P�#�"r1c�^^^�UUU4SjnU$)Nc�0>�[U5nUc^TR TR[La[TlTRR5 [
T[5sSSS5 $[R"UT5nTR Uc'[TT[RRS5 OUTlTRR5 [
T[5sSSS5 $!,(df   g=f!,(df   g=f)Ns Exception deserializing request!)r0r�r�r�r�r�r��_RECEIVE_MESSAGE_TOKENr�deserializer�rr6�internalr�)�receive_message_event�serialized_requestr�r��request_deserializerr?s   ���r/r$�)_receive_message.<locals>.receive_message?s����0�1F�G���%�����<�<�5�(�#*�E�L����*�*�,�,�U�4J�K�	!���)�)�"�$8��G�����?�����)�)�2�2�;�	�%,�E�M����*�*�,�,�U�4J�K�!��!���!��s�AC6�AD�641D�42DrI)r?r�r�r$s``` r/�_receive_messager�:s���43L�2�r1c�^�U4SjnU$)Nc�r>�TR [T[5sSSS5 $!,(df   g=fr3)r�r��_SEND_INITIAL_METADATA_TOKEN)�"unused_send_initial_metadata_eventr?s �r/r#�5_send_initial_metadata.<locals>.send_initial_metadata\s���
�_�_�(��0L�M��_�_�s�(�446rI)r?r#s` r/�_send_initial_metadatar�[s���N�!� r1c�^^�UU4SjnU$)Nc�>�TR TRR5 [TT5sSSS5 $!,(df   g=fr3)r�r�r�)�unused_send_message_eventr?r�s ��r/r%�#_send_message.<locals>.send_messageds.���
�_�_��O�O�&�&�(�(���6��_�_�s	�&>�45ArI)r?r�r%s`` r/�
_send_messager�cs���7�46�r1c��\rSrSr%S\S'S\S'S\S'S SjrS!S	jrS"S47jrS#SjrS$Sjr	S#S
jr48S%SjrS&SjrS'Sjr
S(SjrS)SjrS*SjrS+SjrS,SjrS%SjrS-SjrS.SjrS/SjrS0SjrS1SjrS2SjrS#SjrSrg)3�_Contextil�cygrpc.BaseEvent�49_rpc_eventr;�_state�Optional[DeserializingFunction]r�c�(�XlX lX0lgr3)r�r��_request_deserializer)rX�	rpc_eventr?r�s    r/rn�_Context.__init__qs��$����%9�"r1c��URR [UR5sSSS5 $!,(df   g=fr3)r�r�r�rWs r/�	is_active�_Context.is_active{s'��
�[�[�
"�
"�'����4�#�
"�
"�s	�6�50Ac��[URRR[R"5-51S5$r+)�maxr��call_details�deadline�timerWs r/�time_remaining�_Context.time_remainings*���4�?�?�/�/�8�8�4�9�9�;�F��J�Jr1c�L�URRR5 gr3)r�r��cancelrWs r/r��_Context.cancel�s�������#�#�%r1c���URR URRc52SSS5 gURRRU5 SSS5 g!,(df   g=f)NFT)r�r�r�r�)rX�callbacks  r/�add_callback�_Context.add_callback�sS��
�[�[�
"�
"��{�{�$�$�,��#�
"�
�K�K�!�!�(�(��2��	#�
"�
"�s�A(�&A(�(53A6c��URR SURlSSS5 g!,(df   g=fr�)r�r�r�rWs r/� disable_next_message_compression�)_Context.disable_next_message_compression�s'��
�[�[�
"�
"�37�D�K�K�0�#�
"�
"�s	�2�54Ac�.�URR$r3)r�rPrWs r/rP�_Context.invocation_metadata�s�����2�2�2r1c�r�[R"URRR	55$r3)r�decoder�r��peerrWs r/r�
_Context.peer�s$���~�~�d�o�o�2�2�7�7�9�:�:r1c�V�[R"URR5$r3)r�peer_identitiesr�r�rWs r/r�_Context.peer_identities�s���%�%�d�o�o�&:�&:�;�;r1c��[R"URR5nUcU$[R55"U5$r3)r�peer_identity_keyr�r�rr56)rX�id_keys  r/r�_Context.peer_identity_key�s4���)�)�$�/�/�*>�*>�?����v�C�W�^�^�F�-C�Cr1c���[R"URR5nUc0OUnUR	5VVs0sHup4[57R"U5U_M snn$s snnfr3)r�auth_contextr�r��itemsrr58)rXr�auth_context_dict�key�values     r/r�_Context.auth_context�si���*�*�4�?�?�+?�+?�@��".�"6�B�L��0�5�5�7�59�7�60��
�N�N�3���&�7�61�	62��63s�#A,c��URR XRlSSS5 g!,(df   g=fr3)r�r�r�)rX�compressions  r/�set_compression�_Context.set_compression�s%��
�[�[�
"�
"�0;�K�K�-�#�
"�
"���1�64?c�0�URR URR[La[	UR5 URR65(a�[
URU5nURRRU4[UR55 SURlURRR[5 O
Sn[U5eSSS5 g!,(df   g=f)NFz#Initial metadata no longer allowed!)r�r�r�r�r�r�r�r�r�r�r�r�r�r��66ValueError)rX�initial_metadatar��	error_msgs    r/r#�_Context.send_initial_metadata�s���
�[�[�
"�
"��{�{�!�!�Z�/� ����-��{�{�3�3�;��K�K�!1��	����$�$�7�7��L�"8����"E��8=����4������#�#�$@�A�A�	� ��+�+�B�#�
"�
"�s�C&D�67Dc��URR XRlSSS5 g!,(df   g=fr3)r�r�r�)rXr�s  r/�set_trailing_metadata�_Context.set_trailing_metadata�s%��
�[�[�
"�
"�,=�K�K�)�#�
"�
"�rc�.�URR$r3)r�r�rWs r/r��_Context.trailing_metadata�s���{�{�,�,�,r1c��U[RR:Xa1[R	S5 [RR68nSnURR XRl[R"U5URlSURl[5e!,(df   g=f)Nz4abort() called with StatusCode.OK; returning UNKNOWN�T)r�r6�OK�_LOGGER�error�UNKNOWNr�r�r8r�encoderDr��	Exception)rXr8rDs   r/�abort�_Context.abort�s����4�?�?�%�%�%��M�M�F�
��?�?�*�*�D��G�
�[�[�
"�
"�#�K�K��")�.�.��"9�D�K�K��"&�D�K�K���+��	#�
"�s
�&AB7�769Cc��URURlURURUR5 gr3)r�r�r2r8rD)rX�statuss  r/�abort_with_status�_Context.abort_with_status�s*��(.�(@�(@����%��70�71�6�;�;����/r1c��URR XRlSSS5 g!,(df   g=fr3)r�r�r8)rXr8s  r/�set_code�_Context.set_code�s%��
�[�[�
"�
"�#�K�K��#�
"�
"�rc�.�URR$r3)r�r8rWs r/r8�
_Context.code�s���{�{���r1c��URR [R"U5URlSSS5 g!,(df   g=fr3)r�r�rr0rD)rXrDs  r/�set_details�_Context.set_details�s0��
�[�[�
"�
"�")�.�.��"9�D�K�K��#�
"�
"�s�&A�72Ac�.�URR$r3)r�rDrWs r/rD�_Context.details�s���{�{�"�"�"r1c��gr3rIrWs r/�_finalize_state�_Context._finalize_state�s��r1)r�r�r�N)r�r�r?r;r�r�)rar�)ra�float�ra�None)rrrar�)rar�)rart)razOptional[Sequence[bytes]]r`)razMapping[str, Sequence[bytes]])rzgrpc.CompressionrarG)r"rrarG)r�rrarG)r8�grpc.StatusCoderDrtrarG)r5zgrpc.StatusrarG)r8rHrarG)rarH)rDrtrarG)ra�bytes)rJrKrLrMr�rnr�r�r�rrrPrrrrrr#r&r�r2r6r9r8r>rDrCrNrIr1r/r�r�ls��� � ���9�9�:�#�:��:�>�	:�5�K�&��8�3�;�<�D�73�<�,�">�-��0�$� �:�#�
r1r�c��\rSrSr%S\S'S\S'S\S'SSjrSS	jrSS74jrSSjrSSjr	SS
jr75SSjrSrg)�_RequestIteratori�r;r��cygrpc.Call�_callr�r�c�(�XlX lX0lgr3)r�rMr�)rXr?r�r�s    r/rn�_RequestIterator.__init__�s�����76�%9�"r1c���URR[La[UR5 g[	UR5(d77[5eURR[R"[54[URURUR55 URRR[5 gr3)r�r�r�r�r��
StopIterationrMr�r�ReceiveMessageOperationr�r�r�r�r�r�rWs r/�_raise_or_start_receive_message�0_RequestIterator._raise_or_start_receive_message�s����;�;����+��T�[�[�)�%�d�k�k�2�2��/�!��J�J�)�)��/�/��=�?� ��K�K����T�-G�-G��
�
�K�K�O�O��� 6�7r1c�J�URR[La[UR5 [5eURRc([78URR;a79[5eURRnSURlU$r3)	r�r�r�r�r�r�r�rQ�AssertionError�rXr�s  r/�_look_for_request�"_RequestIterator._look_for_requestsu���;�;����+��T�[�[�)����
�K�K���'�&�d�k�k�o�o�=��/�!��k�k�)�)�G�"&�D�K�K���Nr1c���URR UR5 URRR5 UR	5nUbUsSSS5 $MD!,(df   g=fr3)r�r�rS�waitrXrWs  r/�_next�_RequestIterator._nexts_��
�[�[�
"�
"��0�0�2�����%�%�*�*�,��0�0�2���&�"�
#�
"��#�
"�s�A80A-�+A-�-81A;c��U$r3rIrWs r/�__iter__�_RequestIterator.__iter__s���r1c�"�UR5$r3�r\rWs r/�__next__�_RequestIterator.__next__����z�z�|�r1c�"�UR5$r3rbrWs r/�next�_RequestIterator.next rer1)rMr�r�N)r?r;r�rLr�r�rF)rar)rarK)
rJrKrLrMr�rnrSrXr\r_rcrgrNrIr1r/rKrK�sS������:�:�:��:��:�>�	:�8�
�#���r1rKc�^^^�UUU4SjnU$)Nc	�>�TR [T5(d82SSS5 gTRR[R83"[54[TTRT55 TRR[5 TRR5 TRc�TR[LasSRTR R"5n[%TTR[R&R([*R,"U55 SSS5 gTR[.La84SSS5 gOTRnSTlUsSSS5 $M�!,(df   g=f)Nz*"{}" requires exactly one request message.)r�r�r�r�rrRr�r�r�r�r�r[r�r�r��formatr�rOr�r6�
unimplementedrr0r�)rDr�r�r�r?s  ���r/�
unary_request�%_unary_request.<locals>.unary_request)s4���
�_�_�'��.�.���_�
�N�N�-�-��/�/��=�?� ��	���8L�M�
�
�I�I�M�M�0�1�����$�$�&��=�=�(��|�|�w�.�H�O�O� )� 6� 6� =� =�� �85�!�%�N�N�"�-�-�;�;�#�N�N�7�3�	� $�/�_�0�|�|�z�1�#�3�_�02�$�m�m�G�$(�E�M�"�;�_���_�s#�E>�DE>�E>�E>�<E>�>86FrI)r�r?r�rms``` r/�_unary_requestro$s���87#�@�r1c�`�SSKJn U"XU5nSnUb88U"X7U5nOU"X75nUS4sSSS5 $![Ga[n	UR UR(a1[UUR[RRS5 O�X�R;a�SRU	5n89Oe![aX Sn90[R[R"[!U	5U	U	R"55 [R$"5 Of=f[RU915 [UUR[RR[&R("U9255 SSS5 O!,(df   O=fSn	A	SSS5 gSn	A	ff=f!,(df   g=f)Nr)�_create_servicer_contextT�RPC Abortedz!Exception calling application: {}z1Calling application raised unprintable Exception!�NF)r�rqr1r�r�r�r�rr6r7r�rkr-�	exception�	traceback�format_exception�type�
__traceback__�	print_excrr0)r�r?�behavior�argumentr��send_response_callbackrqr��response_or_iteratorrtrDs           r/�_call_behaviorr~Ls~��.�	!��.�93�	�*	�#'� �%�1�'/��'=�(�$�(0��'B�$�'��-�94�95���!	�����=�=���!����)�)�1�1�&�	��&6�&6�6�.�"E�"L�"L�%�#���%�.�O� � �)�)�%�6�6� $�Y�� )� )� 7� 7���"�+�+�-�.���%�%�g�.���!����)�)�1�1����w�/�	�5!����@�[96�97��!	��98�99�sk�F�6�F�F�
AE9� B2�1E9�2AD	�E9�D	�AE9�0	F�9100F�F�101F�F�F�102F-c103�&�[U5S4$![a g[a�nUR UR(a1[UUR[RRS5 OyX1R;ajSRU5n[RU5 [UUR[RR[R"U55 SSS5 O!,(df   O=fSnAgSnAff=f)NTr�rrz!Exception iterating responses: {}rs)rgrQr1r�r�r�r�rr6r7r�rkr-rtrr0)r�r?�response_iteratorrtrDs     r/�%_take_response_from_response_iteratorr��s���104��%�&��,�,�������
�_�_��}�}����N�N��%�%�-�-�"�	��"2�"2�2�=�D�D�Y�O���!�!�'�*����N�N��%�%�-�-��N�N�7�+�	��_�_��"��%�s1��105D�	D�D�B<C5�,	D�5106D	�?D�Dc���[R"X#5nUcFUR [UUR[107RRS5 SSS5 gU$!,(df   g=f)NsFailed to serialize response!)r�	serializer�r�r�rr6r�)r�r?�response�response_serializer�serialized_responses     r/�_serialize_responser��sc��"�+�+�H�J���"�
�_�_�������!�!�*�*�0�	
������_��s�1A"�"108A0c�d�UR(a[RR$[$r3)r�r�	WriteFlag�no_compressr�r>s r/�%_get_send_message_op_flags_from_stater��s%��
�%�%����+�+�+��r1c�^�UR SUlSSS5 g!,(df   g=frs)r�r�r>s r/�_reset_per_message_stater��s��	���).��&�109���s��110,c�l�UR [U5(d111SSS5 gUR(a:[US5[R112"U[
U554nSUl[nO'[R113"U[
U554n[nURRU[X55 URRU5 [U5 URR5 XAR;a[U5sSSS5 $M?!,(df   g=frs)r�r�r�r�r�SendMessageOperationr��-_SEND_INITIAL_METADATA_AND_SEND_MESSAGE_TOKEN�_SEND_MESSAGE_TOKENr�r�r�r�r�r�r[)r�r?r�r�r�s     r/�_send_responser��s���114���#�E�*�*��115���)�)�/��t�<��+�+�'�9�%�@���J�.3�E�*�A�E��+�+�'�9�%�@���J�(�E����)�)��
�e�3�	116�	�	�	�
�
�e�� ��'���O�O� � �"��I�I�%�+�E�2�;117��4�5118��s�D%�C1D%�#D%�%119D3c	�b�UR UR[La�[U5n[	U5n[120R"URX4[5/nUR(aUR[US55 Ub/UR[121R"U[U555 URRU[!U["55 SUl['U5 UR(R+["5 SSS5 g!,(df   g=fr�)r�r�r�r@rErr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�)r�r?r�r8rDr�s      r/�_statusr��s���122123����<�<�z�)�#�E�*�D��u�o�G��4�4��+�+�T�L���J�124�-�-��!�!�"A�%��"N�O�"�.��!�!��/�/�+�=�e�D���
�N�N�-�-��(��0N�O�
�"�E�N�$�U�+��I�I�M�M�8�9�1125���s�D126D � 127D.c�P�[R"U5 U"5nUb1[XX&U5upxU(a[XXu5n	U	b[	XU	5 [R"5 g![128a [R"5 N7f=f![R"5 f=fr3)	r�'install_context_from_request_call_eventr~r�r�r1rury�uninstall_context)129r�r?rz�argument_thunkr�r�r{r��proceedr�s130          r/�_unary_response_in_poolr�s����2�2�9�=�#�!�#���� .��(�6J�!��H��&9��h�'�#�'�2��I�.A�B�	� � �"����������	� � �"�s#�;A)�)B�B�131B�B�B%c	�^^^�[R"T5 SUUU4SjjnU"5nUbU[US5(a UR(a[	TTUUUUS9 O$[	TTX'U5up�U	(a
[TTXh5 [R"5 g![a [R"5 N7f=f![R"5 f=f)Nc�f>�Uc[TTS5 g[TTUT5nUb[TTU5 ggr3)r�r�r�)r�r�r�r�r?s  ���r/�
send_response�/_stream_response_in_pool.<locals>.send_response-sD������I�u�d�+�"5��5�(�,?�#��#�.��y�%�1D�E�/r1�experimental_non_blocking)r|)r�rrarG)132rr��hasattrr�r~�3_send_message_callback_to_blocking_iterator_adapterr1ruryr�)133r�r?rzr�r�r�r�r{r�r�s134``   `    r/�_stream_response_in_poolr�#s�����2�2�9�=�F�F�#�!�#������"=�>�>��6�6������(�+8�
�.<��u�h�:N�.�*�!��G�!�5�-��	� � �"����������	� � �"�s/�:B�B?� $B�B<�9B?�;B<�<B?�?Cc�V�UR[L=(a UR(+$r3)r�r�r�r>s r/r�r�Ts���<�<�z�)�@�%�.�.�.@�@r1c�h�[XU5upEU(aU"U5 [U5(dgOgM2r3)r�r�)r�r?r|r�r�r�s      r/r�r�XsD���A��/�135����"�8�,�'��.�.��/�
�r1c��[US5(a5[UR[R5(aUR$U$)N�experimental_thread_pool)r��136isinstancer�r�ThreadPoolExecutor)rz�default_thread_pools  r/� _select_thread_pool_for_behaviorr�jsC���x�3�4�4���)�)�7�+E�+E�:�:��0�0�0��r1c137���[XUR5n[URU5nUR	UR138R[UUURUURUR5$r3)	ror�r��unary_unary�submitr��runr�r��r�r?r�r�rm�thread_pools      r/�_handle_unary_unaryr�usz��#��.�=�=��M�3��"�"�$7��K����
�
�
�����
��"�"���+�+��*�*�	�	r1c139���[XUR5n[URU5nUR	UR140R[UUURUURUR5$r3)	ror�r��unary_streamr�r�r�r�r�r�s      r/�_handle_unary_streamr��sz��#��.�=�=��M�3��#�#�%8��K����
�
�
��� ��
��#�#���+�+��*�*�	�	r1c141�^�[XRUR5m[URU5nURURR[UUURU4SjURUR5$)Nc�>�T$r3rI��request_iterators�r/�<lambda>�&_handle_stream_unary.<locals>.<lambda>����� r1)142rKr�r�r��stream_unaryr�r�r�r�r��r�r?r�r�r�r�s     @r/�_handle_stream_unaryr��s����(�
�~�~�~�B�B���3��#�#�%8��K����
�
�
�����
��#�#� ��+�+��*�*�	�	r1c143�^�[XRUR5m[URU5nURURR[UUURU4SjURUR5$)Nc�>�T$r3rIr�s�r/r��'_handle_stream_stream.<locals>.<lambda>�r�r1)144rKr�r�r��
stream_streamr�r�r�r�r�r�s     @r/�_handle_stream_streamr��s����(�
�~�~�~�B�B���3��$�$�&9��K����
�
�
��� ��
��$�$� ��+�+��*�*�	�	r1c�R^�SU4SjjnTR5nU(d*[R"URR5n[UUR5nUb&URRURXF5$URRXF5$)Nc�&>�TRU5$r3)r^)r]�method_with_handlers �r/�query_handlers�,_find_method_handler.<locals>.query_handlers�s���#�*�*�+?�@�@r1rb)145rYrr146r�rOrGrPr�r��execute)r�r?r��interceptor_pipeliner��method_namer]s  `    r/�_find_method_handlerr��s����A�1�A�	(�A�147&�*�*�,�K���n�n�Y�%;�%;�%B�%B�C��.���%�%���148�'��}�}� � � �(�(�.�149�	150��=�=���^�B�Br1c��^�[TS5[R"[5[R"SX#[54nUR151R
UU4Sj5 g)Nc�>�TS4$r�rI)�_ignored_event�	rpc_states �r/r��_reject_rpc.<locals>.<lambda>�s����� 152r1)r�r�ReceiveCloseOnServerOperationr�r�r�r�)r�r�r5rDr�s `   r/�_reject_rpcr��sU���	(�	�4�8��,�,�\�:��,�,��&�<�	153��J��N�N�%�%��	154�r1c��UR URR[R"[15554[
U55 URR[5 UR(a;UR(a[XX#5sSSS5 $[XX#5sSSS5 $UR(a[XX#5sSSS5 $[XX#5sSSS5 $!,(df   g=fr3)r�r�r�rr�r�r�r�r�r��request_streaming�response_streamingr�r�r�r�)r�r?r�r�s    r/�_handle_with_method_handlerr�s���156������)�)�
�
1�
1�,�
?�A�$�U�+�	157�	�	�	�
�
�4�5��+�+��0�0�,��n��158��(��.��159���,�,�'��.��160��$#��n�161�%162���s�BC2�"C2�7C2�C2�2163Dc�`�UR(dgURR(dUR5(a�[	5n[UUUU5nUc*[UU[RRS5 US4$U(a*[UU[RRS5 US4$U[!XXc54$g![aZnSRU5n[RU5 [UU[RRS5 US4sSnA$SnAff=f)a�Handles RPC based on provided handlers.164 165  When receiving a call event from Core, registered method will have its166name as tag, we pass the tag as registered_method_name to this method,167then we can find the handler in registered_method_handlers based on168the method name.169 170  For call event with unregistered method, the method name will be included171in rpc_event.call_details.method and we need to query the generics handlers172to find the actual handler.173)NNzException servicing handler: {}sError in service handler!NsMethod not found!sConcurrent RPC limit exceeded!)�successr�rOrYr;r�r1rkr-rtr�rr6r7rl�resource_exhaustedr�)	r�r�r�r��concurrency_exceededr�r�rtrDs	         r/�_handle_callr�#s/��$�������$�$�(;�(@�(@�(B�(B��K�	�	#�1���#�$�	�N� �!�����!�!�/�/�$�	
��d�?�"������!�!�4�4�1�	
��d�?�"��'��n�
�174�	175���A�		#�7�>�>�y�I�G����g�&�����!�!�)�)�,�	
��d�?�"��		#�s�C	�	176D-�AD(�"D-�(D-c� �\rSrSrSrSrSrSrg)�_ServerStageic�stopped�started�gracerIN)rJrKrLrM�STOPPED�STARTED�GRACErNrIr1r/r�r�cs���G��G��Er1r�c���\rSrSr%S\S'S\S'S\S'S\S	'S177\S'S\S
'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S#S jrS!rg")$�_ServerStateijzthreading.RLock�lock�cygrpc.CompletionQueue�completion_queue�
cygrpc.Server�serverr�r|� Dict[str, grpc.RpcMethodHandler]�registered_method_handlers�'Optional[_interceptor._ServicePipeline]r��futures.ThreadPoolExecutorr�r��stage�threading.Event�termination_eventzList[threading.Event]�shutdown_events�
Optional[int]�maximum_concurrent_rpcs�int�active_rpc_countzSet[_RPCState]�178rpc_stateszSet[str]r�r��server_deallocatedc�|�[R"5UlXlX l[U5UlX@lXPl[RUl[R"5Ul
UR/UlX`lSUl0Ul[%5Ul[%5UlSUlg)NrF)r��RLockr�r�r��listr|r�r�r�r�r��Eventr�r�r�r�r�r�r�r�r�)rXr�r�r|r�r�r�s       r/rn�_ServerState.__init__|s����O�O�%��	� 0���� $�%5� 6���$8�!�&��!�)�)��179�!*���!2��� $� 6� 6�7���'>�$� !���*,��'��%����5���#(��r1)r�r�r�r|r�r�r�r�r�r�r�r�r�r�r�N)r�r�r�r�r|� Sequence[grpc.GenericRpcHandler]r�r�r�r�r�r�)rJrKrLrMr�rnrNrIr1r/r�r�js���180��,�,���2�2� @�@�A�A�+�+���&�&�*�*�*�*�����	�M���(�0�(��(�;�	(�181F�(�0�
(�"/�(r1r�c��UR URRU5 SSS5 g!,(df   g=fr3)r�r|�extend)r?r|s  r/�_add_generic_handlersr�s*��182���
���%�%�&6�7�183����	�2�184Ac��UR URRU5 SSS5 g!,(df   g=fr3)r�r��update)r?�method_handlerss  r/�_add_registered_method_handlersr�s)��185���
�(�(�/�/��@�186���rc��UR URRU5sSSS5 $!,(df   g=fr3)r�r��add_http2_port)r?�addresss  r/�_add_insecure_portr�s%��	����|�|�*�*�7�3�187���s	�2�188Ac��UR URRXR5sSSS5 $!,(df   g=fr3)r�r�r	�_credentials)r?r189�server_credentialss   r/�_add_secure_portr�s0��190191����|�|�*�*��4�4�192�193���s	�%<�194A195c��URRURUR[5 URR[5 gr3)r�r!r��_REQUEST_CALL_TAGr�r�r>s r/�
_request_callr�s;��	�L�L���
���� 6� 6�8I��196�I�I�M�M�#�$r1c��UnURRURURUU5 URR	U5 gr3)r��request_registered_callr�r�r�)r?rO�registered_call_tags   r/�_request_registered_callr�sE�� ��	�L�L�(�(�
���
�����	�197�I�I�M�M�%�&r1c���UR(ddUR(dSURR5 URHnUR5 M [RUlggr�)	r�r�r��destroyr�r�r�r�r�)r?�shutdown_events  r/�
_stop_servingr�sP�����E�I�I�
������#�3�3�N���� �4�"�*�*����r1c�z�UR U=RS-slSSS5 g!,(df   g=f)N�)r�r�r>s r/�_on_call_completedr�s$��	���
���!�#��198���s�,�199:c��^�SnUR[LaHTR TRR	[5 [T5(aSnSSS5 U$UR[LdURTR;Ga�SnURTR;a3URn[UTRRUS55nO[TR5nTR TRR	UR5 TRSL=(a TRTR:�n[UUTRTR U5upgUbTR"R%U5 Ub*T=RS-
sl
UR'U4Sj5 TR([*R,La)UTR;a
[/TU5 O[1T5 O[T5(aSnSSS5 U$URU5uphUHn	U	"5 M
 UbDTR TR"R	U5 [T5(aSnSSS5 U$U$!,(df   U$=f!,(df   U$=f![2a [4R7S5 M�f=f!,(df   U$=f)NTFrc�>�[T5$r3)r)�_unused_futurer?s �r/r��-_process_event_and_continue.<locals>.<lambda>s���+=�e�+Dr1zException calling callback!)�tag�
_SHUTDOWN_TAGr�r�r�rrr�rgr5rwr|r�r�r�r�r�r�r��add_done_callbackr�r�r�rrr1r-rt)200r?�event�should_continue�registered_method_namer�r�r��201rpc_futurer�rs202`         r/�_process_event_and_continuer)�s�����O��y�y�M�!�
�Z�Z��I�I���]�+��U�#�#�"'���x��o	�	�	�&�&��9�9��8�8�8�!%���9�9��8�8�8�%*�Y�Y�"�"3�&��0�0�4�4�*�D��#��#1��&�&�#���Z�Z��I�I���U�Y�Y�'��-�-�T�9�L��*�*�e�.K�.K�K�
!�%1��#��*�*��!�!�$�%�!�I��$�� � �$�$�Y�/��%��&�&�!�+�&��,�,�D���{�{�l�2�2�2�)�U�-M�-M�M�,�U�4J�K�!�%�(��u�%�%�"'��5�N�� %�y�y��/��	�!�H�
A��203�"�204� ����� � �'�'�	�2� ��'�'�&+�O����?��y�Z�x���O�Z�N����
A��!�!�"?�@�
A������s6�2J�=DJ"�<J4�.K�205J�"206J1�4K�K�207K)c�0�[R"5[-nURRU5nUR(a[U5 UR[RR:HnU(d[X5(dgSnM�r3)r��"_DEALLOCATED_SERVER_CHECK_PERIOD_Sr��pollr��_begin_shutdown_once�completion_typer�CompletionType�
queue_timeoutr))r?�timeoutr%�208is_timeouts    r/�_server3s{��209��)�)�+� B�B���&�&�+�+�G�4���#�#� ��'��!�!�V�%:�%:�%H�%H�H�	��"=�e�"K�"K����r1c�F�UR UR[RLa^URRUR[5 [RUlURR[5 SSS5 g!,(df   g=fr3)r�r�r�r�r�r r�r#r�r�r�r>s r/r-r-0s\��	����;�;�,�.�.�.��L�L�!�!�%�"8�"8�-�H�&�,�,�E�K��I�I�M�M�-�(�	210���s�A<B�211B c�4^^^�TR TR[RLa0[R212"5mTR
5 TsSSS5 $[T5 [R213"5mTRRT5 TcTRR5 O7UUU4Sjn[R"US9nUR5 TsSSS5 $SSS5 TR5 T$!,(df   N =f)Nc�>�TRTS9 TR TRR5 SSS5 g!,(df   g=f�N)r1)r[r�r��cancel_all_calls)r�rr?s���r/�cancel_all_calls_after_grace�+_stop.<locals>.cancel_all_calls_after_graceEs5����#�#�E�#�2��Z�Z��L�L�1�1�3� �Z�Z�s�A�214A)�target)r�r�r�r�r�r�r�r-r�r�r�r8�Thread�startr[)r?r�r9�threadrs``  @r/�_stopr?8s����	����;�;�,�.�.�.�&�_�_�.�N���� �!�	215��216	�U�#�"���*��
���$�$�^�4��=��L�L�)�)�+�
4�217�%�%�-I�J�F��L�L�N�!�'218��
,�219�(������+220��s�AD	�BD	�	221Dc��UR UR[RLa
Sn[	U5eUR222R
5 [RUlURHn[X5 M [U5 [R"[U4S9nSUlUR
5 SSS5 g!,(df   g=f)Nz$Cannot start already-started server!)r;�argsT)r�r�r�r�r!r�r=r�r�rrr�r<r3�daemon)r?r#rOr>s    r/�_startrCQs���	����;�;�l�2�2�2�>�I��Y�'�'�
������"�*�*����6�6�F�$�U�3�7�	�e���!�!��u�h�?����
�����223���s�B4C224�225 226Cc�X�UH$n[USS5nUbMSUS3n[U5e g)Nr��"zP" must conform togrpc.GenericRpcHandler type but does not have "service" method!)�getattr�AttributeError)�generic_rpc_handlers�generic_rpc_handler�service_attributer#s    r/�_validate_generic_rpc_handlersrKbsL�� 4��#�$7��D�I���$��'�(�)R�R�
�!��+�+� 4r1c�|�[R"U5n[R"U5n[	U5U-U-$r3)r�create_channel_optionr�(create_server_call_tracer_factory_optionr�)�base_optionsr�xds�compression_option�'maybe_server_call_tracer_factory_options     r/�_augment_optionsrSosG��227&�;�;�K�H���?�?��D�,�	�l��228�	�2291�	2�r1c��\rSrSr%S\S'SSjrSSjrSSjrSSjrSSjr	SS	jr230SSSjjrSSjrS
r
Srg231)�_Serverir�r�c���[R"5n[R"[XFU5U5n	U	R	U5 [UU	U[R"U5UU5UlX�l	gr3)232r�CompletionQueue�ServerrS�register_completion_queuer�r�service_pipeliner��233_cy_server)234rXr�r|�interceptors�optionsr�rrPr�r�s235          r/rn�_Server.__init__�sj��"�1�1�3�����/��c�J�C�P���(�(�)9�:�"�����)�)�,�7��#�
236���!�r1c�F�[U5 [URU5 gr3)rKrr�)rXrHs  r/�add_generic_rpc_handlers� _Server.add_generic_rpc_handlers�s��	'�';�<��d�k�k�+?�@r1c��URR URR[RLa237SSS5 gSSS5 UR5VVs0sHup4[R"X5U_M nnnUHnURRU5 M  [URU5 g!,(df   N�=fs snnfr3)r�r�r�r�r�rr�fully_qualified_methodr[�register_methodr)rX�service_namerrOr��method_to_handlersrcs       r/�add_registered_method_handlers�&_Server.add_registered_method_handlers�s����[�[�
�
��{�{� � �L�$8�$8�8���
�8��+:�*?�*?�*A�238�*A�&��
�*�*�<�@�.�P�*A�	�239�'9�"��O�O�+�+�,B�C�'9�'����5G�H��
��240241s�)C�%#C�242Cc	��[R"U[UR[R"U555$r3)r�validate_port_binding_resultrr�r0)rXr243s  r/�add_insecure_port�_Server.add_insecure_port�s/���3�3��'����W�^�^�G�5L�M�244�	245r1c	��[R"U[UR[R"U5U55$r3)rrjrr�r0)rXr246rs   r/�add_secure_port�_Server.add_secure_port�s7���3�3������W�^�^�G�4�6H�
�247�	248r1c�.�[UR5 gr3)rCr�rWs r/r=�
_Server.start�s���t�{�{�r1Nc��[R"URRRURRRUS9$r7)rr[r�r��is_set)rXr1s  r/�wait_for_termination�_Server.wait_for_termination�s>���|�|��K�K�)�)�.�.��K�K�)�)�0�0��249�	250r1c�.�[URU5$r3)r?r�)rXr�s  r/�stop�_Server.stop�s���T�[�[�%�(�(r1c�J�[US5(aSURlgg)Nr�T)r�r�r�rWs r/�__del__�_Server.__del__�s"���4��"�"�.2�D�K�K�*�#r1)r[r�)r�r�r|r�r\� Sequence[grpc.ServerInterceptor]r]�Sequence[ChannelArgumentType]r�r�rr�rPr��rH� Iterable[grpc.GenericRpcHandler]rarG)rertrr�rarG)r251rtrar�)r252rtr�grpc.ServerCredentialsrar�rFr3)r1�Optional[float]rar�)r�r�rar�)rJrKrLrMr�rnr`rgrkrnr=rtrwrzrNrIr1r/rUrUs�����!�/�!�;�!�7�	!�253/�!�"/�
!�0�!��!�.A�$D�A�	
�A�I��I�:�I�254�	I�&255�256257��258�0F�259�	�260��261�)�2r1rUc	�:�[U5 [UUUUUUU5$r3)rKrU)r�rHr\r]r�rrPs       r/�
create_serverr��s/��#�#7�8����������r1)r.r�rarI)r8rHra�cygrpc.StatusCode)r?r;rar�)r?r;r8r�rar�)r?r;rarI)r?r;rarG)r?r;r�rtrar)r?r;r�rtrar)r?r;r�r�rar�)r?r;r�r�razcygrpc.Operation)262r?r;r�rLr8r�rDrIrarG)r?r;rar)r?r;r�rLr�r�rar)r�r�r?r;r�r�ra�Callable[[], Any]r3)r�r�r?r;rzrr{rr�r�r|z(Optional[Callable[[ResponseType], None]]raz8Tuple[Union[ResponseType, Iterator[ResponseType]], bool])r�r�r?r;r��Iterator[ResponseType]razTuple[ResponseType, bool])263r�r�r?r;r�rr��Optional[SerializingFunction]rar�)r?r;razUnion[int, cygrpc.WriteFlag])r�r�r?r;r�rIrar�)r�r�r?r;r�r�rarG)r�r�r?r;rzrr�r�r�r�r�r�rarG)r�r�r?r;rzrr�r�r�r�r�r�rarG)r?r;rar�)264r�r�r?r;r|zCallable[[ResponseType], None]r�r�rarG)rzrr�r�rar�)265r�r�r?r;r��grpc.RpcMethodHandlerr�r�ra�futures.Future)266r�r�r?r;r�rRr�r�rarc)r�r�r�r;r5r�rDrI)267r�r�r?r;r�r�r�r�rar�)r�r�r�rRr�r�r�r�r�r�raz4Tuple[Optional[_RPCState], Optional[futures.Future]])r?r�r|rrarG)r?r�rr�rarG)r?r�r268rIrar�)r?r�r269rIrr�rar�)r?r�rarG)r?r�rOrtrarG)r?r�rar�)r?r�r%r�rar�)r?r�r�r�rar�r~)rOr}rr�rPr�rar})r�r�rHr�r\r|r]r}r�r�rr�rPr�rarU)��__doc__�270__future__rrd�collections�271concurrentrr��enum�loggingr�r�ru�typingrrrrr	r272rrr
rrrr�rrrr�grpc._cythonr�grpc._typingrrrrrrrrr�typing_extensionsr�	getLoggerrJr-r#rr�r�r�r�r�r�r�r�r�r�r�r+�_INF_TIMEOUTr0r:r@rBrE�273namedtuple�HandlerCallDetailsrG�ABCrRrgrw�objectr;r�r�r�r�r�r�r�r�r�r��ServicerContextr�rKror~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��unique�Enumr�r�rrrrrrrrr)r3r-r?rCrKrSrXrUr�rIr1r/�<module>r�s���2�"�274���������
�
�
�
�������3�,�.�%�,�%�,�*�.�&�275�276�277�H�278%���
�"��!:��6��*��$��*�.�";��5�9�	��279��
�280���%(�"���7�M�281)�)��)�-�)��)�;�282	�����	283��	���284	�	$�c�g�g�	$�(��(�(�W��0 �� �F���� ����#�
��
� 6�
��
� ��� 6�������'��/@��KP��	��D285#����286��:���	�B!��v
�t�#�#�v
�r<�v�<�~%��%��%�:�%��	%�\HL�
7��7��7�)�7��	7�287:�7�E�
7�>�7�t�����.���	�<�������7�	�288��&���!��/�289 3�� 3�(1� 3�HM� 3�	� 3�F:��:��:�)�:�290�	:�@#��#��#�)�#�&�	#�2918�#�7�
#�292�#�8.#��.#��.#�)�.#�&�	.#�293:�.#�7�
.#�294�.#�bA������;��.�	�295296��$�(��3�� �������*��4�	�297��0�����*��4�	�298��0�����*��4�	�299��0�����*��4�	�300��0C��C��C�!�C�B�	C�301%�C�6�����
���	�,302��303��304�*�305�,�	306�307�308�:=��=� �=�B�=�,�	=�309�=�:�
=�@����4�9�9��
��-(�6�-(�`8��8�+K�8�	�8�A��A�*J�A�	�A�4�310311��312�
�313�/�314�	�	315�%�'��$�A��A� 0�A�	�A�H�")��2�"316,�:�317,�	�318,�
�/�
�+�
�319�
�#�	
� W2�d�k�k�W2�t�+��:��3��+�	�320+��,�
�321��
�r1
codekingpro/portable-devtools · Team Ai