o
0i1 @ s@ d dl Z d dlZe jZG dd de jZG dd de jZdS ) Nc @ s. e Zd Z dd Zdd Zdd Zdd Zd S )
BaseStreamc C s | j rtdd S )Nz I/O operation on closed file)closed
ValueErrorself r 3/opt/alt/python310/lib64/python3.10/_compression.py_check_not_closed s z BaseStream._check_not_closedc C | s tdd S )NzFile not open for reading)readableioUnsupportedOperationr 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 td| stdd 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 ZdddZ fddZdd Zd
d Zdd
dZdd Z dd Z
e j fddZ
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 fpZdecomp_factoryZtrailing_errorZ decomp_argsr r r __init__' s
zDecompressReader.__init__c s d | _ t S N)r supercloser __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 )NB)
memoryviewcastreadlen)r bZviewZ byte_viewdatar r r readintoB s ( zDecompressReader.readintor c C s |dk r| S |r
| jrdS d } | jjrA| jjp | jt}|s#n<| jdi | j | _z | j
||}W n$ | j y@ Y n w | jj rR| jt}|sQt
dnd}| j
||}|r^nq|sjd| _| j| _dS | jt|7 _|S )Nr TzACompressed file ended before the end-of-stream marker was reachedr )readallr r eofZ unused_datar r+ BUFFER_SIZEr r
decompressr Z needs_inputEOFErrorr r r, )r sizer. Zrawblockr r r r+ H sH
zDecompressReader.readc C s8 g }| tj }r|| | tj }s
d|S )Nr0 )r+ sysmaxsizeappendjoin)r Zchunksr. r r r r1 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 jr( | t js!| j| }ntd ||| jk r?|
n|| j8 }|dkra| t t j|}|sW | jS |t |8 }|dksH| jS )Nr z Invalid value for whence: {})
r SEEK_SETSEEK_CURr SEEK_ENDr r+ DEFAULT_BUFFER_SIZEr formatr< minr, )r offsetwhencer. r r r r; 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 r/ r+ r1 r< r r= r; rE
__classcell__r r r& r r ! s
) r )r r7 r@ r3 BufferedIOBaser RawIOBaser r r r r s