�
!A?h1 � �t � d Z ddlZddlZej Z G d� dej � � Z G d� dej � � ZdS )z7Internal classes used by the gzip, lzma and bz2 modules� Nc �* � e Zd ZdZd� Zd� Zd� Zd� ZdS )�
BaseStreamz Mode-checking helper functions.c �2 � | j rt d� � �d S )Nz I/O operation on closed file)�closed�
ValueError��selfs �9/opt/alt/python-internal/lib64/python3.11/_compression.py�_check_not_closedz BaseStream._check_not_closed s% � � �;� =� � ;�<�<� <� =� =� c �V � | � � � st j d� � �d S )NzFile not open for reading)�readable�io�UnsupportedOperationr s r
�_check_can_readzBaseStream._check_can_read �1 � ��}�}��� G��)�*E�F�F� F� G� Gr c �V � | � � � st j d� � �d S )NzFile not open for writing)�writabler r r s r
�_check_can_writezBaseStream._check_can_write r r c � � | � � � st j d� � �| � � � st j d� � �d S )Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r r r �seekabler s r
�_check_can_seekzBaseStream._check_can_seek sl � ��}�}��� G��)� +F� G� G�
G��}�}��� F��)� +E� F� F�
F� F� Fr N)�__name__�
__module__� __qualname__�__doc__r r r r � r r
r r sa � � � � � �)�)�=� =� =�G� G� G�G� G� G�F� F� F� F� Fr r c �j � � e Zd ZdZd� Zdd�Z� fd�Zd� Zd� Zdd �Z d
� Z
d � Z e j
fd �Zd
� Z� xZS )�DecompressReaderz5Adapts the decompressor API to a RawIOBase reader APIc � � dS )NTr r s r
r zDecompressReader.readable$ s � ��tr r c � � || _ d| _ d| _ d| _ || _ || _ | j di | j ��| _ || _ d S )NFr �����r )�_fp�_eof�_pos�_size�_decomp_factory� _decomp_args�
_decompressor�_trailing_error)r �fp�decomp_factory�trailing_error� decomp_argss r
�__init__zDecompressReader.__init__' s` � ������ ��� � ��
� .�� � '��� 1�T� 1� F� F�D�4E� F� F��� .�� � � r c �R �� d | _ t � � � � � S �N)r) �super�close)r � __class__s �r
r3 zDecompressReader.close; s �� � !����w�w�}�}��� r c �4 � | j � � � S r1 )r# r r s r
r zDecompressReader.seekable? s � ��x� � �"�"�"r c �4 � t |� � 5 }|� d� � 5 }| � t |� � � � }||d t |� � �< d d d � � n # 1 swxY w Y d d d � � n # 1 swxY w Y t |� � S )N�B)�
memoryview�cast�read�len)r �b�view� byte_view�datas r
�readintozDecompressReader.readintoB s� � �
��]�]� )�d�D�I�I�c�N�N� )�i��9�9�S��^�^�,�,�D�$(�I�j�s�4�y�y�j� !� )� )� )� )� )� )� )� )� )� )� )���� )� )� )� )� )� )� )� )� )� )� )� )� )� )� )���� )� )� )� )� �4�y�y�s4 �B �7A)� B �)A- �-B �0A- �1B � B�Br" c �v � |dk r| � � � S |r| j rdS d } | j j rr| j j p | j � t � � }|sn� | j di | j ��| _ | j �
||� � }nj# | j $ r Y nbw xY w| j j r1| j � t � � }|st d� � �nd}| j �
||� � }|rn��|sd| _ | j | _ dS | xj t! |� � z
c_ |S )Nr r TzACompressed file ended before the end-of-stream marker was reachedr )�readallr$ r) �eof� unused_datar# r: � BUFFER_SIZEr' r( �
decompressr* � needs_input�EOFErrorr% r& r; )r �sizer? �rawblocks r
r: zDecompressReader.readH s� � � �!�8�8��<�<�>�>� !�� �t�y� ��3��� ��!�%�
E� � .� :� 7� �H�M�M�+� 6� 6� � � ��%9�T�%9� &)� &)��'�&)� &)��"�� �-�8�8��4�H�H�D�D���+� � � ��E����� �%�1� #� #�x�}�}�[� 9� 9�H�#� K� &� (J� K� K� K�K� #�H��)�4�4�X�t�D�D���
��1 �2 � � �D�I� ��D�J��3� � � �S��Y�Y� � � �� s �;B �
B$�#B$c �� � g }| � t j � � x}r6|� |� � | � t j � � x}�6d� |� � S )Nr )r: �sys�maxsize�append�join)r �chunksr? s r
rB zDecompressReader.readallq sg � ��� �i�i�� �,�,�,�d� � �M�M�$� � � � �i�i�� �,�,�,�d� � �x�x�� � � r c � � | j � d� � d| _ d| _ | j di | j ��| _ d S )Nr Fr )r# �seekr$ r% r' r( r) r s r
�_rewindzDecompressReader._rewind| sH � � ��
�
�a������ ��� � 1�T� 1� F� F�D�4E� F� F����r c �f � |t j k rn�|t j k r | j |z }n�|t j k rU| j dk r?| � t j � � r | � t j � � � | j |z }n"t d� |� � � � �|| j k r| �
� � n
|| j z }|dk rH| � t t j |� � � � }|sn|t |� � z }|dk �H| j S )Nr z Invalid value for whence: {})
r �SEEK_SET�SEEK_CURr% �SEEK_ENDr& r: �DEFAULT_BUFFER_SIZEr �formatrS �minr; )r �offset�whencer? s r
rR zDecompressReader.seek� s& � � �R�[� � � �
�r�{�
"�
"��Y��'�F�F�
�r�{�
"�
"��z�A�~�~��i�i�� 6�7�7� �� �i�i�� 6�7�7� ��Z�&�(�F�F� � ;� B� B�6� J� J�K�K� K� �D�I� � � �L�L�N�N�N�N� �d�i� �F� �q�j�j��9�9�S��!7�� @� @�A�A�D��
�� �c�$�i�i� �F� �q�j�j� �y�r c � � | j S )z!Return the current file position.)r% r s r
�tellzDecompressReader.tell� s
� ��y�r )r )r" )r r r r r r/ r3 r r@ r: rB rS r rU rR r^ �
__classcell__)r4 s @r
r r ! s� �� � � � � �?�?�� � �.� .� .� .�( � � � � �#� #� #�� � � '� '� '� '�R � � �G� G� G� #%�+� � � � �<� � � � � � r r ) r r rL rX rE �BufferedIOBaser � RawIOBaser r r r
�rb s� �� =� =� � � � �
�
�
�
��$� �F� F� F� F� F��"� F� F� F�0A� A� A� A� A�r�|� A� A� A� A� Ar