← Back
Editing: transports.cpython-313.opt-2.pyc
� M��i8* � � � S r " S S5 r " S S\5 r " S S\5 r " S S\\5 r " S S \5 r " S S \5 r " S S\5 rg))� BaseTransport� ReadTransport�WriteTransport� Transport�DatagramTransport�SubprocessTransportc �D � \ rS rSrSrS S jrS S jrS rS rS r S r Sr g) r � ��_extraNc � � Uc 0 nXl g �Nr )�self�extras �9/opt/alt/python313/lib64/python3.13/asyncio/transports.py�__init__�BaseTransport.__init__ s � � �=��E�� � c �8 � U R R X5 $ r )r �get)r �name�defaults r �get_extra_info� BaseTransport.get_extra_info s � ��{�{���t�-�-r c � � [ er ��NotImplementedError�r s r � is_closing�BaseTransport.is_closing � � �!�!r c � � [ er r r s r �close�BaseTransport.close s � � "�!r c � � [ er r )r �protocols r � set_protocol�BaseTransport.set_protocol% r r c � � [ er r r s r � get_protocol�BaseTransport.get_protocol) r r r ) �__name__� __module__� __qualname__�__firstlineno__� __slots__r r r r" r& r) �__static_attributes__� r r r r s' � � �I� � .�"�"�"�"r r c �* � \ rS rSrSrS rS rS rSrg)r �. r1 c � � [ er r r s r � is_reading�ReadTransport.is_reading3 r r c � � [ er r r s r � pause_reading�ReadTransport.pause_reading7 � � � "�!r c � � [ er r r s r �resume_reading� ReadTransport.resume_reading? r: r N) r+ r, r- r. r/ r5 r8 r< r0 r1 r r r r . s � � �I�"�"�"r r c �L � \ rS rSrSrS S jrS rS rS rS r S r S r S r Sr g) r �H r1 Nc � � [ er r �r �high�lows r �set_write_buffer_limits�&WriteTransport.set_write_buffer_limitsM s � �& "�!r c � � [ er r r s r �get_write_buffer_size�$WriteTransport.get_write_buffer_sizeb r r c � � [ er r r s r �get_write_buffer_limits�&WriteTransport.get_write_buffer_limitsf s � � "�!r c � � [ er r )r �datas r �write�WriteTransport.writel r: r c �H � SR U5 nU R U5 g )Nr )�joinrN )r � list_of_datarM s r � writelines�WriteTransport.writelinest s � � �x�x� �%�� � � �4�r c � � [ er r r s r � write_eof�WriteTransport.write_eof} � � � "�!r c � � [ er r r s r � can_write_eof� WriteTransport.can_write_eof� r r c � � [ er r r s r �abort�WriteTransport.abort� rX r �NN)r+ r, r- r. r/ rD rG rJ rN rS rV rZ r] r0 r1 r r r r H s1 � � �I�"�*"�"� "��"�"�"r r c � � \ rS rSrSrSrg)r � r1 N)r+ r, r- r. r/ r0 r1 r r r r � s � �* �Ir r c �( � \ rS rSrSrSS jrS rSrg)r � r1 Nc � � [ er r )r rM �addrs r �sendto�DatagramTransport.sendto� s � � "�!r c � � [ er r r s r r] �DatagramTransport.abort� rX r r )r+ r, r- r. r/ rf r] r0 r1 r r r r � s � � �I� "�"r r c �< � \ rS rSrSrS rS rS rS rS r S r Sr g ) r �� r1 c � � [ er r r s r �get_pid�SubprocessTransport.get_pid� r r c � � [ er r r s r �get_returncode�"SubprocessTransport.get_returncode� r: r c � � [ er r )r �fds r �get_pipe_transport�&SubprocessTransport.get_pipe_transport� r r c � � [ er r )r �signals r � send_signal� SubprocessTransport.send_signal� r: r c � � [ er r r s r � terminate� SubprocessTransport.terminate� s � � "�!r c � � [ er r r s r �kill�SubprocessTransport.kill� s � � "�!r N) r+ r, r- r. r/ rm rp rt rx r{ r~ r0 r1 r r r r � s% � ��I�"�"�"�"� "� "r r c �\ ^ � \ rS rSrSrS U 4S jjrS rS rS rS S jr S S jr S r S r U =r $ ) �_FlowControlMixin� )�_loop�_protocol_paused� _high_water� _low_waterc �^ >� [ TU ] U5 X l SU l U R 5 g )NF)�superr r� r� �_set_write_buffer_limits)r r �loop� __class__s �r r �_FlowControlMixin.__init__ s) �� � ���� �� � %�� � �%�%�'r c �N � U R 5 nXR :: a g U R ( d# SU l U R R 5 g g ! [ [ 4 a e [ a4 nU R R SUU U R S.5 S nAg S nAff = f)NTz protocol.pause_writing() failed��message� exception� transportr% ) rG r� r� � _protocol� pause_writing� SystemExit�KeyboardInterrupt� BaseExceptionr� �call_exception_handler)r �size�excs r �_maybe_pause_protocol�'_FlowControlMixin._maybe_pause_protocol s� � ��)�)�+�� �#�#� #� ��$�$�$(�D� !� ����,�,�.� %�� � 1�2� �� � �� � �1�1� @�!$�!%� $��� 3� � �� �s �A �B$�0*B � B$c �L � U R ( aB U R 5 U R :: a# SU l U R R 5 g g g ! [ [ 4 a e [ a4 nU R R SUU U R S.5 S nAg S nAff = f)NFz protocol.resume_writing() failedr� ) r� rG r� r� �resume_writingr� r� r� r� r� )r r� s r �_maybe_resume_protocol�(_FlowControlMixin._maybe_resume_protocol) s� � � � !� !��*�*�,����?�$)�D� !� ����-�-�/� @� "�� � 1�2� �� � �� � �1�1� A�!$�!%� $��� 3� � �� �s �A �B#�/*B � B#c �2 � U R U R 4$ r )r� r� r s r rJ �)_FlowControlMixin.get_write_buffer_limits9 s � �����!1�!1�2�2r c � � Uc Uc SnOSU- nUc US- nXs=:� a S:� d O [ SU< SU< S35 eXl X l g )Ni � � zhigh (z) must be >= low (z) must be >= 0)� ValueErrorr� r� rA s r r� �*_FlowControlMixin._set_write_buffer_limits< sb � � �<��{� ���3�w�� �;��!�)�C�� �a� � ���� 2�3�'� �H�J� J� �� �r c �B � U R XS9 U R 5 g )N)rB rC )r� r� rA s r rD �)_FlowControlMixin.set_write_buffer_limitsL s � � �%�%�4�%�9� �"�"�$r c � � [ er r r s r rG �'_FlowControlMixin.get_write_buffer_sizeP s � �!�!r )r� r� r� r� r_ )r+ r, r- r. r/ r r� r� rJ r� rD rG r0 � __classcell__)r� s @r r� r� � s3 �� �" K�I�(��$� 3� � %�"� "r r� N)�__all__r r r r r r r� r1 r r �<module>r� sg �� �� ""� ""�J"�M� "�4I"�]� I"�X� �~� �0"� � "�63"�-� 3"�lT"� � T"r
Save File
Cancel