File manager

3


 \��@s6dd
lZej
ZGdd�dej�ZGdd�dej�Zd
S)�Nc@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
�
BaseStreamc

Cs|jrt
d
�
�
dS)NzI/O operation on closed file)�closed�
ValueError)
�self�r�$/usr/lib64/python3.6/_compression.py�_check_not_closeds

zBaseStream._check_not_closedc

Cs|j�st
jd
�
�
dS)NzFile not open for reading)�readable�io�UnsupportedOperation)
rrrr�_check_can_reads

zBaseStream._check_can_readc

Cs|j�st
jd
�
�
dS)NzFile not open for writing)�writabler
r)
rrrr�_check_can_writes

zBaseStream._check_can_writec

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



zBaseStream._check_can_seekN)�__name__�
__module__�__qualname__rrrrrrrrr	srcsheZ
dZd
d�Zff
dd�
Z�f
dd�Zdd�Zd	d
�Zddd
�
Zdd�Z	e
jf
dd�
Zdd�Z
�ZS)�DecompressReaderc


Csd
S)NTr)
rrrrr	$s
zDecompressReader.readablecKs>|
|_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
�j�S)
N)r�super�close)
r)
�	__class__rrr";s

zDecompressReader.closec


Cs
|jj
�S)
N)rr)
rrrrr?s
zDecompressReader.seekablecCsPt|
�
�:}|j
d
�
�$}|jt|�
�
}||dt|�
�<WdQRXWdQRXt|�
S)N�
B)�
memoryview�cast�read�len)r�
bZviewZ	byte_view�datarrr�readintoBs


$
zDecompressReader.readintorcCs�|
d
kr|j�S|
s|j
r dSd}x�|jjr�|jjp@|jjt�
}|sHP|jf|j	�
|_y|jj
||
�}Wq�|jk
r�


PYq�Xn4|jjr�|jjt�
}|s�t
d�
�
nd}|jj
||
�}|r&Pq&W|s�d|_
|j|_dS|jt|�
7_|S)Nr
�zACompressed file ended before the end-of-stream marker was reachedT)�readallrr�eofZunused_datarr'�BUFFER_SIZErrZ
decompressrZneeds_input�EOFErrorrrr()r�sizer*Zrawblockrrrr'Hs>



























zDecompressReader.readc

Cs,|jj
d
�

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


zDecompressReader._rewindcCs�|tj
krnV|tjkr"|j|
}
n@|tjkrT|jd
krHx|jtj�
rFq8W|j|
}
ntdj	|�
�
�
|
|jkrv|j
�
n
|
|j8}
x0|
d
kr�|jttj|
��
}|s�P|
t|�
8}
q�W|jS)Nr
zInvalid value for whence: {})
r
�SEEK_SET�SEEK_CURr�SEEK_ENDrr'�DEFAULT_BUFFER_SIZEr�formatr3�minr()r�offset�whencer*rrrr2xs&



















zDecompressReader.seekc


Cs|jS)
N)
r)
rrrr�tell�szDecompressReader.tellr)
r)rrrr	r r"rr+r'r3r
r4r2r<�
__classcell__rr)
r#rr!s
*r)r
r7r/�BufferedIOBaser�	RawIOBaserrrrr�<module>s