File manager

U

i�f��@s:dZd
dl
Z
e
jZGdd�de
j�ZGdd�de
j�ZdS)z7Internal classes used by the gzip, lzma and bz2 modules�Nc@s0eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
S)�
BaseStreamzMode-checking helper functions.c

Cs|jrt
d
�
�
dS)NzI/O operation on closed file)�closed�
ValueError�
�self�r�1/opt/alt/python38/lib64/python3.8/_compression.py�_check_not_closeds

zBaseStream._check_not_closedc

Cs|��st
�d
�
�
dS)NzFile not open for reading)�readable�io�UnsupportedOperationrrrr�_check_can_reads

zBaseStream._check_can_readc

Cs|��st
�d
�
�
dS)NzFile not open for writing)�writablerrrrrr�_check_can_writes

zBaseStream._check_can_writec

Cs(|��st
�d
�
�
|��s$t
�d�
�
dS)Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r
rr�seekablerrrr�_check_can_seeks



zBaseStream._check_can_seekN)�__name__�
__module__�__qualname__�__doc__r	r
rrrrrrr	s

rcsjeZ
dZd
Zdd�Zddd�
Z�f
dd�Zd	d
�Zdd�Zddd�
Z	dd�Z
ejf
dd�
Z
dd�Z�ZS)�DecompressReaderz5Adapts the decompressor API to a RawIOBase reader APIc


Csd
S)NTrrrrrr
$s
zDecompressReader.readablercKs>|
|_d
|_
d|_d|_||_||_|jf|j�
|_||_dS)NFr
���)�_fp�_eof�_pos�_size�_decomp_factory�_decomp_args�
_decompressor�_trailing_error)r�fpZdecomp_factoryZtrailing_errorZdecomp_argsrrr�__init__'s




zDecompressReader.__init__c

sd|_t
���S�
N)r�super�closer�
�	__class__rrr$;s

zDecompressReader.closec

Cs
|j�
�Sr")rrrrrrr?s
zDecompressReader.seekablec
CsPt|
�
�:}|�
d
�
�$}|�t|�
�
}||dt|�
�<W5QRXW5QRXt|�
S)N�
B)�
memoryview�cast�read�len)r�
bZviewZ	byte_view�datarrr�readintoBs


$
zDecompressReader.readintorcCs�|
d
kr|��S|
r|j
rdSd}|jjr�|jjp<|j�t�
}|sDq�|jf|j	�
|_z|j�
||
�}Wq�|jk
r�


Yq�Yq�Xn4|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�eofZunused_datarr*�BUFFER_SIZErr�
decompressrZneeds_input�EOFErrorrrr+)r�sizer-Zrawblockrrrr*Hs@







�

�














zDecompressReader.readc

Cs,|j�
d
�

d|_d
|_|jf|j�
|_dS)Nr
F)r�seekrrrrrrrrr�_rewindrs



zDecompressReader._rewindcCs�|tj
krnR|tjkr"|j|
}
n<|tjkrP|jd
krD|�tj�
rDq6|j|
}
ntd�	|�
�
�
|
|jkrr|�
�
n
|
|j8}
|
d
kr�|�ttj|
��
}|s�q�|
t|�
8}
q||jS)Nr
zInvalid value for whence: {})
r�SEEK_SET�SEEK_CURr�SEEK_ENDrr*�DEFAULT_BUFFER_SIZEr�formatr7�minr+)r�offset�whencer-rrrr6xs&


















zDecompressReader.seekc


Cs|jS)
z!Return the current file position.)
rrrrr�tell�szDecompressReader.tell)
r)
r)rrrrr
r!r$rr.r*r7rr8r6r@�
__classcell__rrr%rr!s


*r)rrr;r2�BufferedIOBaser�	RawIOBaserrrrr�<module>
s