H5" r d dl Z d dlZe j Z G d de j Z G d de j ZdS ) Nc ( e Zd Z d Zd Zd Zd ZdS )
BaseStreamc 2 | j rt d d S )Nz I/O operation on closed file)closed
ValueErrorselfs 3/opt/alt/python311/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__r r r r r r
r r s^ )= = =G G GG G GF F F F Fr r c h e Zd Z d Zd
dZ fdZd Zd ZddZd Z d
Z
e j fd Z
d Z xZS )DecompressReaderc 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
r2 zDecompressReader.close; s !ww}} r c 4 | j S r0 )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" r9 BUFFER_SIZEr& r'
decompressr) needs_inputEOFErrorr$ r% r: )r sizer> rawblocks r
r9 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 )r9 sysmaxsizeappendjoin)r chunksr> s r
rA 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% r9 DEFAULT_BUFFER_SIZEr formatrR minr: )r offsetwhencer> s r
rQ 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 r0 )r$ r s r
tellzDecompressReader.tell s
/yr )r )r! )r r r r r. r2 r r? r9 rA rR r rT rQ r]
__classcell__)r3 s @r
r r ! s ? . . . .( # # # ' ' ' 'R G G G #%+ < r r )r rK rW rD BufferedIOBaser RawIOBaser r r r
ra s =
$ F F F F F" F F F0A A A A Ar| A A A A Ar