| Server IP : 118.27.122.248 / Your IP : 216.73.216.153 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python36/lib64/python3.6/test/__pycache__/ |
Upload File : |
3
�w2_}` � @ s: d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlmZmZ ddlmZmZ ddlmZ ddlmZmZ ddlmZ ddlZddl Z ddl Z y ddl Z W n e k
r� dZ Y nX y ddl!Z!W n e k
�r dd � Z"Y n X d
d � Z"G d d � d e!j#�Z$d
d� Z%G dd� d�Z&G dd� de&e j'�Z(G dd� de&e j'�Z)G dd� de&�Z*G dd� de*e j'�Z+G dd� de*e j'�Z,G dd � d e*�Z-G d d � d e-e j'�Z.G d d � d e-e j'�Z/G d!d"� d"e*�Z0G d#d$� d$e0e j'�Z1G d%d&� d&e0e j'�Z2G d'd(� d(�Z3G d)d*� d*e3e j4�Z5G d+d,� d,e3e j4�Z6G d-d.� d.�Z7G d/d0� d0e7e j4�Z8G d1d2� d2e7e j4�Z9G d3d4� d4�Z:G d5d6� d6e:e j'�Z;G d7d8� d8e:e j'�Z<G d9d:� d:e j=�Z>G d;d<� d<e>�Z?G d=d>� d>e>�Z@ejAG d?d@� d@e j=��ZBG dAdB� dB�ZCG dCdD� dD�ZDG dEdF� dFe j=eC�ZEG dGdH� dHeEeD�ZFG dIdJ� dJeE�ZGG dKdL� dLe j=eC�ZHG dMdN� dNeHeD�ZIG dOdP� dPeH�ZJG dQdR� dRe j=�ZKG dSdT� dTeK�ZLG dUdV� dVeK�ZMG dWdX� dXeEeH�ZNG dYdZ� dZeNeD�ZOG d[d\� d\eN�ZPG d]d^� d^ejQ�ZRejSeRjT� G d_d`� d`e j=�ZUG dadb� dbe j=�ZVG dcdd� dde j4�ZWdedf� ZXG dgdh� dheV�ZYG didj� djeV�ZZG dkdl� dle j=�Z[G dmdn� dne[�Z\G dodp� dpe[�Z]G dqdr� dre j=�Z^G dsdt� dte^�Z_G dudv� dve^�Z`e jaejbdwkdx�G dydz� dze j=��ZcG d{d|� d|ec�ZdG d}d~� d~ec�Zedd�� Zfegd�k�r6e jh� dS )�z Unit tests for the io module.� N)�deque�UserList)�cycle�count)�support)�assert_python_ok�run_python_until_end)�FakePathc O s t j dt| |��S )N�b)�array�bytes)�pos�kw� r �1/opt/alt/python36/lib64/python3.6/test/test_io.py� byteslike4 s r c O s: t | |�}t� }tj|t|�� |t|�jd�dd�< |S )z?Create a bytes-like object having no string or sequence methods�BN)r � EmptyStruct�ctypesZresize�len�
memoryview�cast)r
r �data�objr r r r 7 s
c @ s e Zd ZdS )r N)�__name__�
__module__� __qualname__r r r r r > s r c C s t tddd��} | jS Q R X dS )z(Get the default TextIOWrapper chunk size�rzlatin-1)�encodingN)�open�__file__� _CHUNK_SIZE)�fr r r �_default_chunk_sizeA s r# c @ sf e Zd ZdZf fdd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z ddd�Z
dS )�MockRawIOWithoutReadzmA RawIO implementation without read(), so as to exercise the default
RawIO.read() which calls readinto().c C s t |�| _g | _d| _d| _d S )Nr )�list� _read_stack� _write_stack�_reads�_extraneous_reads)�selfZ
read_stackr r r �__init__K s
z MockRawIOWithoutRead.__init__c C s | j jt|�� t|�S )N)r' �appendr r )r* r
r r r �writeQ s zMockRawIOWithoutRead.writec C s dS )NTr )r* r r r �writableU s z MockRawIOWithoutRead.writablec C s dS )N�* r )r* r r r �filenoX s zMockRawIOWithoutRead.filenoc C s dS )NTr )r* r r r �readable[ s z MockRawIOWithoutRead.readablec C s dS )NTr )r* r r r �seekable^ s z MockRawIOWithoutRead.seekablec C s dS )Nr r )r* r
�whencer r r �seeka s zMockRawIOWithoutRead.seekc C s dS )Nr r )r* r r r �telld s zMockRawIOWithoutRead.tellc C s� | j d7 _ t|�}y| jd }W n" tk
rF | jd7 _dS X |d kr\| jd= d S t|�}t|�|kr�| jd= ||d |�< |S |d |� |d d �< ||d � | jd< |S d S )N� r )r( r r& �
IndexErrorr) )r* �bufZmax_lenr �nr r r �readintog s$ z MockRawIOWithoutRead.readintoNc C s |S )Nr )r* r
r r r �truncate| s z MockRawIOWithoutRead.truncate)N)r r r �__doc__r+ r- r. r0 r1 r2 r4 r5 r: r; r r r r r$ G s r$ c @ s e Zd ZdS )�CMockRawIOWithoutReadN)r r r r r r r r= s r= c @ s e Zd ZdS )�PyMockRawIOWithoutReadN)r r r r r r r r> � s r> c @ s e Zd Zddd�ZdS )� MockRawIONc C s8 | j d7 _ y | jjd�S | jd7 _dS d S )Nr6 r � )r( r& �popr) )r* r9 r r r �read� s zMockRawIO.read)N)r r r rB r r r r r? � s r? c @ s e Zd ZdS )�
CMockRawION)r r r r r r r rC � s rC c @ s e Zd ZdS )� PyMockRawION)r r r r r r r rD � s rD c sF e Zd Z� fdd�Zd � fdd� Zdd� Zdd � Z� fd
d �Z� ZS )
�MisbehavedRawIOc s t � j|�d S )N� )�superr- )r* r
)� __class__r r r- � s zMisbehavedRawIO.writeNc s t � j|�d S )NrF )rG rB )r* r9 )rH r r rB � s zMisbehavedRawIO.readc C s dS )N�{ i����r )r* r
r3 r r r r4 � s zMisbehavedRawIO.seekc C s dS )Ni� i8���r )r* r r r r5 � s zMisbehavedRawIO.tellc s t � j|� t|�d S )N� )rG r: r )r* r8 )rH r r r: � s zMisbehavedRawIO.readinto)N) r r r r- rB r4 r5 r: �
__classcell__r r )rH r rE � s
rE c @ s e Zd ZdS )�CMisbehavedRawION)r r r r r r r rL � s rL c @ s e Zd ZdS )�PyMisbehavedRawION)r r r r r r r rM � s rM c @ s e Zd ZdZdd� ZdS )�CloseFailureIOr c C s | j sd| _ t�d S )Nr6 )�closed�OSError)r* r r r �close� s zCloseFailureIO.closeN)r r r rO rQ r r r r rN � s rN c @ s e Zd ZdS )�CCloseFailureION)r r r r r r r rR � s rR c @ s e Zd ZdS )�PyCloseFailureION)r r r r r r r rS � s rS c s6 e Zd Z� fdd�Zd� fdd� Z� fdd�Z� ZS ) �
MockFileIOc s g | _ t� j|� d S )N)� read_historyrG r+ )r* r )rH r r r+ � s zMockFileIO.__init__Nc s, t � j|�}| jj|d kr d nt|�� |S )N)rG rB rU r, r )r* r9 �res)rH r r rB � s zMockFileIO.readc s t � j|�}| jj|� |S )N)rG r: rU r, )r* r
rV )rH r r r: � s zMockFileIO.readinto)N)r r r r+ rB r: rK r r )rH r rT � s rT c @ s e Zd ZdS )� CMockFileION)r r r r r r r rW � s rW c @ s e Zd ZdS )� PyMockFileION)r r r r r r r rX � s rX c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�MockUnseekableIOc C s dS )NFr )r* r r r r2 � s zMockUnseekableIO.seekablec G s | j d��d S )Nz not seekable)�UnsupportedOperation)r* �argsr r r r4 � s zMockUnseekableIO.seekc G s | j d��d S )Nz not seekable)rZ )r* r[ r r r r5 � s zMockUnseekableIO.tellc G s | j d��d S )Nz not seekable)rZ )r* r[ r r r r; � s zMockUnseekableIO.truncateN)r r r r2 r4 r5 r; r r r r rY � s rY c @ s e Zd ZejZdS )�CMockUnseekableION)r r r �iorZ r r r r r\ � s r\ c @ s e Zd ZejZdS )�PyMockUnseekableION)r r r �pyiorZ r r r r r^ � s r^ c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�MockNonBlockWriterIOc C s g | _ d | _d S )N)r' �
_blocker_char)r* r r r r+ � s z MockNonBlockWriterIO.__init__c C s dj | j�}g | jd d �< |S )Nr@ )�joinr' )r* �sr r r � pop_written� s z MockNonBlockWriterIO.pop_writtenc C s
|| _ dS )z'Block when a given char is encountered.N)ra )r* �charr r r �block_on� s z MockNonBlockWriterIO.block_onc C s dS )NTr )r* r r r r1 � s z MockNonBlockWriterIO.readablec C s dS )NTr )r* r r r r2 � s z MockNonBlockWriterIO.seekablec C s dS )NTr )r* r r r r. � s z MockNonBlockWriterIO.writablec C sv t |�}d}| jrby|j| j�}W n tk
r6 Y n,X |dkrX| jj|d |� � |S d | _d S | jj|� t|�S )Nr6 r ���)r ra �index�
ValueErrorr' r, r )r* r
r9 r r r r- s zMockNonBlockWriterIO.writeN)
r r r r+ rd rf r1 r2 r. r- r r r r r` � s r` c @ s e Zd ZejZdS )�CMockNonBlockWriterION)r r r r] �BlockingIOErrorr r r r rj s rj c @ s e Zd ZejZdS )�PyMockNonBlockWriterION)r r r r_ rk r r r r rl s rl c @ s� e Zd Zdd� Zdd� Zdd� Zdcdd �ZddZd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z d>d?� Z!d@dA� Z"dBdC� Z#dDdE� Z$dFdG� Z%dHdI� Z&dJdK� Z'dLdM� Z(dNdO� Z)dPdQ� Z*dRdS� Z+dTdU� Z,dVdW� Z-dXdY� Z.dZd[� Z/d\d]� Z0d^d_� Z1d`da� Z2dbS )e�IOTestc C s t jt j� d S )N)r �unlink�TESTFN)r* r r r �setUp s z IOTest.setUpc C s t jt j� d S )N)r rn ro )r* r r r �tearDown! s zIOTest.tearDownc C sD | j |jd�d� |jd� | j |j� d� |jd� | j |jd�d� | j |jd�d� | j |jd�d� | j |j� d� | j |jdd�d� | j |j� d� td�}| j |j|�d� d|d d �< | j |jd�d� | j |jd
�d� | j |jdd �d � | j |j� d � | j |jd
�d
� | j |j� d � | jt|jd� d S )Ns blah.rJ r s Hello.� r6 s world
� � *� hrF �
� g rg s *********rg )� assertEqualr- r; r5 r4 � bytearray� assertRaises� TypeError)r* r" �bufferr r r � write_ops$ s(
zIOTest.write_opsFc C s� |j d�}| j|d� t|�}| j|j|�d� | jt|�d� td�}| j|j|�d� | jt|�d� | j|d d� d� | j|jd�d� | j|j d�d� | j|j d �d
� | j|jtd ��d� | j|jdd�d � | j|j d�d
� | j|j d�d
� | j|jt� �d� | j|jdd �d� | j|j d�d� | j|j� d� | j t
|jd� |�r�|jd� | j|j � d� |jd � | j|j � d� | j|j � d
� |jd� td�}| j|j |�d� | jt|�d� d S )NrJ s hellos worlrF s d
r � s hello world
r6 r@ � xrr s world�
g s world
i����i����) rB rx r r: r ry r r4 r5 rz r{ � readinto1)r* r" Zbufferedr r r r �read_ops< s>
zIOTest.read_opsrF � c C sj |j � s t�|j� st�y| j|j| j�| j� W n" ttfk
rT | jd� Y nX | j|j � | j� | j|j
d�d� | j|j � | jd � | j|jdd�| jd � | j|j � | jd � | j|j � | jd � | j|jdd�| jd � | j|j | jd �| jd � | j|j � | jd � | j|jdd�| jd � | j|jd d�| j� | j|j d�d� d S )
Nzno largefile supports xxx� r6 rF r r rg rg )
r1 �AssertionErrorr. rx r4 �LARGE�
OverflowErrorri �skipTestr5 r- r; rB )r* r" r r r �large_file_ops_ s$ zIOTest.large_file_opsc ! C sh | j }xBd D ]:}| jtj|��"}| j||j� | j||j� W d Q R X q W | jtjddd��"}| j||j� | j||j� W d Q R X | jtjddd��(}| j||jd� | j||jdg� W d Q R X | jtjd��(}| j||jd� | j||jdg� W d Q R X | jtjd��P}| j||jd � | j||jd
g� | j||j d | j
� | j||j d
| j � W d Q R X d S )N�w�wbr )� buffering�rbs blahs blah
r Zblahzblah
r6 )r� r� rg ) rZ r r ro rz rB �readliner- �
writelinesr4 �SEEK_CUR�SEEK_END)r* �exc�mode�fpr r r �test_invalid_operationss s&
z IOTest.test_invalid_operationsc s� � fdd�}� fdd�}� fdd�}� fdd�}� fd d
�}� fd d �}� fd
d�}� fdd�}|df|df|df|df|df|df|df|df� j df� jdff
} �x�| D �]�\}
} |
|kr�t r�q�� j|
���� |
� ���} d| k}
� j| j� |
� d| k}� j| j� |� t| � j��r"d}n$t| � j � j
f��r<d}n
� j d� d| k�rZ| j � n� j
t| j � |
�r�| jd� | j� n � j
t| jd� � j
t| j� |�r�| j|� n� j
t| j|� tjjd ��r�|
||fk�r�w�d | k}� j| j� |� |�r| j� | jd � n � j
t| j� � j
t| jd � |�rP|�rP| j� | jd � n � j
t| j� � j
t| jd � W d Q R X W d Q R X q�W d S ) Nc s" t j� \} }t j|� � j| d�S )Nr )�os�piperQ �FileIO)r r� )r* r r � pipe_reader� s
z3IOTest.test_optional_abilities.<locals>.pipe_readerc sN t j� \} }� jt j| � tjt j| dfd�}|j� � j|j� � j |d�S )N�d )�targetr[ r� )
r� r� �
addCleanuprQ � threading�ThreadrB �startrb r� )r r� Zthread)r* r r � pipe_writer� s z3IOTest.test_optional_abilities.<locals>.pipe_writerc s � j � j� �S )N)�BufferedReaderrY r )r* r r �buffered_reader� s z7IOTest.test_optional_abilities.<locals>.buffered_readerc s � j � j� �S )N)�BufferedWriterrY r )r* r r �buffered_writer� s z7IOTest.test_optional_abilities.<locals>.buffered_writerc s � j � j� �S )N)�BufferedRandom�BytesIOr )r* r r �buffered_random� s z7IOTest.test_optional_abilities.<locals>.buffered_randomc s � j � j� � j� �S )N)�BufferedRWPairrY r )r* r r �buffered_rw_pair� s
z8IOTest.test_optional_abilities.<locals>.buffered_rw_pairc s$ G � fdd�d� j �} � j| � d�S )Nc s e Zd Z� jjZ� jjZdS )zMIOTest.test_optional_abilities.<locals>.text_reader.<locals>.UnseekableReaderN)r r r �BufferedIOBaser. r- r )r* r r �UnseekableReader� s r� �ascii)rY �
TextIOWrapper)r� )r* r r � text_reader� s z3IOTest.test_optional_abilities.<locals>.text_readerc s$ G � fdd�d� j �} � j| � d�S )Nc s e Zd Z� jjZ� jjZdS )zMIOTest.test_optional_abilities.<locals>.text_writer.<locals>.UnseekableWriterN)r r r r� r1 rB r )r* r r �UnseekableWriter� s r� r� )rY r� )r� )r* r r � text_writer� s z3IOTest.test_optional_abilities.<locals>.text_writer�fr�fwr r� Zrws�rw�3� 3zUnknown base classr" r6 �winrc r )r� �StringIOr� �subTestrx r1 r. �
isinstance�
TextIOBaser� � RawIOBase�failr0 rz rP rB r- �sys�platform�
startswithr2 r5 r4 r; )r* r� r� r� r� r� r� r� r� �tests�testZ abilitiesr r1 r. r r2 r )r* r �test_optional_abilities� sh
z IOTest.test_optional_abilitiesc C sV d}| j t| j|d� t|d�}tj� �$ tjdt� | j t| j|d� W d Q R X d S )Nzfoo barr� r� �ignore)rz ri r r �warnings�catch_warnings� simplefilter�DeprecationWarning)r* Z fn_with_NULZbytes_fnr r r �test_open_handles_NUL_chars� s
z"IOTest.test_open_handles_NUL_charsc C s� | j tjddd��@}| j|j� d� | j|j� d� | j|j� d� | j|� W d Q R X | j tjddd��@}| j|j� d� | j|j� d� | j|j� d� | j|� W d Q R X d S )Nr� r )r� FTr� ) r r ro rx r1 r. r2 r} r� )r* r" r r r �test_raw_file_io� s zIOTest.test_raw_file_ioc C s� | j tjd��@}| j|j� d� | j|j� d� | j|j� d� | j|� W d Q R X | j tjd��B}| j|j� d� | j|j� d� | j|j� d� | j|d� W d Q R X d S )Nr� FTr� ) r r ro rx r1 r. r2 r} r� )r* r" r r r �test_buffered_file_io s z IOTest.test_buffered_file_ioc C s� | j tjd��}|jd� W d Q R X | j tjd��~}| j|j� d� | j|jd�d� | j|jd�d� | j|jd �d
� | j|j� d � | j|jd �d � | jt|jd
� W d Q R X | j tjd��}| jt|jd
� W d Q R X d S )Nr� s" abc
def
xyzzy
foo bar
another liner� s abc
r� s def
rF s xy� s zzy
s foo bar
s another lineg333333@r )r r ro r- rx r� rz r{ )r* r" r r r �
test_readline s zIOTest.test_readlinec C s* G dd� d| j �}| jttft|� � d S )Nc @ s e Zd Zdd� ZdS )z+IOTest.test_readline_nonsizeable.<locals>.Rc S s d S )Nr )r* r r r r� ' s z4IOTest.test_readline_nonsizeable.<locals>.R.readlineN)r r r r� r r r r �R& s r� )�IOBaserz r{ �
StopIteration�next)r* r� r r r �test_readline_nonsizeable# s z IOTest.test_readline_nonsizeablec C s( G dd� d| j �}| jt|� jd� d S )Nc @ s e Zd Zdd� ZdS )z'IOTest.test_next_nonsizeable.<locals>.Rc S s d S )Nr )r* r r r �__next__/ s z0IOTest.test_next_nonsizeable.<locals>.R.__next__N)r r r r� r r r r r� . s r� r6 )r� rz r{ � readlines)r* r� r r r �test_next_nonsizeable+ s z IOTest.test_next_nonsizeablec C s@ | j � }| j|� |j� }| j|d� | j |�}| j|d� d S )Ns hello world
T)r� r} �getvaluerx r� )r* r" r r r r �test_raw_bytes_io3 s
zIOTest.test_raw_bytes_ioc C s| t jd d� dks t jdkr.tjdd| j � | jtjdd��}| j|� W d Q R X | jtjd��}| j|� W d Q R X d S )Nr� r� �darwinZ largefilez-test requires %s bytes and a long time to runzw+br )r� r� r Zrequiresr� r ro r� )r* r" r r r �test_large_file_ops; s zIOTest.test_large_file_opsc C s� x�dD ]�}d }| j tjd|��}|jd� W d Q R X | j|jd� d }y(| j tjd|��}dd W d Q R X W n" tk
r� | j|jd� Y qX | jd� qW d S ) Nr r6 r� r� s xxxTz 1/0 didn't raise an exception)r r6 r� )r r ro r- rx rO �ZeroDivisionErrorr� )r* �bufsizer" r r r �test_with_openH s
zIOTest.test_with_openc C s� | j tjd��}|jd� W d Q R X | j tjddd��}| j|j� d� W d Q R X | j tjd��}| j|j� d� W d Q R X | j tjd��}| j|j� d� W d Q R X d S )Nr� s xxx�abr )r� r� �a)r r ro r- rx r5 �
assertGreater)r* r" r r r �test_append_mode_tellX s z IOTest.test_append_mode_tellc s� g � G � fdd�d| j �}tjdtf��b |tjd�}|jd� ~tj� | j� dddg� | jtjd ��}| j|j � d� W d Q R X W d Q R X d S )
Nc s: e Zd Z� �fdd�Z� �fdd�Z� �fdd�Z� ZS )z(IOTest.test_destructor.<locals>.MyFileIOc s6 �j d� y t� j}W n tk
r* Y nX |� d S )Nr6 )r, rG �__del__�AttributeError)r* r" )rH �recordr r r� e s
z0IOTest.test_destructor.<locals>.MyFileIO.__del__c s �j d� t� j� d S )NrF )r, rG rQ )r* )rH r� r r rQ m s
z.IOTest.test_destructor.<locals>.MyFileIO.closec s �j d� t� j� d S )Nr� )r, rG �flush)r* )rH r� r r r� p s
z.IOTest.test_destructor.<locals>.MyFileIO.flush)r r r r� rQ r� rK r )r� )rH r �MyFileIOd s r� � r� s xxxr6 rF r� r� )
r� r �check_warnings�ResourceWarningro r- �
gc_collectrx r rB )r* r� r" r )r� r �test_destructorb s
zIOTest.test_destructorc s> g � G � fdd�d|�}|� }~t j� | j� dddg� d S )Nc sB e Zd Zdd� Z� �fdd�Z� �fdd�Z� �fdd�Z� ZS ) z+IOTest._check_base_destructor.<locals>.MyIOc S s d| _ d| _d| _d S )Nr6 rF r� )�on_del�on_close�on_flush)r* r r r r+ s z4IOTest._check_base_destructor.<locals>.MyIO.__init__c s8 �j | j� y t� j}W n tk
r, Y nX |� d S )N)r, r� rG r� r� )r* r" )rH r� r r r� � s z3IOTest._check_base_destructor.<locals>.MyIO.__del__c s �j | j� t� j� d S )N)r, r� rG rQ )r* )rH r� r r rQ � s z1IOTest._check_base_destructor.<locals>.MyIO.closec s �j | j� t� j� d S )N)r, r� rG r� )r* )rH r� r r r� � s z1IOTest._check_base_destructor.<locals>.MyIO.flush)r r r r+ r� rQ r� rK r )r� )rH r �MyIO~ s r� r6 rF r� )r r� rx )r* �baser� r" r )r� r �_check_base_destructor| s z IOTest._check_base_destructorc C s | j | j� d S )N)r� r� )r* r r r �test_IOBase_destructor� s z IOTest.test_IOBase_destructorc C s | j | j� d S )N)r� r� )r* r r r �test_RawIOBase_destructor� s z IOTest.test_RawIOBase_destructorc C s | j | j� d S )N)r� r� )r* r r r � test_BufferedIOBase_destructor� s z%IOTest.test_BufferedIOBase_destructorc C s | j | j� d S )N)r� r� )r* r r r �test_TextIOBase_destructor� s z!IOTest.test_TextIOBase_destructorc C sR | j tjd��}|jd� W d Q R X | j tjd��}| j|j� d� W d Q R X d S )Nr� s xxxr� )r r ro r- rx rB )r* r" r r r �test_close_flushes� s zIOTest.test_close_flushesc s� t j dtd��� t� j� ��� ��fdd�}|�j� � |�jtjd�� |�j�j � �� |�j
�j � �� |�j �j � �j � �� d S )N�ir� c
s2 | �$ �j | j� ��� | j� f� W d Q R X d S )N)rx r- r� )r" )r� r9 r* r r �check� s z'IOTest.test_array_writes.<locals>.checkr� ) r �ranger �tobytesr� r� r ro r� r? r� r� )r* r� r )r� r9 r* r �test_array_writes� s zIOTest.test_array_writesc C s | j t| jtjddd� d S )Nr� F)�closefd)rz ri r r ro )r* r r r � test_closefd� s zIOTest.test_closefdc C s� | j tjd��}|jd� W d Q R X | j tjd��J}| j |j� ddd�}| j|j� d� |jd� |j� | j t
|j� W d Q R X | j tjd��N}| j |j� ddd�}| j|j� d d� d � |j� | j t
|j t d
�� W d Q R X d S ) Nr� zegg
r F)r� r r� r� s eggr6 )
r r ro r- r0 rx rB r4 rQ rz ri r: ry )r* r" �filer r r �test_read_closed� s
zIOTest.test_read_closedc C s | j t| jtjddd� d S )Nr F)r� )rz ri r r ro )r* r r r � test_no_closefd_with_filename� s z$IOTest.test_no_closefd_with_filenamec C sz | j tjd��}|jd� W d Q R X | j tjd��>}| j|jjjd� | j |j� ddd�}| j|jjjd� W d Q R X d S )Nr� s egg
r TF)r� ) r r ro r- rx r| �rawr� r0 )r* r" r� r r r �test_closefd_attr� s zIOTest.test_closefd_attrc C s� t jdtf��8 | jt jd�}|jd� ||_tj|�}~t j � W d Q R X | j
|� |� | j t jd��}| j |j
� d� W d Q R X d S )Nr� r� s abcxxxr� )r r� r� r� ro r- r" �weakref�refr� � assertIsNoner rx rB )r* r" �wrr r r �test_garbage_collection� s
z IOTest.test_garbage_collectionc C s� d}t jj|�s | jdj|�� tjdkr4| jd� tjtj k rJ| jd� | j
|ddd��}| j t |j
� W d Q R X | j
|d��}| j t |j
� W d Q R X | j
|d ��}| j t |j
� W d Q R X d S )
Nz /dev/zeroz{0} does not existi���z+test can only run in a 32-bit address spacez$test requires at least 2GB of memoryr� r )r� r )r� �path�existsr� �formatr� �maxsizer Zreal_max_memuseZ_2Gr rz r� rB )r* Zzeror" r r r �test_unbounded_file� s
zIOTest.test_unbounded_filec sd | j ||��g � � �fdd�}|�_| jt�j� | j�j� | j� � | j� d � dd� �_d S )Nc s �j g� d d �< t� �d S )N)rO rP r )rO r" r r � bad_flush� s z4IOTest.check_flush_error_on_close.<locals>.bad_flushr c S s d S )Nr r r r r �<lambda> s z3IOTest.check_flush_error_on_close.<locals>.<lambda>)r r� rz rP rQ �
assertTruerO � assertFalse)r* r[ �kwargsr r )rO r" r �check_flush_error_on_close� s
z!IOTest.check_flush_error_on_closec C s. | j tjddd� tjtjtjtjB �}| j |ddd� tjtjtjtjB �}| j |dddd� tj|� | j tjd� tjtjtjtjB �}| j |d� tjtjtjtjB �}| j |ddd� tj|� | j tjd� tjtjtjtjB �}| j |d� tjtjtjtjB �}| j |ddd� tj|� d S )Nr� r )r� F)r� r� )r� r� )r r ro r� r �O_WRONLY�O_CREATrQ )r* �fdr r r �test_flush_error_on_close s$
z IOTest.test_flush_error_on_closec C s< | j tjddd�}|j� |j� |j� | jt|j� d S )Nr� r )r� )r r ro rQ rz ri r� )r* r" r r r �test_multi_close s
zIOTest.test_multi_closec C s� | j d
�}| j|jd�d� | j|jd�d� | j|jd�d� | j|jd�d � | j|jd�d� | j|jd�d� | j|jd�d � | j|jd�d � d S ) N� abc� d� efgrF s ab� cs ef� gr@ )r r Nr N)r$ rx rB )r* �rawior r r �test_RawIOBase_read$ s
zIOTest.test_RawIOBase_readc C sD | j � | j� | j� | j� | j� f}x |D ]}| jt|d�� q(W d S )N�__dict__)r� r� r� r� r� r
�hasattr)r* r� r r r r �test_types_have_dict1 s
zIOTest.test_types_have_dictc sp | j tjd��}|jd� W d Q R X tj tjtj�� � fdd�}| j dd|d��}| j|j� d� W d Q R X d S )Nr� zegg
c s � S )Nr )r �flags)r r r �opener@ s z"IOTest.test_opener.<locals>.openerz non-existentr )r! )r r ro r- r� �O_RDONLYrx rB )r* r" r! r )r r � test_opener< s zIOTest.test_openerc C sB dd� }| j t��}tdd|d� W d Q R X | jt|j�d� d S )Nc S s dS )Nr6 rg r )�fnamer r r r � badopenerG s z4IOTest.test_bad_opener_negative_1.<locals>.badopenerz non-existentr )r! zopener returned -1)rz ri r rx �str� exception)r* r% �cmr r r �test_bad_opener_negative_1E s z!IOTest.test_bad_opener_negative_1c C sB dd� }| j t��}tdd|d� W d Q R X | jt|j�d� d S )Nc S s dS )NrF ���r )r$ r r r r r% O s z8IOTest.test_bad_opener_other_negative.<locals>.badopenerz non-existentr )r! zopener returned -2)rz ri r rx r& r' )r* r% r( r r r � test_bad_opener_other_negativeM s z%IOTest.test_bad_opener_other_negativec C sp | j td��Z}| j td��B}| j|j� dd�}|j|j� dd� |j� |j� |j� W d Q R X W d Q R X d S )Nr� F)r� )r r r� r0 r+ r� rQ )r* �f1�f2Zfileior r r �test_fileio_closefdU s zIOTest.test_fileio_closefdc C sB t j| ��. | jt�� | jt jddd� W d Q R X W d Q R X d S )Nr� r )r� )r �check_no_resource_warningrz ri r ro )r* r r r �test_nonbuffered_textioa s z IOTest.test_nonbuffered_textioc C sB t j| ��. | jt�� | jt jddd� W d Q R X W d Q R X d S )Nr� Zinvalid)�newline)r r/ rz ri r ro )r* r r r �test_invalid_newlinef s zIOTest.test_invalid_newlinec C sn G dd� d| j �}|� }xPdD ]H}| j|��4 td�}| jt||�|�d� | jt|�d� W d Q R X q W d S )Nc @ s e Zd Zdd� ZeZdS )z3IOTest.test_buffered_readinto_mixin.<locals>.Streamc S s dS )Ns 12345r )r* �sizer r r rB n s z8IOTest.test_buffered_readinto_mixin.<locals>.Stream.readN)r r r rB �read1r r r r �Streamm s r5 r: r� rJ s 12345)r: r� )r� r� r rx �getattrr )r* r5 �stream�methodr| r r r � test_buffered_readinto_mixink s
z#IOTest.test_buffered_readinto_mixinc & s� � fdd�}|t tj�� |t tjjd��� � jtjd��4}t |j� �}� jt�� � j|d� W d Q R X W d Q R X t d �}� jt�� � j|d� W d Q R X t t�}� jt�� � j|d� W d Q R X � j t
d�� � jt tj�d� W d Q R X d S )Nc sN � j | d��}|jd� W d Q R X � j | d��}� j|j� d� W d Q R X d S )Nr� zegg
r )r r- rx rB )r r" )r* r r �check_path_succeedsy s z7IOTest.test_fspath_support.<locals>.check_path_succeedszutf-8r� zread/write/append modeZrwxa) r r ro �encoder r0 rz r{ �FloatingPointError�assertRaisesRegexri )r* r: r" Zbad_pathr )r* r �test_fspath_supportx s zIOTest.test_fspath_supportc C s8 | j d�}| j|j� d� | j d�}| j|j� d� d S )N� abcr � efgs abcdefg)r? r r@ )r? r r@ )r$ rx rB �readall)r* r r r r �test_RawIOBase_readall� s
z IOTest.test_RawIOBase_readallc
C s� G dd� d| j �}d}d
}x�|D ]�}| j|��� |\}}}}|tt|���} t|f| �}
t| |�}| j||
�|� | jt|
�|� | j|
d |� t|�� |f|| } | j|
|d � | � | jt| j �|| � W d Q R X q W d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z3IOTest.test_BufferedIOBase_readinto.<locals>.Readerc S s
|| _ d S )N)�avail)r* rC r r r r+ � s z<IOTest.test_BufferedIOBase_readinto.<locals>.Reader.__init__c S s" | j d |� }| j |d � | _ |S )N)rC )r* r3 �resultr r r rB � s z8IOTest.test_BufferedIOBase_readinto.<locals>.Reader.readc S s | j t|d��S )z$Returns no more than 5 bytes at oncerJ )rB �min)r* r3 r r r r4 � s z9IOTest.test_BufferedIOBase_readinto.<locals>.Reader.read1N)r r r r+ rB r4 r r r r �Reader� s rF r: r� rJ rr � r r� � �r: r� rJ rJ �r: r� rr rr �r: rJ rr rJ �r: rr rG rr �r: r� r r �r� r� rJ rJ �r� r� rr rJ �r� rJ rr rJ �r� rr rG rJ �r� r� r r )
rI rJ rK rL rM rN rO rP rQ rR )
r� r� r r� ry r6 rx r ZassertSequenceEqualrC ) r* rF r� Z UNUSED_BYTEr� r8 rC ZrequestrD �readerr| Zunusedr r r � test_BufferedIOBase_readinto� s0
z#IOTest.test_BufferedIOBase_readintoc C s* G dd� d| j �}|� }| jt|j� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z#IOTest.test_close_assert.<locals>.Rc S s d S )Nr )r* �name�valuer r r � __setattr__� s z/IOTest.test_close_assert.<locals>.R.__setattr__c S s
t � �d S )N)rP )r* r r r r� � s z)IOTest.test_close_assert.<locals>.R.flushN)r r r rW r� r r r r r� � s r� )r� rz rP rQ )r* r� r" r r r �test_close_assert� s zIOTest.test_close_assertN)Fl )3r r r rp rq r} r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r
r r r r r r# r) r+ r. r0 r2 r9 r> rB rT rX r r r r rm s`
!j
)rm c @ s e Zd Zdd� ZdS )�CIOTestc C sL G dd� d| j �}|� |� }||_tj|�}~~tj� | j|� |� d S )Nc @ s e Zd Zdd� ZdS )z*CIOTest.test_IOBase_finalize.<locals>.MyIOc S s d S )Nr )r* r r r rQ � s z0CIOTest.test_IOBase_finalize.<locals>.MyIO.closeN)r r r rQ r r r r r� � s r� )r� r r r r r� r )r* r� r r r r r �test_IOBase_finalize� s
z CIOTest.test_IOBase_finalizeN)r r r rZ r r r r rY � s rY c @ s e Zd ZdS )�PyIOTestN)r r r r r r r r[ � s r[ c @ s e Zd Zdd� Zdd� ZdS )�APIMismatchTestc C s* t jtjtjdd�}| j|t� dd� dS )z:Test that pyio RawIOBase class has all c RawIOBase methods� __weakref__)r� z6Python RawIOBase does not have all C RawIOBase methods)�msgN)r] )r �detect_api_mismatchr_ r� r] rx �set)r* �mismatchr r r � test_RawIOBase_io_in_pyio_match� s z/APIMismatchTest.test_RawIOBase_io_in_pyio_matchc C s& t jtjtj�}| j|t� dd� dS )z:Test that c RawIOBase class has all pyio RawIOBase methodsz6C RawIOBase does not have all Python RawIOBase methods)r^ N)r r_ r] r� r_ rx r` )r* ra r r r � test_RawIOBase_pyio_in_io_match� s z/APIMismatchTest.test_RawIOBase_pyio_in_io_matchN)r r r rb rc r r r r r\ � s r\ c @ s| e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd S ) �CommonBufferedTestsc C s< | j � }| j|�}| j|j� |� | jt|j� t|� d S )N)r? �tp�assertIs�detachrz ri �repr)r* r� r8 r r r � test_detach� s
z CommonBufferedTests.test_detachc C s& | j � }| j|�}| jd|j� � d S )Nr/ )r? re rx r0 )r* r �bufior r r � test_fileno s
z CommonBufferedTests.test_filenoc C s: | j � }| j|�}| jt|jdd� | jt|jdd� d S )Nr r6 rs rg )r? re rz ri r4 )r* r rj r r r �test_invalid_args s
z%CommonBufferedTests.test_invalid_argsc sN | j }g � G � fdd�d|�}| j� }||�}~tj� | j� dddg� d S )Nc s: e Zd Z� �fdd�Z� �fdd�Z� �fdd�Z� ZS )zBCommonBufferedTests.test_override_destructor.<locals>.MyBufferedIOc s6 �j d� y t� j}W n tk
r* Y nX |� d S )Nr6 )r, rG r� r� )r* r" )rH r� r r r� s
zJCommonBufferedTests.test_override_destructor.<locals>.MyBufferedIO.__del__c s �j d� t� j� d S )NrF )r, rG rQ )r* )rH r� r r rQ s
zHCommonBufferedTests.test_override_destructor.<locals>.MyBufferedIO.closec s �j d� t� j� d S )Nr� )r, rG r� )r* )rH r� r r r� s
zHCommonBufferedTests.test_override_destructor.<locals>.MyBufferedIO.flush)r r r r� rQ r� rK r )r� )rH r � MyBufferedIO s rm r6 rF r� )re r? r r� rx )r* re rm r rj r )r� r �test_override_destructor s z,CommonBufferedTests.test_override_destructorc s4 | j � }| j|�� � fdd�}|� | jt|� d S )Nc s � � W d Q R X d S )Nr r )rj r r �_with+ s z7CommonBufferedTests.test_context_manager.<locals>._with)r? re rz ri )r* r ro r )rj r �test_context_manager' s
z(CommonBufferedTests.test_context_managerc
s� �j � � � �fdd�}tjd��}�jt|� W d Q R X |j� j� }|r��jt|j � �d� �j
|j d�|� �j
|j d�|� d S )Nc s �j � �j d S )N)re �xyzzyr )r r* r r r" 7 s z<CommonBufferedTests.test_error_through_destructor.<locals>.f�stderrr6 zException OSError: z ignored)
rN r �captured_outputrz r� r� �striprx r �
splitlinesr
r� �endswith)r* r" rc r )r r* r � test_error_through_destructor3 s z1CommonBufferedTests.test_error_through_destructorc C sr | j � }| j|�}d| jj| jjf }| jt|�d| � d|_| jt|�d| � d|_| jt|�d| � d S )Nz%s.%sz<%s>�dummyz<%s name='dummy'>s dummyz<%s name=b'dummy'>)r? re r r rx rh rU )r* r� r
Zclsnamer r r � test_reprB s
z CommonBufferedTests.test_reprc C sR | j � }| j|�}tj|d|��( y t|� W n tk
rB Y nX W d Q R X d S )NrU )r? re r � swap_attrrh � RuntimeError)r* r� r
r r r �test_recursive_reprL s
z'CommonBufferedTests.test_recursive_reprc s� | j � �g �� ��fdd�}|�_| j��� | jt� j� | j� j� | j�j� | j�� | j�d � | j�d � dd� �_d S )Nc s � j �j g�d d �< t� �d S )N)rO rP r )r
rO r� r r r [ s z@CommonBufferedTests.test_flush_error_on_close.<locals>.bad_flushr r6 c S s d S )Nr r r r r r f s z?CommonBufferedTests.test_flush_error_on_close.<locals>.<lambda>) r? r� re rz rP rQ r
rO r )r* r r )r
rO r� r r V s
z-CommonBufferedTests.test_flush_error_on_closec
C s� | j � }dd� }dd� }||_| j|�}||_| jt��}|j� W d Q R X | j|jjd� | j |jj
t� | j|jj
jd� | j |j � d S ) Nc S s t d��d S )Nr� )rP r r r r r j s z@CommonBufferedTests.test_close_error_on_close.<locals>.bad_flushc S s t d��d S )NrQ )rP r r r r � bad_closel s z@CommonBufferedTests.test_close_error_on_close.<locals>.bad_closerQ r� )rQ )r� )
r? rQ re r� rz rP rx r' r[ �assertIsInstance� __context__r rO )r* r� r r} r
�errr r r �test_close_error_on_closeh s
z-CommonBufferedTests.test_close_error_on_closec C s� | j � }dd� }dd� }||_| j|�}||_| jt��}|j� W d Q R X | jdt|j�� | j |jj
t� | jdt|jj
�� | j |j � d S )Nc S s t �d S )N)�non_existing_flushr r r r r { s zNCommonBufferedTests.test_nonnormalized_close_error_on_close.<locals>.bad_flushc S s t �d S )N)�non_existing_closer r r r r} } s zNCommonBufferedTests.test_nonnormalized_close_error_on_close.<locals>.bad_closer� r� )
r? rQ re r� rz � NameError�assertInr& r' r~ r r rO )r* r� r r} r
r� r r r �'test_nonnormalized_close_error_on_closex s
z;CommonBufferedTests.test_nonnormalized_close_error_on_closec C s< | j � }| j|�}|j� |j� |j� | jt|j� d S )N)r? re rQ rz ri r� )r* r� r
r r r r � s
z$CommonBufferedTests.test_multi_closec C s6 | j | jd��}| j| j|j� | j| j|jd� d S )N� Ar� r s
AAAAAAAAAA)re rY rz rZ r5 r4 )r* rj r r r �test_unseekable� s z#CommonBufferedTests.test_unseekablec C s: | j � }| j|�}| j � }| jt�� ||_W d Q R X d S )N)r? re rz r� r� )r* r� r8 �xr r r �test_readonly_attributes� s
z,CommonBufferedTests.test_readonly_attributesN)r r r ri rk rl rn rp rw ry r| r r� r� r r� r� r r r r rd � s
rd c @ s( e Zd Zejdd� �Zejdd� �ZdS )�
SizeofTestc C s\ d}d}| j � }| j||d�}tj|�| }| j � }| j||d�}| jtj|�|| � d S )Ni i )� buffer_size)r? re r� � getsizeofrx )r* Zbufsize1Zbufsize2r rj r3 r r r � test_sizeof� s zSizeofTest.test_sizeofc C sF d}| j � }| j||d�}tj|�| }|j� | jtj|�|� d S )Ni )r� )r? re r� r� rQ rx )r* r� r rj r3 r r r �test_buffer_freeing� s z SizeofTest.test_buffer_freeingN)r r r r � cpython_onlyr� r� r r r r r� � s r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zejed �ejd �d d � ��Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(S ))�BufferedReaderTestr� c C s� | j dg�}| j|�}|j|� |j|dd� |j|dd� | jd|j� � | jt|j|dd� | jt|j|dd� | jt|j|dd� | j dg�}|j|� | jd|j� � d S ) Ns abci )r� � r r6 i�rg )r? re r+ rx rB rz ri )r* r rj r r r �test_constructor� s
z#BufferedReaderTest.test_constructorc C sX | j j| j �}~| j j| j �}| jttfd|jd� |j| j� � | j|jd�d� d S )Nz uninitialized|has no attributer r@ ) re �__new__r= ri r� rB r+ r? rx )r* rj r r r �test_uninitialized� s
z%BufferedReaderTest.test_uninitializedc C sH x2dD ]*}| j d�}| j|�}| jd|j|�� qW | jt|jd � d S )
NrG � abcr � efgs abcdefgrF )NrG )r� r r� r* )r? re rx rB rz ri )r* �argr rj r r r � test_read� s
z BufferedReaderTest.test_readc C s� | j d
�}| j|�}| jd|jd�� | jd|jd�� | j|jd� | jd|jd�� | j|jd� | jd|jd�� | j|jd � | jd|jd�� | j|jd
� | jd |jd�� | j|jd � | jt|jd� d S )N� abcr � efg� ar6 � br r� rF r� r@ r� )r� r r� rg )r? re rx rB r4 r( rz ri )r* r rj r r r �
test_read1� s
z BufferedReaderTest.test_read1c C s | j d �}| j|�}td�}| j|j|�d� | j|d� | j|j|�d� | j|d� | j|j|�d� | j|d� | j|j|�d� | j|d � | j|j|�d
� | j|d � | j d
�}| j|�}| j|j|�d� | j|d� | j|j|�d� | j|d � d S )N� abcr � efgrF s abs cds efr6 s gfr s cb)r� r r� )r� N)r? re ry rx r: )r* r rj r
r r r �
test_readinto� s&
z BufferedReaderTest.test_readintoc C s4 d}| j d�}| j||d�}td�}| j|jd�d� | j|jd � | j|j|�d� | j|d
� | j|jd � | j|j|�d � | j|d d � d � | j|jd � | j|j|�d� | j|d� | j|jd� td| �}| j|jd�d� | j|jd� | j|j|�d � | j|d d � d
� | j|jd� d S )Nr� � abc� de� fgh� jkl)r� rF r� r6 s abr rr s fghjklr� )r� r� r� r� )r? re ry rx �peekr( r� )r* r� r rj r
r r r �test_readinto1� s*
z!BufferedReaderTest.test_readinto1c C s� d}dd }| j |f�}| j||d�}tjddd �}t|�dksFt�|j|�}| j|t|�� t|�jd �}| j |t|�� | j
|d |� |d |� � | j
||d � dt||d � � � d S )
N�< r� � )r� r� r � r� r ) r? re r r r� r: r� r r �
assertLessrx )r* r� r r rj r
r9 �bmr r r �test_readinto_array s
z&BufferedReaderTest.test_readinto_arrayc C s� d}dd }| j |f�}| j||d�}tjddd �}t|�dksFt�|j|�}| j|t|�� t|�jd �}| j |t|�� | j
|d |� |d |� � | j
||d � dt||d � � � d S )
Nr� r� r� )r� r� r r� r� r ) r? re r r r� r� r� r r r� rx )r* r� r r rj r
r9 r� r r r �test_readinto1_array) s
z'BufferedReaderTest.test_readinto1_arrayc sZ � fdd�}� j |� j� dddg� � j |� jd�ddg� � j |� jd �dddg� d S )Nc s � j d�} � j| �S )N� abc
� d
� ef)r� r� r� )r? re )r )r* r r rj ? s
z0BufferedReaderTest.test_readlines.<locals>.bufios abc
s d
s efrJ )rx r� )r* rj r )r* r �test_readlines> s z!BufferedReaderTest.test_readlinesc C s� d}t |�}dddddg|dggddddg|ggdddddgdddggg}xp|D ]h\}}}| j|�}| j||d �}d} x2|D ]*}
| j|j|
�|| | |
� � | |
7 } q|W | j|j|� qPW d S )
Ns abcdefghir� r� r6 r� � r rF )r� )r rT re rx rB rU ) r* r Zdlenr� r� Zbuf_read_sizesZraw_read_sizesr rj r
�nbytesr r r �test_bufferingF s
z!BufferedReaderTest.test_bufferingc C s� | j d �}| j|�}| jd|jd�� | jd|jd�� | jd|j� � | jd |jd�� | j|j� � | jd |j� � | j d �}| jd
|j� � | j|j� � d S )
N� abcr � efgs abcdrr � er6 s fgr@ r� )r� r Nr� NNN)r� NN)r? re rx rB r� r rA )r* r rj r r r �test_read_non_blockingZ s
z)BufferedReaderTest.test_read_non_blockingc C s* | j d�}| j|�}| jd|jd�� d S )N� abcr � efgs abcdefgi(# )r� r r� )r? re rx rB )r* r rj r r r �test_read_past_eofi s
z%BufferedReaderTest.test_read_past_eofc C s( | j d�}| j|�}| jd|j� � d S )N� abcr � efgs abcdefg)r� r r� )r? re rx rB )r* r rj r r r �
test_read_allo s
z BufferedReaderTest.test_read_allz!Threading required for this test.�cpuc s. �zd}t td��| }tj|� tt|��}| jtjd����j |� W d Q R X | jtj| j
dd���}| j |d�� g �g �� ��fdd���fd d
�td �D �}tj |�� t
jd � W d Q R X | j�d
� � dj��}x0td�D ]$}tt|g��}| j|j|�|� q�W W d Q R X W d tjtj� X d S )Ni� � r� r )r� r� c sh y4x.t ddg�D ] } � j| �}|s$P �j|� qW W n. tk
rb } z�j|� � W Y d d }~X nX d S )Nr6 � )r rB r, � Exception)r9 rc �e)rj �errors�resultsr r r" � s
z*BufferedReaderTest.test_threads.<locals>.fc s g | ]}t j� d ��qS ))r� )r� r� )�.0r� )r" r r �
<listcomp>� s z3BufferedReaderTest.test_threads.<locals>.<listcomp>r~ g{�G�z�?z(the following exceptions were caught: %rr@ )r% r� �randomZshuffler ry r r ro r- � read_modere �
start_threads�time�sleepr rb rx r rn )r* �N�lrc r� �threadsr� �cr )rj r� r" r� r � test_threadsu s,
$z BufferedReaderTest.test_threadsc C sb | j | jd��}| j| j|j� | j| j|jd� |jd� | j| j|jd� | j| j|j� d S )Nr� r� r r6 s
AAAAAAAAAA)re rY rz rZ r5 r4 rB )r* rj r r r r� � s
z"BufferedReaderTest.test_unseekablec C s6 | j d�}| j|�}| jt|jd� | jt|j� d S )N� abcr � efgr )r� r r� )rE re rz rP r4 r5 )r* r rj r r r �test_misbehaved_io� s
z%BufferedReaderTest.test_misbehaved_ioc C s� d}x�d|d ||d |d fD ]�}| j d| g�}| j||�}| j|j|�d| � | j|jddj||j�� | j d|d dg�}| j||�}| j|j|�d| � | j|jddj||j�� q W d S )Nr� rF r6 r r zfailed for {}: {} != 0)r? re rx rB r) r )r* r� r9 r rj r r r �test_no_extraneous_read� s
z*BufferedReaderTest.test_no_extraneous_readc C sD t jt jd��}|jd� |j� | jt|j� | jt|jd� d S )Ns 12r6 ) r] r� r� rB rQ rz ri r� r4 )r* r
r r r �test_read_on_closed� s
z&BufferedReaderTest.test_read_on_closedN)r r r r� r� r� r� r� r� r� r� r� r� r� r� r� r� �unittest�
skipUnlessr� r �requires_resourcer� r� r� r� r� r r r r r� � s(
(r� c @ s: e Zd ZejZdd� Zdd� Zdd� Zdd� Z d d
� Z
d S ) �CBufferedReaderTestc C sD t j| � tjdkr@| j� }| j|�}| jttt f|j
|tj� d S )Ni���) r� r� r� r r? re rz r� � MemoryErrorri r+ )r* r rj r r r r� � s
z$CBufferedReaderTest.test_constructorc C s� | j dg�}| j|�}| jt|j|dd� | jt|j� | jt|j|dd� | jt|j� | jt|j|dd� | jt|j� d S )Ns abcr )r� r� r6 i�rg )r? re rz ri r+ rB )r* r rj r r r �test_initialization� s
z'CBufferedReaderTest.test_initializationc C s( | j d�}| j|�}| jt|jd� d S )N� abcr � efgr� )r� r r� )rE re rz rP rB )r* r rj r r r �test_misbehaved_io_read� s
z+CBufferedReaderTest.test_misbehaved_io_readc
C sn | j tjtj� tjdtf��8 | jtjd�}| j|�}||_t j
|�}~tj � W d Q R X | j |� |� d S )Nr� zw+b)
r� r rn ro r� r� r� re r" r r r� r )r* r r" r r r r r � s
z+CBufferedReaderTest.test_garbage_collectionc C s0 | j td�� | jtj� ddd� W d Q R X d S )Nr� i )r= r{ re r] r� )r* r r r �test_args_error� s z#CBufferedReaderTest.test_args_errorN) r r r r] r� re r� r� r� r r� r r r r r� � s
r� c @ s e Zd ZejZdS )�PyBufferedReaderTestN)r r r r_ r� re r r r r r� � s r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zejed(�ejd)�d*d+� ��Z d,d-� Z d.d/� Z d0d1� Z d2S )3�BufferedWriterTestr� c C s� | j � }| j|�}|j|� |j|dd� |j|dd� | jd|jd�� |j� | jt|j|dd� | jt|j|d d� | jt|j|d d� |j|� | jd|jd�� |j� | jd j|j �d
� d S )
Ni )r� r� r� s abcr r6 s ghir@ s abcghii�rg )
r? re r+ rx r- r� rz ri rb r' )r* r rj r r r r� s
z#BufferedWriterTest.test_constructorc C sX | j j| j �}~| j j| j �}| jttfd|jd� |j| j� � | j|jd�d� d S )Nz uninitialized|has no attributer@ r ) re r� r= ri r� r- r+ r? rx )r* rj r r r r� s
z%BufferedWriterTest.test_uninitializedc C sD | j � }| j|�}|jd� | j|j� |j� | j|jdg� d S )Ns howdy!)r? re r- r r' rg rx )r* r� r8 r r r �test_detach_flush s
z$BufferedWriterTest.test_detach_flushc C sh | j � }| j|d�}|jd� | j|j� td�}|j|� d|d d �< |j� | jdj|j�d� d S )Nr� s abcs defs ***r@ s abcdef) r? re r- r r' ry r� rx rb )r* �writerrj r| r r r �
test_write# s
z BufferedWriterTest.test_writec C sr | j � }| j|d�}d}x.tdt|�d�D ]}|j|||d � � q*W dj|j�}| j|j|d d� �|� d S )Nr� s abcdefghijklmnopr r� r@ i����) r? re r� r r- rb r' r
r� )r* r� rj �contentsr9 Zflushedr r r �test_write_overflow/ s z&BufferedWriterTest.test_write_overflowc C s� t td��d }d}| j� }| j|d�}dd� }|� }xT|t|�k r�tt|�t|�| �}| j|j|||| � �|� ||� ||7 }q8W |j � | j|dj
|j �� d S )Nr� i� r rv c s s. x(t d�D ] } xtd�D ]
}| V qW q
W d S )Nr6 � )r r� )r3 r� r r r � gen_sizesA s z2BufferedWriterTest.check_writes.<locals>.gen_sizesr@ ) r r� r? re r rE r� rx r- r� rb r' ) r* Zintermediate_funcr� r9 r� rj r� �sizesr3 r r r � check_writes: s z BufferedWriterTest.check_writesc C s | j dd� � d S )Nc S s d S )Nr )rj r r r r O s z0BufferedWriterTest.test_writes.<locals>.<lambda>)r� )r* r r r � test_writesN s z BufferedWriterTest.test_writesc C s | j dd� � d S )Nc S s | j � S )N)r� )rj r r r r R s z<BufferedWriterTest.test_writes_and_flushes.<locals>.<lambda>)r� )r* r r r �test_writes_and_flushesQ s z*BufferedWriterTest.test_writes_and_flushesc C s( dd� }| j |� dd� }| j |� d S )Nc S s8 | j � }| j|d d� | j|d d� | j|d� d S )Nr6 r )r5 r4 )rj r
r r r �_seekabsU s z:BufferedWriterTest.test_writes_and_seeks.<locals>._seekabsc S s4 | j dd�}| j dd� | j dd� | j |d� d S )Nr r6 r6 rg )r4 )rj r
r r r �_seekrel[ s z:BufferedWriterTest.test_writes_and_seeks.<locals>._seekrel)r� )r* r� r� r r r �test_writes_and_seeksT s
z(BufferedWriterTest.test_writes_and_seeksc C s | j dd� � d S )Nc S s | j | j� �S )N)r; r5 )rj r r r r c s z>BufferedWriterTest.test_writes_and_truncates.<locals>.<lambda>)r� )r* r r r �test_writes_and_truncatesb s z,BufferedWriterTest.test_writes_and_truncatesc C s� | j � }| j|d�}| j|jd�d� | j|jd�d� |jd� | j|jd�d� |jd� y|jd � W n* | jk
r� } z |j}W Y d d }~X n X | jd
� | j|d � | j|j� d � | j|jd
�d� |j� }| j |j
d�|� d S )Nr� s abcdr� s efghirJ � ks jklmn� 0s opqrwxyz0123456789z'BlockingIOError should have been raisedr� s abcdefghijklmnopqrwxyzs ABCDEFGHIrs s 01234567A) r` re rx r- rf rk �characters_writtenr� rd r
r� )r* r� rj r� �writtenrc r r r �test_write_non_blockinge s$
z*BufferedWriterTest.test_write_non_blockingc C s� t j� }| j|d�}| j|jd�d� | j|j� d� |jdd� | j|jd�d� |jdd� | j|j� d� | j|jd�d� |j� | j|j� d � d S )
Nr� s abcdefrr r s XYrF s XYcdefs 123456s XYcdef123456) r] r� re rx r- r5 r4 r� r� )r* r� rj r r r �test_write_and_rewind� s z(BufferedWriterTest.test_write_and_rewindc C s< | j � }| j|d�}|jd� |j� | jd|jd � d S )Nr� s abcr )r? re r- r� rx r' )r* r� rj r r r �
test_flush� s
z BufferedWriterTest.test_flushc C sH dddg}| j � }| j|d�}|j|� |j� | jdj|j�d� d S )Ns abs cds efr� r@ s abcdef)r? re r� r� rx rb r' )r* r� r� rj r r r �test_writelines� s
z"BufferedWriterTest.test_writelinesc C sL t dddg�}| j� }| j|d�}|j|� |j� | jdj|j�d� d S )Ns abs cds efr� r@ s abcdef)r r? re r� r� rx rb r' )r* r� r� rj r r r �test_writelines_userlist� s
z+BufferedWriterTest.test_writelines_userlistc C sN | j � }| j|d�}| jt|jdddg� | jt|jd � | jt|jd� d S )Nr� r6 rF r� �abc)r? re rz r{ r� )r* r� rj r r r �test_writelines_error� s
z(BufferedWriterTest.test_writelines_errorc C s> | j � }| j|d�}|jd� ~tj� | jd|jd � d S )Nr� s abcr )r? re r- r r� rx r' )r* r� rj r r r r� � s
z"BufferedWriterTest.test_destructorc C s� | j tjtj� | jtj| jdd��>}| j|d�}|jd� | j|j d�d� | j|j
� d� W d Q R X | jtjddd��}| j|j � d� W d Q R X d S ) Nr )r� r� s abcdefr� rr r� s abc) r� r rn ro r �
write_modere r- rx r; r5 rB )r* r� rj r" r r r �
test_truncate� s
z BufferedWriterTest.test_truncatec C s� | j tjtj� | jtjd��}|jdd � W d Q R X dddg}xb|D ]Z}| jtjd|d��>}|jd|d � |jd � |j� | j|j � |d
� W d Q R X qHW d S ) Nr� � i' i i �� zr+b)r� r6 rF )
r� r rn ro r r- rB r; rx r5 )r* r" Z buffer_sizesr� r r r �test_truncate_after_write� s
z,BufferedWriterTest.test_truncate_after_writez!Threading required for this test.r� c
sZ �zDd}t td��| }tddg�}d}t� �x6|t|�k rdt|�}�j|||| � � ||7 }q0W ~| jtj | j
dd��t}| j |d�� g �� ��fdd ���fd
d �td �D �}tj |�� t
jd
� W d Q R X | j�d� � � j� W d Q R X | jtj d����j� }W d Q R X x*td�D ] } | j|jt | g��|� �q"W W d tjtj � X d S )Ni� r� r6 r� r )r� r� c sj y6x0y �j � } W n tk
r$ d S X � j| � qW W n. tk
rd } z�j|� � W Y d d }~X nX d S )N)�popleftr7 r- r� r, )rc r� )rj r� �queuer r r" � s
z*BufferedWriterTest.test_threads.<locals>.fc s g | ]}t j� d ��qS ))r� )r� r� )r� r� )r" r r r� � s z3BufferedWriterTest.test_threads.<locals>.<listcomp>r~ g{�G�z�?z(the following exceptions were caught: %rr� )r r� r r r r� r, r r ro r� re r� r� r� r rQ rB rx r rn )
r* r� r� r� r9 r3 r� r� rc r� r )rj r� r" r r r� � s4
"z BufferedWriterTest.test_threadsc C sF | j � }| j|d�}| jt|jd� | jt|j� | jt|jd� d S )NrJ r s abcdef)rE re rz rP r4 r5 r- )r* r rj r r r r� s
z%BufferedWriterTest.test_misbehaved_ioc C s, | j t�� | j| j� dd� W d Q R X d S )Nr� rw )rz r{ re r? )r* r r r � test_max_buffer_size_removal s z/BufferedWriterTest.test_max_buffer_size_removalc C sH | j � }dd� }||_| j|�}|jd� | jt|j� | j|j� d S )Nc S s
t � �d S )N)rP )r
r r r � bad_write
s z?BufferedWriterTest.test_write_error_on_close.<locals>.bad_writes spam)r? r- re rz rP rQ r
rO )r* r� r r
r r r �test_write_error_on_close s
z,BufferedWriterTest.test_write_error_on_closeN) r r r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� r r� r� r� r r r r r r r� � s2
/r� c @ s2 e Zd ZejZdd� Zdd� Zdd� Zdd� Z d S )
�CBufferedWriterTestc C sD t j| � tjdkr@| j� }| j|�}| jttt f|j
|tj� d S )Ni���) r� r� r� r r? re rz r� r� ri r+ )r* r rj r r r r� s
z$CBufferedWriterTest.test_constructorc C s� | j � }| j|�}| jt|j|dd� | jt|jd� | jt|j|dd� | jt|jd� | jt|j|dd� | jt|jd� d S )Nr )r� s defr� r6 i�rg )r? re rz ri r+ r- )r* r rj r r r r� # s
z'CBufferedWriterTest.test_initializationc C s� | j tjtj� tjdtf��B | jtjd�}| j|�}|jd� ||_ t
j |�}~tj � W d Q R X | j
|� |� | jtjd��}| j|j� d� W d Q R X d S )Nr� zw+bs 123xxxr� )r� r rn ro r� r� r� re r- r� r r r� r r rx rB )r* r r" r r r r r - s
z+CBufferedWriterTest.test_garbage_collectionc C s0 | j td�� | jtj� ddd� W d Q R X d S )Nr� i )r= r{ re r] r� )r* r r r r� > s z#CBufferedWriterTest.test_args_errorN)
r r r r] r� re r� r� r r� r r r r r s
r c @ s e Zd ZejZdS )�PyBufferedWriterTestN)r r r r_ r� re r r r r r D s r c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+S ),�BufferedRWPairTestc C s$ | j | j� | j� �}| j|j� d S )N)re r? r rO )r* �pairr r r r� I s z#BufferedRWPairTest.test_constructorc C s� | j j| j �}~| j j| j �}| jttfd|jd� | jttfd|jd� |j| j� | j� � | j |jd�d� | j |jd�d� d S )Nz uninitialized|has no attributer r@ )
re r� r= ri r� rB r- r+ r? rx )r* r r r r r� M s
z%BufferedRWPairTest.test_uninitializedc C s( | j | j� | j� �}| j| j|j� d S )N)re r? rz rZ rg )r* r r r r ri [ s z BufferedRWPairTest.test_detachc C s2 | j t�� | j| j� | j� dd� W d Q R X d S )Nr� rw )rz r{ re r? )r* r r r �(test_constructor_max_buffer_size_removal_ s z;BufferedRWPairTest.test_constructor_max_buffer_size_removalc C s, G dd� dt �}| jt| j|� | j � � d S )Nc @ s e Zd Zdd� ZdS )zJBufferedRWPairTest.test_constructor_with_not_readable.<locals>.NotReadablec S s dS )NFr )r* r r r r1 e s zSBufferedRWPairTest.test_constructor_with_not_readable.<locals>.NotReadable.readableN)r r r r1 r r r r � NotReadabled s r
)r? rz rP re )r* r
r r r �"test_constructor_with_not_readablec s z5BufferedRWPairTest.test_constructor_with_not_readablec C s, G dd� dt �}| jt| j| j � |� � d S )Nc @ s e Zd Zdd� ZdS )zLBufferedRWPairTest.test_constructor_with_not_writeable.<locals>.NotWriteablec S s dS )NFr )r* r r r r. l s zUBufferedRWPairTest.test_constructor_with_not_writeable.<locals>.NotWriteable.writableN)r r r r. r r r r � NotWriteablek s r )r? rz rP re )r* r r r r �#test_constructor_with_not_writeablej s z6BufferedRWPairTest.test_constructor_with_not_writeablec C sv | j | jd�| j� �}| j|jd�d� | j|jd�d� | j|j� d� | j | jd�| j� �}| j|jd �d� d S )Ns abcdefr� s abcr6 r s ef)re r� r? rx rB )r* r r r r r� q s z BufferedRWPairTest.test_readc sX � fdd�}� j |� j� dddg� � j |� j� dddg� � j |� jd�ddg� d S )Nc s � j � jd�� j� �S )Ns abc
def
h)re r� r? r )r* r r r { s z3BufferedRWPairTest.test_readlines.<locals>.<lambda>s abc
s def
ru rJ )rx r� )r* r r )r* r r� z s z!BufferedRWPairTest.test_readlinesc C s, | j | jd�| j� �}| j|jd�d� d S )Ns abcdefr� s abc)re r� r? rx r4 )r* r r r r r� � s z BufferedRWPairTest.test_read1c C sl xfdD ]^}| j |��J | j| jd�| j� �}td�}| jt||�|�d� | jt|�d� W d Q R X qW d S ) Nr: r� s abcdefr rJ s abcde)r: r� s )r� re r� r? r rx r6 r )r* r8 r r r r r r� � s
z BufferedRWPairTest.test_readintoc C sf | j � }| j| j � |�}|jd� |j� td�}|j|� d|d d �< |j� | j|jddg� d S )Ns abcs defs ***)r? re r- r� ry rx r' )r* r� r r| r r r r� � s
z BufferedRWPairTest.test_writec C sB | j | jd�| j� �}| j|jd�jd�� | j|jd�d� d S )Ns abcdefr� s abc)re r� r? r
r� r� rx rB )r* r r r r � test_peek� s z BufferedRWPairTest.test_peekc C s& | j | j� | j� �}| j|j� � d S )N)re r? r
r1 )r* r r r r �
test_readable� s z BufferedRWPairTest.test_readablec C s& | j | j� | j� �}| j|j� � d S )N)re r? r
r. )r* r r r r �test_writeable� s z!BufferedRWPairTest.test_writeablec C s& | j | j� | j� �}| j|j� � d S )N)re r? r r2 )r* r r r r �
test_seekable� s z BufferedRWPairTest.test_seekablec C s8 | j | j� | j� �}| j|j� |j� | j|j� d S )N)re r? r rO rQ r
)r* r r r r �test_close_and_closed� s z(BufferedRWPairTest.test_close_and_closedc C s� dd� }| j � }||_| j � }| j||�}| jt��}|j� W d Q R X | jdt|j�� | j|j � | j
|j � | j|j � d S )Nc S s t d S )N)�reader_non_existingr r r r � reader_close� s zIBufferedRWPairTest.test_reader_close_error_on_close.<locals>.reader_closer ) r? rQ re rz r� r� r& r' r
rO r )r* r rS r� r r� r r r � test_reader_close_error_on_close� s z3BufferedRWPairTest.test_reader_close_error_on_closec C s� dd� }| j � }| j � }||_| j||�}| jt��}|j� W d Q R X | jdt|j�� | j|j � | j
|j � | j|j � d S )Nc S s t d S )N)�writer_non_existingr r r r � writer_close� s zIBufferedRWPairTest.test_writer_close_error_on_close.<locals>.writer_closer ) r? rQ re rz r� r� r& r' r rO r
)r* r rS r� r r� r r r � test_writer_close_error_on_close� s z3BufferedRWPairTest.test_writer_close_error_on_closec C s� dd� }dd� }| j � }||_| j � }||_| j||�}| jt��}|j� W d Q R X | jdt|j�� | j|jj t� | jdt|jj �� | j
|j � | j
|j � | j
|j � d S )Nc S s t d S )N)r r r r r r � s zPBufferedRWPairTest.test_reader_writer_close_error_on_close.<locals>.reader_closec S s t d S )N)r r r r r r � s zPBufferedRWPairTest.test_reader_writer_close_error_on_close.<locals>.writer_closer r ) r? rQ re rz r� r� r& r' r~ r r rO )r* r r rS r� r r� r r r �'test_reader_writer_close_error_on_close� s z:BufferedRWPairTest.test_reader_writer_close_error_on_closec C s� G dd� dt �}| j|d�|d��}| j|j� � | j|d�|d��}| j|j� � | j|d�|d��}| j|j� � | j|d�|d��}| j|j� � d S )Nc @ s e Zd Zdd� Zdd� ZdS )z8BufferedRWPairTest.test_isatty.<locals>.SelectableIsAttyc S s t j| � || _d S )N)r? r+ �_isatty)r* �isattyr r r r+ � s
zABufferedRWPairTest.test_isatty.<locals>.SelectableIsAtty.__init__c S s | j S )N)r )r* r r r r � s z?BufferedRWPairTest.test_isatty.<locals>.SelectableIsAtty.isattyN)r r r r+ r r r r r �SelectableIsAtty� s r FT)r? re r r r
)r* r r r r r � test_isatty� s z BufferedRWPairTest.test_isattyc C s* | j | j� | j� �}tj|�}d }d }d S )N)re r? r r )r* Zbrwr r r r �test_weakref_clearing� s
z(BufferedRWPairTest.test_weakref_clearingN)r r r r� r� ri r r r r� r� r� r� r� r r r r r r r r r r! r r r r r
G s* r
c @ s e Zd ZejZdS )�CBufferedRWPairTestN)r r r r] r� re r r r r r" s r" c @ s e Zd ZejZdS )�PyBufferedRWPairTestN)r r r r_ r� re r r r r r# s r# c @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+Zd+S ),�BufferedRandomTestzrb+zwb+c C s t j| � tj| � d S )N)r� r� r� )r* r r r r� s
z#BufferedRandomTest.test_constructorc C s t j| � tj| � d S )N)r� r� r� )r* r r r r� s
z%BufferedRandomTest.test_uninitializedc C sn | j d
�}| j|d�}| jd|jd�� |jd� |jd� | j|j� | jd|j� � | jd|jd � d S ) N� asdf� ghjkr� s asrF s ddds eees dddeeer )r% r& )r? re rx rB r- r r' )r* r� r� r r r �test_read_and_write s
z&BufferedRandomTest.test_read_and_writec C s | j d�}| j|�}| jd|jd�� | jd|j� � |jdd� | jd|jd�� |jd� |jdd� | jd|j� � | jd |j� � |jdd� | jd
|j� � |jdd � | jd |j� � | jd
|jd�� |j� | jd|j� � | j t
|jd� d S )Ns asdfghjkls asrF r s asdfr� s 123fs asdf123flrs rJ r6 rG s fl� g ���) r� re rx rB r5 r4 r- r� r� rz r{ )r* r� r� r r r �test_seek_and_tell! s$
z%BufferedRandomTest.test_seek_and_tellc C s� | j d�}| j|�}| jd||d�� |jd� | jd||d�� | jd|j� � |j� | jd|j� � | jd||�� |jdd� |jd � |j� |jdd� | jd ||d
�� d S ) Ns abcdefghis abrF s 12s efrr s ghir s XYZr� )r� re rx r- r5 r� r4 )r* Z read_funcr� rj r r r �check_flush_and_read8 s
z'BufferedRandomTest.check_flush_and_readc C s | j dd� � d S )Nc W s
| j |� S )N)rB )rj r[ r r r r K s z8BufferedRandomTest.test_flush_and_read.<locals>.<lambda>)r+ )r* r r r �test_flush_and_readJ s z&BufferedRandomTest.test_flush_and_readc C s ddd�}| j |� d S )Nr6 c S s. t |dkr|nd�}| j|�}t|d |� �S )Nr i' )ry r: r )rj r9 r
r r r � _readintoN s
z=BufferedRandomTest.test_flush_and_readinto.<locals>._readintorg )rg )r+ )r* r- r r r �test_flush_and_readintoM s
z*BufferedRandomTest.test_flush_and_readintoc C s ddd�}| j |� d S )Nr6 c S s2 | j |�}|dkr |d |� }| jt|�d� |S )Nr6 rg )r� r4 r )rj r9 r
r r r �_peekU s
z5BufferedRandomTest.test_flush_and_peek.<locals>._peekrg )rg )r+ )r* r/ r r r �test_flush_and_peekT s
z&BufferedRandomTest.test_flush_and_peekc C sh | j d�}| j|�}|jd� |j� |jd� |j� |jdd� | jd|j� � | jd|j� � d S )Ns abcdefghis 123s 45r s 12345fghi)r� re r- r� r4 rx r� rB )r* r� rj r r r �test_flush_and_write_ s
z'BufferedRandomTest.test_flush_and_writec C s t j| � tj| � d S )N)r� r� r� )r* r r r r� k s
z BufferedRandomTest.test_threadsc C s( dd� }| j |� dd� }| j |� d S )Nc S s | j d� d S )Nr6 )r� )rj r r r r/ p s z6BufferedRandomTest.test_writes_and_peek.<locals>._peekc S s. | j � }| jdd� | jd� | j|d� d S )Nr6 r rg )r5 r4 r� )rj r
r r r r/ s s
)r� )r* r/ r r r �test_writes_and_peeko s
z'BufferedRandomTest.test_writes_and_peekc C s dd� }| j |� d S )Nc S s | j dd� | jd� d S )Nr6 rg )r4 rB )rj r r r �_read{ s z7BufferedRandomTest.test_writes_and_reads.<locals>._read)r� )r* r3 r r r �test_writes_and_readsz s z(BufferedRandomTest.test_writes_and_readsc C s dd� }| j |� d S )Nc S s | j dd� | jd� d S )Nr6 rg )r4 r4 )rj r r r �_read1� s z9BufferedRandomTest.test_writes_and_read1s.<locals>._read1)r� )r* r5 r r r �test_writes_and_read1s� s z)BufferedRandomTest.test_writes_and_read1sc C s dd� }| j |� d S )Nc S s | j dd� | jtd�� d S )Nr6 rg )r4 r: ry )rj r r r r3 � s z;BufferedRandomTest.test_writes_and_readintos.<locals>._read)r� )r* r3 r r r �test_writes_and_readintos� s z,BufferedRandomTest.test_writes_and_readintosc C s� x�dD ]�}| j d �}| j|d�}| j|jd�d� | j|j� d� |jd| � | j|j� |d � |j� | j|j� |d � |j� }| j|dd| dd| � qW d S )
Nr6 rJ r� r� r� � Brs )r6 rJ s
AAAAAAAAAA)r� re rx rB r5 r- r� r� )r* Zoverwrite_sizer� rj rc r r r �test_write_after_readahead� s
z-BufferedRandomTest.test_write_after_readaheadc C s� dd� }d}x�t dt|��D ]x}xrt |t|��D ]`}| j|�}| j|d�}||||� |j� t|�}d||< d||< | j|j� |d||f � q0W q W d S ) Nc S sF ||ks t �| j|� | j|| � | jd� | j|� | jd� d S )N� � )r� r4 rB r- )rj Zpos1Zpos2r r r �mutate� s
z:BufferedRandomTest.test_write_rewind_write.<locals>.mutates �����r r� rF r6 z failed result for i=%d, j=%d)r� r r� re r� ry rx r� )r* r< r
r� �jr� rj �expectedr r r �test_write_rewind_write� s
z*BufferedRandomTest.test_write_rewind_writec C s^ | j d�}| j|d�}| j|jd�d� | j|j� d� | j|jd�d� | j|j� d� d S ) Nr� r� r� rF s AAs BBr� s
AAAAAAAAAA)r� re rx rB r; r- )r* r� rj r r r �!test_truncate_after_read_or_write� s
z4BufferedRandomTest.test_truncate_after_read_or_writec C s t j| � tj| � d S )N)r� r� r� )r* r r r r� � s
z%BufferedRandomTest.test_misbehaved_ioc C s: | j d���}| j|d���}|jd� | j|jd�d� |jd� | j|jd�d� |jd� td�}|j|� | j|d � |jd
� | j|jd�d � |j � | j|j
� d � W d Q R X W d Q R X | j d
��d}| j|d��L}| j|jd�d� |jd� | j|jd�d� |j � | j|j
� d� W d Q R X W d Q R X d S )Ns abcdefghr� � 1r6 r� � 2r r� � f� 4ru s 1b2d3f4hs abcr� r s a2c) r� re r- rx rB r4 ry r: r� r� r� )r* r� r" r8 r r r �test_interleaved_read_write� s*
$
z.BufferedRandomTest.test_interleaved_read_writec C s� | j d���}| j|��l}|jd� | j|j� d� |jd� | j|j� d� |jd� | j|j� d� |j� | j|j� d� W d Q R X W d Q R X d S ) Ns
ab
cdef
g
rA s b
rB s def
r� �
s
1b
2def
3
)r� re r- rx r� r� r� )r* r� r" r r r � test_interleaved_readline_write� s
z2BufferedRandomTest.test_interleaved_readline_writeN)r r r r� r� r� r� r' r* r+ r, r. r0 r1 r� r2 r4 r6 r7 r9 r? r@ r� rE rG r� r r r r r$
s.
r$ c @ s* e Zd ZejZdd� Zdd� Zdd� ZdS )�CBufferedRandomTestc C sD t j| � tjdkr@| j� }| j|�}| jttt f|j
|tj� d S )Ni���) r$ r� r� r r? re rz r� r� ri r+ )r* r rj r r r r� � s
z$CBufferedRandomTest.test_constructorc C s t j| � tj| � d S )N)r� r r )r* r r r r � s
z+CBufferedRandomTest.test_garbage_collectionc C s0 | j td�� | jtj� ddd� W d Q R X d S )Nr� i )r= r{ re r] r� )r* r r r r� s z#CBufferedRandomTest.test_args_errorN) r r r r] r� re r� r r� r r r r rH � s
rH c @ s e Zd ZejZdS )�PyBufferedRandomTestN)r r r r_ r� re r r r r rI s rI c @ s\ e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zddd�Z dd� Z
d
Z e dd� �Z
dS )�StatefulIncrementalDecodera�
For testing seek/tell behavior with a stateful, buffering decoder.
Input is a sequence of words. Words may be fixed-length (length set
by input) or variable-length (period-terminated). In variable-length
mode, extra periods are ignored. Possible words are:
- 'i' followed by a number sets the input length, I (maximum 99).
When I is set to 0, words are space-terminated.
- 'o' followed by a number sets the output length, O (maximum 99).
- Any other word is converted into a word followed by a period on
the output. The output word consists of the input word truncated
or padded out with hyphens to make its length equal to O. If O
is 0, the word is output verbatim without truncating or padding.
I and O are initially set to 1. When I changes, any buffered input is
re-scanned according to the new I. EOF also terminates the last word.
�strictc C s t jj| |� | j� d S )N)�codecs�IncrementalDecoderr+ �reset)r* r� r r r r+ ' s z#StatefulIncrementalDecoder.__init__c C s dt | � S )Nz<SID %x>)�id)r* r r r �__repr__+ s z#StatefulIncrementalDecoder.__repr__c C s d| _ d| _t� | _d S )Nr6 )r� �ory r| )r* r r r rN . s z StatefulIncrementalDecoder.resetc C s, | j dA | jdA }}t| j�|d | fS )Nr6 r� )r� rQ r r| )r* r� rQ r r r �getstate3 s z#StatefulIncrementalDecoder.getstatec C s: |\}}t |�| _t|d�\}}|dA |dA | _| _d S )Nr� r6 )ry r| �divmodr� rQ )r* �stater| r] r� rQ r r r �setstate7 s
z#StatefulIncrementalDecoder.setstateFc C s� d}xl|D ]d}| j dkrF|td�kr8| jrD|| j� 7 }qn| jj|� q
| jj|� t| j�| j kr
|| j� 7 }q
W |r�| jr�|| j� 7 }|S )Nr� r �.)r� �ordr| � process_wordr, r )r* �input�final�outputr
r r r �decode= s
z!StatefulIncrementalDecoder.decodec C s� d}| j d td�kr6tdt| j dd � p,d��| _nv| j d td�krhtdt| j dd � p^d��| _nD| j jd�}t|�| jk r�|d| j 7 }| jr�|d | j� }|d 7 }t� | _ |S )
Nr� r r� �c r6 rQ r� �-rV ) r| rW rE �intr� rQ r\ r ry )r* r[ r r r rX N s z'StatefulIncrementalDecoder.process_wordc C s6 | j r2|dkr2tjd�}tjd|jd d d d | d�S d S )N� test_decoderzlatin-1)rU r; r\ �incrementalencoder� streamreader� streamwriter�incrementaldecoder)� codecEnabledrL �lookup� CodecInfor; )�clsrU �latin1r r r �lookupTestDecoder` s
z,StatefulIncrementalDecoder.lookupTestDecoderN)rK )F)r r r r< r+ rP rN rR rU r\ rX re � classmethodrj r r r r rJ s
rJ c
@ s* e Zd ZdZd d d d d!d"d,gZdd� Zd S )-� StatefulIncrementalDecoderTestzB
Make sure the StatefulIncrementalDecoder actually works.
� abcdF�a.b.c.d.� oiabcdT�abcd.� oi...abcd...� i.o6.x.xyz.toolongtofit.�x-----.xyz---.toolon.�
i.i2.o6xyz�xy----.z-----.� i.o3.i6.abcdefghijklmnop� abc.ghi.mno.�; i.o29.a.b.cde.o15.abcdefghijabcdefghij.i3.a.b.c.d.ei00k.l.mz a----------------------------.z b----------------------------.z cde--------------------------.zabcdefghijabcde.za.b------------.z.c.------------.zd.e------------.zk--------------.zl--------------.zm--------------.c C s` x.| j D ]$\}}}t� }| j|j||�|� qW t� }| j|jd�d� | j|jdd�d� d S )Ns oiabcdr� r@ r6 zabcd.)�
test_casesrJ rx r\ )r* rY �eofr[ �dr r r r` � s z+StatefulIncrementalDecoderTest.test_decoderN)rm Frn )ro Trp )rq Trp )rr Frs )rt Tru )rv Trw z<a----------------------------.b----------------------------.zZa----------------------------.b----------------------------.cde--------------------------.zja----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.zza----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.a.b------------.z�a----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.a.b------------..c.------------.z�a----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.a.b------------..c.------------.d.e------------.z�a----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.a.b------------..c.------------.d.e------------.k--------------.z�a----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.a.b------------..c.------------.d.e------------.k--------------.l--------------.��a----------------------------.b----------------------------.cde--------------------------.abcdefghijabcde.a.b------------..c.------------.d.e------------.k--------------.l--------------.m--------------.)rx Tr| )r r r r< ry r` r r r r rl o s rl c @ s( e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z e
jdd� �Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z d1d2� Z d3d4� Z d5d6� Z d7d8� Z d9d:� Z!d;d<� Z"d=d>� Z#d?d@� Z$dAdB� Z%dCdD� Z&dEdF� Z'dGdH� Z(dIdJ� Z)dKdL� Z*dMdN� Z+dOdP� Z,dQdR� Z-dSdT� Z.dUdV� Z/dWdX� Z0e
j1e2j3e4dY�dZd[� ��Z5d\d]� Z6d^d_� Z7d`da� Z8dbdc� Z9ddde� Z:dfdg� Z;dhdi� Z<djdk� Z=dldm� Z>dndo� Z?dpdq� Z@drds� ZAdtdu� ZBe
jCdvdw� �ZDe
jCdxdy� �ZEdzd{� ZFd|d}� ZGd~d� ZHd�S )��TextIOWrapperTestc C s" d| _ djd�| _tjtj� d S )Ns AAA
BBB
CCC
DDD
EEE
s AAA
BBB
CCC
DDD
EEE
r� )�testdatar\ �
normalizedr rn ro )r* r r r rp � s zTextIOWrapperTest.setUpc C s t jt j� d S )N)r rn ro )r* r r r rq � s zTextIOWrapperTest.tearDownc C s� | j d�}| j|d�}| j|�}|j|ddd� | j|jd� | j|jd� |j|ddd � | j|jd� | j|jd� | jd
|j� � | jt |j|d d � | jt
|j|d
d � d S )Ns é
i� zlatin-1z
)r r1 Fzutf-8T)r �line_bufferingu é
r/ )r1 rq ) r� r� r� r+ rx r r� r� rz r{ ri )r* r r
�tr r r r� � s
z"TextIOWrapperTest.test_constructorc C sf | j j| j �}~| j j| j �}| jtt|� | jttfd|jd� |j | j
� � | j |jd�d� d S )Nz uninitialized|has no attributer r� ) r� r� rz r� rh r= ri r� rB r+ r? rx )r* r� r r r r� � s
z$TextIOWrapperTest.test_uninitializedc C s< | j � }| j|�}| jtd�� | j|dd� W d Q R X d S )Nzis not a text encoding�hex)r )r� r� r= � LookupErrorr� )r* r r
r r r �*test_non_text_encoding_codecs_are_rejected� s
z<TextIOWrapperTest.test_non_text_encoding_codecs_are_rejectedc C s� | j � }| j|�}| j|�}| j|j� |� | j|dd�}|jd� | j|j� � |j� | j|j� d� | j t
|j� t |� | j|j d� | j|j
d� | j|j� d S )Nr� )r Zhowdys howdyrK )r� r� r� rf rg r- r r� rx rz ri rh r r� r� )r* r r
r� r r r ri � s
z TextIOWrapperTest.test_detachc C s� | j djd��}| j|�}| j|dd�}| jj}| jt|�d| � d|_| jt|�d| � d|_| jt|�d| � d |_| jt|�d
| � |j j
� t|� d S ) NZhellozutf-8)r z#<%s.TextIOWrapper encoding='utf-8'>rx z0<%s.TextIOWrapper name='dummy' encoding='utf-8'>r z9<%s.TextIOWrapper name='dummy' mode='r' encoding='utf-8'>s dummyz:<%s.TextIOWrapper name=b'dummy' mode='r' encoding='utf-8'>) r� r; r� r� r rx rh rU r� r| rg )r* r� r
r� �modnamer r r ry � s"
zTextIOWrapperTest.test_reprc C sR | j � }| j|�}tj|d|��( y t|� W n tk
rB Y nX W d Q R X d S )NrU )r� r� r rz rh r{ )r* r� r� r r r r| � s
z%TextIOWrapperTest.test_recursive_reprc C sv | j � }| j|d�}| j|ddd�}|jd� | j|j� d� |jd� | j|j� d� |jd � | j|j� d
� d S ) Ni� �
T)r1 r� �Xr@ zY
Zs XY
ZzA
Bs XY
ZA
B)r� r� r� r- rx r� )r* r r
r� r r r �test_line_buffering� s
z%TextIOWrapperTest.test_line_bufferingc C sv t tj�}zNx dD ]}|tjkrtj|= qW tjd�}| j� }| j|�}| j|j|� W d tjj � tjj
|� X d S )N�LC_ALL�LANG�LC_CTYPEF)r� r� r� ) �dictr� �environ�locale�getpreferredencodingr� r� rx r �clear�update)r* Z old_environ�keyZcurrent_locale_encodingr
r� r r r �test_default_encoding
s
z'TextIOWrapperTest.test_default_encodingc sP dd l � | j� }� fdd�|_| jt| j|� � fdd�|_| jt| j|� d S )Nr c s
� j d S )Nr6 )ZINT_MAXr )� _testcapir r r
s z8TextIOWrapperTest.test_device_encoding.<locals>.<lambda>c s
� j d S )Nr6 )ZUINT_MAXr )r� r r r
s )r� r� r0 rz r� r� )r* r
r )r� r �test_device_encoding
s z&TextIOWrapperTest.test_device_encodingc C sJ | j � }| j|dd�}| j|jd� | j|�}| j|j� tj|j� d S )Nzutf-8)r )r� r� rx r �assertIsNotNonerL rf )r* r
r� r r r �
test_encoding
s
z TextIOWrapperTest.test_encodingc C s� | j d�}| j|dd�}| jt|j� | j d�}| j|ddd�}| jt|j� | j d�}| j|ddd�}| j|j� d� | j d�}| j|ddd�}| j|j� d � d S )
Ns abc
�
r� )r rK )r r� r� zabc
�replaceu abc
�
)r� r� rz � UnicodeErrorrB rx )r* r
r� r r r � test_encoding_errors_reading'
s
z.TextIOWrapperTest.test_encoding_errors_readingc C s� | j � }| j|dd�}| jt|jd� | j � }| j|ddd�}| jt|jd� | j � }| j|dddd�}|jd � |j� | j|j� d
� | j � }| j|dd dd�}|jd � |j� | j|j� d � d S )
Nr� )r � ÿrK )r r� r� r� )r r� r1 u abcÿdef
s abcdef
r� s abc?def
)r� r� rz r� r- r� rx r� )r* r
r� r r r � test_encoding_errors_writing9
s$
z.TextIOWrapperTest.test_encoding_errors_writingc C sX dddddg}d dddddggd|gd ddd
dggd d d
ggddddggg}d }�x |D ]�}t dj|�j|��}x�d!D ]�}x�td d �D ]�}x�|D ]�\}} | j| j|�|�}
| j|
||d �} |�rg } xD| jd �}
|
dkr�P | jt |
�d � | j
|
| j � � q�W nt | �} x$t
| | �D ]\}}| j||� �qW | jt | �t | �� q�W q�W qvW qXW d S )"Nzunix
z windows
zos9
zlast
Znonlzwindows
zos9
r� r� z os9
last
z
zunix
windows
z
os9
last
nonl�
z
unix
windows
z
os9
z last
nonl�utf-8�latin-1�utf-16� utf-16-le� utf-16-be�utf-32� utf-32-le� utf-32-beFTr6 r� )r1 r rF )r� r� r� r� r� r� r� r� )FT)r rb r; r� r� r� r� rB rx r r, r� r% �zip)r* Z input_linesr� � encodingsr r Zdo_readsr� r1 Z exp_linesrj �textioZ got_linesZc2Zgot_lineZexp_liner r r �
test_newlinesQ
s:
z TextIOWrapperTest.test_newlinesc
C s� d}|j dd�j dd�}x�d |jd�jdd�fd|jd�jdd�fd d
d d d
dgfddd
dgfddddddgfgD ]R\}}| j|�}| j|d|d�}| j|j� |� |jd� | j|j� dj |�� qrW d S )Ns AAA
BB B
CCC
DDD
EEE
FFF
GGGs
rF �
r� T)�keependsr� r� zAAA
zBB B
z
CCC
DDD
EEE
zFFF
ZGGGz
zAAA
BB B
CCC
DDD
EEE
r� z
AAA
BB B
CCC
zDDD
zEEE
z
FFF
z
GGG)r r1 r )
r� r\ ru r� r� rx r� r4 rB rb )r* r~ r r1 r> r8 �txtr r r �test_newlines_input{
s
z%TextIOWrapperTest.test_newlines_inputc C s� ddddd�}d |t j fgt|j� � }xl|D ]d\}}| j� }| j|d|d�}|jd� |jd� |jd � |j� | j|j d
� | j|j
� |� q0W d S ) Ns AAA
BBB
CCC
X
Y
Zs AAA
BBB
CCC
X
Y
Zs AAA
BBB
CCC
X
Y
Z)r� r� r� z
r� )r r1 zAAA
BzBB
CCC
zX
Y
ZF) r� �linesep�sorted�itemsr� r� r- r� rx rO r� )r* Ztestdictr� r1 r> r8 r� r r r �test_newlines_output�
s
z&TextIOWrapperTest.test_newlines_outputc sZ g �| j � G � �fdd�d� �}|� }| j|dd�}|jd� ~tj� | jdg�� d S )Nc s e Zd Z� �fdd�ZdS )z4TextIOWrapperTest.test_destructor.<locals>.MyBytesIOc s �j | j� � � j| � d S )N)r, r� rQ )r* )r� r� r r rQ �
s z:TextIOWrapperTest.test_destructor.<locals>.MyBytesIO.closeN)r r r rQ r )r� r� r r � MyBytesIO�
s r� r� )r r� s abc)r� r� r- r r� rx )r* r� r
r� r )r� r� r r� �
s
z!TextIOWrapperTest.test_destructorc sN g � G � fdd�d| j �}| j� }||dd�}~tj� | j� dddg� d S )Nc s: e Zd Z� �fdd�Z� �fdd�Z� �fdd�Z� ZS )z<TextIOWrapperTest.test_override_destructor.<locals>.MyTextIOc s6 �j d� y t� j}W n tk
r* Y nX |� d S )Nr6 )r, rG r� r� )r* r" )rH r� r r r� �
s
zDTextIOWrapperTest.test_override_destructor.<locals>.MyTextIO.__del__c s �j d� t� j� d S )NrF )r, rG rQ )r* )rH r� r r rQ �
s
zBTextIOWrapperTest.test_override_destructor.<locals>.MyTextIO.closec s �j d� t� j� d S )Nr� )r, rG r� )r* )rH r� r r r� �
s
zBTextIOWrapperTest.test_override_destructor.<locals>.MyTextIO.flush)r r r r� rQ r� rK r )r� )rH r �MyTextIO�
s r� r� )r r6 rF r� )r� r� r r� rx )r* r� r
r� r )r� r rn �
s z*TextIOWrapperTest.test_override_destructorc
s� �j � � � �fdd�}tjd��}�jt|� W d Q R X |j� j� }|r��jt|j � �d� �j
|j d�|� �j
|j d�|� d S )Nc s �j � �j d S )N)r� rq r )r r* r r r" �
s z:TextIOWrapperTest.test_error_through_destructor.<locals>.frr r6 zException OSError: z ignored)
rN r rs rz r� r� rt rx r ru r
r� rv )r* r" rc r )r r* r rw �
s z/TextIOWrapperTest.test_error_through_destructorc C s� �x�d D �]�}�x~d D �]t}| j tjd|d�}||_| j|jd�d� |j� | j tjd|d�}||_| j|j� d� | j|j� d� |j� }| j|j d�d� | j|jd �d� |j d� | j|jd�d� | j|jd�d� | j|jd�d� | j|j� d� | j|j� |� | j|j d�d� | j|j dd�|� | j|jd�d� | j|j |�|� | j|j� d� |j
d��r�| j ||� |j� qW qW d S ) Nr6 rF r� r� rJ r� r� � r� r� �! �? �@ �A r� �latin-1�utf-8zw+)r r� zr+r r� r� r� �def�utf)r6 rF r� r� rJ r� r� r� r� r� r� r� r� r� )r� r� r� ) r r ro r! rx r- rQ r5 rB r4 r� �multi_line_test)r* Z chunksize�encr" �cookier r r �
test_basic_io�
s6
z TextIOWrapperTest.test_basic_ioc C s� |j d� |j� d}g }xbdD ]Z}g }x&t|�D ]}|j||t|� � q2W dj|�d }|j|j� |f� |j|� q W |j d� g } x(|j� }
|j� }|s�P | j|
|f� q�W | j | |� d S )Nr u sÿr6 rF r� r� rJ � r� r� r� �> r� r� r� �� r� r� )r r6 rF r� r� rJ r� r� r� r� r� r� r� r� r� )
r4 r; r� r, r rb r5 r- r� rx ) r* r" r� ZsampleZwlinesr3 �charsr� �lineZrlinesr
r r r r� �
s(
z!TextIOWrapperTest.multi_line_testc C s� | j tjddd�}|j� }|jd� |j� }|jd� |j� }|jd� | j|j� |� | j|j� d� | j|j� |� | j|j� d� | j|j� |� |jd� x&|D ] }| j|d� | jt |j� q�W | j|j� |� |j
� d S )Nzw+zutf-8)r u ÿ
r ) r r ro r5 r- r4 rx r� rz rP rQ )r* r" Zp0Zp1Zp2r� r r r � test_telling s$
z TextIOWrapperTest.test_tellingc
C s� t � }|d }d| }t|jd��}| jt|�t|�� d}t|jd��}|| }| jtjd��}|j|d � W d Q R X | jtjddd��B}|j |�} | j| t
|d�� | j|j � |� | j|j � |� W d Q R X d S ) NrF r� zutf-8u 袈
r� r )r r� )
r# r r; rx r r r ro r- rB r& r5 r� )
r* Z
chunk_sizeZ prefix_sizeZu_prefix�prefixZu_suffix�suffixr� r" rc r r r � test_seeking s
z TextIOWrapperTest.test_seekingc C sf d}| j tjd��}|j|� W d Q R X | j tjddd��"}|j d|_|j� |j� W d Q R X d S )Ns
r� r zutf-8)r rF )r r ro r- r! r� r5 )r* r r" r r r �test_seeking_too+ s z"TextIOWrapperTest.test_seeking_tooc s� d� d� �fdd� }dt _zfx tjD ]\}}}||� q$W xBtjD ]8\}}}� t|�d }d| }|d }||| |� qBW W d dt _X d S ) N� r c s� �j tjd�}|j| � |j� �j tjdd�}� |_|j� }|j� x�t|t|�d �D ]�}x�ddt|�| gD ]~}�j tjdd�}�j |j|�|d|� � |j
� }�j |j|�|||| � � |j |� �j |j� ||d� � |j� qrW qZW dS )zTell/seek to various points within a data stream and ensure
that the decoded data returned by read() is consistent.r� r` )r r6 rJ N) r r ro r- rQ r! rB r� r rx r5 r4 )r �min_posr" Zdecodedr� r= r� )�
CHUNK_SIZEr* r r � test_seek_and_tell_with_data; s
zJTextIOWrapperTest.test_seek_and_tell.<locals>.test_seek_and_tell_with_datar6 rF � .)r )rJ re rl ry r )r* r� rY �_�offsetr� r� r )r� r* r r* 6 s z$TextIOWrapperTest.test_seek_and_tellc C s� d}d }x�|D ]�}| j � }| j||d�}|j|� |j|� |jd � | j|j� |d
� |jd � | j|j� |d
� | j|j� |d
j|�� qW d S ) NZ
1234567890�utf-16� utf-16-le� utf-16-be�utf-32� utf-32-le� utf-32-be)r r rF )r� r� r� r� r� r� )r� r� r- r4 rx rB r� r; )r* r r� r r8 r" r r r �test_encoded_writese s"
z%TextIOWrapperTest.test_encoded_writesc C s0 G dd� d| j �}| j|� �}| jt|j� d S )Nc @ s e Zd Zdd� ZdS )z5TextIOWrapperTest.test_unreadable.<locals>.UnReadablec S s dS )NFr )r* r r r r1 { s z>TextIOWrapperTest.test_unreadable.<locals>.UnReadable.readableN)r r r r1 r r r r �
UnReadablez s r� )r� r� rz rP rB )r* r� r� r r r �test_unreadabley s z!TextIOWrapperTest.test_unreadablec C sB | j | jd��}d}x |jd�}|s&P ||7 }qW | j|d� d S )Ns AA
BBr� r6 zAA
BB)r� r� rB rx )r* r� �readsr� r r r �test_read_one_by_one� s
z&TextIOWrapperTest.test_read_one_by_onec C sl | j | jd��}| j|j� dddg� |jd� | j|jd �dddg� |jd� | j|jd�ddg� d S )Ns AA
BB
CCzAA
zBB
�CCr rJ )r� r� rx r� r4 )r* r� r r r r� � s
z TextIOWrapperTest.test_readlinesc C sR | j | jdd d ��}d}x |jd�}|s.P ||7 }q W | j|dd d � d S )Nr� � s
Br� r� �Az
B)r� r� rB rx )r* r� r� r� r r r �test_read_by_chunk� s
z$TextIOWrapperTest.test_read_by_chunkc C sB dddg}| j � }| j|�}|j|� |j� | j|j� d� d S )Nr� �cd�efs abcdef)r� r� r� r� rx r� )r* r� r8 r� r r r r� � s
z!TextIOWrapperTest.test_writelinesc C sF t dddg�}| j� }| j|�}|j|� |j� | j|j� d� d S )Nr� r� r� s abcdef)r r� r� r� r� rx r� )r* r� r8 r� r r r r� � s
z*TextIOWrapperTest.test_writelines_userlistc C sH | j | j� �}| jt|jdddg� | jt|jd � | jt|jd� d S )Nr6 rF r� s abc)r� r� rz r{ r� )r* r� r r r r� � s z'TextIOWrapperTest.test_writelines_errorc C sJ | j | j| j�dd�}d}x |jd�}|s,P ||7 }q W | j|| j� d S )Nr� )r r� r6 )r� r� r~ rB rx r )r* r� r� r� r r r �test_issue1395_1� s
z"TextIOWrapperTest.test_issue1395_1c C sP | j | j| j�dd�}d|_d}x |jd�}|s2P ||7 }q"W | j|| j� d S )Nr� )r r� r� )r� r� r~ r! rB rx r )r* r� r� r� r r r �test_issue1395_2� s
z"TextIOWrapperTest.test_issue1395_2c C sj | j | j| j�dd�}d|_|jd�}||jd�7 }||j� 7 }||j� 7 }||j� 7 }| j|| j� d S )Nr� )r r� )r� r� r~ r! rB r� rx r )r* r� r� r r r �test_issue1395_3� s
z"TextIOWrapperTest.test_issue1395_3c C sD | j | j| j�dd�}d|_|jd�}||j� 7 }| j|| j� d S )Nr� )r r� )r� r� r~ r! rB rx r )r* r� r� r r r �test_issue1395_4� s
z"TextIOWrapperTest.test_issue1395_4c C sX | j | j| j�dd�}d|_|jd�}|j� }|jd� |j|� | j|jd�d� d S )Nr� )r r� r zBBB
)r� r� r~ r! rB r5 r4 rx )r* r� r� r
r r r �test_issue1395_5� s
z"TextIOWrapperTest.test_issue1395_5c C s2 | j | j�}| j|dd�}| j|j� |j� � d S )Nr� )r )r� r~ r� rx r2 )r* r| r� r r r �test_issue2282� s z TextIOWrapperTest.test_issue2282c ! C s� t j}x�d D ]�}| j|d|d��}|jd� |j� }W d Q R X | j|d�� }| j|j� dj|�� W d Q R X | j|d|d��}|jd � W d Q R X | j|d�� }| j|j� d
j|�� W d Q R X q W d S ) N� utf-8-sig�utf-16�utf-32r� )r �aaar� r� �xxx�aaaxxx)r� r� r� )r ro r r- r5 rx rB r; )r* �filename�charsetr" r
r r r �test_append_bom� s
z!TextIOWrapperTest.test_append_bomc C s� t j}x�d
D ]�}| j|d|d��}|jd� |j� }W d Q R X | j|d|d��.}|j|� |jd� |jd � |jd
� W d Q R X | j|d �� }| j|j� d j|�� W d Q R X q W d S )N� utf-8-sig�utf-16�utf-32r� )r r� zr+Zzzzr Zbbbr� Zbbbzzz)r� r� r� ) r ro r r- r5 r4 rx rB r; )r* r� r� r" r
r r r �
test_seek_bom� s
z TextIOWrapperTest.test_seek_bomc C s� t j}x�d D ]�}| j|d|d��}|jd� W d Q R X | j|d|d��(}|jd� |jd| j� |jd � W d Q R X | j|d
�� }| j|j� d j|�� W d Q R X q W d S )
N� utf-8-sig�utf-16�utf-32r� )r r� r� r r� r� r� )r� r� r� ) r ro r r- r4 r� rx rB r; )r* r� r� r" r r r �test_seek_append_bom
s
z&TextIOWrapperTest.test_seek_append_bomc C sX | j tjd��}| j|jd� W d Q R X | j tjddd��}| j|jd� W d Q R X d S )Nr� rK r� )r� )r r ro rx r� )r* r" r r r �test_errors_property s z&TextIOWrapperTest.test_errors_propertyz!Threading required for this test.c s� t j� � | jtjddd��N�� �fdd���fdd�td�D �}tj|� j�� tj d � W d Q R X W d Q R X | jtj��6��j
� }x&td�D ]}| j |j d
| �d� q�W W d Q R X d S ) Nr� r6 )r� c s d| }� j � �j|� d S )Nz Thread%03d
)�waitr- )r9 �text)�eventr" r r �run& s z1TextIOWrapperTest.test_threads_write.<locals>.runc s g | ]}t j� |fd ��qS ))r� r[ )r� r� )r� r� )r� r r r� * s z8TextIOWrapperTest.test_threads_write.<locals>.<listcomp>r~ g{�G�z�?z Thread%03d
)
r� ZEventr r ro r� r� r` r� r� rB rx r )r* r� Zcontentr9 r )r� r" r� r �test_threads_write s
z$TextIOWrapperTest.test_threads_writec s� | j | j| j�dd��g � � �fdd�}|�_| jt�j� | j�j� | j�j j� | j� � | j
� d � | j
� d � dd� �_d S ) Nr� )r c s �j �jj g� d d �< t� �d S )N)rO r| rP r )rO r� r r r 8 s z>TextIOWrapperTest.test_flush_error_on_close.<locals>.bad_flushr r6 c S s d S )Nr r r r r r B s z=TextIOWrapperTest.test_flush_error_on_close.<locals>.<lambda>) r� r� r~ r� rz rP rQ r
rO r| r )r* r r )rO r� r r 3 s
z+TextIOWrapperTest.test_flush_error_on_closec
C s� | j | j�}dd� }dd� }||_| j|dd�}||_| jt��}|j� W d Q R X | j|jj d � | j
|jj t� | j|jj j d
� | j |j
� d S ) Nc S s t d��d S )Nr� )rP r r r r r F s z>TextIOWrapperTest.test_close_error_on_close.<locals>.bad_flushc S s t d��d S )NrQ )rP r r r r r} H s z>TextIOWrapperTest.test_close_error_on_close.<locals>.bad_closer� )r rQ r� )rQ )r� )r� r~ rQ r� r� rz rP rx r' r[ r~ r r rO )r* r| r r} r� r� r r r r� D s z+TextIOWrapperTest.test_close_error_on_closec C s� | j | j�}dd� }dd� }||_| j|dd�}||_| jt��}|j� W d Q R X | jdt|j �� | j
|j j t� | jdt|j j �� | j |j
� d S ) Nc S s t �d S )N)r� r r r r r W s zLTextIOWrapperTest.test_nonnormalized_close_error_on_close.<locals>.bad_flushc S s t �d S )N)r� r r r r r} Y s zLTextIOWrapperTest.test_nonnormalized_close_error_on_close.<locals>.bad_closer� )r r� r� )r� r~ rQ r� r� rz r� r� r& r' r~ r r rO )r* r| r r} r� r� r r r r� T s z9TextIOWrapperTest.test_nonnormalized_close_error_on_closec C s@ | j | j| j�dd�}|j� |j� |j� | jt|j� d S )Nr� )r )r� r� r~ rQ rz ri r� )r* r� r r r r e s
z"TextIOWrapperTest.test_multi_closec C s8 | j | j| j��}| j| j|j� | j| j|jd� d S )Nr )r� rY r~ rz rZ r5 r4 )r* r� r r r r� l s z!TextIOWrapperTest.test_unseekablec C sB | j | j| j�dd�}| j| j�}| jt�� ||_W d Q R X d S )Nr� )r )r� r� r~ rz r� r| )r* r� r8 r r r r� q s z*TextIOWrapperTest.test_readonly_attributesc C sZ | j dddg�}| j|ddd�}| j|jd�d� | j|j� d � | jt|�d
d g� d S ) Ns abcs defs ghi
jkl
opq
r� r� )r r1 r� Zabcdzefghi
zjkl
zopq
)r? r� rx rB r� r% )r* r� r� r r r �
test_rawiow s
z TextIOWrapperTest.test_rawioc C sX | j dddg�}| j|dddd�}|jd� |jd � |jd
� | jd j|j�d � d S )
Ns abcs defs ghi
jkl
opq
r� r� T)r r1 �
write_through�1z23
4�5r@ s 123
45)r? r� r- rx rb r' )r* r� r� r r r �test_rawio_write_through� s
z*TextIOWrapperTest.test_rawio_write_throughc s� g g � �G � �fdd�d| j �}| j� }d}||t|�d �}| j|ddd�}|jd�}|j|� | j� � | j�� | j|j � d� g �|j|d � | j�� | j|j � |d
� d S ) Nc s, e Zd Z� �fdd�Z� �fdd�Z� ZS )zBTextIOWrapperTest.test_bufio_write_through.<locals>.BufferedWriterc s �j d� t� j||�S )NT)r, rG r� )r* r[ r )rH � flush_calledr r r� � s
zHTextIOWrapperTest.test_bufio_write_through.<locals>.BufferedWriter.flushc s �j d� t� j||�S )NT)r, rG r- )r* r[ r )rH � write_calledr r r- � s
zHTextIOWrapperTest.test_bufio_write_through.<locals>.BufferedWriter.write)r r r r� r- rK r )r r )rH r r� � s r� r� rF r� T)r r r@ r� r( )
r� r� r r� r\ r- r r
rx r� )r* r� r r rj r� r� r )r r r �test_bufio_write_through� s
z*TextIOWrapperTest.test_bufio_write_throughc C s` | j | jd��}| jt|jd� | j | jd��}| jt|j� | j | jd��}| jt|j� d S )Nr� r6 )r� r� rz r{ rB r� )r* r� r r r �test_read_nonbytes� s z$TextIOWrapperTest.test_read_nonbytesc C sL t jd�}tj|dd�� tjtjd�dd�}W d Q R X | jt|j d� d S )N�rot13�_is_text_encodingTs foo)r Zbar)
rL rf r rz r] r� r� rz r{ r- )r* r r� r r r �test_illegal_encoder� s
z&TextIOWrapperTest.test_illegal_encoderc s� �fdd�� � � }�j t|jd� � � }�j t|j� � � }�j t|j� � fdd�}|d�}�j t|jd� |f �}�j t|jd� |d�}�j t|jd� d S ) Nc s8 t jd�} d| _z� j� jd�ddd�}W d d| _X |S )N�quopriTs aaaaaar� )r1 r F)rL rf r
r� r� )r r� )r* r r �_make_illegal_wrapper� s
zETextIOWrapperTest.test_illegal_decoder.<locals>._make_illegal_wrapperr6 c sH G �fdd�d�� � fdd�}t jd�}tj|d|�� �� S Q R X d S )Nc s e Zd Z� fdd�ZdS )z^TextIOWrapperTest.test_illegal_decoder.<locals>._make_very_illegal_wrapper.<locals>.BadDecoderc s � S )Nr )r* )�getstate_ret_valr r rR � s zgTextIOWrapperTest.test_illegal_decoder.<locals>._make_very_illegal_wrapper.<locals>.BadDecoder.getstateN)r r r rR r )r r r �
BadDecoder� s r c s � � S )Nr )rx )r r r �_get_bad_decoder� s zdTextIOWrapperTest.test_illegal_decoder.<locals>._make_very_illegal_wrapper.<locals>._get_bad_decoderr rd )rL rf r rz )r r r )r
)r r r �_make_very_illegal_wrapper� s
zJTextIOWrapperTest.test_illegal_decoder.<locals>._make_very_illegal_wrapperr/ rF )r6 rF )rz r{ rB r� )r* r� r r )r
r* r �test_illegal_decoder� s
z&TextIOWrapperTest.test_illegal_decoderc K s | j j}dj||d�}td|�S )Na� if 1:
import codecs
import {iomod} as io
# Avoid looking up codecs at shutdown
codecs.lookup('utf-8')
class C:
def __init__(self):
self.buf = io.BytesIO()
def __del__(self):
io.TextIOWrapper(self.buf, **{kwargs})
print("ok")
c = C()
)�iomodr z-c)r] r r r )r* r r �coder r r �_check_create_at_shutdown� s z+TextIOWrapperTest._check_create_at_shutdownc C s> | j � \}}}|r&| j| j|j� � n| jd|j� j� � d S )N�ok)r r� �shutdown_errorr\ rx rt )r* �rc�outr� r r r �(test_create_at_shutdown_without_encoding� s z:TextIOWrapperTest.test_create_at_shutdown_without_encodingc C s6 | j ddd�\}}}| j|� | jd|j� j� � d S )Nzutf-8rK )r r� r )r r rx r\ rt )r* r r r� r r r �%test_create_at_shutdown_with_encoding
s
z7TextIOWrapperTest.test_create_at_shutdown_with_encodingc C s@ t d�}| j|d�}t|j� �j� }| j|jd�|jd�� d S )Ns Just some random string
zutf-8r )�MemviewBytesIOr� �_to_memoryviewr� r� rx rB r\ )r* r r� Z bytes_valr r r �test_read_byteslike
s z%TextIOWrapperTest.test_read_byteslikec C sj G dd� dt �}x:td�D ].}y| j|� dd� W q tk
rF Y qX qW dd� |_| j|� dd�}d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z,TextIOWrapperTest.test_issue22849.<locals>.Fc S s dS )NTr )r* r r r r1
s z5TextIOWrapperTest.test_issue22849.<locals>.F.readablec S s dS )NTr )r* r r r r.
s z5TextIOWrapperTest.test_issue22849.<locals>.F.writablec S s dS )NTr )r* r r r r2
s z5TextIOWrapperTest.test_issue22849.<locals>.F.seekableN)r r r r1 r. r2 r r r r �F
s r r� zutf-8)r c S s dS )Nr r )r� r r r r #
s z3TextIOWrapperTest.test_issue22849.<locals>.<lambda>)�objectr� r� r� r5 )r* r r� r� r r r �test_issue22849
s
z!TextIOWrapperTest.test_issue22849c C sb | j | jd�dd�}|jd� |j� |j� | j | jd�dd�}|jd� |jd� |j� d S )Ns testr� )r r6 r� )r� r� rB r5 r- )r* r� r r r �test_issue25862&
s
z!TextIOWrapperTest.test_issue25862N)Ir r r rp rq r� r� r� ri ry r| r� r� r r� r� r� r� r� r� r� r� r� rn rw r� r� r� r� r� r* r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �
no_tracingr� r� r� r� r r� r� r r� r� r r r r r r r Zrequires_type_collectingr r r r! r" r r r r r} � s�
* /
(
r} c s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )r zOA BytesIO object whose read method returns memoryviews
rather than bytesc s t t� j|��S )N)r rG r4 )r* �len_)rH r r r4 6
s zMemviewBytesIO.read1c s t t� j|��S )N)r rG rB )r* r$ )rH r r rB 9
s zMemviewBytesIO.read)r r r r< r4 rB rK r r )rH r r 2
s r c C s: t j d�}t| �t| �|j }|j| d|� � t|�S )z6Convert bytes-object *buf* to a non-trivial memoryviewr� N)r r �itemsizeZ frombytesr )r8 Zarr�idxr r r r <
s
r c @ s, e Zd ZeZdZdd� Zdd� Zdd� ZdS ) �CTextIOWrapperTestz,RuntimeError: could not find io module statec C sb | j d�}| j|d�}| j|�}| jt|j|dd� | jt|j� | jj| j�}| jtt |� d S )Ns é
i� rq )r1 )
r� r� r� rz ri r+ rB r� r� rh )r* r r
r� r r r r� I
s
z&CTextIOWrapperTest.test_initializationc C s� t jdtf��P tjt jd�}| j|�}| j|dd�}|jd� ||_ t
j |�}~t j � W d Q R X | j
|� |� | jt jd��}| j|j� d� W d Q R X d S )Nr� r� r� )r Z456defr� s 456def)r r� r� r] r� ro r� r� r- r� r r r� r r rx rB )r* r r
r� r r" r r r r S
s
z*CTextIOWrapperTest.test_garbage_collectionc C sn x`t d�D ]T}| j| j� | j� �}| j|dd�}| j| j� | j� �}| j|dd�}||_||_q
W tj� d S )Ni� r� )r )r� r� r? r� Zbuddyr r� )r* r� Zb1Zt1Zb2Zt2r r r �!test_rwpair_cleared_before_textiod
s
z4CTextIOWrapperTest.test_rwpair_cleared_before_textioN)r r r r] r r� r r( r r r r r' E
s
r' c @ s e Zd ZeZdZdS )�PyTextIOWrapperTestz$LookupError: unknown encoding: asciiN)r r r r_ r] r r r r r r) s
s r) c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) � IncrementalNewlineDecoderTestc s � �fdd�}|dd� |dd� |dd� |dd� |dd� |dd� |dd� |dd� �j t� jd d
d � � j� |d d
� |dd� |d d
d
d � |dd
d
d � |dd� |dd� |dd� |dd� |dd
� |dd� |dd� |dd� |d d
� |dd� |d d
� d S )Nc sB � j � }�j� j| f|�|� � j|� �j� j| f|�|� d S )N)rR rx r\ rU )r
rc r rT )�decoderr* r r �
_check_decode|
s
zPIncrementalNewlineDecoderTest.check_newline_decoding_utf8.<locals>._check_decodes 袈u 袈� �r� � �� �r@ T)rZ rF r� r� r� z
as
z
s
as 袈
u 袈
s 袈
)rz �UnicodeDecodeErrorr\ rN )r* r+ r, r )r+ r* r �check_newline_decoding_utf8z
s4
z9IncrementalNewlineDecoderTest.check_newline_decoding_utf8c s g �|d k r*t j|�� �� ��fdd�}nd �� �fdd�}| j� jd � |d� | j� jd� |d� | j� jd
� |d� | j� jd� |d � | j� jd� |d� | jd j��d � � j� d }�d k r�j� �j|�}| j� j|�d � | j� jd � d S )Nc s. x(�j | �D ]}�j� jt|g��� q W d S )N)r; r, r\ r )rc r
)r+ �encoderrD r r �_decode_bytewise�
s zNIncrementalNewlineDecoderTest.check_newline_decoding.<locals>._decode_bytewisec s" x | D ]}�j � j|�� qW d S )N)r, r\ )rc r� )r+ rD r r r3 �
s
zabc
r� z
abc�
zabc
r� r� r� zabc
abcabc
abcabc)r� r4 )r� r4 )r� r� r4 )rL �getincrementalencoderrx �newlinesrb rN r; r\ )r* r+ r r3 rY r )r+ r2 rD r �check_newline_decoding�
s0
z4IncrementalNewlineDecoderTest.check_newline_decodingc C st d }x6|D ].}|o t j|�� }| j|d d
�}| j||� q
W t jd�� }| j|d d
�}| j|� | jt|jd � d S )
N�utf-8�latin-1�utf-16� utf-16-le� utf-16-be�utf-32� utf-32-le� utf-32-beT)� translater/ ) Nr8 r9 r: r; r< r= r> r? )rL �getincrementaldecoder�IncrementalNewlineDecoderr7 r1 rz r{ rU )r* r� r� r+ r r r �test_newline_decoder�
s
z2IncrementalNewlineDecoderTest.test_newline_decoderc s< � fdd�}� j d dd�}||� � j d dd�}||� d S )Nc sR � j | jd � � j | jd�d� � j | jd � � j | jd�d� � j | jd � d S )Nu ഀu )rx r6 r\ )�dec)r* r r �_check�
s
z@IncrementalNewlineDecoderTest.test_newline_bytes.<locals>._checkF)r@ T)rB )r* rE rD r )r* r �test_newline_bytes�
s
z0IncrementalNewlineDecoderTest.test_newline_bytesc C s` x.d
D ]&}t jd�� }| j||�}| j|� qW t jd�� }| j|dd�}| j|jd�d� d S ) NrF r6 zutf-8r )r@ s
z
r* rg )r* rg r6 rF )rL rA rB r1 rx r\ )r* r@ r+ r r r �test_translate�
s
z,IncrementalNewlineDecoderTest.test_translateN)r r r r1 r7 rC rF rG r r r r r* x
s
*!
r* c @ s e Zd ZdS )� CIncrementalNewlineDecoderTestN)r r r r r r r rH �
s rH c @ s e Zd ZdS )� PyIncrementalNewlineDecoderTestN)r r r r r r r rI �
s rI c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zejeed!�d"�d#d$� �Zd%d&� Zd'd(� Zd)d*� Zd+S ),�
MiscIOTestc C s t jt j� d S )N)r rn ro )r* r r r rq �
s zMiscIOTest.tearDownc C s� xz| j jD ]n}t| j |d �}| j||� |dkr4q
q
d|j� ksH|dkr\| jt|t�|� q
|jd�s
| jt|| j �� q
W d S )Nr �errorrZ ZSEEK_)
r] �__all__r6 r� �lowerr
�
issubclassr� r� r� )r* rU r r r r � test___all__�
s
zMiscIOTest.test___all__c C sh | j tjddd�}| j|jd� |j� tjdtf�� | j tjd�}W d Q R X | j|jtj� | j|j jtj� | j|j j
jtj� | j|jd� | j|j jd� | j|j j
jd� |j� | j tjd�}| j|jd� | j|j jd� | j|j j
jd� | j |j � dd d
�}| j|jd� | j|j
jd� | j|j|j � � | j|j
j|j � � |j� |j� d S ) Nr� r )r� r� �Ur� zw+zrb+F)r� ) r r ro rx r� rQ r� r� rU r| r� r0 )r* r" �gr r r �test_attributes s. zMiscIOTest.test_attributesc C s �x ddiddiddd�ddd�ddd�ddidd iddd�ddd�d dd�dd
idd id
dd�d
dd�d dd�gD �]�}| j tjf|�}|j� | jt|j� | jt|j� | jt|j� | jt|j � t
|d �r�| jt|j d� | jt|j � t
|d
��r| jt|j
d� t
|d��r(| jt|j� t
|d��rH| jt|jtd�� t
|d��rh| jt|jtd�� | jt|j� | jt|j� | jt|jd� | jt|jd� | jt|j� | jt|j� | jt|jd|d k�r�dnd� | jt|jg � | jtt|� qtW d S )Nr� r� r� r6 )r� r� rF r r r� zw+zw+br� r4 i rA r: r� r
r@ r� )r r ro rQ rz ri r� r0 r �__iter__r r� rB r4 rA r: ry r� r� r� r4 r5 r; r- r� r� )r* r r" r r r �test_io_after_close" sV
z MiscIOTest.test_io_after_closec C sX G dd� dt �}|d�}| jd|�}||_||_tj|�}~~tj� | j|� |� d S )Nc @ s e Zd ZdS )z*MiscIOTest.test_blockingioerror.<locals>.CN)r r r r r r r �CR s rU r� r6 ) r& rk r
r� r r r r� r )r* rU r� r
r r r r �test_blockingioerrorP s
z MiscIOTest.test_blockingioerrorc C sD | j | jtj� | j | jtj� | j | jtj� | j | jtj� d S )N)r~ r� r� �ABCMetar� r� r� )r* r r r � test_abcs] s zMiscIOTest.test_abcsc C s� | j tjddd��>}| j||j� | j||j� | j||j� | j||j� W d Q R X | j tjd��>}| j||j� | j||j� | j||j� | j||j� W d Q R X | j tjd��>}| j||j� | j||j� | j||j� | j||j� W d Q R X d S )Nr� r )r� r� ) r r ro r~ r� r� ZassertNotIsInstancer� r� )r* Z abcmoduler" r r r �_check_abc_inheritanced s z!MiscIOTest._check_abc_inheritancec C s | j | � d S )N)rY )r* r r r �test_abc_inheritanceu s z MiscIOTest.test_abc_inheritancec C s | j t� d S )N)rY r] )r* r r r � test_abc_inheritance_officialy s z(MiscIOTest.test_abc_inheritance_officialc O sP t ||�}t|�}| jt��}d }tj� W d Q R X | j|t|jj d �� d S )Nr )
r rh Z assertWarnsr� r r� r� r& Zwarningr[ )r* r[ r r" r r( r r r �_check_warn_on_dealloc~ s
z!MiscIOTest._check_warn_on_deallocc C s2 | j tjddd� | j tjd� | j tjd� d S )Nr� r )r� r� )r\ r ro )r* r r r �test_warn_on_dealloc� s z MiscIOTest.test_warn_on_deallocc s� g � � fdd�}| j |� tj� \}}� ||f7 � | j|f|�|� tj� \}}� ||f7 � tj| �� t|f|�ddi|�� W d Q R X d S )Nc sR xL� D ]D} yt j| � W q tk
rH } z|jtjkr8� W Y d d }~X qX qW d S )N)r� rQ rP �errno�EBADF)r r� )�fdsr r � cleanup_fds� s
z9MiscIOTest._check_warn_on_dealloc_fd.<locals>.cleanup_fdsr� F)r� r� r� r\ r r/ r )r* r[ r ra r r� r )r` r �_check_warn_on_dealloc_fd� s
z$MiscIOTest._check_warn_on_dealloc_fdc C s& | j ddd� | j d� | j d� d S )Nr� r )r� r )rb )r* r r r �test_warn_on_dealloc_fd� s
z"MiscIOTest.test_warn_on_dealloc_fdc C s� x�ddiddiddd�ddiddiddd�ddidd id dd�g D ]J}xDt tjd
�D ]2}| jtjf|��}| jttj||� W d Q R X qVW qBW d S ) Nr� r� r� r )r� r� r r� zw+zw+br6 ) r� �pickleZHIGHEST_PROTOCOLr r ro rz r{ �dumps)r* r Zprotocolr" r r r �
test_pickling� s zMiscIOTest.test_picklingc C s | j d� d S )Nr� i i @ )�_test_nonblock_pipe_write)r* r r r � test_nonblock_pipe_write_bigbuf� s z*MiscIOTest.test_nonblock_pipe_write_bigbufc C s | j d� d S )Ni )rg )r* r r r �!test_nonblock_pipe_write_smallbuf� s z,MiscIOTest.test_nonblock_pipe_write_smallbuf� set_blockingz(os.set_blocking() required for this testc C s g }g }t j� \}}t j|d� t j|d� | j|dd|d�}| j|dd|d�}|��� |��r x�dD ]�}y@d } x6t| d
d g�| }
|j|
� |j|
� | d 7 } qrW W qf | jk
�r4 } zj| j| j d t
j � | j| j d
| j � |d d | j � |d< |j|j
� � d}
|j|
� |j|
� W Y d d } ~ X qfX qfW x�y|j� P W nj | jk
�r� } zJ| j| j d t
j � | j| j d
| j � | j| j d � |j|j
� � W Y d d } ~ X nX �q<W |t|j
d �7 }W d Q R X W d Q R X dj|�dj|� }}| j||� | j|j� | j|j� d S )NFr� T)r� r� r� r� �' �I � r r� �a r6 rF s BLOCKEDr@ )rk rl rm rg rg )r� r� rj r r r, r- rk rx r[ r^ ZEAGAINr� rB r� �iterrb r
rO ) r* r� ZsentZreceivedr r� ZrfZwfr� r� r^ r� r r r rg � sL
&$ z$MiscIOTest._test_nonblock_pipe_writec C s2 | j tjd�� W d Q R X | jt| j tjd� d S )Nr� r� )r r ro rz �FileExistsError)r* r r r �test_create_fail� s
zMiscIOTest.test_create_failc C sR | j tjd��}|jd� W d Q R X | j tjd��}| jd|j� � W d Q R X d S )NZxbs spamr� )r r ro r- rx rB )r* r" r r r �test_create_writes� s z MiscIOTest.test_create_writesc C s | j t| jtjd� d S )Nzrwax+)rz ri r r ro )r* r r r �test_open_allargs� s z MiscIOTest.test_open_allargsN)r r r rq rO rR rT rV rX rY rZ r[ r\ r] rb rc rf rh ri r� r� r r� rg rq rr rs r r r r rJ �
s* .
3rJ c @ s< e Zd ZeZdd� Zejed�dd� �Zdd� Z dd � Z
d
S ) � CMiscIOTestc C s6 G dd� d| j j�}|� }td�}| jt|j|� d S )Nc @ s e Zd Zddd�ZdS )z<CMiscIOTest.test_readinto_buffer_overflow.<locals>.BadReaderr6 c S s dd S )Nr r� rr i@B r )r* r9 r r r rB s zACMiscIOTest.test_readinto_buffer_overflow.<locals>.BadReader.readNrg )rg )r r r rB r r r r � BadReader s ru rF )r] r� ry rz ri r: )r* ru rj r
r r r � test_readinto_buffer_overflow s z)CMiscIOTest.test_readinto_buffer_overflowz!Threading required for this test.c C sX dj t� �}td|�\}}|jj� }|jdkrD| jdj t� �|� n| j|jd�� d S )Na� if 1:
import sys
import time
import threading
from test.support import SuppressCrashReport
file = sys.{stream_name}
def run():
while True:
file.write('.')
file.flush()
crash = SuppressCrashReport()
crash.__enter__()
# don't call __exit__(): the crash occurs at Python shutdown
thread = threading.Thread(target=run)
thread.daemon = True
thread.start()
time.sleep(0.5)
file.write('!')
file.flush()
z-cr z�Fatal Python error: could not acquire lock for <_io.BufferedWriter name='<{stream_name}>'> at interpreter shutdown, possibly due to daemon threadsz.!) �
format_map�localsr r� r\ r r� r rt )r* Z stream_namer rV r� r� r r r �&check_daemon_threads_shutdown_deadlock
s
z2CMiscIOTest.check_daemon_threads_shutdown_deadlockc C s | j d� d S )N�stdout)ry )r* r r r �,test_daemon_threads_shutdown_stdout_deadlock6 s z8CMiscIOTest.test_daemon_threads_shutdown_stdout_deadlockc C s | j d� d S )Nrr )ry )r* r r r �,test_daemon_threads_shutdown_stderr_deadlock9 s z8CMiscIOTest.test_daemon_threads_shutdown_stderr_deadlockN) r r r r] rv r� r� r� ry r{ r| r r r r rt s
)rt c @ s e Zd ZeZdS )� PyMiscIOTestN)r r r r_ r] r r r r r} = s r} �ntz%POSIX signals required for this test.c @ s� e Zd Zdd� Zdd� Zdd� Zejed�dd � �Z d
d � Z
d d
� Z e j
d�dd� �Ze jdd� �Zdd� Zdd� Zdd� Zdd� Zdd � Zejed�d d � �Zd d � Zd!d"� Zd#S )$� SignalsTestc C s t j t j| j�| _d S )N)�signal�SIGALRM�alarm_interrupt�oldalrm)r* r r r rp D s zSignalsTest.setUpc C s t j t j| j� d S )N)r� r� r� )r* r r r rq G s zSignalsTest.tearDownc C s dd d S )Nr6 r r )r* �sig�framer r r r� J s zSignalsTest.alarm_interruptz!Threading required for this test.c
s. g �� �fdd�}t j|d�}d|_tj� \� }d|d< |tjt|� d }z�| jj |f|�}|j
� t j d� z| j
t|j|� W dt j d � |j� X �jtj� d�� | j�|d d� |dd
� g� W dtj|� tj� � y |j� W n4 tk
�r& } z| jtjk�r� W Y dd} ~ X nX X dS ) z�Check that a partial write, when it gets interrupted, properly
invokes the signal handler, and bubbles up the exception raised
in the latter.c s6 t td�r tjtjtjg� tj� d�} �j| � d S )N�pthread_sigmaskr6 )r r� r� � SIG_BLOCKr� r� rB r, )rc )r � read_resultsr r r3 S s
z2SignalsTest.check_interrupted_write.<locals>._read)r� TFr� r6 Nr rF )r� r� �daemonr� r� r �
PIPE_MAX_SIZEr r] r r� r� �alarmrz r� r- rb r, rB rx rQ rP r^ r_ )
r* �itemr �
fdopen_kwargsr3 r� r� �
large_data�wior� r )r r� r �check_interrupted_writeM s0
$
z#SignalsTest.check_interrupted_writec C s | j ddddd� d S )Ns xyr� r )r� r� )r� )r* r r r �!test_interrupted_write_unbuffered| s z-SignalsTest.test_interrupted_write_unbufferedc C s | j dddd� d S )Ns xyr� )r� )r� )r* r r r � test_interrupted_write_buffered s z+SignalsTest.test_interrupted_write_bufferedr� c C s | j ddddd� d S )N�xys xyr� r� )r� r )r� )r* r r r �test_interrupted_write_text� s z'SignalsTest.test_interrupted_write_textc s� � �fdd�}t j t j|� tj� \}}| jj|f|��z�t jd� | jtt f��D}x<x"t
d�D ]}�j � � �j � q`W tj
|t� �d � qVW W d Q R X |j}t|t �r�| jt|�jd�t|�� W d t jd� �j� tj|� X d S )Nc s �j � � dd d S )Nr6 r )r- )r[ )r r� r r �on_alarm� s
z3SignalsTest.check_reentrant_write.<locals>.on_alarmr6 r� zreentrant callr )r� r� r� r� r] r r� rz r� r{ r� r- r� rB r r' r� r
r& r� rQ ) r* r r� r� r r� r( r� r� r )r r� r �check_reentrant_write� s$
"
z!SignalsTest.check_reentrant_writec C s | j ddd� d S )Ns xyr� )r� )r� )r* r r r � test_reentrant_write_buffered� s z)SignalsTest.test_reentrant_write_bufferedc C s | j dddd� d S )Nr� r� r� )r� r )r� )r* r r r �test_reentrant_write_text� s z%SignalsTest.test_reentrant_write_textc s� t j� \}� d|d< � fdd�}tjtj|� z@| jj|f|�}t j� d� tjd� | j||j d��d� W d tjd
� |j
� t j
� � t j
|� X d S ) z�Check that a buffered read, when it gets interrupted (either
returning a partial result or EINTR), properly invokes the signal
handler and retries if the latter returned successfully.Fr� c s t j� d� d S )Ns bar)r� r- )r� r� )r� r r �
alarm_handler� s z?SignalsTest.check_interrupted_read_retry.<locals>.alarm_handlers foor6 rr ZfoobarNr ) r� r� r� r� r] r r- r� rx rB rQ )r* r\ r� r r� Zrior )r� r � check_interrupted_read_retry� s
z(SignalsTest.check_interrupted_read_retryc C s | j dd� dd� d S )Nc S s
| j d�S )Nri )r\ )r� r r r r � s zBSignalsTest.test_interrupted_read_retry_buffered.<locals>.<lambda>r� )r� )r� )r* r r r �$test_interrupted_read_retry_buffered� s
z0SignalsTest.test_interrupted_read_retry_bufferedc C s | j dd� dd� d S )Nc S s | S )Nr )r� r r r r � s z>SignalsTest.test_interrupted_read_retry_text.<locals>.<lambda>r )r� )r� )r* r r r � test_interrupted_read_retry_text� s
z,SignalsTest.test_interrupted_read_retry_textc s\ t jd��t j}tj� \�}d|d< g �d�d������fdd�}tj|d��d�_� fd d
�}�fd d �� || }tjtj |� zl| j
j |f|�}tj d
� |j
|�} | j|| � |j� d��j� | j�� | j|tdd� �D ��� W dtj d� d�tj|� tj�� y |j� W n4 tk
�rT }
z|
jtjk�rD� W Y dd}
~
X nX X dS )z�Check that a buffered write, when it gets interrupted (either
returning a partial result or EINTR), properly invokes the signal
handler and retries if the latter returned successfully.�selectFr� Nc sp yDx>�s@x4��j �gg g d�d kr<tj�d�} �j| � q
W qW W n& tk
rj } z
|� W Y d d }~X nX d S )Ng �?r i )r� r� rB r, �
BaseException)rc r� )rK r r� r� �write_finishedr r r3 � s z8SignalsTest.check_interrupted_write_retry.<locals>._read)r� Tc s t j t j� � t jd� d S )Nr6 )r� r� r� )r� r� )�alarm2r r �alarm1� s z9SignalsTest.check_interrupted_write_retry.<locals>.alarm1c s � j � d S )N)r� )r� r� )r� r r r� � s z9SignalsTest.check_interrupted_write_retry.<locals>.alarm2r6 c s s | ]}t |�V qd S )N)r )r� r� r r r � <genexpr>� s z<SignalsTest.check_interrupted_write_retry.<locals>.<genexpr>r )r �
import_moduler� r� r� r� r� r� r� r� r] r r� r- rx r� rb r �sumrQ rP r^ r_ ) r* r� r� r� r� r3 r� r� r� r� r� r )r� rK r r� r� r� r� r � check_interrupted_write_retry� sB
z)SignalsTest.check_interrupted_write_retryc C s | j ddd� d S )Nr r� )r� )r� )r* r r r �%test_interrupted_write_retry_buffered s z1SignalsTest.test_interrupted_write_retry_bufferedc C s | j dddd� d S )Nr� r� ri )r� r )r� )r* r r r �!test_interrupted_write_retry_text s z-SignalsTest.test_interrupted_write_retry_textN)r r r rp rq r� r� r� r� r� r� r� r Zrequires_freebsd_versionr� r# r� r� r� r� r� r� r� r� r� r r r r r A s / Er c @ s e Zd ZeZdS )� CSignalsTestN)r r r r] r r r r r� s r� c @ s e Zd ZeZdZdZdS )�
PySignalsTestN)r r r r_ r] r� r� r r r r r� s r� c
s* t ttttttttt t
t t t
ttttttf}tttttttf}tj dg }dd� |D �}dd� |D �}t � � |j � fdd�|D �� |j � fdd�|D �� t j |d< xj|D ]b}|j!j"d �r�xP|j#� D ]\}}t$|||� q�W q�|j!j"d
�r�x |j#� D ]\}}t$|||� q�W q�W t%j&d d � |D ��} | S )
NrB c S s i | ]}t t|�|�qS r )r6 r] )r� rU r r r �
<dictcomp>3 s z load_tests.<locals>.<dictcomp>c S s i | ]}t t|�|�qS r )r6 r_ )r� rU r r r r� 4 s c 3 s" | ]}|j � d |j fV qdS )rU N)r )r� r� )�globsr r r� 6 s z load_tests.<locals>.<genexpr>c 3 s" | ]}|j � d |j fV qdS )�PyN)r )r� r� )r� r r r� 7 s r rU r� c S s g | ]}t j|��qS r )r� Z makeSuite)r� r� r r r r� B s z load_tests.<locals>.<listcomp>)'rY r[ r\ r� r� r r r" r# rH rI rl rH rI r' r) rt r} r� r� r? rE rT rN r` rY r$ r] rL �globalsr� r_ � OpenWrapperr r� r� �setattrr� Z TestSuite)
r[ r� ZmocksZ all_membersZc_io_nsZpy_io_nsr� rU r Zsuiter )r� r �
load_tests! s8
r� �__main__)ir< r� r r^ r� r� rd r� r� r� r� r� r� r � collectionsr r � itertoolsr r r� r Ztest.support.script_helperr r Z test.supportr rL r] Z_pyior_ r� � ImportErrorr r Z Structurer r# r$ r� r= r> r? rC rD rE rL rM rN rR rS rT r� rW rX rY r\ r^ r` rj rl ZTestCaserm rY r[ r� r\ rd r� r� r� r� r� r r r
r" r# r$ rH rI rM rJ �registerrj rl r} r r r' r) r* rH rI rJ rt r} ZskipIfrU r r� r� r� r �mainr r r r �<module> s�
8
, 9
( 1 . = fW +
.u
<
T $