[EDIT] FILE: transports.cpython-312.opt-2.pyc
� �{|j�) � � � d Z G d� d� Z G d� de� Z G d� de� Z G d� dee� Z G d � d e� Z G d � d e� Z G d � de� Zy))� BaseTransport� ReadTransport�WriteTransport� Transport�DatagramTransport�SubprocessTransportc �: � e Zd Z dZd d�Zd d�Zd� Zd� Zd� Zd� Z y) r ��_extraNc � � |�i }|| _ y �Nr )�self�extras �+/usr/lib64/python3.12/asyncio/transports.py�__init__zBaseTransport.__init__ s � � �=��E��� � c �< � | j j ||� S r )r �get)r �name�defaults r �get_extra_infoz BaseTransport.get_extra_info s � �1��{�{���t�W�-�-r c � � t �r ��NotImplementedError�r s r � is_closingzBaseTransport.is_closing s � �@�!�!r c � � t �r r r s r �closezBaseTransport.close � � � � "�!r c � � t �r r )r �protocols r � set_protocolzBaseTransport.set_protocol% s � �!�!�!r c � � t �r r r s r � get_protocolzBaseTransport.get_protocol) s � �*�!�!r r ) �__name__� __module__� __qualname__� __slots__r r r r r! r# � r r r r s( � �$��I� � .�"�"�"�"r r c �$ � e Zd Z dZd� Zd� Zd� Zy)r r( c � � t �r r r s r � is_readingzReadTransport.is_reading3 s � �8�!�!r c � � t �r r r s r � pause_readingzReadTransport.pause_reading7 � � � � "�!r c � � t �r r r s r �resume_readingz ReadTransport.resume_reading? r. r N)r$ r% r& r' r+ r- r0 r( r r r r . s � �-��I�"�"�"r r c �D � e Zd Z dZd d�Zd� Zd� Zd� Zd� Zd� Z d � Z d � Z y) r r( Nc � � t �r r �r �high�lows r �set_write_buffer_limitsz&WriteTransport.set_write_buffer_limitsM s � � �$ "�!r c � � t �r r r s r �get_write_buffer_sizez$WriteTransport.get_write_buffer_sizeb s � �:�!�!r c � � t �r r r s r �get_write_buffer_limitsz&WriteTransport.get_write_buffer_limitsf s � � %� "�!r c � � t �r r )r �datas r �writezWriteTransport.writel r. r c �J � dj |� }| j |� y )Nr )�joinr= )r � list_of_datar< s r � writelineszWriteTransport.writelinest s# � � � �x�x� �%�� � � �4�r c � � t �r r r s r � write_eofzWriteTransport.write_eof} � � � � "�!r c � � t �r r r s r � can_write_eofz WriteTransport.can_write_eof� s � �O�!�!r c � � t �r r r s r �abortzWriteTransport.abort� rD r �NN) r$ r% r& r' r6 r8 r: r= rA rC rF rH r( r r r r H s2 � �.��I�"�*"�"� "��"�"�"r r c � � e Zd Z dZy)r r( N)r$ r% r& r' r( r r r r � s � ��( �Ir r c � � e Zd Z dZdd�Zd� Zy)r r( Nc � � t �r r )r r< �addrs r �sendtozDatagramTransport.sendto� r r c � � t �r r r s r rH zDatagramTransport.abort� rD r r )r$ r% r& r' rN rH r( r r r r � s � �2��I�"�"r r c �4 � e Zd ZdZd� Zd� Zd� Zd� Zd� Zd� Z y) r r( c � � t �r r r s r �get_pidzSubprocessTransport.get_pid� s � � �!�!r c � � t �r r r s r �get_returncodez"SubprocessTransport.get_returncode� r. r c � � t �r r )r �fds r �get_pipe_transportz&SubprocessTransport.get_pipe_transport� s � �4�!�!r c � � t �r r )r �signals r � send_signalz SubprocessTransport.send_signal� r. r c � � t �r r r s r � terminatez SubprocessTransport.terminate� s � � � "�!r c � � t �r r r s r �killzSubprocessTransport.kill� s � � � "�!r N) r$ r% r& r' rR rT rW rZ r\ r^ r( r r r r � s% � ��I�"�"�"�"� "� "r r c �N � � e Zd Z dZd � fd� Zd� Zd� Zd� Zd d�Zd d�Z d� Z � xZ S ) �_FlowControlMixin)�_loop�_protocol_paused� _high_water� _low_waterc �` �� t �| � |� || _ d| _ | j � y )NF)�superr ra rb �_set_write_buffer_limits)r r �loop� __class__s �r r z_FlowControlMixin.__init__ s+ �� � ���� ��� � %�� � �%�%�'r c �@ � | j � }|| j k ry | j s#d| _ | j j � y y # t t f$ r � t $ r4}| j j d|| | j d�� Y d }~y d }~ww xY w)NTz protocol.pause_writing() failed��message� exception� transportr ) r8 rc rb � _protocol� pause_writing� SystemExit�KeyboardInterrupt� BaseExceptionra �call_exception_handler)r �size�excs r �_maybe_pause_protocolz'_FlowControlMixin._maybe_pause_protocol s� � ��)�)�+�� �4�#�#� #� ��$�$�$(�D� !� ����,�,�.� %�� � 1�2� �� � �� � �1�1� @�!$�!%� $��� 3� � �� �s �A �B �)*B�B c �< � | j rA| j � | j k r#d| _ | j j � y y y # t t f$ r � t $ r4}| j j d|| | j d�� Y d }~y d }~ww xY w)NFz protocol.resume_writing() failedrk ) rb r8 rd ro �resume_writingrq rr rs ra rt )r rv s r �_maybe_resume_protocolz(_FlowControlMixin._maybe_resume_protocol' s� � � � !� !��*�*�,����?�$)�D� !� ����-�-�/� @� "�� � 1�2� �� � �� � �1�1� A�!$�!%� $��� 3� � �� �s �A �B�'*B�Bc �2 � | j | j fS r )rd rc r s r r: z)_FlowControlMixin.get_write_buffer_limits7 s � �����!1�!1�2�2r c � � |� |�d}nd|z }|�|dz }||cxk\ rdk\ sn t d|�d|�d�� �|| _ || _ y )Ni � � zhigh (z) must be >= low (z) must be >= 0)� ValueErrorrc rd r3 s r rg z*_FlowControlMixin._set_write_buffer_limits: sh � � �<��{� ���3�w�� �;��!�)�C��s� �a� � ���� 2�3�'� �H�J� J� ��� ��r c �J � | j ||�� | j � y )N)r4 r5 )rg rw r3 s r r6 z)_FlowControlMixin.set_write_buffer_limitsJ s! � � �%�%�4�S�%�9� �"�"�$r c � � t �r r r s r r8 z'_FlowControlMixin.get_write_buffer_sizeN s � �!�!r rI ) r$ r% r& r' r rw rz r: rg r6 r8 � __classcell__)ri s @r r` r` � s3 �� �� K�I�(��$� 3� � %�"r r` N)�__all__r r r r r r r` r( r r �<module>r� sj �� � �� ""� ""�J"�M� "�4I"�]� I"�X� �~� �0"� � "�23"�-� 3"�lT"� � T"r
SAVE
CANCEL