codekingpro/portable-devtools
114k
1�
2 ��j� � �| � S r SSKrSSKrSSKJr SSKJr SSKJr SSKJr Sr " S S \R 5 r S3 r g) z'Utilities for the gRPC Python Beta API.� N)�implementations)�4interfaces)�
callable_util)�futurez6Exception calling connectivity future "done" callback!c �n � \ rS rSrS rS rS rS rS rS r S r5SS6 jr SS jr SS jr
S
rS rS rSrg )�_ChannelReadyFuture� c �n � [ R " 5 U l Xl SU l SU l / U l g )NF)� threading� Condition�7_condition�_channel�_matured�8_cancelled�_done_callbacks)�self�channels �YD:\code\apps\devtools\python\user_packages\Python313\site-packages\grpc/beta/utilities.py�__init__� _ChannelReadyFuture.__init__ s- � �#�-�-�/��� �
� ��
� ��� !�� � c �� � Uc S O[ R " 5 U- nU R U R ( a [ R " 5 eU R9 ( a10 S S S 5 g Uc U R R
5 OLU[ R " 5 -11 nUS: a [ R " 5 eU R R
US9 M� ! , ( d f g = f)Nr )�timeout)�timer
r r �CancelledErrorr �wait� TimeoutError)r r �until� remainings r �_block�_ChannelReadyFuture._block' s� � � ���T�Y�Y�[�7�-B��
�_�_���?�?� �/�/�1�1��=�=�� �_� �=��O�O�(�(�*� %�� � � � 3�I� �1�}� $� 1� 1� 3�3��O�O�(�(��(�;� � �_�s �:C�-A,C�12C'c �� � U R U R ( d� U[ R R L ac SU l U R R U R 5 U R R 5 [ U R 5 nS U l O13 S S S 5 g S S S 5 W H n[ R " U[ U 5 M! g ! , ( d f N4= f)NT)r
r r �ChannelConnectivity�READYr r � unsubscribe�_update�14notify_all�tupler r �call_logging_exceptions�$_DONE_CALLBACK_EXCEPTION_LOG_MESSAGE)r � connectivity�done_callbacks�
done_callbacks r r& �_ChannelReadyFuture._update7 s� � �
�_�_��O�O� �J�$B�$B�$H�$H�H� $��
��
�
�)�)�$�,�,�7����*�*�,�!&�t�';�';�!<��'+��$�� �_� %� � ,�M� � 1� 1� � C�T�
� ,� �_�s �BC�15C&c � � U R U R ( dc SU l U R R U R16 5 U R R
5 [ U R 5 nS U l O17 S S S 5 g S S S 5 W H n[ R " U[ U 5 M! g! , ( d f N4= f)NTF) r
r r r r% r& r' r( r r r) r* )r r, r- s r �cancel�_ChannelReadyFuture.cancelJ s� � �
�_�_��=�=�"&����
�
�)�)�$�,�,�7����*�*�,�!&�t�';�';�!<��'+��$� � �_� %�
� ,�M� � 1� 1� � C�T�
� ,�18 � �_�s �A6B;�;19C c �h � U R U R sS S S 5 $ ! , ( d f g = f�N)r
r �r s r � cancelled� _ChannelReadyFuture.cancelled\ s � �
�_�_��?�?� �_�_�s � #�201c � � U R U R ( + =( a U R ( + sS S S 5 $ ! , ( d f g = fr3 �r
r r r4 s r �running�_ChannelReadyFuture.running` s) � �
�_�_����&�<�t�}�}�+<� �_�_�s �)A � 21Ac � � U R U R =( d U R sS S S 5 $ ! , ( d f g = fr3 r8 r4 s r �done�_ChannelReadyFuture.doned s# � �
�_�_��?�?�3�d�m�m� �_�_�s � 6�22ANc �& � U R U5 g r3 �r �r r s r �result�_ChannelReadyFuture.resulth � � � � � �G� r c �& � U R U5 g r3 r? r@ s r � exception� _ChannelReadyFuture.exceptionk rC r c �& � U R U5 g r3 r? r@ s r � traceback� _ChannelReadyFuture.tracebackn rC r c �� � U R U R ( d6 U R ( d% U R R U5 S S S 5 g S S S 5 U" U 5 g ! , ( d f N= fr3 )r
r r r �append)r �fns r �add_done_callback�%_ChannelReadyFuture.add_done_callbackq sG � �
�_�_��?�?�4�=�=��$�$�+�+�B�/�� �_�_�23 �4�� �_�s �?A&�&24A4c � � U R U R R U R SS9 S S S 5 g ! , ( d f g = f)NT)�try_to_connect)r
r � subscriber& r4 s r �start�_ChannelReadyFuture.starty s. � �
�_�_� �M�M� #� #�D�L�L�� #� F� �_�_�s �%;�25A c �� � U R U R ( d6 U R ( d% U R R U R26 5 S S S 5 g ! , ( d f g = fr3 )r
r r r r% r& r4 s r �__del__�_ChannelReadyFuture.__del__} s6 � �
�_�_��?�?�4�=�=��
�
�)�)�$�,�,�7� �_�_�s �AA � 27A,)r r r
r r r3 )�__name__�28__module__� __qualname__�__firstlineno__r r r& r0 r5 r9 r< rA rE rH rM rR rU �__static_attributes__� r r r r sD � �"�<� �&�$#�=�4� � � ��G�8r r c �< � [ U 5 nUR 5 U$ )a� Creates a future.Future tracking when an implementations.Channel is ready.29 30Cancelling the returned future.Future does not tell the given31implementations.Channel to abandon attempts it may have been making to32connect; cancelling merely deactivates the return future.Future's33subscription to the given implementations.Channel's connectivity.34 35Args:36 channel: An implementations.Channel.37 38Returns:39 A future.Future that matures when the given Channel has connectivity40 interfaces.ChannelConnectivity.READY.41)r rR )r � ready_futures r �channel_ready_futurer_ � s � � '�w�/�L����� �r )
�__doc__r r � grpc.betar r �grpc.framework.foundationr r r* �Futurer r_ r\ r r �<module>rd s@ �� .� � � &� � 3� ,� =� %�42b8�&�-�-� b8�Jr