File: //usr/local/lib/python3.10/__pycache__/_compression.cpython-310.opt-2.pyc
o
�i1 � @ s@ d dl Z d dlZe jZG dd� de j�ZG dd� de j�ZdS )� Nc @ s. e Zd Z dd� Zdd� Zdd� Zdd� Zd S )
�
BaseStreamc C s | j rtd��d S )Nz I/O operation on closed file)�closed�
ValueError��self� r �)/usr/local/lib/python3.10/_compression.py�_check_not_closed s �z BaseStream._check_not_closedc C � | � � s t�d��d S )NzFile not open for reading)�readable�io�UnsupportedOperationr r r r �_check_can_read �
�zBaseStream._check_can_readc C r
)NzFile not open for writing)�writabler r
r r r r �_check_can_write r zBaseStream._check_can_writec C s( | � � s t�d��| �� st�d��d S )Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r r r
�seekabler r r r �_check_can_seek s
�zBaseStream._check_can_seekN)�__name__�
__module__� __qualname__r r r r r r r r r s r c sp e Zd Z dd� Zddd�Z� fdd�Zdd � Zd
d � Zdd
d�Zdd� Z dd� Z
e j fdd�Z
dd� Z� ZS )�DecompressReaderc C s dS )NTr r r r r r $ s zDecompressReader.readabler c K sB || _ d| _d| _d| _|| _|| _| jdi | j��| _|| _d S )NFr ���r )�_fp�_eof�_pos�_size�_decomp_factory� _decomp_args�
_decompressor�_trailing_error)r �fp�decomp_factory�trailing_error� decomp_argsr r r �__init__' s
zDecompressReader.__init__c s d | _ t� �� S �N)r �super�closer �� __class__r r r( ; s
zDecompressReader.closec C s
| j �� S r& )r r r r r r r ? s
zDecompressReader.seekablec C s� t |��9}|�d��}| �t|��}||d t|��< W d � n1 s$w Y W d � t|�S W d � t|�S 1 s@w Y t|�S )N�B)�
memoryview�cast�read�len)r �b�view� byte_view�datar r r �readintoB s (� ��zDecompressReader.readintor c C s� |dk r| � � S |r
| jrdS d } | jjrA| jjp | j�t�}|s#n<| jdi | j ��| _z | j�
||�}W n$ | j y@ Y n w | jj rR| j�t�}|sQt
d��nd}| j�
||�}|r^nq|sjd| _| j| _dS | jt|�7 _|S )Nr � 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 �sizer3 �rawblockr r r r. H sH
��� ��zDecompressReader.readc C s8 g }| � tj� }r|�|� | � tj� }s
d�|�S )Nr5 )r. �sys�maxsize�append�join)r �chunksr3 r r r r6 q s
�
zDecompressReader.readallc C s0 | j �d� d| _d| _| jdi | j��| _d S )Nr Fr )r �seekr r r r r r r r r �_rewind| s zDecompressReader._rewindc C s� |t jkrn/|t jkr| j| }n$|t jkr.| jdk r(| �t j�r( | �t j�s!| j| }ntd� |���|| jk r?| �
� n|| j8 }|dkra| �t t j|��}|sW | jS |t |�8 }|dksH| jS )Nr z Invalid value for whence: {})
r �SEEK_SET�SEEK_CURr �SEEK_ENDr r. �DEFAULT_BUFFER_SIZEr �formatrE �minr/ )r �offset�whencer3 r r r rD � s,
�
��zDecompressReader.seekc C s | j S r& )r r r r r �tell� s zDecompressReader.tell)r )r )r r r r r% r( r r4 r. r6 rE r rF rD rN �
__classcell__r r r) r r ! s
) r )r r? rI r9 �BufferedIOBaser � RawIOBaser r r r r �<module> s