File: //lib64/python3.9/__pycache__/bz2.cpython-39.opt-2.pyc
a
�DOg�0 � @ s� g d �Z dZddlmZ ddlZddlZddlZddlm Z ddl
m Z m Z dZ
dZdZG d d
� d
ej�Zdd
d�Zddd�Zdd� ZdS ))�BZ2File�
BZ2Compressor�BZ2Decompressor�open�compress�
decompressz%Nadeem Vawda <nadeem.vawda@gmail.com>� )r N)�RLock)r r � � c @ s� e Zd Zd)dd�dd�Zdd� Zedd � �Zd
d � Zd d
� Zdd� Z dd� Z
d*dd�Z d+dd�Z d,dd�Z
dd� Zd-d d �Zd.d d �Zd d!� Zd"d#� Zejfd$d%�Zd&d'� Zd(S )/r �r� ��
compresslevelc C s8 t � | _d | _d| _t| _d| kr.dks8n td��|dv rJd}t}nb|dv rfd}t}t |�| _
nF|d v r�d
}t}t |�| _
n*|d v r�d }t}t |�| _
ntd
|f ��t |t t
tjf�r�t||�| _d| _|| _n*t|d�s�t|d�r�|| _|| _ntd��| jtk�r.tj| jttd�}t�|�| _nd| _d S )NFr r z%compresslevel must be between 1 and 9)� r �rbr )�w�wbr )�x�xbr )�a�abr �Invalid mode: %rT�read�writez6filename must be a str, bytes, file or PathLike object)�trailing_errorr )r �_lock�_fp�_closefp� _MODE_CLOSED�_mode�
ValueError�
_MODE_READ� _MODE_WRITEr � _compressor�
isinstance�str�bytes�os�PathLike�
_builtin_open�hasattr� TypeError� _compression�DecompressReaderr �OSError�io�BufferedReader�_buffer�_pos)�self�filename�moder � mode_code�raw� r8 �/usr/lib64/python3.9/bz2.py�__init__& sH �zBZ2File.__init__c C s | j �� | jtkr"W d � d S z�| jtkr:| j�� n"| jtkr\| j�| j �
� � d | _ W z,| j rp| j�� W d | _d| _ t| _d | _q�d | _d| _ t| _d | _0 nJz,| j r�| j�� W d | _d| _ t| _d | _nd | _d| _ t| _d | _0 0 W d � n1 �s0 Y d S )NF) r r r r! r1 �closer" r r r# �flushr �r3 r8 r8 r9 r; e s>
�
� �z
BZ2File.closec C s
| j tkS �N)r r r= r8 r8 r9 �closed~ s zBZ2File.closedc C s | � � | j�� S r> )�_check_not_closedr �filenor= r8 r8 r9 rA � s zBZ2File.filenoc C s | � � o| j�� S r> )�readabler1 �seekabler= r8 r8 r9 rC � s zBZ2File.seekablec C s | � � | jtkS r> )r@ r r! r= r8 r8 r9 rB � s zBZ2File.readablec C s | � � | jtkS r> )r@ r r" r= r8 r8 r9 �writable� s zBZ2File.writabler c C s> | j �$ | �� | j�|�W d � S 1 s00 Y d S r> )r �_check_can_readr1 �peek)r3 �nr8 r8 r9 rF � s z BZ2File.peek���c C s> | j �$ | �� | j�|�W d � S 1 s00 Y d S r> )r rE r1 r �r3 �sizer8 r8 r9 r � s z BZ2File.readc C sL | j �2 | �� |dk r tj}| j�|�W d � S 1 s>0 Y d S )Nr )r rE r/ �DEFAULT_BUFFER_SIZEr1 �read1rI r8 r8 r9 rL � s
z
BZ2File.read1c C s> | j �$ | �� | j�|�W d � S 1 s00 Y d S r> )r rE r1 �readinto)r3 �br8 r8 r9 rM � s zBZ2File.readintoc C sb t |t�s$t|d�s td��|�� }| j�$ | �� | j�|�W d � S 1 sT0 Y d S �N� __index__zInteger argument expected) r$ �intr* r+ rP r rE r1 �readlinerI r8 r8 r9 rR � s
zBZ2File.readlinec C sb t |t�s$t|d�s td��|�� }| j�$ | �� | j�|�W d � S 1 sT0 Y d S rO ) r$ rQ r* r+ rP r rE r1 � readlinesrI r8 r8 r9 rS � s
zBZ2File.readlinesc C s� | j �h | �� t|ttf�r(t|�}nt|�}|j}| j� |�}| j
� |� | j |7 _ |W d � S 1 st0 Y d S r> )
r �_check_can_writer$ r& � bytearray�len�
memoryview�nbytesr# r r r r2 )r3 �data�length�
compressedr8 r8 r9 r � s
z
BZ2File.writec C s8 | j � tj�| |�W d � S 1 s*0 Y d S r> )r r, �
BaseStream�
writelines)r3 �seqr8 r8 r9 r] � s zBZ2File.writelinesc C s@ | j �& | �� | j�||�W d � S 1 s20 Y d S r> )r �_check_can_seekr1 �seek)r3 �offset�whencer8 r8 r9 r` s z BZ2File.seekc C sZ | j �@ | �� | jtkr2| j�� W d � S | jW d � S 1 sL0 Y d S r> )r r@ r r! r1 �tellr2 r= r8 r8 r9 rc s
z BZ2File.tellN)r )r )rH )rH )rH )rH )�__name__�
__module__� __qualname__r: r; �propertyr? rA rC rB rD rF r rL rM rR rS r r] r/ �SEEK_SETr` rc r8 r8 r8 r9 r s$ ?
r r r c C s� d|v r d|v rPt d|f ��n0|d ur0t d��|d ur@t d��|d urPt d��|�dd�}t| ||d�}d|v r�t�||||�S |S d S ) N�trN r z0Argument 'encoding' not supported in binary modez.Argument 'errors' not supported in binary modez/Argument 'newline' not supported in binary moder r
)r �replacer r/ �
TextIOWrapper)r4 r5 r �encoding�errors�newline�bz_mode� binary_filer8 r8 r9 r s r c C s t |�}|�| �|�� S r> )r r r< )rY r �compr8 r8 r9 r G s r c C sf g }| r\t � }z|�| �}W n ty: |r4Y q\n� Y n0 |�|� |jsTtd��|j} qd�|�S )NzACompressed data ended before the end-of-stream marker was reached� )r r r. �append�eofr � unused_data�join)rY �results�decomp�resr8 r8 r9 r R s
r )r r NNN)r )�__all__�
__author__�builtinsr r) r/ r' r, � threadingr �_bz2r r r r! r" r\ r r r r8 r8 r8 r9 �<module> s$ �
)