B
US
k @ s d dddddgZ dZddlmZ dd lZdd lZdd lZdd lZdd
l m
Z
dd l m Z m
Z
dZd Zd
ZG dd d ejZdddZdddZdd Zd S )BZ2File
BZ2CompressorBZ2Decompressoropencompress
decompressz%Nadeem Vawda )r N)RLock)r r c @ s e Zd Zd(ddZdd Zedd Zd
d Zd d
Zdd Z dd Z
d)ddZ d*ddZ d+ddZ
dd Zd,d d Zd-d d Zd d! Zd"d# Zejfd$d%Zd&d' ZdS ).r rN c C sP t | _d | _d| _t| _|d k r.tdt d| krBdksLn t d|dkr^d}t
}nb|dkrzd }t }t || _
nF|d
krd }t }t || _
n*|d krd
}t }t || _
nt d|f t|tttjfrt||| _d| _|| _n.t|dst|dr|| _|| _ntd| jt
krFtj| jttd}t|| _ nd| _ d S )NFz)Use of 'buffering' argument is deprecatedr r z%compresslevel must be between 1 and 9) r rbr )wwbr )xxbr )aabr zInvalid mode: %rTreadwritez6filename must be a str, bytes, file or PathLike object)Ztrailing_errorr ) r _lock_fp_closefp _MODE_CLOSED_modewarningswarnDeprecationWarning
ValueError
_MODE_READ _MODE_WRITEr _compressor
isinstancestrbytesosPathLike
_builtin_openhasattr TypeError _compressionZDecompressReaderr OSErrorioBufferedReader_buffer_pos)selffilenamemode buffering
compresslevelZ mode_coderaw r7 (/opt/alt/python37/lib64/python3.7/bz2.py__init__' sL
zBZ2File.__init__c C s | j | jtkrd S z<| jtkr.| j n"| jtkrP| j| j
d | _ W d z| j rf| j W d d | _d| _ t| _d | _X X W d Q R X d S )NF) r r r r r/ closer! r r r" flushr )r1 r7 r7 r8 r: l s
z
BZ2File.closec C s
| j tkS )N)r r )r1 r7 r7 r8 closed s zBZ2File.closedc C s | | j S )N)_check_not_closedr fileno)r1 r7 r7 r8 r> s zBZ2File.filenoc C s | o| j S )N)readabler/ seekable)r1 r7 r7 r8 r@ s zBZ2File.seekablec C s | | jtkS )N)r= r r )r1 r7 r7 r8 r? s zBZ2File.readablec C s | | jtkS )N)r= r r! )r1 r7 r7 r8 writable s zBZ2File.writabler c C s& | j | | j|S Q R X d S )N)r _check_can_readr/ peek)r1 nr7 r7 r8 rC s z BZ2File.peekc C s& | j | | j|S Q R X d S )N)r rB r/ r )r1 sizer7 r7 r8 r s z BZ2File.readc C s4 | j $ | |dk r tj}| j|S Q R X d S )Nr )r rB r- DEFAULT_BUFFER_SIZEr/ read1)r1 rF r7 r7 r8 rH s
z
BZ2File.read1c C s& | j | | j|S Q R X d S )N)r rB r/ readinto)r1 br7 r7 r8 rI s zBZ2File.readintoc C sJ t |ts$t|ds td| }| j | | j|S Q R X d S )N __index__zInteger argument expected) r# intr) r* rK r rB r/ readline)r1 rF r7 r7 r8 rM s
zBZ2File.readlinec C sJ t |ts$t|ds td| }| j | | j|S Q R X d S )NrK zInteger argument expected) r# rL r) r* rK r rB r/ readlines)r1 rF r7 r7 r8 rN s
zBZ2File.readlinesc C sL | j < | | j|}| j| | jt|7 _t|S Q R X d S )N)r Z_check_can_writer" r r r r0 len)r1 dataZ
compressedr7 r7 r8 r s z
BZ2File.writec C s | j tj| |S Q R X d S )N)r r+
BaseStream
writelines)r1 seqr7 r7 r8 rR s zBZ2File.writelinesc C s( | j | | j||S Q R X d S )N)r Z_check_can_seekr/ seek)r1 offsetwhencer7 r7 r8 rT s z BZ2File.seekc C s4 | j $ | | jtkr$| j S | jS Q R X d S )N)r r= r r r/ tellr0 )r1 r7 r7 r8 rW s
z BZ2File.tell)r Nr )r )rE )rE )rE )rE )__name__
__module__ __qualname__r9 r: propertyr< r> r@ r? rA rC r rH rI rM rN r rR r- SEEK_SETrT rW r7 r7 r7 r8 r s"
E
r r c C s d|kr d|krPt d|f n0|d k r0t d|d k r@t d|d k rPt d|dd}t| ||d}d|krt||||S |S d S ) NtrJ zInvalid mode: %rz0Argument 'encoding' not supported in binary modez.Argument 'errors' not supported in binary modez/Argument 'newline' not supported in binary moder
)r5 )r replacer r-
TextIOWrapper)r2 r3 r5 encodingerrorsnewlineZbz_modeZ binary_filer7 r7 r8 r s c C s t |}|| | S )N)r r r; )rP r5 compr7 r7 r8 r F s c C sj g }xZ| r^t }y|| }W n tk
r< |r6P n Y nX || |jsVtd|j} qW d|S )NzACompressed data ended before the end-of-stream marker was reached )r r r, appendeofr Z unused_datajoin)rP resultsZdecompZresr7 r7 r8 r Q s
)r r NNN)r )__all__
__author__builtinsr r( r- r& r r+ Z threadingr Z_bz2r r r r r! rQ r r r r7 r7 r7 r8 s&
(