a
XC?h�l � @ sv d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ej dv rTd dl
m Z ndZ d dl
Z
d dl
mZmZmZmZ h d�Zee d�r�e�e j� e�e j� dZeZeed �p�ejjZeZ d5d
d�Z dd� Z z
e
j Z W n e � y� e Z Y n0 G dd� d�Z!G dd� d�Z"z
e
j#Z#W n& e �yB G dd� de$e%�Z#Y n0 G dd� dej&d�Z'e
j'�(e'� G dd� de'�Z)e
j)�(e)� d d l*m+Z+ e)�(e+� G d d � d e'�Z,e
j,�(e,� G d d � d e,�Z-G d!d"� d"e,�Z.G d#d$� d$e-�Z/G d%d&� d&e-�Z0G d'd(� d(e,�Z1G d)d*� d*e0e/�Z2G d+d,� d,e)�Z+G d-d.� d.e'�Z3e
j3�(e3� G d/d0� d0ej4�Z5G d1d2� d2e3�Z6G d3d4� d4e6�Z7dS )6� N)�
allocate_lock> �cygwinZwin32)�setmode)�__all__�SEEK_SET�SEEK_CUR�SEEK_END> r � � � SEEK_HOLEi Zgettotalrefcount�r�����Tc C s� t | t�st�| �} t | tttf�s0td| ��t |t�sFtd| ��t |t�s\td| ��|d urzt |t�sztd| ��|d ur�t |t�s�td| ��t|�}|td� s�t|�t|�kr�t d| ��d|v } d|v }
d |v } d
|v } d |v }
d |v }d
|v }d|v �rD| �s"| �s"| �s"|
�r*t d��dd l
}|� dt d� d}
|�rX|�rXt d��| |
| | dk�rvt d��| �s�|
�s�| �s�| �s�t d��|�r�|d u�r�t d��|�r�|d u�r�t d��|�r�|d u�r�t d��|�r|dk�rdd l
}|� dt
d� t| | �rd�pd |
�r"d�p$d | �r2d �p4d | �rBd
�pDd |
�rRd �pTd ||d �}|}�z"d }|dk�s�|dk �r�|�� �r�d }d}|dk �r�t}zt�|�� �j}W n ttf�y� Y n0 |dk�r�|}|dk �r�t d ��|dk�r |�r|W S t d!��|
�r t||�}n<| �s0| �s0| �r � � d�} | sdS | �d�d p&t| �}�dkr:t|��}|S )Nr �
r )rz �findr! �min)Z readahead�n�rH �sizer@ rA �
nreadahead s
z#IOBase.readline..nreadaheadc S s dS �Nr r@ r@ r@ r@ rA r� ! s r
� is not an integerr r{ ) �hasattr� __index__r. r � bytearrayr! �read�endswithr )rH r� r� �
size_index�resr r@ r rA �readline s&
zIOBase.readlinec C s | � � | S rP re r` r@ r@ rA �__iter__6 s zIOBase.__iter__c C s | � � }|st�|S rP )r� �
StopIteration�rH �liner@ r@ rA �__next__: s zIOBase.__next__c C sP |d u s|dkrt | �S d}g }| D ]&}|�|� |t|�7 }||kr$ qLq$|S �Nr )�list�appendr! )rH �hintr~ �linesr� r@ r@ rA � readlines@ s
zIOBase.readlinesc C s | � � |D ]}| �|� q d S rP )rf �write)rH r� r� r@ r@ rA �
writelinesR s zIOBase.writelines)r )N)N)N)N)N)r
)N) rL rM rN rY rZ ra rc rg rh r4 rk rm rp rq rr rs rt �propertyri rf rx ry r+ r( r� r� r� r� r� r@ r@ r@ rA rV ; s4 "
*
rV )� metaclassc @ s. e Zd Zd dd�Zdd� Zdd� Zdd � Zd
S ) � RawIOBaser
c C sP |d u r d}|dk r | � � S t|�� �}| �|�}|d u r>d S ||d �= t|�S )Nr
r )�readallr� r� �readintor )rH r� r r~ r@ r@ rA r� m s
zRawIOBase.readc C s4 t � }| �t�}|sq ||7 }q|r,t|�S |S d S rP )r� r� r) r )rH r� �datar@ r@ rA r� ~ s
zRawIOBase.readallc C s | � d� d S )Nr� r[ �rH r r@ r@ rA r� � s zRawIOBase.readintoc C s | � d� d S �Nr� r[ r� r@ r@ rA r� � s zRawIOBase.writeN)r
)rL rM rN r� r� r� r� r@ r@ r@ rA r� _ s
r� )r' c @ sH e Zd Zddd�Zddd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dS )�BufferedIOBaser
c C s | � d� d S �Nr� r[ r r@ r@ rA r� � s zBufferedIOBase.readc C s | � d� d S )N�read1r[ r r@ r@ rA r� � s zBufferedIOBase.read1c C s | j |dd�S )NF�r� �� _readintor� r@ r@ rA r� � s zBufferedIOBase.readintoc C s | j |dd�S )NTr� r� r� r@ r@ rA � readinto1� s zBufferedIOBase.readinto1c C sV t |t�st|�}|�d�}|r0| �t|��}n| �t|��}t|�}||d |�< |S �N�B)r �
memoryview�castr� r! r� )rH r r� r� r~ r@ r@ rA r� � s
zBufferedIOBase._readintoc C s | � d� d S r� r[ r� r@ r@ rA r� � s zBufferedIOBase.writec C s | � d� d S �N�detachr[ r` r@ r@ rA r� � s zBufferedIOBase.detachN)r
)r
)
rL rM rN r� r� r� r� r� r� r� r@ r@ r@ rA r� � s
r� c @ s� e Zd Zdd� Zd#dd�Zdd� Zd$d d
�Zd d � Zd
d� Zdd� Z dd� Z
e dd� �Z e dd� �Z
e dd� �Ze dd� �Zdd � Zd d � Zd d � Zd!d"� ZdS )%�_BufferedIOMixinc C s
|| _ d S rP ��_raw�rH r< r@ r@ rA �__init__ s z_BufferedIOMixin.__init__r c C s" | j �||�}|dk r td��|S )Nr z#seek() returned an invalid position)r< rZ r- )rH r] r^ Z new_positionr@ r@ rA rZ s z_BufferedIOMixin.seekc C s | j �� }|dk rtd��|S )Nr z#tell() returned an invalid position)r< ra r- rd r@ r@ rA ra s
z_BufferedIOMixin.tellNc C s4 | � � | �� | �� |d u r(| �� }| j�|�S rP )rf rt rg ra r< rc rd r@ r@ rA rc % s z_BufferedIOMixin.truncatec C s | j rtd��| j�� d S )N�flush on closed file)ri r" r< rg r` r@ r@ rA rg 6 s z_BufferedIOMixin.flushc C s8 | j d ur4| js4z| �� W | j �� n | j �� 0 d S rP )r< ri rg r4 r` r@ r@ rA r4 ; s
z_BufferedIOMixin.closec C s* | j d u rtd��| �� | j}d | _|S )Nzraw stream already detached)r< r" rg r� r� r@ r@ rA r� C s
z_BufferedIOMixin.detachc C s
| j �� S rP )r< rm r` r@ r@ rA rm M s z_BufferedIOMixin.seekablec C s | j S rP r� r` r@ r@ rA r< P s z_BufferedIOMixin.rawc C s | j jS rP )r< ri r` r@ r@ rA ri T s z_BufferedIOMixin.closedc C s | j jS rP )r< rX r` r@ r@ rA rX X s z_BufferedIOMixin.namec C s | j jS rP )r< r3 r` r@ r@ rA r3 \ s z_BufferedIOMixin.modec C s t d| jj�d���d S �Nzcannot pickle z object�r rW rL r` r@ r@ rA � __getstate__` s z _BufferedIOMixin.__getstate__c C sL | j j}| j j}z
| j}W n ty8 d�||� Y S 0 d�|||�S d S )Nz<{}.{}>z<{}.{} name={!r}>)rW rM rN rX r. �format)rH �modnameZclsnamerX r@ r@ rA �__repr__c s
z_BufferedIOMixin.__repr__c C s
| j �� S rP )r< r+ r` r@ r@ rA r+ o s z_BufferedIOMixin.filenoc C s
| j �� S rP )r< r( r` r@ r@ rA r( r s z_BufferedIOMixin.isatty)r )N)rL rM rN r� rZ ra rc rg r4 r� rm r� r< ri rX r3 r� r� r+ r( r@ r@ r@ rA r� s(
r� c s� e Zd ZdZd dd�Zdd� Zdd� Zdd � Z� fd
d �Zd!d
d�Z d"dd�Z
dd� Z d#dd�Z dd� Z
d$dd�Zdd� Zd d � Zd d � Z� ZS )%�BytesIONc C s& t � }|d ur||7 }|| _d| _d S r� )r� �_buffer�_pos)rH Z
initial_bytes�bufr@ r@ rA r� ~ s
zBytesIO.__init__c C s | j rtd��| j�� S )Nz__getstate__ on closed file)ri r" �__dict__�copyr` r@ r@ rA r� � s zBytesIO.__getstate__c C s | j rtd��t| j�S )Nzgetvalue on closed file)ri r" r r� r` r@ r@ rA �getvalue� s zBytesIO.getvaluec C s | j rtd��t| j�S )Nzgetbuffer on closed file)ri r" r� r� r` r@ r@ rA � getbuffer� s zBytesIO.getbufferc s" | j d ur| j �� t� �� d S rP )r� �clear�superr4 r` �rW r@ rA r4 � s
z
BytesIO.closer
c C s� | j rtd��|d u r d}n2z
|j}W n tyF t|�d���Y n0 |� }|dk r`t| j�}t| j�| jkrtdS tt| j�| j| �}| j| j|� }|| _t |�S )N�read from closed filer
r� r � )
ri r" r� r. r r! r� r� r} r )rH r� r� Znewposr r@ r@ rA r� � s"
z BytesIO.readc C s
| � |�S rP )r� r r@ r@ rA r� � s z
BytesIO.read1c C s� | j rtd��t|t�r td��t|��}|j}W d � n1 sD0 Y |dkrZdS | j}|t| j �kr�d|t| j � }| j |7 _ || j ||| �< | j|7 _|S )N�write to closed file� can't write str to binary streamr � )
ri r" r r r r� �nbytesr� r! r� )rH r Zviewr~ r] Zpaddingr@ r@ rA r� � s
$z
BytesIO.writer c C s� | j rtd��z
|j}W n ty8 t|�d���Y n0 |� }|dkrf|dk r^td|f ��|| _nD|dkr�td| j| �| _n(|dkr�tdt| j�| �| _ntd��| jS )Nzseek on closed filer� r �negative seek position %rr r
zunsupported whence value) ri r" r� r. r r� �maxr! r� )rH r] r^ � pos_indexr@ r@ rA rZ � s"
z BytesIO.seekc C s | j rtd��| jS )N�tell on closed file)ri r" r� r` r@ r@ rA ra � s z BytesIO.tellc C sv | j rtd��|d u r | j}nHz
|j}W n tyH t|�d���Y n0 |� }|dk rftd|f ��| j|d �= |S )Nztruncate on closed filer� r z negative truncate position %r)ri r" r� r� r. r r� )rH r] r� r@ r@ rA rc � s
zBytesIO.truncatec C s | j rtd��dS �Nrv Trw r` r@ r@ rA rq � s zBytesIO.readablec C s | j rtd��dS r� rw r` r@ r@ rA rs � s zBytesIO.writablec C s | j rtd��dS r� rw r` r@ r@ rA rm � s zBytesIO.seekable)N)r
)r
)r )N)rL rM rN r� r� r� r� r� r4 r� r� r� rZ ra rc rq rs rm �
__classcell__r@ r@ r� rA r� v s
r� c @ st e Zd Zefdd�Zdd� Zdd� Zddd �Zdd
d �Zd d
d�Z d dd�Z
d dd�Z dd� Z dd� Z
d dd�ZdS ) r1 c C sF |� � std��t�| |� |dkr,td��|| _| �� t� | _d S )Nz "raw" argument must be readable.r �invalid buffer size) rq r- r� r� r" � buffer_size�_reset_read_buf�Lock�
_read_lock�rH r< r� r@ r@ rA r� s zBufferedReader.__init__c C s
| j �� S rP )r< rq r` r@ r@ rA rq s zBufferedReader.readablec C s d| _ d| _d S )Nr� r )� _read_buf� _read_posr` r@ r@ rA r� s z BufferedReader._reset_read_bufNc C sL |d ur|dk rt d��| j� | �|�W d � S 1 s>0 Y d S )Nr
z invalid number of bytes to read)r" r� �_read_unlockedr r@ r@ rA r� $ s zBufferedReader.readc C s� d}d}| j }| j}|d u s$|dkr�| �� t| jd�rj| j�� }|d u rZ||d � pXd S ||d � | S ||d � g}d}| j�� }||v r�|}q�|t|�7 }|�|� q|d� |�p�|S t|�| } || kr�| j|7 _|||| � S ||d � g}t
| j |�}
| |k �rH| j�|
�}||v �r.|}�qH| t|�7 } |�|� �qt || �}d� |�} | |d � | _ d| _| �r�| d |� S |S )Nr� )r� Nr
r� r )
r� r� r� r� r< r� r� r! r� �joinr� r� r} ) rH r~ Z
nodata_valZ empty_valuesr� r] �chunkZchunksZ current_size�availZwanted�outr@ r@ rA r� 1 sL
z BufferedReader._read_unlockedr c C s4 | j � | �|�W d � S 1 s&0 Y d S rP )r� �_peek_unlockedr r@ r@ rA rz e s zBufferedReader.peekc C sr t || j�}t| j�| j }||k s,|dkrb| j| }| j�|�}|rb| j| jd � | | _d| _| j| jd � S r� )r} r� r! r� r� r< r� )rH r~ ZwantZhaveZto_readZcurrentr@ r@ rA r� o s
z BufferedReader._peek_unlockedr
c C sj |dk r| j }|dkrdS | j�6 | �d� | �t|t| j�| j ��W d � S 1 s\0 Y d S )Nr r� r )r� r� r� r� r} r! r� r� r r@ r@ rA r� z s
�zBufferedReader.read1c C s t |t�st|�}|jdkr dS |�d�}d}| j�� |t|�k r�tt| j�| j t|��}|r�| j| j| j| � |||| �< | j|7 _||7 }|t|�kr�q�t|�| | j kr�| j
� ||d � �}|s�q�||7 }n|r�|s�| � d�s�q�|r6|r6q�q6W d � n1 �s0 Y |S )Nr r� r )
r r� r� r� r� r! r} r� r� r� r< r� r� )rH r� r� �writtenr� r~ r@ r@ rA r� � s6
�
$zBufferedReader._readintoc C s t �| �t| j� | j S rP )r� ra r! r� r� r` r@ r@ rA ra � s zBufferedReader.tellc C sp |t vrtd��| j�F |dkr4|t| j�| j 8 }t�| ||�}| �� |W d � S 1 sb0 Y d S )N�invalid whence valuer ) �valid_seek_flagsr" r� r! r� r� r� rZ r� r\ r@ r@ rA rZ � s zBufferedReader.seek)N)N)r )r )r
)r )rL rM rN r) r� rq r� r� r� rz r� r� r� ra rZ r@ r@ r@ rA r1 s
4
.r1 c @ s\ e Zd Zefdd�Zdd� Zdd� Zddd �Zd
d � Zd d
� Z dd� Z
ddd�Z dd� Z dS )r0 c C sF |� � std��t�| |� |dkr,td��|| _t� | _t� | _ d S )Nz "raw" argument must be writable.r r� )
rs r- r� r� r" r� r� �
_write_bufr� � _write_lockr� r@ r@ rA r� � s zBufferedWriter.__init__c C s
| j �� S rP )r< rs r` r@ r@ rA rs � s zBufferedWriter.writablec C s t |t�rtd��| j�� | jr(td��t| j�| jkr@| � � t| j�}| j�
|� t| j�| }t| j�| jkr�z | � � W nn t y� } zVt| j�| jkr�t| j�| j }||8 }| jd | j� | _t |j |j
|��W Y d }~n
d }~0 0 |W d � S 1 �s
0 Y d S )Nr� r� )r r r r� ri r" r! r� r� �_flush_unlocked�extend�BlockingIOError�errno�strerror)rH r Zbeforer� �eZoverager@ r@ rA r� � s(
&zBufferedWriter.writeNc C sP | j �6 | �� |d u r"| j�� }| j�|�W d � S 1 sB0 Y d S rP )r� r� r< ra rc rd r@ r@ rA rc � s
zBufferedWriter.truncatec C s2 | j � | �� W d � n1 s$0 Y d S rP )r� r� r` r@ r@ rA rg s zBufferedWriter.flushc C s� | j rtd��| jr�z| j�| j�}W n ty@ td��Y n0 |d u rXttjdd��|t | j�ksn|dk rvt
d��| jd |�= qd S )Nr� zHself.raw should implement RawIOBase: it should not raise BlockingIOErrorz)write could not complete without blockingr z*write() returned incorrect number of bytes) ri r" r� r< r� r� � RuntimeErrorr� ZEAGAINr! r- �rH r~ r@ r@ rA r� s �z BufferedWriter._flush_unlockedc C s t �| �t| j� S rP )r� ra r! r� r` r@ r@ rA ra s zBufferedWriter.tellr c C sP |t vrtd��| j�& | �� t�| ||�W d � S 1 sB0 Y d S )Nr� )r� r" r� r� r� rZ r\ r@ r@ rA rZ s
zBufferedWriter.seekc C s� | j �0 | jd u s| jr(W d � d S W d � n1 s<0 Y z<| �� W | j � | j�� W d � q�1 sx0 Y n2| j � | j�� W d � n1 s�0 Y 0 d S rP )r� r< ri rg r4 r` r@ r@ rA r4 s .
*�zBufferedWriter.close)N)r )
rL rM rN r) r� rs r� rc rg r� ra rZ r4 r@ r@ r@ rA r0 � s
r0 c @ s� e Zd Zefdd�Zd dd�Zdd� Zdd � Zd d d �Zd d
d�Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zedd � �Zd S )!�BufferedRWPairc C s< |� � std��|�� s td��t||�| _t||�| _d S )Nz#"reader" argument must be readable.z#"writer" argument must be writable.)rq r- rs r1 �readerr0 �writer)rH r� r� r� r@ r@ rA r� @ s zBufferedRWPair.__init__r
c C s |d u r d}| j �|�S �Nr
)r� r� r r@ r@ rA r� N s zBufferedRWPair.readc C s | j �|�S rP )r� r� r� r@ r@ rA r� S s zBufferedRWPair.readintoc C s | j �|�S rP )r� r� r� r@ r@ rA r� V s zBufferedRWPair.writer c C s | j �|�S rP )r� rz r r@ r@ rA rz Y s zBufferedRWPair.peekc C s | j �|�S rP )r� r� r r@ r@ rA r� \ s zBufferedRWPair.read1c C s | j �|�S rP )r� r� r� r@ r@ rA r� _ s zBufferedRWPair.readinto1c C s
| j �� S rP )r� rq r` r@ r@ rA rq b s zBufferedRWPair.readablec C s
| j �� S rP )r� rs r` r@ r@ rA rs e s zBufferedRWPair.writablec C s
| j �� S rP )r� rg r` r@ r@ rA rg h s zBufferedRWPair.flushc C s* z| j �� W | j�� n | j�� 0 d S rP )r� r4 r� r` r@ r@ rA r4 k s zBufferedRWPair.closec C s | j �� p| j�� S rP )r� r( r� r` r@ r@ rA r( q s zBufferedRWPair.isattyc C s | j jS rP )r� ri r` r@ r@ rA ri t s zBufferedRWPair.closedN)r
)r )r
)rL rM rN r) r� r� r� r� rz r� r� rq rs rg r4 r( r� ri r@ r@ r@ rA r� 0 s
r� c @ sj e Zd Zefdd�Zddd�Zdd� Zdd d
�Zdd d �Zd
d� Z ddd�Z
d dd�Z dd� Z dd� Z
dS ) r/ c C s( |� � t�| ||� t�| ||� d S rP )rp r1 r� r0 r� r@ r@ rA r� � s zBufferedRandom.__init__r c C s� |t vrtd��| �� | jr^| j�* | j�| jt| j� d� W d � n1 sT0 Y | j�||�}| j� | � � W d � n1 s�0 Y |dk r�t
d��|S )Nr� r r z seek() returned invalid position) r� r" rg r� r� r< rZ r� r! r� r- r\ r@ r@ rA rZ � s 8&zBufferedRandom.seekc C s | j rt�| �S t�| �S d S rP )r� r0 ra r1 r` r@ r@ rA ra � s
zBufferedRandom.tellNc C s |d u r| � � }t�| |�S rP )ra r0 rc rd r@ r@ rA rc � s zBufferedRandom.truncatec C s |d u r d}| � � t�| |�S r� )rg r1 r� r r@ r@ rA r� � s zBufferedRandom.readc C s | � � t�| |�S rP )rg r1 r� r� r@ r@ rA r� � s zBufferedRandom.readintoc C s | � � t�| |�S rP )rg r1 rz r r@ r@ rA rz � s zBufferedRandom.peekr
c C s | � � t�| |�S rP )rg r1 r� r r@ r@ rA r� � s zBufferedRandom.read1c C s | � � t�| |�S rP )rg r1 r� r� r@ r@ rA r� � s zBufferedRandom.readinto1c C sZ | j rN| j�2 | j�| jt| j � d� | �� W d � n1 sD0 Y t�| |�S r� ) r� r� r< rZ r� r! r� r0 r� r� r@ r@ rA r� � s
&zBufferedRandom.write)r )N)N)r )r
)rL rM rN r) r� rZ ra rc r� r� rz r� r� r� r@ r@ r@ rA r/ y s
r/ c s� e Zd ZdZdZdZdZdZdZdZ d0dd�Z
dd � Z d
d � Z d d
� Z
dd� Zd1dd�Zd2dd�Zdd� Zdd� Zdd� Zefdd�Zd d � Zd3d d �Z� fd d!�Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z e d,d-� �Z e d.d/� �Z � Z!S )4r' r
FNTr c
C sH | j dkr0z | jr t�| j � W d| _ nd| _ 0 t|t�rBtd��t|t�rb|}|dk rftd��nd}t|t �s~td|f ��t
|�t
d�ks�td|f ��t dd� |D ��d ks�|� d
�d kr�td ��d |v r�d
| _
d
| _tjtjB }nTd|v r�d
| _d}n@d|v �r d
| _tjtjB }n"d|v �r>d
| _d
| _tjtjB }d
|v �rTd
| _d
| _| j�rp| j�rp|tjO }n | j�r�|tjO }n
|tjO }|ttdd�O }ttdd��p�ttdd�}||O }d }�zT|dk �r@|�s�td��|d u �r�t�||d�}n0|||�}t|t��std��|dk �r*td��|}|�s@t�|d� || _t� |�} z(t � | j ��rvt t!j"t�#t!j"�|��W n t$�y� Y n0 t| dd�| _%| j%d k�r�t&| _%t'�r�t'|tj(� || _)| j�rzt�*|dt+� W n6 t�y }
z |
j!t!j,k�r� W Y d }
~
n
d }
~
0 0 W n" |d u�r6t�|� � Y n0 || _ d S )Nr r
z$integer argument expected, got floatznegative file descriptorzinvalid mode: %szxrwab+c s s | ]}|d v V qdS )ZrwaxNr@ )�.0�cr@ r@ rA � � r� z"FileIO.__init__..r r zKMust have exactly one of create/read/write/append mode and at most one plusr Tr r r �O_BINARYZ O_NOINHERIT� O_CLOEXECz'Cannot use closefd=False with file namei� z expected integer from openerzNegative file descriptorFr, )-�_fd�_closefdr r4 r �floatr r r" r r �sum�count�_created� _writable�O_EXCL�O_CREAT� _readable�O_TRUNC�
_appending�O_APPEND�O_RDWR�O_RDONLY�O_WRONLY�getattrrB r- �set_inheritabler* �stat�S_ISDIR�st_mode�IsADirectoryErrorr� ZEISDIRr� r. �_blksizer) �_setmoder� rX �lseekr ZESPIPE) rH r5 r3 r: r �fd�flagsZnoinherit_flagZowned_fdZfdfstatr� r@ r@ rA r� � s�
$
�
�
zFileIO.__init__c C sB | j dkr>| jr>| js>dd l}|jd| f td| d� | �� d S )Nr zunclosed file %rr
)�
stacklevel�source)r� r� ri r# r$ �ResourceWarningr4 )rH r# r@ r@ rA rk E s �zFileIO.__del__c C s t d| jj�d���d S r� r� r` r@ r@ rA r� L s zFileIO.__getstate__c C sn d| j j| j jf }| jr"d| S z
| j}W n( tyT d|| j| j| jf Y S 0 d||| j| jf S d S )Nz%s.%sz
<%s [closed]>z <%s fd=%d mode=%r closefd=%r>z <%s name=%r mode=%r closefd=%r>) rW rM rN ri rX r. r� r3 r� )rH �
class_namerX r@ r@ rA r� O s �
�
�zFileIO.__repr__c C s | j std��d S )NzFile not open for reading)r� rU r` r@ r@ rA rr ] s zFileIO._checkReadablec C s | j std��d S )NzFile not open for writing)r� rU rn r@ r@ rA rt a s zFileIO._checkWritablec C sR | � � | �� |d u s |dk r(| �� S zt�| j|�W S tyL Y d S 0 d S r� )rf rr r� r r� r� r� r r@ r@ rA r� e s z FileIO.readc C s� | � � | �� t}z6t�| jdt�}t�| j�j}||krH|| d }W n t y\ Y n0 t
� }t |�|kr�t |�}|t |t�7 }|t |� }zt�
| j|�}W n ty� |r�Y q�Y d S 0 |s�q�||7 }qdt|�S r_ )rf rr r) r r
r� r r* �st_sizer- r� r! r� r� r� r )rH �bufsizer] �endr= r~ r� r@ r@ rA r� u s2
zFileIO.readallc C s4 t |��d�}| �t|��}t|�}||d |�< |S r� )r� r� r� r! )rH r �mr� r~ r@ r@ rA r� � s
zFileIO.readintoc C s: | � � | �� zt�| j|�W S ty4 Y d S 0 d S rP )rf rt r r� r� r� r� r@ r@ rA r� � s z FileIO.writec C s* t |t�rtd��| �� t�| j||�S )Nzan integer is required)r r� r rf r r
r� r\ r@ r@ rA rZ � s
z FileIO.seekc C s | � � t�| jdt�S r� )rf r r
r� r r` r@ r@ rA ra � s z FileIO.tellc C s2 | � � | �� |d u r | �� }t�| j|� |S rP )rf rt ra r � ftruncater� r r@ r@ rA rc � s zFileIO.truncatec s8 | j s4z | jrt�| j� W t� �� n t� �� 0 d S rP )ri r� r r4 r� r� r` r� r@ rA r4 � s
z FileIO.closec C sD | � � | jd u r>z | �� W n ty6 d| _Y n0 d| _| jS )NFT)rf � _seekablera r- r` r@ r@ rA rm � s
zFileIO.seekablec C s | � � | jS rP )rf r� r` r@ r@ rA rq � s zFileIO.readablec C s | � � | jS rP )rf r� r` r@ r@ rA rs � s zFileIO.writablec C s | � � | jS rP )rf r� r` r@ r@ rA r+ � s z
FileIO.filenoc C s | � � t�| j�S rP )rf r r( r� r` r@ r@ rA r( � s z
FileIO.isattyc C s | j S rP )r� r` r@ r@ rA r: � s zFileIO.closefdc C sJ | j r| jrdS dS n0| jr,| jr&dS dS n| jrB| jrd?� Z#dRd@dA�Z$dBdC� Z%dSdDdE�Z&dTdFdG�Z'dHdI� Z(dUdJdK�Z)e dLdM� �Z*dS )Vr2 i NFc C s$ | � |� |d u rrzt�|�� �}W n ttfy: Y n0 |d u rrz dd l}W n tyf d}Y n 0 |�d�}t |t
�s�t d| ��t �
|�js�d}t|| ��|d u r�d}n$t |t
�s�t d| ��tr�t �|� || _d| _d| _d | _| j�� | _| _t| jd �| _| � |||||� d S )
Nr �asciiFr zG%r is not a text encoding; use codecs.open() to handle arbitrary codecsr r r r� ) �_check_newliner �device_encodingr+ r. rU �locale� ImportErrorZgetpreferredencodingr r r" r �lookup�_is_text_encoding� LookupError�
_CHECK_ERRORS� lookup_errorr� �_decoded_chars�_decoded_chars_used� _snapshotr? rm r �_tellingr� �
_has_read1�
_configure) rH r? r7 r8 r9 r> �
write_throughr< ro r@ r@ rA r� � s@
�zTextIOWrapper.__init__c C s> |d ur$t |t�s$tdt|�f ��|dvr:td|f ��d S )Nzillegal newline type: %r)Nr r* r( r) zillegal newline value: %r)r r r �typer" )rH r9 r@ r@ rA r: � s z TextIOWrapper._check_newlinec C s� || _ || _d | _d | _d| _| | _|d u | _|| _|dk| _|pHt j
| _ || _ || _
| jr�| �� r�| j�� }|dkr�z| �� �d� W n ty� Y n0 d S )N� r r )� _encoding�_errors�_encoder�_decoder� _b2cratio�_readuniversal�_readtranslate�_readnl�_writetranslater �linesep�_writenl�_line_buffering�_write_throughr rs r? ra � _get_encoderr5 r@ )rH r7 r8 r9 r> rI �positionr@ r@ rA rH s&
zTextIOWrapper._configurec C s| d� | jj| jj�}z
| j}W n ty0 Y n0 |d� |�7 }z
| j}W n ty\ Y n0 |d� |�7 }|d� | j� S )Nz<{}.{}z name={0!r}z mode={0!r}z encoding={0!r}>)r� rW rM rN rX r. r3 r7 )rH r= rX r3 r@ r@ rA r� ' s
�
zTextIOWrapper.__repr__c C s | j S rP )rL r` r@ r@ rA r7 8 s zTextIOWrapper.encodingc C s | j S rP )rM r` r@ r@ rA r8 < s zTextIOWrapper.errorsc C s | j S rP )rW r` r@ r@ rA r> @ s z TextIOWrapper.line_bufferingc C s | j S rP )rX r` r@ r@ rA rI D s zTextIOWrapper.write_throughc C s | j S rP )r� r` r@ r@ rA r? H s zTextIOWrapper.buffer)r7 r8 r9 r> rI c C s� | j d ur*|d us"|d us"|tur*td��|d u rH|d u rB| j}q^d}nt|t�s^td| ��|d u rn| j}nt|t�s�td| ��|tu r�| j}| � |� |d u r�| j
}|d u r�| j }| � � | �
|||||� d S )NzPIt is not possible to set the encoding or newline of stream after the first readr r r )rO �EllipsisrU rM r r r rL rS r: r> rI rg rH )rH r7 r8 r9 r> rI r@ r@ rA � reconfigureL s>
����
�zTextIOWrapper.reconfigurec C s | j rtd��| jS ru )ri r" r r` r@ r@ rA rm u s zTextIOWrapper.seekablec C s
| j �� S rP )r? rq r` r@ r@ rA rq z s zTextIOWrapper.readablec C s
| j �� S rP )r? rs r` r@ r@ rA rs } s zTextIOWrapper.writablec C s | j �� | j| _d S rP )r? rg r rF r` r@ r@ rA rg � s
zTextIOWrapper.flushc C s8 | j d ur4| js4z| �� W | j �� n | j �� 0 d S rP )r? ri rg r4 r` r@ r@ rA r4 � s
zTextIOWrapper.closec C s | j jS rP )r? ri r` r@ r@ rA ri � s zTextIOWrapper.closedc C s | j jS rP )r? rX r` r@ r@ rA rX � s zTextIOWrapper.namec C s
| j �� S rP )r? r+ r` r@ r@ rA r+ � s zTextIOWrapper.filenoc C s
| j �� S rP )r? r( r` r@ r@ rA r( � s zTextIOWrapper.isattyc C s� | j rtd��t|t�s(td|jj ��t|�}| js<| j oBd|v }|rf| jrf| j
dkrf|� d| j
�}| j pr| �
� }|�|�}| j�|� | j r�|s�d|v r�| �� | �d� d | _| jr�| j�� |S )Nr� z can't write %s to text streamr* r( r )ri r" r r r rW rL r! rT rW rV r/ rN rY �encoder? r� rg �_set_decoded_charsrE rO r7 )rH r ZlengthZhaslf�encoderr r@ r@ rA r� � s(
�
zTextIOWrapper.writec C s t �| j�}|| j�| _| jS rP )r �getincrementalencoderrL rM rN )rH Z make_encoderr@ r@ rA rY � s zTextIOWrapper._get_encoderc C s2 t �| j�}|| j�}| jr(t|| j�}|| _|S rP )r �getincrementaldecoderrL rM rQ r rR rO )rH Z make_decoderr# r@ r@ rA � _get_decoder� s
zTextIOWrapper._get_decoderc C s || _ d| _d S r� )rC rD )rH �charsr@ r@ rA r^ � s z TextIOWrapper._set_decoded_charsc C sF | j }|d u r | j|d � }n| j||| � }| j t|�7 _ |S rP )rD rC r! )rH r~ �offsetrc r@ r@ rA �_get_decoded_chars� s z TextIOWrapper._get_decoded_charsc C s$ | j |k rtd��| j |8 _ d S )Nz"rewind decoded_chars out of bounds)rD �AssertionErrorr� r@ r@ rA �_rewind_decoded_chars� s
z#TextIOWrapper._rewind_decoded_charsc C s� | j d u rtd��| jr&| j �� \}}| jr<| j�| j�}n| j�| j�}| }| j � ||�}| �
|� |r�t |�t | j � | _
nd| _
| jr�||| f| _| S )Nz
no decoderrK )rO r" rF r2 rG r? r� � _CHUNK_SIZEr� r+ r^ r! rC rP rE )rH �
dec_buffer� dec_flags� input_chunk�eofZ
decoded_charsr@ r@ rA � _read_chunk� s
zTextIOWrapper._read_chunkr c C s( ||d> B |d> B |d> B t |�d> B S )N�@ � �� � )r4 )rH rZ rj �
bytes_to_feed�need_eof�
chars_to_skipr@ r@ rA � _pack_cookie� s
�
�zTextIOWrapper._pack_cookiec C sJ t |d�\}}t |d�\}}t |d�\}}t |d�\}}|||t|�|fS )Nl )�divmodr4 )rH Zbigint�restrZ rj rr rs rt r@ r@ rA �_unpack_cookie s
z TextIOWrapper._unpack_cookiec C sP | j std��| js td��| �� | j�� }| j}|d u sF| jd u rX| j rTt
d��|S | j\}}|t |�8 }| j }|dkr�| �
||�S |�� }�z�t| j| �}d}|dk�r"|�d|f� t |�|d |� ��} | |k�r|�� \}
} |
s�| }|| 8 }�q4|t |
�8 }d}q�||8 }|d }q�d}|�d|f� || } |}
|dk�rb| �
| |
�W |�|� S d}d}d}t|t |��D ]x}|d7 }|t |�|||d � ��7 }|�� \}}|�s�||k�r�| |7 } ||8 }|dd }
}}||k�r| �q"�q||t |jdd d
��7 }d }||k �r"td ��| �
| |
|||�W |�|� S |�|� 0 d S ) N�!underlying stream is not seekablez(telling position disabled by next() callzpending decoded textr r r� r
FTr& z'can't reconstruct logical file position)r rU rF r- rg r? ra rO rE rC rf r! rD ru r2 r rP r5 r+ �range)rH rZ r# rj Z
next_inputrt Z saved_stateZ
skip_bytesZ skip_backr~ r �d� start_posZ start_flagsZ bytes_fedrs Z
chars_decoded�iri r@ r@ rA ra s�
�
�
�zTextIOWrapper.tellc C s$ | � � |d u r| �� }| j�|�S rP )rg ra r? rc rd r@ r@ rA rc s s zTextIOWrapper.truncatec C s* | j d u rtd��| �� | j}d | _|S )Nzbuffer is already detached)r? r" rg r� )rH r? r@ r@ rA r� y s
zTextIOWrapper.detachc s� � fdd�}� j rtd��� js(td��|tkrN|dkr@td��d}� �� }nZ|tkr�|dkrftd��� �� � j� d|�}� �
d� d � _ � j r�� j �
� ||� |S |dkr�td |f ��|dk r�td
|f ��� �� � �|�\}}}}} � j� |� � �
d� d � _ |dk�r*� j �r*� j �
� n@� j �s>|�s>| �rj� j �pL� �� � _ � j �d |f� |d f� _ | �r�� j�|�}
� �
� j �|
|�� ||
f� _ t� j�| k �r�td ��| � _||� |S )
Nc sF z� j p� �� }W n ty$ Y n 0 | dkr:|�d� n|�� d S r� )rN rY r@ r5 r7 )rZ r_ r` r@ rA �_reset_encoder� s z*TextIOWrapper.seek.._reset_encoderr� ry r z#can't do nonzero cur-relative seeksz#can't do nonzero end-relative seeksr zunsupported whence (%r)r� r� z#can't restore logical file position)ri r" r rU r ra r rg r? rZ r^ rE rO r7 rx rb r5 r� r+ r! rC r- rD ) rH Zcookier^ r~ rZ r| rj rr rs rt rk r@ r` rA rZ � s`
�
�
zTextIOWrapper.seekc C s� | � � |d u rd}n2z
|j}W n ty@ t|�d���Y n0 |� }| jpT| �� }|dk r�| �� |j| j� � dd� }| �
d� d | _ |S d}| �|�}t |�|k r�|s�| �
� }|| �|t |� �7 }q�|S d S )Nr
r� r Tr& r F)rr r� r. r rO rb re r+ r? r� r^ rE r! rm )rH r� r� r# r= rl r@ r@ rA r� � s,
�
zTextIOWrapper.readc C s( d| _ | �� }|s$d | _| j| _ t�|S rl )rF r� rE r r� r� r@ r@ rA r� � s zTextIOWrapper.__next__c C s | j rtd��|d u r d}n2z
|j}W n tyF t|�d���Y n0 |� }| �� }d}| jsh| �� d }}| jr�|� d|�}|dkr�|d }�q�nt
|�}n�| j �rD|� d|�}|� d|�}|dkr�|dkr�t
|�}n |d }�q�nX|dk�r|d }�q�n@||k �r|d }�q�n(||d k�r6|d }�q�n |d }�q�n(|� | j �}|dk�rl|t
| j � }�q�|dk�r�t
|�|k�r�|}�q�| �
� �r�| j�r��q��q�| j�r�|| �� 7 }qp| �d � d | _|S qp|dk�r�||k�r�|}| �t
|�| � |d |� S )
Nr� r
r� r r* r r( r
r )ri r" r� r. r re rO rb rR r| r! rQ rS rm rC r^ rE rg ) rH r� r� r� �startr] �endposZnlposZcrposr@ r@ rA r� � st
zTextIOWrapper.readlinec C s | j r| j jS d S rP )rO r r` r@ r@ rA r N
s zTextIOWrapper.newlines)NNNFF)NNNFF)N)r r Fr )N)r )N)N)+rL rM rN rh r� r� r: rH r� r� r7 r8 r> rI r? r[ r\ rm rq rs rg r4 ri rX r+ r( r� rY rb r^ re rg rm ru rx ra rc r� rZ r� r� r� r r@ r@ r@ rA r2 � sl �
* �
$
� )
* �
c
K
]r2 c sN e Zd Zd� fdd� Zdd� Zdd� Zed d
� �Zed d � �Zd
d� Z � Z
S )�StringIOr r* c sf t t| �jt� dd|d� |d u r(d| _|d urbt|t�sNtd�t |�j
���| � |� | � d� d S )Nzutf-8�
surrogatepass)r7 r8 r9 Fz*initial_value must be str or None, not {0}r )
r� r� r� r� rT r r r r� rJ rL r� rZ )rH Z
initial_valuer9 r� r@ rA r� Z
s �
�
zStringIO.__init__c C sX | � � | jp| �� }|�� }|�� z |j| j�� dd�W |�|� S |�|� 0 d S )NTr& ) rg rO rb r2 r7 r+ r? r� r5 )rH r# Z old_stater@ r@ rA r� j
s
�zStringIO.getvaluec C s
t �| �S rP )�objectr� r` r@ r@ rA r� t
s zStringIO.__repr__c C s d S rP r@ r` r@ r@ rA r8 y
s zStringIO.errorsc C s d S rP r@ r` r@ r@ rA r7 }
s zStringIO.encodingc C s | � d� d S r� r[ r` r@ r@ rA r� �
s zStringIO.detach)r r* ) rL rM rN r� r� r� r� r8 r7 r� r� r@ r@ r� rA r� S
s
r� )r r
NNNTN)8r �abcr r� r �sys�_threadr r� �platformZmsvcrtr r �ior r r r r� r� �addr � SEEK_DATAr) r� r �dev_moderj rA rB rE � open_coder. rF rO rU r- r" �ABCMetarV �registerr� �_ior' r� r� r� r1 r0 r� r/ r r! r r2 r� r@ r@ r@ rA � s�
�
[
# =
g k CiIJ Y@ U &