cj1 d dl Z d dlZe j Z G d de j Z G d de j Zy) Nc & e Zd Z d Zd Zd Zd Zy)
BaseStreamc 2 | j r t d y )Nz I/O operation on closed file)closed
ValueErrorselfs %/usr/lib64/python3.12/_compression.py_check_not_closedz BaseStream._check_not_closed s ;; ;< < c N | j st j d y )NzFile not open for reading)readableioUnsupportedOperationr s r
_check_can_readzBaseStream._check_can_read " }}))*EF F r c N | j st j d y )NzFile not open for writing)writabler r r s r
_check_can_writezBaseStream._check_can_write r r c | j st j d | j st j d y )Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r r r seekabler s r
_check_can_seekzBaseStream._check_can_seek sO }})) +F G
G}})) +E F
F r N)__name__
__module__ __qualname__r r r r r r
r r s )=GGFr r c r e Zd Z d Zd dZ fdZd Zd Zd dZd Z d Z
e j fd Z
d
Z xZS )
DecompressReaderc y)NTr r s r
r zDecompressReader.readable$ s r c || _ d| _ d| _ d| _ || _ || _ | j di | j
| _ || _ y )NFr r )_fp_eof_pos_size_decomp_factory _decomp_args
_decompressor_trailing_error)r fpdecomp_factorytrailing_error decomp_argss r
__init__zDecompressReader.__init__' sZ
. ' 1T 1 1 FD4E4E F . r c . d | _ t | S N)r( superclose)r __class__s r
r2 zDecompressReader.close; s !w} r c 6 | j j S r0 )r" r r s r
r zDecompressReader.seekable? s xx ""r c t | 5 }|j d 5 }| j t | }||d t | d d d d d d t S # 1 sw Y xY w# 1 sw Y t S xY w)NB)
memoryviewcastreadlen)r bview byte_viewdatas r
readintozDecompressReader.readintoB sc
]dDIIcNi99S^,D$(Ijs4y ! %3] 4y %3N] 4ys" A.)A"A."A+ 'A..Bc |dk r| j S |r | j ryd } | j j ry| j j xs | j
j
t }|sn | j di | j | _ | j j || }n`| j j r,| j
j
t }|s
t d d}| j j || }|rn|sd| _ | j | _ y| xj t! | z
c_ |S # | j $ r Y Lw xY w)Nr r TzACompressed file ended before the end-of-stream marker was reachedr )readallr# r( eof unused_datar" r9 BUFFER_SIZEr& r'
decompressr) needs_inputEOFErrorr$ r% r: )r sizer> rawblocks r
r9 zDecompressReader.readH sY !8<<> !tyy !!%% . . : : 7 HHMM+ 6 %9T%9%9 &)''&)" --884HD
%%11 #xx}}[ 9H# & (J K K #H))44XtD1 2 DI DJ SY ' ++ s E E('E(c g }| j t j x}r3|j | | j t j x}r3dj | S )Nr )r9 sysmaxsizeappendjoin)r chunksr> s r
rA zDecompressReader.readallq sX ii ,,d, MM$ ii ,,d, xx r c | j j d d| _ d| _ | j di | j
| _ y )Nr Fr )r" seekr# r$ r& r' r( r s r
_rewindzDecompressReader._rewind| s>
a 1T 1 1 FD4E4E Fr c |t j k( rn|t j k( r| j |z }n|t j k( r_| j
dk r@| j
t j r! | j
t j r!| j
|z }nt dj | || j k r| j n|| j z }|dkD rL| j
t t j | }|s
| j S |t | z }|dkD rL| j S )Nr z Invalid value for whence: {})
r SEEK_SETSEEK_CURr$ SEEK_ENDr% r9 DEFAULT_BUFFER_SIZEr formatrR minr: )r offsetwhencer> s r
rQ zDecompressReader.seek s R[[
r{{
"YY'F
r{{
"zzA~ii 6 67 ii 6 67ZZ&(F ; B B6 JK K DII LLN dii F qj99S!7!7 @AD yy
c$i F qj yyr c | j S r0 )r$ r s r
tellzDecompressReader.tell s /yyr )r )r! )r r r r r. r2 r r? r9 rA rR r rT rQ r]
__classcell__)r3 s @r
r r ! sC ?.( # 'R G #%++ <r r )r rK rW rD BufferedIOBaser RawIOBaser r r r
ra s? =
$$ F"" F0Ar|| Ar