a �DOg��@s6ddlZejZGdd�dej�ZGdd�dej�ZdS)�Nc@s,eZdZdd�Zdd�Zdd�Zdd�Zd S) � BaseStreamcCs|jrtd��dS)NzI/O operation on closed file)�closed� ValueError��self�r�$/usr/lib64/python3.9/_compression.py�_check_not_closed szBaseStream._check_not_closedcCs|��st�d��dS)NzFile not open for reading)�readable�io�UnsupportedOperationrrrr�_check_can_readszBaseStream._check_can_readcCs|��st�d��dS)NzFile not open for writing)�writabler r rrrr�_check_can_writeszBaseStream._check_can_writecCs(|��st�d��|��s$t�d��dS)Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r r r �seekablerrrr�_check_can_seeks zBaseStream._check_can_seekN)�__name__� __module__� __qualname__r r rrrrrrr srcsfeZdZdd�Zddd�Z�fdd�Zdd �Zd d �Zdd d�Zdd�Z e j fdd�Z dd�Z �ZS)�DecompressReadercCsdS)NTrrrrrr $szDecompressReader.readablercKsB||_d|_d|_d|_||_||_|jfi|j��|_||_dS)NFr�����)�_fp�_eof�_pos�_size�_decomp_factory� _decomp_args� _decompressor�_trailing_error)r�fp�decomp_factory�trailing_error� decomp_argsrrr�__init__'szDecompressReader.__init__csd|_t���S�N)r�super�closer�� __class__rrr&;szDecompressReader.closecCs |j��Sr$)rrrrrrr?szDecompressReader.seekablec Csxt|��X}|�d��.}|�t|��}||dt|��<Wd�n1sH0YWd�n1sf0Yt|�S)N�B)� memoryview�cast�read�len)r�b�view� byte_view�datarrr�readintoBsLzDecompressReader.readintorcCs�|dkr|��S|r|jrdSd}|jjr�|jjp<|j�t�}|sDq�|jfi|j ��|_z|j� ||�}Wq�|j y�Yq�Yq�0n4|jj r�|j�t�}|s�t d��nd}|j� ||�}|r"q�q"|s�d|_|j|_dS|jt|�7_|S)Nr�zACompressed file ended before the end-of-stream marker was reachedT)�readallrr�eof� unused_datarr,� BUFFER_SIZErr� decompressr� needs_input�EOFErrorrrr-)r�sizer1�rawblockrrrr,Hs@  ��   zDecompressReader.readcCs0|j�d�d|_d|_|jfi|j��|_dS)NrF)r�seekrrrrrrrrr�_rewindrs zDecompressReader._rewindcCs�|tjkr nR|tjkr"|j|}n<|tjkrP|jdkrD|�tj�rDq6|j|}ntd� |���||jkrr|� �n ||j8}|dkr�|�t tj|��}|s�q�|t |�8}q||jS)NrzInvalid value for whence: {}) r �SEEK_SET�SEEK_CURr�SEEK_ENDrr,�DEFAULT_BUFFER_SIZEr�formatr>�minr-)r�offset�whencer1rrrr=xs&          zDecompressReader.seekcCs|jSr$)rrrrr�tell�szDecompressReader.tell)r)r)rrrr r#r&rr2r,r>r r?r=rG� __classcell__rrr'rr!s   *r)r rBr7�BufferedIOBaser� RawIOBaserrrrr�s