관리-도구
편집 파일: _pyio.cpython-38.opt-2.pyc
U e5d�k � @ sx d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ej dkrTd dl m Z ndZ d dl Z d dl mZmZmZmZ d ddhZee d�r�e�e j� e�e j� d ZeZeed �p�ejjZd6dd�Z dd� Z z e j Z W n e k � r� e Z Y nX G dd� d�Z G dd� d�Z!z e j"Z"W n( e k �rD G dd� de#e$�Z"Y nX G dd� dej%d�Z&e j&�'e&� G dd � d e&�Z(e j(�'e(� d d l)m*Z* e(�'e*� G d d � d e&�Z+e j+�'e+� G d d!� d!e+�Z,G d"d#� d#e+�Z-G d$d%� d%e,�Z.G d&d'� d'e,�Z/G d(d)� d)e+�Z0G d*d+� d+e/e.�Z1G d,d-� d-e(�Z*G d.d/� d/e&�Z2e j2�'e2� G d0d1� d1ej3�Z4G d2d3� d3e2�Z5G d4d5� d5e5�Z6dS )7� N)� allocate_lock> �win32�cygwin)�setmode)�__all__�SEEK_SET�SEEK_CUR�SEEK_END� � � SEEK_HOLEi Zgettotalrefcount�r���Tc C s� t | t�st�| �} t | tttf�s0td| ��t |t�sFtd| ��t |t�s\td| ��|d k rzt |t�sztd| ��|d k r�t |t�s�td| ��t|�}|td� s�t|�t|�kr�t d| ��d|k} d|k} d |k} d |k} d |k} d |k}d |k}d|k�rD| �s"| �s"| �s"| �r*t d��dd l }|� dt d� d} |�rX|�rXt d��| | | | dk�rvt d��| �s�| �s�| �s�| �s�t d��|�r�|d k �r�t d��|�r�|d k �r�t d��|�r�|d k �r�t d��|�r|dk�rdd l }|� dt d� t| | �rd�pd | �r"d�p$d | �r2d �p4d | �rBd �pDd | �rRd �pTd ||d �}|}�z$d }|dk�s�|dk �r�|�� �r�d }d}|dk �r�t}zt�|�� �j}W n ttfk �r� Y nX |dk�r�|}|dk �r�t d ��|dk�r|�r|W S t d!��| �r t||�}n<| �s2| �s2| �r>t||�}n | �rPt||�}n t d"| ��|}|�rl|W S t|||||�}|}||_|W S |�� � Y nX d S )#Nzinvalid file: %rzinvalid mode: %rzinvalid buffering: %r�invalid encoding: %r�invalid errors: %rzaxrwb+tU�xr �w�a�+�t�b�Uz4mode U cannot be combined with 'x', 'w', 'a', or '+'r z'U' mode is deprecatedr Tz'can't have text and binary mode at oncer z)can't have read/write/append mode at oncez/must have exactly one of read/write/append modez-binary mode doesn't take an encoding argumentz+binary mode doesn't take an errors argumentz+binary mode doesn't take a newline argumentzaline buffering (buffering=1) isn't supported in binary mode, the default buffer size will be used� )�openerFr zinvalid buffering sizez can't have unbuffered text I/Ozunknown mode: %r) � isinstance�int�os�fspath�str�bytes� TypeError�set�len� ValueError�warnings�warn�DeprecationWarning�RuntimeWarning�FileIO�isatty�DEFAULT_BUFFER_SIZE�fstat�fileno� st_blksize�OSError�AttributeError�BufferedRandom�BufferedWriter�BufferedReader� TextIOWrapper�mode�close)�filer4 � buffering�encoding�errors�newline�closefdr ZmodesZcreatingZreadingZwritingZ appendingZupdating�textZbinaryr$ �raw�result�line_bufferingZbs�buffer� rA � /usr/lib64/python3.8/_pyio.py�open) s� { � ����� � rC c C s dd l }|�dtd� t| d�S )Nr z(_pyio.open_code() may not be using hooksr �rb)r$ r% r' rC )�pathr$ rA rA rB �_open_code_with_warning s �rF c @ s e Zd Zddd�ZdS )� DocDescriptorNc C s dt j S )Nz\open(file, mode='r', buffering=-1, encoding=None, errors=None, newline=None, closefd=True) )rC �__doc__)�self�obj�typrA rA rB �__get__ s ��zDocDescriptor.__get__)N)�__name__� __module__� __qualname__rL rA rA rA rB rG s rG c @ s e Zd Ze� Zdd� ZdS )� OpenWrapperc O s t ||�S �N)rC )�cls�args�kwargsrA rA rB �__new__, s zOpenWrapper.__new__N)rM rN rO rG rH rU rA rA rA rB rP " s rP c @ s e Zd ZdS )�UnsupportedOperationN)rM rN rO rA rA rA rB rV 5 s rV c @ s� e Zd Zdd� Zd5dd�Zdd� Zd6d d �Zd d � Zd Zdd� Z dd� Z dd� Z d7dd�Z dd� Z d8dd�Zdd� Zd9d d �Zed d � �Zd:d d!�Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd;d+d,�Zd-d.� Zd/d0� Zd<d1d2�Zd3d4� Z dS )=�IOBasec C s t d| jj|f ��d S )Nz%s.%s() not supported)rV � __class__rM )rI �namerA rA rB � _unsupported\ s �zIOBase._unsupportedr c C s | � d� d S )N�seek�rZ �rI �pos�whencerA rA rB r[ c s z IOBase.seekc C s | � dd�S �Nr r )r[ �rI rA rA rB �tells s z IOBase.tellNc C s | � d� d S �N�truncater\ �rI r^ rA rA rB rd w s zIOBase.truncatec C s | � � d S rQ �� _checkClosedra rA rA rB �flush� s z IOBase.flushFc C s | j s z | �� W 5 d| _ X d S )NT)�_IOBase__closedrh ra rA rA rB r5 � s z IOBase.closec C sV z | j }W n tk r Y d S X |r*d S tr8| �� nz | �� W n Y nX d S rQ )�closedr/ �_IOBASE_EMITS_UNRAISABLEr5 )rI rj rA rA rB �__del__� s zIOBase.__del__c C s dS �NFrA ra rA rA rB �seekable� s zIOBase.seekablec C s | � � s t|d krdn|��d S )Nz File or stream is not seekable.)rn rV �rI �msgrA rA rB �_checkSeekable� s ��zIOBase._checkSeekablec C s dS rm rA ra rA rA rB �readable� s zIOBase.readablec C s | � � s t|d krdn|��d S )Nz File or stream is not readable.)rr rV ro rA rA rB �_checkReadable� s ��zIOBase._checkReadablec C s dS rm rA ra rA rA rB �writable� s zIOBase.writablec C s | � � s t|d krdn|��d S )Nz File or stream is not writable.)rt rV ro rA rA rB �_checkWritable� s ��zIOBase._checkWritablec C s | j S rQ )ri ra rA rA rB rj � s z IOBase.closedc C s | j rt|d krdn|��d S �N� I/O operation on closed file.�rj r# ro rA rA rB rg � s ��zIOBase._checkClosedc C s | � � | S rQ rf ra rA rA rB � __enter__� s zIOBase.__enter__c G s | � � d S rQ )r5 )rI rS rA rA rB �__exit__� s zIOBase.__exit__c C s | � d� d S )Nr, r\ ra rA rA rB r, � s z IOBase.filenoc C s | � � dS rm rf ra rA rA rB r) s z IOBase.isattyr c s� t � d�r� �fdd�}ndd� }�d kr0d�n4z �j}W n" tk r\ t��d���Y nX |� �t� }�dk s~t|��k r�� �|� �}|s�q�||7 }|�d�rjq�qjt|�S ) N�peekc s> � � d�} | sdS | �d�d p&t| �}�dkr:t|��}|S )Nr � r )r{ �findr" �min)Z readahead�n�rI �sizerA rB � nreadahead s z#IOBase.readline.<locals>.nreadaheadc S s dS �Nr rA rA rA rA rB r� s r � is not an integerr r| ) �hasattr� __index__r/ r � bytearrayr" �read�endswithr )rI r� r� � size_index�resr rA r� rB �readline s& zIOBase.readlinec C s | � � | S rQ rf ra rA rA rB �__iter__5 s zIOBase.__iter__c C s | � � }|st�|S rQ )r� � StopIteration�rI �linerA rA rB �__next__9 s zIOBase.__next__c C sP |d ks|dkrt | �S d}g }| D ]&}|�|� |t|�7 }||kr$ qLq$|S �Nr )�list�appendr" )rI Zhintr �linesr� rA rA rB � readlines? s zIOBase.readlinesc C s | � � |D ]}| �|� q d S rQ )rg �write)rI r� r� rA rA rB � writelinesQ s zIOBase.writelines)r )N)N)N)N)N)r )N) rM rN rO rZ r[ rb rd rh ri r5 rl rn rq rr rs rt ru �propertyrj rg ry rz r, r) r� r� r� r� r� rA rA rA rB rW 9 s4 # * rW )� metaclassc @ s. e Zd Zd dd�Zdd� Zdd� Zdd � Zd S ) � RawIOBaser c C sP |d kr d}|dk r | � � S t|�� �}| �|�}|d kr>d S ||d �= t|�S )Nr r )�readallr� r� �readintor )rI r� r r rA rA rB r� l s zRawIOBase.readc C s4 t � }| �t�}|sq ||7 }q|r,t|�S |S d S rQ )r� r� r* r )rI r� �datarA rA rB r� } s zRawIOBase.readallc C s | � d� d S )Nr� r\ �rI r rA rA rB r� � s zRawIOBase.readintoc C s | � d� d S �Nr� r\ r� rA rA rB r� � s zRawIOBase.writeN)r )rM rN rO r� r� r� r� rA rA rA rB r� ^ s r� )r( c @ sH e Zd Zddd�Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dS )�BufferedIOBaser c C s | � d� d S �Nr� r\ r� rA rA rB r� � s zBufferedIOBase.readc C s | � d� d S )N�read1r\ r� rA rA rB r� � s zBufferedIOBase.read1c C s | j |dd�S )NF�r� �� _readintor� rA rA rB r� � s zBufferedIOBase.readintoc C s | j |dd�S )NTr� r� r� rA rA rB � readinto1� s zBufferedIOBase.readinto1c C sV t |t�st|�}|�d�}|r0| �t|��}n| �t|��}t|�}||d |�< |S �N�B)r � memoryview�castr� r" r� )rI r r� r� r rA rA rB r� � s zBufferedIOBase._readintoc C s | � d� d S r� r\ r� rA rA rB r� � s zBufferedIOBase.writec C s | � d� d S �N�detachr\ ra rA rA rB r� � s zBufferedIOBase.detachN)r )r ) rM rN rO r� r� r� r� r� r� r� rA rA rA rB r� � s r� c @ s� e Zd Zdd� Zd#dd�Zdd� Zd$d d �Zd d � Zd d� Zdd� Z dd� Z e dd� �Z e dd� �Z e dd� �Ze dd� �Zdd � Zd d � Zd d � Zd!d"� ZdS )%�_BufferedIOMixinc C s || _ d S rQ ��_raw�rI r= rA rA rB �__init__ s z_BufferedIOMixin.__init__r c C s" | j �||�}|dk r td��|S )Nr z#seek() returned an invalid position)r= r[ r. )rI r^ r_ Z new_positionrA rA rB r[ s z_BufferedIOMixin.seekc C s | j �� }|dk rtd��|S )Nr z#tell() returned an invalid position)r= rb r. re rA rA rB rb s z_BufferedIOMixin.tellNc C s$ | � � |d kr| �� }| j�|�S rQ )rh rb r= rd re rA rA rB rd $ s z_BufferedIOMixin.truncatec C s | j rtd��| j�� d S )N�flush on closed file)rj r# r= rh ra rA rA rB rh 2 s z_BufferedIOMixin.flushc C s. | j d k r*| js*z | �� W 5 | j �� X d S rQ )r= rj r5 rh ra rA rA rB r5 7 s z_BufferedIOMixin.closec C s* | j d krtd��| �� | j}d | _|S )Nzraw stream already detached)r= r# rh r� r� rA rA rB r� ? s z_BufferedIOMixin.detachc C s | j �� S rQ )r= rn ra rA rA rB rn I s z_BufferedIOMixin.seekablec C s | j S rQ r� ra rA rA rB r= L s z_BufferedIOMixin.rawc C s | j jS rQ )r= rj ra rA rA rB rj P s z_BufferedIOMixin.closedc C s | j jS rQ )r= rY ra rA rA rB rY T s z_BufferedIOMixin.namec C s | j jS rQ )r= r4 ra rA rA rB r4 X s z_BufferedIOMixin.modec C s t d| jj�d���d S �Nzcannot pickle z object�r rX rM ra rA rA rB � __getstate__\ s z _BufferedIOMixin.__getstate__c C sN | j j}| j j}z | j}W n tk r: d�||� Y S X d�|||�S d S )Nz<{}.{}>z<{}.{} name={!r}>)rX rN rO rY r/ �format)rI �modnameZclsnamerY rA rA rB �__repr___ s z_BufferedIOMixin.__repr__c C s | j �� S rQ )r= r, ra rA rA rB r, k s z_BufferedIOMixin.filenoc C s | j �� S rQ )r= r) ra rA rA rB r) n s z_BufferedIOMixin.isatty)r )N)rM rN rO r� r[ rb rd rh r5 r� rn r� r= rj rY r4 r� r� r, r) rA rA rA rB r� s( r� c s� e Zd ZdZd dd�Zdd� Zdd� Zdd � Z� fd d �Zd!d d�Z d"dd�Z dd� Z d#dd�Z dd� Z d$dd�Zdd� Zd d � Zd d � Z� ZS )%�BytesIONc C s& t � }|d k r||7 }|| _d| _d S r� )r� �_buffer�_pos)rI Z initial_bytes�bufrA rA rB r� z s zBytesIO.__init__c C s | j rtd��| j�� S )Nz__getstate__ on closed file)rj r# �__dict__�copyra rA rA rB r� � s zBytesIO.__getstate__c C s | j rtd��t| j�S )Nzgetvalue on closed file)rj r# r r� ra rA rA rB �getvalue� s zBytesIO.getvaluec C s | j rtd��t| j�S )Nzgetbuffer on closed file)rj r# r� r� ra rA rA rB � getbuffer� s zBytesIO.getbufferc s" | j d k r| j �� t� �� d S rQ )r� �clear�superr5 ra �rX rA rB r5 � s z BytesIO.closer c C s� | j rtd��|d kr d}n4z |j}W n" tk rH t|�d���Y nX |� }|dk rbt| j�}t| j�| jkrvdS tt| j�| j| �}| j| j|� }|| _t |�S )N�read from closed filer r� r � ) rj r# r� r/ r r" r� r� r~ r )rI r� r� Znewposr rA rA rB r� � s" z BytesIO.readc C s | � |�S rQ )r� r� rA rA rB r� � s z BytesIO.read1c C s� | j rtd��t|t�r td��t|�� }|j}W 5 Q R X |dkrFdS | j}|t| j �krzd|t| j � }| j |7 _ || j ||| �< | j|7 _|S )N�write to closed file� can't write str to binary streamr � ) rj r# r r r r� �nbytesr� r" r� )rI r Zviewr r^ ZpaddingrA rA rB r� � s z BytesIO.writer c C s� | j rtd��z |j}W n" tk r: t|�d���Y nX |� }|dkrh|dk r`td|f ��|| _nD|dkr�td| j| �| _n(|dkr�tdt| j�| �| _ntd��| jS )Nzseek on closed filer� r �negative seek position %rr r zunsupported whence value) rj r# r� r/ r r� �maxr" r� )rI r^ r_ � pos_indexrA rA rB r[ � s" z BytesIO.seekc C s | j rtd��| jS )N�tell on closed file)rj r# r� ra rA rA rB rb � s z BytesIO.tellc C sx | j rtd��|d kr | j}nJz |j}W n" tk rJ t|�d���Y nX |� }|dk rhtd|f ��| j|d �= |S )Nztruncate on closed filer� r z negative truncate position %r)rj r# r� r� r/ r r� )rI r^ r� rA rA rB rd � s zBytesIO.truncatec C s | j rtd��dS �Nrw Trx ra rA rA rB rr � s zBytesIO.readablec C s | j rtd��dS r� rx ra rA rA rB rt � s zBytesIO.writablec C s | j rtd��dS r� rx ra rA rA rB rn � s zBytesIO.seekable)N)r )r )r )N)rM rN rO r� r� r� r� r� r5 r� r� r� r[ rb rd rr rt rn � __classcell__rA rA r� rB r� r s r� c @ st e Zd Zefdd�Zdd� Zdd� Zddd �Zdd d �Zd d d�Z d dd�Z d dd�Z dd� Z dd� Z d dd�ZdS ) r2 c C sF |� � std��t�| |� |dkr,td��|| _| �� t� | _d S )Nz "raw" argument must be readable.r �invalid buffer size) rr r. r� r� r# � buffer_size�_reset_read_buf�Lock� _read_lock�rI r= r� rA rA rB r� s zBufferedReader.__init__c C s | j �� S rQ )r= rr ra rA rA rB rr s zBufferedReader.readablec C s d| _ d| _d S )Nr� r )� _read_buf� _read_posra rA rA rB r� s z BufferedReader._reset_read_bufNc C s@ |d k r|dk rt d��| j� | �|�W 5 Q R � S Q R X d S )Nr z invalid number of bytes to read)r# r� �_read_unlockedr� rA rA rB r� s zBufferedReader.readc C s� d}d}| j }| j}|d ks$|dkr�| �� t| jd�rj| j�� }|d krZ||d � pXd S ||d � | S ||d � g}d}| j�� }||kr�|}q�|t|�7 }|�|� q|d� |�p�|S t|�| } || kr�| j|7 _|||| � S ||d � g}t | j |�} | |k �rH| j�| �}||k�r.|}�qH| t|�7 } |�|� �qt || �}d� |�} | |d � | _ d| _| �r�| d |� S |S )Nr� )r� Nr r� r ) r� r� r� r� r= r� r� r" r� �joinr� r� r~ ) rI r Z nodata_valZ empty_valuesr� r^ �chunkZchunksZ current_size�availZwanted�outrA rA rB r� - sL z BufferedReader._read_unlockedr c C s( | j � | �|�W 5 Q R � S Q R X d S rQ )r� �_peek_unlockedr� rA rA rB r{ a s zBufferedReader.peekc C sr t || j�}t| j�| j }||k s,|dkrb| j| }| j�|�}|rb| j| jd � | | _d| _| j| jd � S r� )r~ r� r" r� r� r= r� )rI r ZwantZhaveZto_readZcurrentrA rA rB r� k s z BufferedReader._peek_unlockedr c C s^ |dk r| j }|dkrdS | j�4 | �d� | �t|t| j�| j ��W 5 Q R � S Q R X d S )Nr r� r )r� r� r� r� r~ r" r� r� r� rA rA rB r� v s �zBufferedReader.read1c C s t |t�st|�}|jdkr dS |�d�}d}| j�� |t|�k r�tt| j�| j t|��}|r�| j| j| j| � |||| �< | j|7 _||7 }|t|�kr�q�t|�| | j kr�| j � ||d � �}|s�q�||7 }n|r�|s�| � d�s�q�|r6|r6q�q6W 5 Q R X |S )Nr r� r ) r r� r� r� r� r" r~ r� r� r� r= r� r� )rI r� r� �writtenr� r rA rA rB r� � s6 � zBufferedReader._readintoc C s t �| �t| j� | j S rQ )r� rb r" r� r� ra rA rA rB rb � s zBufferedReader.tellc C sd |t krtd��| j�D |dkr4|t| j�| j 8 }t�| ||�}| �� |W 5 Q R � S Q R X d S )N�invalid whence valuer ) �valid_seek_flagsr# r� r" r� r� r� r[ r� r] rA rA rB r[ � s zBufferedReader.seek)N)N)r )r )r )r )rM rN rO r* r� rr r� r� r� r{ r� r� r� rb r[ rA rA rA rB r2 s 4 .r2 c @ s\ e Zd Zefdd�Zdd� Zdd� Zddd �Zd d � Zd d � Z dd� Z ddd�Z dd� Z dS )r1 c C sF |� � std��t�| |� |dkr,td��|| _t� | _t� | _ d S )Nz "raw" argument must be writable.r r� ) rt r. r� r� r# r� r� � _write_bufr� � _write_lockr� rA rA rB r� � s zBufferedWriter.__init__c C s | j �� S rQ )r= rt ra rA rA rB rt � s zBufferedWriter.writablec C s t |t�rtd��| j�� | jr(td��t| j�| jkr@| � � t| j�}| j� |� t| j�| }t| j�| jkr�z | � � W nl t k r� } zNt| j�| jkr�t| j�| j }||8 }| jd | j� | _t |j |j |��W 5 d }~X Y nX |W 5 Q R � S Q R X d S )Nr� r� )r r r r� rj r# r" r� r� �_flush_unlocked�extend�BlockingIOError�errno�strerror)rI r Zbeforer� �eZoveragerA rA rB r� � s( "zBufferedWriter.writeNc C sD | j �4 | �� |d kr"| j�� }| j�|�W 5 Q R � S Q R X d S rQ )r� r� r= rb rd re rA rA rB rd � s zBufferedWriter.truncatec C s | j � | �� W 5 Q R X d S rQ )r� r� ra rA rA rB rh � s zBufferedWriter.flushc C s� | j rtd��| jr�z| j�| j�}W n tk rB td��Y nX |d krZttjdd��|t | j�ksp|dk rxt d��| jd |�= qd S )Nr� zHself.raw should implement RawIOBase: it should not raise BlockingIOErrorz)write could not complete without blockingr z*write() returned incorrect number of bytes) rj r# r� r= r� r� � RuntimeErrorr� ZEAGAINr" r. �rI r rA rA rB r� s �z BufferedWriter._flush_unlockedc C s t �| �t| j� S rQ )r� rb r" r� ra rA rA rB rb s zBufferedWriter.tellr c C sD |t krtd��| j�$ | �� t�| ||�W 5 Q R � S Q R X d S )Nr� )r� r# r� r� r� r[ r] rA rA rB r[ s zBufferedWriter.seekc C s` | j �$ | jd ks| jr&W 5 Q R � d S W 5 Q R X z | �� W 5 | j � | j�� W 5 Q R X X d S rQ )r� r= rj r5 rh ra rA rA rB r5 s zBufferedWriter.close)N)r ) rM rN rO r* r� rt r� rd rh r� rb r[ r5 rA rA rA rB r1 � s r1 c @ s� e Zd Zefdd�Zd dd�Zdd� Zdd � Zd d d �Zd d d�Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zedd � �Zd S )!�BufferedRWPairc C s< |� � std��|�� s td��t||�| _t||�| _d S )Nz#"reader" argument must be readable.z#"writer" argument must be writable.)rr r. rt r2 �readerr1 �writer)rI r� r� r� rA rA rB r� < s zBufferedRWPair.__init__r c C s |d kr d}| j �|�S �Nr )r� r� r� rA rA rB r� J s zBufferedRWPair.readc C s | j �|�S rQ )r� r� r� rA rA rB r� O s zBufferedRWPair.readintoc C s | j �|�S rQ )r� r� r� rA rA rB r� R s zBufferedRWPair.writer c C s | j �|�S rQ )r� r{ r� rA rA rB r{ U s zBufferedRWPair.peekc C s | j �|�S rQ )r� r� r� rA rA rB r� X s zBufferedRWPair.read1c C s | j �|�S rQ )r� r� r� rA rA rB r� [ s zBufferedRWPair.readinto1c C s | j �� S rQ )r� rr ra rA rA rB rr ^ s zBufferedRWPair.readablec C s | j �� S rQ )r� rt ra rA rA rB rt a s zBufferedRWPair.writablec C s | j �� S rQ )r� rh ra rA rA rB rh d s zBufferedRWPair.flushc C s z| j�� W 5 | j �� X d S rQ )r� r5 r� ra rA rA rB r5 g s zBufferedRWPair.closec C s | j �� p| j�� S rQ )r� r) r� ra rA rA rB r) m s zBufferedRWPair.isattyc C s | j jS rQ )r� rj ra rA rA rB rj p s zBufferedRWPair.closedN)r )r )r )rM rN rO r* r� r� r� r� r{ r� r� rr rt rh r5 r) r� rj rA rA rA rB r� , s r� c @ sj e Zd Zefdd�Zddd�Zdd� Zdd d �Zdd d �Zd d� Z ddd�Z d dd�Z dd� Z dd� Z dS ) r0 c C s( |� � t�| ||� t�| ||� d S rQ )rq r2 r� r1 r� rA rA rB r� ~ s zBufferedRandom.__init__r c C s� |t krtd��| �� | jrJ| j� | j�| jt| j� d� W 5 Q R X | j�||�}| j� | � � W 5 Q R X |dk r�t d��|S )Nr� r r z seek() returned invalid position) r� r# rh r� r� r= r[ r� r" r� r. r] rA rA rB r[ � s $zBufferedRandom.seekc C s | j rt�| �S t�| �S d S rQ )r� r1 rb r2 ra rA rA rB rb � s zBufferedRandom.tellNc C s |d kr| � � }t�| |�S rQ )rb r1 rd re rA rA rB rd � s zBufferedRandom.truncatec C s |d kr d}| � � t�| |�S r� )rh r2 r� r� rA rA rB r� � s zBufferedRandom.readc C s | � � t�| |�S rQ )rh r2 r� r� rA rA rB r� � s zBufferedRandom.readintoc C s | � � t�| |�S rQ )rh r2 r{ r� rA rA rB r{ � s zBufferedRandom.peekr c C s | � � t�| |�S rQ )rh r2 r� r� rA rA rB r� � s zBufferedRandom.read1c C s | � � t�| |�S rQ )rh r2 r� r� rA rA rB r� � s zBufferedRandom.readinto1c C sF | j r:| j�( | j�| jt| j � d� | �� W 5 Q R X t�| |�S r� ) r� r� r= r[ r� r" r� r1 r� r� rA rA rB r� � s zBufferedRandom.write)r )N)N)r )r )rM rN rO r* r� r[ rb rd r� r� r{ r� r� r� rA rA rA rB r0 u s r0 c s� e Zd ZdZdZdZdZdZdZdZ d0dd�Z dd � Z d d � Z d d � Z dd� Zd1dd�Zd2dd�Zdd� Zdd� Zdd� Zefdd�Zd d � Zd3d d �Z� fd d!�Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z e d,d-� �Z e d.d/� �Z � Z!S )4r( r FNTr c C sB | j dkr*z| jr t�| j � W 5 d| _ X t|t�r<td��t|t�r\|}|dk r`td��nd}t|t �sxtd|f ��t |�t d�ks�td|f ��t dd� |D ��d ks�|� d �d kr�td ��d |kr�d | _ d | _tjtjB }nTd|kr�d | _d}n@d|k�rd | _tjtjB }n"d|k�r8d | _d | _tjtjB }d |k�rNd | _d | _| j�rj| j�rj|tjO }n | j�r~|tjO }n |tjO }|ttdd�O }ttdd��p�ttdd�}||O }d }�zT|dk �r:|�s�td��|d k�r�t�||d�}n0|||�}t|t��std��|dk �r$td��|}|�s:t�|d� || _t� |�} z(t � | j ��rpt t!j"t�#t!j"�|��W n t$k �r� Y nX t| dd�| _%| j%d k�r�t&| _%t'�r�t'|tj(� || _)| j�rzt�*|dt+� W n4 tk �r } z| j!t!j,k�r � W 5 d } ~ X Y nX W n" |d k �r0t�|� � Y nX || _ d S )Nr r z$integer argument expected, got floatznegative file descriptorzinvalid mode: %szxrwab+c s s | ]}|d kV qdS )ZrwaxNrA )�.0�crA rA rB � <genexpr>� s z"FileIO.__init__.<locals>.<genexpr>r r zKMust have exactly one of create/read/write/append mode and at most one plusr Tr r r �O_BINARYZ O_NOINHERIT� O_CLOEXECz'Cannot use closefd=False with file namei� z expected integer from openerzNegative file descriptorFr- )-�_fd�_closefdr r5 r �floatr r r# r r! �sum�count�_created� _writable�O_EXCL�O_CREAT� _readable�O_TRUNC� _appending�O_APPEND�O_RDWR�O_RDONLY�O_WRONLY�getattrrC r. �set_inheritabler+ �stat�S_ISDIR�st_mode�IsADirectoryErrorr� ZEISDIRr� r/ �_blksizer* �_setmoder� rY �lseekr ZESPIPE) rI r6 r4 r; r �fd�flagsZnoinherit_flagZowned_fdZfdfstatr� rA rA rB r� � s� $ � � zFileIO.__init__c C sB | j dkr>| jr>| js>dd l}|jd| f td| d� | �� d S )Nr zunclosed file %rr )� stacklevel�source)r� r� rj r$ r% �ResourceWarningr5 )rI r$ rA rA rB rl A s �zFileIO.__del__c C s t d| jj�d���d S r� r� ra rA rA rB r� H s zFileIO.__getstate__c C sp d| j j| j jf }| jr"d| S z | j}W n* tk rV d|| j| j| jf Y S X d||| j| jf S d S )Nz%s.%sz <%s [closed]>z <%s fd=%d mode=%r closefd=%r>z <%s name=%r mode=%r closefd=%r>) rX rN rO rj rY r/ r� r4 r� )rI � class_namerY rA rA rB r� K s � � �zFileIO.__repr__c C s | j std��d S )NzFile not open for reading)r� rV ra rA rA rB rs Y s zFileIO._checkReadablec C s | j std��d S )NzFile not open for writing)r� rV ro rA rA rB ru ] s zFileIO._checkWritablec C sT | � � | �� |d ks |dk r(| �� S zt�| j|�W S tk rN Y d S X d S r� )rg rs r� r r� r� r� r� rA rA rB r� a s z FileIO.readc C s� | � � | �� t}z6t�| jdt�}t�| j�j}||krH|| d }W n t k r^ Y nX t � }t |�|kr�t |�}|t |t�7 }|t |� }zt� | j|�}W n tk r� |r�Y q�Y d S X |s�q�||7 }qft|�S r` )rg rs r* r r r� r r+ �st_sizer. r� r" r� r� r� r )rI �bufsizer^ �endr> r r� rA rA rB r� q s2 zFileIO.readallc C s4 t |��d�}| �t|��}t|�}||d |�< |S r� )r� r� r� r" )rI r �mr� r rA rA rB r� � s zFileIO.readintoc C s< | � � | �� zt�| j|�W S tk r6 Y d S X d S rQ )rg ru r r� r� r� r� rA rA rB r� � s z FileIO.writec C s* t |t�rtd��| �� t�| j||�S )Nzan integer is required)r r� r rg r r r� r] rA rA rB r[ � s z FileIO.seekc C s | � � t�| jdt�S r� )rg r r r� r ra rA rA rB rb � s z FileIO.tellc C s2 | � � | �� |d kr | �� }t�| j|� |S rQ )rg ru rb r � ftruncater� r� rA rA rB rd � s zFileIO.truncatec s. | j s*z| jrt�| j� W 5 t� �� X d S rQ )rj r� r5 r� r r� ra r� rA rB r5 � s z FileIO.closec C sF | � � | jd kr@z | �� W n tk r8 d| _Y nX d| _| jS )NFT)rg � _seekablerb r. ra rA rA rB rn � s zFileIO.seekablec C s | � � | jS rQ )rg r� ra rA rA rB rr � s zFileIO.readablec C s | � � | jS rQ )rg r� ra rA rA rB rt � s zFileIO.writablec C s | � � | jS rQ )rg r� ra rA rA rB r, � s z FileIO.filenoc C s | � � t�| j�S rQ )rg r r) r� ra rA rA rB r) � s z FileIO.isattyc C s | j S rQ )r� ra rA rA rB r; � s zFileIO.closefdc C sJ | j r| jrdS dS n0| jr,| jr&dS dS n| jrB| jr<dS dS ndS d S )Nzxb+Zxbzab+Zabzrb+rD �wb)r� r� r r� ra rA rA rB r4 s z FileIO.mode)r TN)N)N)N)"rM rN rO r� r� r� r� r r r� r� rl r� r� rs ru r� r� r� r� r r[ rb rd r5 rn rr rt r, r) r� r; r4 r� rA rA r� rB r( � s< y # r( c @ s\ e Zd Zddd�Zdd� Zddd�Zd d � Zd d � Zed d� �Z edd� �Z edd� �Z dS )� TextIOBaser c C s | � d� d S r� r\ r� rA rA rB r� s zTextIOBase.readc C s | � d� d S r� r\ )rI �srA rA rB r� ( s zTextIOBase.writeNc C s | � d� d S rc r\ re rA rA rB rd , s zTextIOBase.truncatec C s | � d� d S )Nr� r\ ra rA rA rB r� 0 s zTextIOBase.readlinec C s | � d� d S r� r\ ra rA rA rB r� 7 s zTextIOBase.detachc C s d S rQ rA ra rA rA rB r8 @ s zTextIOBase.encodingc C s d S rQ rA ra rA rA rB �newlinesE s zTextIOBase.newlinesc C s d S rQ rA ra rA rA rB r9 O s zTextIOBase.errors)r )N) rM rN rO r� r� rd r� r� r� r8 r r9 rA rA rA rB r s r c @ sP e Zd Zddd�Zddd�Zdd� Zd d � Zd d � Zd ZdZ dZ e dd� �Z dS )�IncrementalNewlineDecoder�strictc C s, t jj| |d� || _|| _d| _d| _d S )N)r9 r F)�codecs�IncrementalDecoderr� � translate�decoder�seennl� pendingcr)rI r# r" r9 rA rA rB r� ` s z"IncrementalNewlineDecoder.__init__Fc C s� | j d kr|}n| j j||d�}| jr<|s.|r<d| }d| _|�d�r\|s\|d d� }d| _|�d�}|�d�| }|�d�| }| j|o�| j|o�| jB |o�| jB O _| j r�|r�|� dd�}|r�|� dd�}|S )N��final� Fr T� � ) r# �decoder% r� r� r$ �_LF�_CR�_CRLFr" �replace)rI �inputr' �outputZcrlfZcrZlfrA rA rB r+ g s* � z IncrementalNewlineDecoder.decodec C s@ | j d krd}d}n| j �� \}}|dK }| jr8|dO }||fS )Nr� r r )r# �getstater% )rI r� �flagrA rA rB r2 � s z"IncrementalNewlineDecoder.getstatec C s8 |\}}t |d@ �| _| jd k r4| j�||d? f� d S r� )�boolr% r# �setstate)rI �stater� r3 rA rA rB r5 � s z"IncrementalNewlineDecoder.setstatec C s$ d| _ d| _| jd k r | j�� d S )Nr F)r$ r% r# �resetra rA rA rB r7 � s z IncrementalNewlineDecoder.resetr r � c C s d| j S )N)Nr* r( )r( r* r) )r* r) )r( r) )r( r* r) )r$ ra rA rA rB r � s �z"IncrementalNewlineDecoder.newlinesN)r )F) rM rN rO r� r+ r2 r5 r7 r, r- r. r� r rA rA rA rB r Y s r c @ sr e Zd ZdZdZdNdd�Zdd� ZdOdd �Zd d � Ze d d � �Z e dd� �Z e dd� �Z e dd� �Z e dd� �Zddeddd�dd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Ze d#d$� �Ze d%d&� �Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z d1d2� Z dPd3d4�Z d5d6� Z d7d8� Z dQd:d;�Z!d<d=� Z"d>d?� Z#dRd@dA�Z$dBdC� Z%dSdDdE�Z&dTdFdG�Z'dHdI� Z(dUdJdK�Z)e dLdM� �Z*dS )Vr3 i NFc C s | � |� |d krvzt�|�� �}W n ttfk r< Y nX |d krvz dd l}W n tk rj d}Y n X |�d�}t |t �s�t d| ��t � |�js�d}t|| ��|d kr�d}nt |t �s�t d| ��|| _d| _d| _d | _| j�� | _| _t| jd �| _| �|||||� d S ) Nr �asciiFr zG%r is not a text encoding; use codecs.open() to handle arbitrary codecsr r r r� )�_check_newliner �device_encodingr, r/ rV �locale� ImportErrorZgetpreferredencodingr r r# r �lookup�_is_text_encoding� LookupErrorr� �_decoded_chars�_decoded_chars_used� _snapshotr@ rn r �_tellingr� � _has_read1� _configure) rI r@ r8 r9 r: r? � write_throughr< rp rA rA rB r� � s> �zTextIOWrapper.__init__c C s> |d k r$t |t�s$tdt|�f ��|dkr:td|f ��d S )Nzillegal newline type: %r)Nr r* r( r) zillegal newline value: %r)r r r �typer# )rI r: rA rA rB r: � s z TextIOWrapper._check_newlinec C s� || _ || _d | _d | _d| _| | _|d k| _|| _|dk| _|pHt j | _ || _ || _ | jr�| �� r�| j�� }|dkr�z| �� �d� W n tk r� Y nX d S )N� r r )� _encoding�_errors�_encoder�_decoder� _b2cratio�_readuniversal�_readtranslate�_readnl�_writetranslater �linesep�_writenl�_line_buffering�_write_throughr rt r@ rb � _get_encoderr5 r@ )rI r8 r9 r: r? rG �positionrA rA rB rF � s& zTextIOWrapper._configurec C s� d� | jj| jj�}z | j}W n tk r2 Y nX |d� |�7 }z | j}W n tk r` Y nX |d� |�7 }|d� | j� S )Nz<{}.{}z name={0!r}z mode={0!r}z encoding={0!r}>)r� rX rN rO rY r/ r4 r8 )rI r> rY r4 rA rA rB r� ! s � zTextIOWrapper.__repr__c C s | j S rQ )rJ ra rA rA rB r8 2 s zTextIOWrapper.encodingc C s | j S rQ )rK ra rA rA rB r9 6 s zTextIOWrapper.errorsc C s | j S rQ )rU ra rA rA rB r? : s z TextIOWrapper.line_bufferingc C s | j S rQ )rV ra rA rA rB rG > s zTextIOWrapper.write_throughc C s | j S rQ )r� ra rA rA rB r@ B s zTextIOWrapper.buffer)r8 r9 r: r? rG c C s� | j d k r*|d k s"|d k s"|tk r*td��|d krH|d krB| j}q^d}nt|t�s^td| ��|d krn| j}nt|t�s�td| ��|tkr�| j}| � |� |d kr�| j }|d kr�| j }| � � | � |||||� d S )NzPIt is not possible to set the encoding or newline of stream after the first readr r r )rM �EllipsisrV rK r r r rJ rQ r: r? rG rh rF )rI r8 r9 r: r? rG rA rA rB � reconfigureF s@ ���� �zTextIOWrapper.reconfigurec C s | j rtd��| jS rv )rj r# r ra rA rA rB rn o s zTextIOWrapper.seekablec C s | j �� S rQ )r@ rr ra rA rA rB rr t s zTextIOWrapper.readablec C s | j �� S rQ )r@ rt ra rA rA rB rt w s zTextIOWrapper.writablec C s | j �� | j| _d S rQ )r@ rh r rD ra rA rA rB rh z s zTextIOWrapper.flushc C s. | j d k r*| js*z | �� W 5 | j �� X d S rQ )r@ rj r5 rh ra rA rA rB r5 ~ s zTextIOWrapper.closec C s | j jS rQ )r@ rj ra rA rA rB rj � s zTextIOWrapper.closedc C s | j jS rQ )r@ rY ra rA rA rB rY � s zTextIOWrapper.namec C s | j �� S rQ )r@ r, ra rA rA rB r, � s zTextIOWrapper.filenoc C s | j �� S rQ )r@ r) ra rA rA rB r) � s zTextIOWrapper.isattyc C s� | j rtd��t|t�s(td|jj ��t|�}| js<| j oBd|k}|rf| jrf| j dkrf|� d| j �}| j pr| � � }|�|�}| j�|� | j r�|s�d|kr�| �� | �d� d | _| jr�| j�� |S )Nr� z can't write %s to text streamr* r( r )rj r# r r r rX rM r" rR rU rT r/ rL rW �encoder@ r� rh �_set_decoded_charsrC rM r7 )rI r ZlengthZhaslf�encoderr rA rA rB r� � s( � zTextIOWrapper.writec C s t �| j�}|| j�| _| jS rQ )r �getincrementalencoderrJ rK rL )rI Z make_encoderrA rA rB rW � s zTextIOWrapper._get_encoderc C s2 t �| j�}|| j�}| jr(t|| j�}|| _|S rQ )r �getincrementaldecoderrJ rK rO r rP rM )rI Z make_decoderr# rA rA rB � _get_decoder� s zTextIOWrapper._get_decoderc C s || _ d| _d S r� )rA rB )rI �charsrA rA rB r\ � s z TextIOWrapper._set_decoded_charsc C sF | j }|d kr | j|d � }n| j||| � }| j t|�7 _ |S rQ )rB rA r" )rI r �offsetra rA rA rB �_get_decoded_chars� s z TextIOWrapper._get_decoded_charsc C s$ | j |k rtd��| j |8 _ d S )Nz"rewind decoded_chars out of bounds)rB �AssertionErrorr� rA rA rB �_rewind_decoded_chars� s z#TextIOWrapper._rewind_decoded_charsc C s� | j d krtd��| jr&| j �� \}}| jr<| j�| j�}n| j�| j�}| }| j � ||�}| � |� |r�t |�t | j � | _ nd| _ | jr�||| f| _| S )Nz no decoderrI )rM r# rD r2 rE r@ r� � _CHUNK_SIZEr� r+ r\ r" rA rN rC )rI � dec_buffer� dec_flags� input_chunk�eofZ decoded_charsrA rA rB � _read_chunk� s zTextIOWrapper._read_chunkr c C s( ||d> B |d> B |d> B t |�d> B S )N�@ � � � )r4 )rI rX rh � bytes_to_feed�need_eof� chars_to_skiprA rA rB � _pack_cookie� s � �zTextIOWrapper._pack_cookiec C sF t |d�\}}t |d�\}}t |d�\}}t |d�\}}|||||fS )Nl )�divmod)rI Zbigint�restrX rh rp rq rr rA rA rB �_unpack_cookie s z TextIOWrapper._unpack_cookiec C s@ | j std��| js td��| �� | j�� }| j}|d ksF| jd krX| j rTt d��|S | j\}}|t |�8 }| j }|dkr�| � ||�S |�� }�z�t| j| �}d}|dk�r"|�d|f� t |�|d |� ��} | |k�r|�� \} } | s�| }|| 8 }�q4|t | �8 }d}q�||8 }|d }q�d}|�d|f� || } |} |dk�rZ| � | | �W ��S d}d}d}t|t |��D ]x}|d7 }|t |�|||d � ��7 }|�� \}}|�s�||k�r�| |7 } ||8 }|dd } }}||k�rt �q�qt|t |jddd ��7 }d}||k �rtd ��| � | | |||�W �S |�|� X d S ) N�!underlying stream is not seekablez(telling position disabled by next() callzpending decoded textr r r� r Tr& z'can't reconstruct logical file position)r rV rD r. rh r@ rb rM rC rA rd r" rB rs r2 r5 r rN r+ �range)rI rX r# rh Z next_inputrr Z saved_stateZ skip_bytesZ skip_backr r �d� start_posZ start_flagsZ bytes_fedrq Z chars_decoded�irg rA rA rB rb s� �zTextIOWrapper.tellc C s$ | � � |d kr| �� }| j�|�S rQ )rh rb r@ rd re rA rA rB rd m s zTextIOWrapper.truncatec C s* | j d krtd��| �� | j}d | _|S )Nzbuffer is already detached)r@ r# rh r� )rI r@ rA rA rB r� s s zTextIOWrapper.detachc s� � fdd�}� j rtd��� js(td��|tkrN|dkr@td��d}� �� }nZ|tkr�|dkrftd��� �� � j� d|�}� � d� d � _ � j r�� j � � ||� |S |dkr�td |f ��|dk r�td |f ��� �� � �|�\}}}}} � j� |� � � d� d � _ |dk�r*� j �r*� j � � n@� j �s>|�s>| �rj� j �pL� �� � _ � j �d |f� |d f� _ | �r�� j�|�} � � � j �| |�� || f� _ t� j�| k �r�td ��| � _||� |S ) Nc sH z� j p� �� }W n tk r& Y n X | dkr<|�d� n|�� d S r� )rL rW r@ r5 r7 )rX r] ra rA rB �_reset_encoder| s z*TextIOWrapper.seek.<locals>._reset_encoderr� rw r z#can't do nonzero cur-relative seeksz#can't do nonzero end-relative seeksr zunsupported whence (%r)r� r� z#can't restore logical file position)rj r# r rV r rb r rh r@ r[ r\ rC rM r7 rv r` r5 r� r+ r" rA r. rB ) rI Zcookier_ r| rX rz rh rp rq rr ri rA ra rB r[ { s` � � zTextIOWrapper.seekc C s� | � � |d krd}n4z |j}W n" tk rB t|�d���Y nX |� }| jpV| �� }|dk r�| �� |j| j� � dd� }| � d� d | _ |S d}| �|�}t |�|k r�|s�| � � }|| �|t |� �7 }q�|S d S )Nr r� r Tr& r F)rs r� r/ r rM r` rc r+ r@ r� r\ rC r" rk )rI r� r� r# r> rj rA rA rB r� � s, � zTextIOWrapper.readc C s( d| _ | �� }|s$d | _| j| _ t�|S rm )rD r� rC r r� r� rA rA rB r� � s zTextIOWrapper.__next__c C s | j rtd��|d kr d}n4z |j}W n" tk rH t|�d���Y nX |� }| �� }d}| jsj| �� d }}| jr�|� d|�}|dkr�|d }�q�nt |�}n�| j �rF|� d|�}|� d|�}|dkr�|dkr�t |�}n |d }�q�nX|dk�r|d }�q�n@||k �r |d }�q�n(||d k�r8|d }�q�n |d }�q�n(|� | j �}|dk�rn|t | j � }�q�|dk�r�t |�|k�r�|}�q�| � � �r�| j�r��q��q�| j�r�|| �� 7 }qr| �d � d | _|S qr|dk�r�||k�r�|}| �t |�| � |d |� S ) Nr� r r� r r* r r( r r )rj r# r� r/ r rc rM r` rP r} r" rO rQ rk rA r\ rC re ) rI r� r� r� �startr^ �endposZnlposZcrposrA rA rB r� � st zTextIOWrapper.readlinec C s | j r| j jS d S rQ )rM r ra rA rA rB r H s zTextIOWrapper.newlines)NNNFF)NNNFF)N)r r r r )N)r )N)N)+rM rN rO rf r� r� r: rF r� r� r8 r9 r? rG r@ rY rZ rn rr rt rh r5 rj rY r, r) r� rW r` r\ rc re rk rs rv rb rd r� r[ r� r� r� r rA rA rA rB r3 � sz � ( � $ � ) * � c K ]r3 c sN e Zd Zd� fdd� Zdd� Zdd� Zed d � �Zed d � �Zd d� Z � Z S )�StringIOr r* c sf t t| �jt� dd|d� |d kr(d| _|d k rbt|t�sNtd�t |�j ���| � |� | � d� d S )Nzutf-8� surrogatepass)r8 r9 r: Fz*initial_value must be str or None, not {0}r ) r� r r� r� rR r r r r� rH rM r� r[ )rI Z initial_valuer: r� rA rB r� T s � � zStringIO.__init__c C sP | � � | jp| �� }|�� }|�� z|j| j�� dd�W �S |�|� X d S )NTr& ) rh rM r` r2 r7 r5 r+ r@ r� )rI r# Z old_staterA rA rB r� d s zStringIO.getvaluec C s t �| �S rQ )�objectr� ra rA rA rB r� n s zStringIO.__repr__c C s d S rQ rA ra rA rA rB r9 s s zStringIO.errorsc C s d S rQ rA ra rA rA rB r8 w s zStringIO.encodingc C s | � d� d S r� r\ ra rA rA rB r� { s zStringIO.detach)r r* ) rM rN rO r� r� r� r� r9 r8 r� r� rA rA r� rB r M s r )r r NNNTN)7r �abcr r� r �sys�_threadr r� �platformZmsvcrtr r �ior r r r r� r� �addr � SEEK_DATAr* r� r �dev_moderk rC rF � open_coder/ rG rP rV r. r# �ABCMetarW �registerr� �_ior( r� r� r� r2 r1 r� r0 r r! r r3 r rA rA rA rB �<module> s� � [ $ = g h CiIJ Y@ U $