֦i1 d Z ddlZddlZej Z G d dej
Z G d dej Zy)z7Internal classes used by the gzip, lzma and bz2 modules Nc ( e Zd ZdZd Zd Zd Zd Zy)
BaseStreamz Mode-checking helper functions.c 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____doc__r r r r r r
r r s )=GGFr r c t e Zd ZdZd Zd dZ fdZd Zd Zd
dZ d Z
d Z e j fd
Zd Z xZS )DecompressReaderz5Adapts the decompressor API to a RawIOBase reader APIc 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
r3 zDecompressReader.close; s !w} r c 6 | j j S r1 )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# r: BUFFER_SIZEr' r(
decompressr* needs_inputEOFErrorr% r& r; )r sizer? rawblocks r
r: 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 )r: sysmaxsizeappendjoin)r chunksr? s r
rB 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& r: DEFAULT_BUFFER_SIZEr formatrS minr; )r offsetwhencer? s r
rR 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 )z!Return the current file position.)r% r s r
tellzDecompressReader.tell s yyr )r )r" )r r r r r r/ r3 r r@ r: rB rS r rU rR r^
__classcell__)r4 s @r
r r ! sC ?.( # 'R G #%++ <r r ) r r rL rX rE BufferedIOBaser RawIOBaser r r r
rb s? =
$$ F"" F0Ar|| Ar