!A?h1 t d Z ddlZddlZej Z G d dej Z G d dej ZdS )z7Internal classes used by the gzip, lzma and bz2 modules Nc * e Zd ZdZd Zd Zd Zd ZdS )
BaseStreamz Mode-checking helper functions.c 2 | j rt d d S )Nz I/O operation on closed file)closed
ValueErrorselfs 9/opt/alt/python-internal/lib64/python3.11/_compression.py_check_not_closedz BaseStream._check_not_closed s% ; = ;<< < = = c V | st j d d S )NzFile not open for reading)readableioUnsupportedOperationr s r
_check_can_readzBaseStream._check_can_read 1 }} G)*EFF F G Gr c V | st j d d S )NzFile not open for writing)writabler r r s r
_check_can_writezBaseStream._check_can_write r r c | st j d | st j d d S )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 sl }} G) +F G G
G}} F) +E F F
F F Fr N)__name__
__module__ __qualname____doc__r r r r r r
r r sa ))= = =G G GG G GF F F F Fr r c j e Zd ZdZd ZddZ fdZd Zd Zdd Z d
Z
d Z e j
fd Zd
Z xZS )DecompressReaderz5Adapts the decompressor API to a RawIOBase reader APIc dS )NTr r s r
r zDecompressReader.readable$ s tr r c || _ d| _ d| _ d| _ || _ || _ | j di | j | _ || _ d S )NFr r )_fp_eof_pos_size_decomp_factory _decomp_args
_decompressor_trailing_error)r fpdecomp_factorytrailing_error decomp_argss r
__init__zDecompressReader.__init__' s`
. ' 1T 1 F FD4E F F . r c R d | _ t S N)r) superclose)r __class__s r
r3 zDecompressReader.close; s !ww}} r c 4 | j S r1 )r# r r s r
r zDecompressReader.seekable? s x """r c 4 t | 5 }| d 5 }| t | }||d t | < d d d n # 1 swxY w Y d d d n # 1 swxY w Y t | S )NB)
memoryviewcastreadlen)r bview byte_viewdatas r
readintozDecompressReader.readintoB s
]] )dDIIcNN )i99S^^,,D$(Ijs4yyj ! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) 4yys4 B 7A) B )A- -B 0A- 1B BBr" c v |dk r| S |r| j rdS d } | j j rr| j j p | j t }|sn | j di | j | _ | j
|| }nj# | j $ r Y nbw xY w| j j r1| j t }|st d nd}| j
|| }|rn|sd| _ | j | _ dS | xj t! | z
c_ |S )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 s !88<<>> ! ty 3 !%
E . : 7 HMM+ 6 6 %9T%9 &) &)'&) &)" -884HHDD+ E %1 # #x}}[ 9 9H# K & (J K K KK #H)44XtDD
1 2 DI DJ3 SYY s ;B
B$#B$c g }| t j x}r6| | | t j x}6d | S )Nr )r: sysmaxsizeappendjoin)r chunksr? s r
rB zDecompressReader.readallq sg ii ,,,d MM$ ii ,,,d xx r c | j d d| _ d| _ | j di | j | _ d S )Nr Fr )r# seekr$ r% r' r( r) r s r
_rewindzDecompressReader._rewind| sH
a 1T 1 F FD4E F Fr c f |t j k rn|t j k r | j |z }n|t j k rU| j dk r?| t j r | t j | j |z }n"t d | || j k r|
n
|| j z }|dk rH| t t j | }|sn|t | z }|dk H| 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{
"
"Y'FF
r{
"
"zA~~ii 677 ii 677 Z&(FF ; B B6 J JKK K DI LLNNNN di F qjj99S!7 @ @AAD
c$ii F qjj yr c | j S )z!Return the current file position.)r% r s r
tellzDecompressReader.tell s
yr )r )r" )r r r r r r/ r3 r r@ r: rB rS r rU rR r^
__classcell__)r4 s @r
r r ! s ?? . . . .( # # # ' ' ' 'R G G G #%+ < r r ) r r rL rX rE BufferedIOBaser RawIOBaser r r r
rb s = =
$ F F F F F" F F F0A A A A Ar| A A A A Ar