B vlƵ@s6ddlZejZGdddejZGdddejZdS)Nc@s,eZdZddZddZddZddZd S) BaseStreamcCs|jrtddS)NzI/O operation on closed file)closed ValueError)selfr//opt/alt/python37/lib/python3.7/_compression.py_check_not_closed szBaseStream._check_not_closedcCs|stddS)NzFile not open for reading)readableioUnsupportedOperation)rrrr_check_can_readszBaseStream._check_can_readcCs|stddS)NzFile not open for writing)writabler r )rrrr_check_can_writeszBaseStream._check_can_writecCs(|std|s$tddS)Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r r r seekable)rrrr_check_can_seeks zBaseStream._check_can_seekN)__name__ __module__ __qualname__rr rrrrrrr srcsfeZdZddZdddZfddZdd Zd d Zdd dZddZ e j fddZ ddZ ZS)DecompressReadercCsdS)NTr)rrrrr $szDecompressReader.readablercKs>||_d|_d|_d|_||_||_|jf|j|_||_dS)NFr)_fp_eof_pos_size_decomp_factory _decomp_args _decompressor_trailing_error)rfpZdecomp_factoryZtrailing_errorZ decomp_argsrrr__init__'szDecompressReader.__init__csd|_tS)N)rsuperclose)r) __class__rrr!;szDecompressReader.closecCs |jS)N)rr)rrrrr?szDecompressReader.seekablec CsPt|:}|d$}|t|}||dt|<WdQRXWdQRXt|S)NB) memoryviewcastreadlen)rbZviewZ byte_viewdatarrrreadintoBs$zDecompressReader.readintorcCs|dkr|S|r|jrdSd}x|jjr|jjp>|jt}|sFP|jf|j |_y|j ||}Wq|j k rPYqXn4|jj r|jt}|st dnd}|j ||}|r$Pq$W|sd|_|j|_dS|jt|7_|S)NrzACompressed file ended before the end-of-stream marker was reachedT)readallrreofZ unused_datarr& BUFFER_SIZErrZ decompressrZ needs_inputEOFErrorrrr')rsizer)Zrawblockrrrr&Hs>      zDecompressReader.readcCs,|jdd|_d|_|jf|j|_dS)NrF)rseekrrrrr)rrrr_rewindrs zDecompressReader._rewindcCs|tjkr nV|tjkr"|j|}n@|tjkrT|jdkrHx|tjrFq8W|j|}ntd |||jkrv| n ||j8}x0|dkr|t tj|}|sP|t |8}qW|jS)NrzInvalid value for whence: {}) r SEEK_SETSEEK_CURrSEEK_ENDrr&DEFAULT_BUFFER_SIZErformatr2minr')roffsetwhencer)rrrr1xs&          zDecompressReader.seekcCs|jS)N)r)rrrrtellszDecompressReader.tell)r)r)rrrr rr!rr*r&r2r r3r1r; __classcell__rr)r"rr!s   *r)r r6r.BufferedIOBaser RawIOBaserrrrrs