B
bOcʻ @ s8 d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ej dkrTd dl
m Z ndZ d dl
Z
d dl
mZmZmZmZ d ddhZee dree j ee j d ZeZd3d
dZG dd dZG dd dZy
e
j Z W n( e k
r G dd de e Z Y nX G dd dej dZ!e
j!"e! G dd de!Z#e
j#"e# d dl$m%Z% e#"e% G dd 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&Z+G d'd( d(e*e)Z,G d)d* d*e#Z%G d+d, d,e!Z-e
j-"e- G d-d. d.ej.Z/G d/d0 d0e-Z0G d1d2 d2e0Z1dS )4 N)
allocate_lock> cygwinwin32)setmode)__all__SEEK_SETSEEK_CURSEEK_END SEEK_HOLEi rTc C sz t | tst| } t | tttfs0td| t |tsFtd| t |ts\td| |d k rzt |tsztd| |d k rt |tstd| t|}|td st|t|krt d| d|k} d|k}
d |k} d
|k} d |k}
d |k}d
|k}d|krD| s"| s"| s"|
r*t ddd l
}| dt d d}
|rX|rXt d| |
| | dkrvt d| s|
s| s| st d|r|d k rt d|r|d k rt d|r|d k rt dt
| | rdpd|
rdpd | r d pd | r d
p d |
r,d p.d ||d }|}y d }|dksd|dk rl| rld }d}|dk rt}yt| j}W n ttfk
r Y nX |dkr|}|dk rt d |dkr|r|S t d |
rt||}n<| s
| s
| rt||}n |
r(t||}n t d!| |}|rB|S t|||||}|}||_|S | Y nX d S )"Nzinvalid file: %rzinvalid mode: %rzinvalid buffering: %rzinvalid encoding: %rzinvalid errors: %rzaxrwb+tUxr
wa+tbUz4mode 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 argument )openerFr zinvalid buffering sizez can't have unbuffered text I/Ozunknown mode: %r)
isinstanceintosfspathstrbytes TypeErrorsetlen
ValueErrorwarningswarnDeprecationWarningFileIOisattyDEFAULT_BUFFER_SIZEfstatfileno
st_blksizeOSErrorAttributeErrorBufferedRandomBufferedWriterBufferedReader
TextIOWrappermodeclose)filer1 bufferingencodingerrorsnewlineclosefdr ZmodesZcreatingZreadingZwritingZ appendingZupdatingtextZbinaryr" rawresultline_bufferingbsbuffer r? */opt/alt/python37/lib64/python3.7/_pyio.pyopen% s {
>
rA c @ s e Zd Zdd ZdS )
DocDescriptorc C s
dt j S )Nz\open(file, mode='r', buffering=-1, encoding=None, errors=None, newline=None, closefd=True)
)rA __doc__)selfobjtypr? r? r@ __get__ s zDocDescriptor.__get__N)__name__
__module__ __qualname__rG r? r? r? r@ rB s rB c @ s e Zd Ze Zdd ZdS ) OpenWrapperc O s
t ||S )N)rA )clsargskwargsr? r? r@ __new__ s zOpenWrapper.__new__N)rH rI rJ rB rC rO r? r? r? r@ rK s rK c @ s e Zd ZdS )UnsupportedOperationN)rH rI rJ r? r? r? r@ rP s rP c @ s e Zd Zdd Zd5ddZdd Zd6d d
Zd d Zd
Zdd Z dd Z
dd Z d7ddZ dd Z
d8ddZdd Zd9d d Zed d Zd:d d!Zd"d# Zd$d% Zd&d' Zd(d) Zd;d+d,Zd-d. Zd/d0 Zddk st|k r | }|sP ||7 }|drlP qlW t|S ) Npeekc s> d} | sdS | dd p&t| }dkr:t|}|S )Nr
r )rh findr min)Z readaheadn)rD sizer? r@
nreadahead s
z#IOBase.readline..nreadaheadc S s dS )Nr
r? r? r? r? r@ rn s r z is not an integerr ri ) hasattr __index__r, r bytearrayr readendswithr )rD rm rn
size_indexresr r? )rD rm r@ readline s&
zIOBase.readlinec C s | | S )N)rZ )rD r? r? r@ __iter__ s zIOBase.__iter__c C s | }|st|S )N)rv
StopIteration)rD liner? r? r@ __next__ s zIOBase.__next__c C sR |d ks|dkrt | S d}g }x,| D ]$}|| |t|7 }||kr&P q&W |S )Nr )listappendr )rD Zhintrl linesry r? r? r@ readlines s
zIOBase.readlinesc C s$ | x|D ]}| | qW d S )N)rZ write)rD r} ry r? r? r@
writelines$ s
zIOBase.writelines)r )N)N)N)N)N)r )N) rH rI rJ rT rU rX rY r[ r\ r2 r] r^ r` ra rb rc rd propertyre rZ rf rg r) r& rv rw rz r~ r r? r? r? r@ rQ s2 #
*
rQ ) metaclassc @ s. e Zd Zd ddZdd Zdd Zdd Zd
S ) RawIOBaser c C sP |d kr d}|dk r | S t| }| |}|d kr>d S ||d = t|S )Nr r )readallrq rp readintor )rD rm r rl r? r? r@ rr ? s
zRawIOBase.readc C s8 t }x | t}|sP ||7 }qW |r0t|S |S d S )N)rq rr r' r )rD ru datar? r? r@ r P s
zRawIOBase.readallc C s | d d S )Nr )rT )rD r r? r? r@ r ^ s zRawIOBase.readintoc C s | d d S )Nr )rT )rD r r? r? r@ r f s zRawIOBase.writeN)r )rH rI rJ rr r r r r? r? r? r@ r 1 s
r )r% c @ sH e Zd ZdddZdddZdd Zdd Zd
d Zd d
Zdd Z dS )BufferedIOBaser c C s | d d S )Nrr )rT )rD rm r? r? r@ rr s zBufferedIOBase.readc C s | d d S )Nread1)rT )rD rm r? r? r@ r s zBufferedIOBase.read1c C s | j |ddS )NF)r ) _readinto)rD r r? r? r@ r s zBufferedIOBase.readintoc C s | j |ddS )NT)r )r )rD r r? r? r@ readinto1 s zBufferedIOBase.readinto1c C sV t |tst|}|d}|r0| t|}n| t|}t|}||d |< |S )NB)r
memoryviewcastr r rr )rD r r r rl r? r? r@ r s
zBufferedIOBase._readintoc C s | d d S )Nr )rT )rD r r? r? r@ r s zBufferedIOBase.writec C s | d d S )Ndetach)rT )rD r? r? r@ r s zBufferedIOBase.detachN)r )r )
rH rI rJ rr r r r r r r r? r? r? r@ r s s
r c @ s e Zd Zdd Zd#ddZdd 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 )N)_raw)rD r: r? r? r@ __init__ s z_BufferedIOMixin.__init__r c C s" | j ||}|dk r td|S )Nr z#seek() returned an invalid position)r: rU r+ )rD rV rW Z new_positionr? r? r@ rU s z_BufferedIOMixin.seekc C s | j }|dk rtd|S )Nr z#tell() returned an invalid position)r: rX r+ )rD rV r? r? r@ rX s
z_BufferedIOMixin.tellNc C s$ | |d kr| }| j|S )N)r[ rX r: rY )rD rV r? r? r@ rY s z_BufferedIOMixin.truncatec C s | j rtd| j d S )Nzflush on closed file)re r! r: r[ )rD r? r? r@ r[ s z_BufferedIOMixin.flushc C s. | j d k r*| js*z | W d | j X d S )N)r: re r[ r2 )rD r? r? r@ r2
s z_BufferedIOMixin.closec C s* | j d krtd| | j}d | _|S )Nzraw stream already detached)r: r! r[ r )rD r: r? r? r@ r s
z_BufferedIOMixin.detachc C s
| j S )N)r: r^ )rD r? r? r@ r^ s z_BufferedIOMixin.seekablec C s | j S )N)r )rD r? r? r@ r: s z_BufferedIOMixin.rawc C s | j jS )N)r: re )rD r? r? r@ re # s z_BufferedIOMixin.closedc C s | j jS )N)r: rS )rD r? r? r@ rS ' s z_BufferedIOMixin.namec C s | j jS )N)r: r1 )rD r? r? r@ r1 + s z_BufferedIOMixin.modec C s t d| jjd S )Nz can not serialize a '{0}' object)r formatrR rH )rD r? r? r@ __getstate__/ s z _BufferedIOMixin.__getstate__c C sJ | j j}| j j}y
| j}W n tk
r6 d||S X d|||S d S )Nz<{}.{}>z<{}.{} name={!r}>)rR rI rJ rS Exceptionr )rD modnameZclsnamerS r? r? r@ __repr__3 s
z_BufferedIOMixin.__repr__c C s
| j S )N)r: r) )rD r? r? r@ r) ? s z_BufferedIOMixin.filenoc C s
| j S )N)r: r& )rD r? r? r@ r& B s z_BufferedIOMixin.isatty)r )N)rH rI rJ r rU rX rY r[ r2 r r^ r r: re rS r1 r r r) r& r? r? r? r@ r s
r c s e Zd ZdZd ddZdd Zdd Zdd Z fd
d Zd!d
dZ d"ddZ
dd Z d#ddZ dd Z
d$ddZdd Zd d Zd d Z ZS )%BytesIONc C s& t }|d k r||7 }|| _d| _d S )Nr )rq _buffer_pos)rD Z
initial_bytesbufr? r? r@ r N s
zBytesIO.__init__c C s | j rtd| j S )Nz__getstate__ on closed file)re r! __dict__copy)rD r? r? r@ r U s zBytesIO.__getstate__c C s | j rtdt| jS )Nzgetvalue on closed file)re r! r r )rD r? r? r@ getvalueZ s zBytesIO.getvaluec C s | j rtdt| jS )Nzgetbuffer on closed file)re r! r r )rD r? r? r@ getbuffera s zBytesIO.getbufferc s" | j d k r| j t d S )N)r clearsuperr2 )rD )rR r? r@ r2 h s
z
BytesIO.closer c C s | j rtd|d kr d}n4y
|j}W n" tk
rH t|dY nX | }|dk rbt| j}t| j| jkrvdS tt| j| j| }| j| j| }|| _t |S )Nzread from closed filer z is not an integerr )
re r! rp r, r r r r rk r )rD rm rt Znewposr r? r? r@ rr m s"
z BytesIO.readc C s
| |S )N)rr )rD rm r? r? r@ r s z
BytesIO.read1c C s | j rtdt|tr tdt| }|j}W d Q R X |dkrFdS | j}|t| j krzd|t| j }| j |7 _ || j ||| < | j|7 _|S )Nzwrite to closed filez can't write str to binary streamr )
re r! r r r r nbytesr r r )rD r Zviewrl rV Zpaddingr? r? r@ r s
z
BytesIO.writer c C s | j rtdy
|j}W n" tk
r: t|dY nX | }|dkrh|dk r`td|f || _nD|dkrtd| j| | _n(|dkrtdt| j| | _ntd| jS )Nzseek on closed filez is not an integerr znegative seek position %rr
r zunsupported whence value) re r! rp r, r r maxr r )rD rV rW pos_indexr? r? r@ rU s"
z BytesIO.seekc C s | j rtd| jS )Nztell on closed file)re r! r )rD r? r? r@ rX s z BytesIO.tellc C sx | j rtd|d kr | j}nJy
|j}W n" tk
rJ t|dY nX | }|dk rhtd|f | j|d = |S )Nztruncate on closed filez is not an integerr z negative truncate position %r)re r! r rp r, r r )rD rV r r? r? r@ rY s
zBytesIO.truncatec C s | j rtddS )Nz I/O operation on closed file.T)re r! )rD r? r? r@ ra s zBytesIO.readablec C s | j rtddS )Nz I/O operation on closed file.T)re r! )rD r? r? r@ rc s zBytesIO.writablec C s | j rtddS )Nz I/O operation on closed file.T)re r! )rD r? r? r@ r^ s zBytesIO.seekable)N)r )r )r )N)rH rI rJ r r r r r r2 rr r r rU rX rY ra rc r^
__classcell__r? r? )rR r@ r F s
r c @ st e Zd ZefddZdd Zdd Zddd Zdd
d Zd d
dZ d ddZ
d ddZ dd Z dd Z
d ddZdS ) r/ c C sF | stdt| | |dkr,td|| _| t | _d S )Nz "raw" argument must be readable.r zinvalid buffer size) ra r+ r r r! buffer_size_reset_read_bufLock
_read_lock)rD r: r r? r? r@ r s zBufferedReader.__init__c C s
| j S )N)r: ra )rD r? r? r@ ra s zBufferedReader.readablec C s d| _ d| _d S )Nr r ) _read_buf _read_pos)rD r? r? r@ r s z BufferedReader._reset_read_bufNc C s4 |d k r|dk rt d| j | |S Q R X d S )Nr z invalid number of bytes to read)r! r _read_unlocked)rD rm r? r? r@ rr s zBufferedReader.readc C s d}d}| j }| j}|d ks$|dkr| t| jdrj| j }|d krZ||d pXd S ||d | S ||d g}d}x2| j }||kr|}P |t|7 }|| q~W d |p|S t|| } || kr| j|7 _|||| S ||d g}t
| j |}
xB| |k rL| j|
}||kr2|}P | t|7 } || q W t || }d |} | |d | _ d| _| r| d | S |S )Nr )r Nr r r )
r r r ro r: r rr r r| joinr r rk ) rD rl Z
nodata_valZ empty_valuesr rV chunkZchunksZ current_sizeavailZwantedoutr? r? r@ r sN
z BufferedReader._read_unlockedr c C s | j | |S Q R X d S )N)r _peek_unlocked)rD rm r? r? r@ rh 5 s zBufferedReader.peekc C sr t || j}t| j| j }||k s,|dkrb| j| }| j|}|rb| j| jd | | _d| _| j| jd S )Nr )rk r r r r r: rr )rD rl ZwantZhaveZto_readZcurrentr? r? r@ r ? s
z BufferedReader._peek_unlockedr c C sR |dk r| j }|dkrdS | j( | d | t|t| j| j S Q R X d S )Nr r r
)r r r r rk r r r )rD rm r? r? r@ r J s
zBufferedReader.read1c C s t |tst|}|jdkr dS |d}d}| j x|t|k rtt| j| j t|}|r| j| j| j| |||| < | j|7 _||7 }|t|krP t|| | j kr| j
||d }|sP ||7 }n|r|s| dsP |r8|r8P q8W W d Q R X |S )Nr r r
)
r r r r r r rk r r r r: r r )rD r r writtenr rl r? r? r@ r \ s4
"
zBufferedReader._readintoc C s t | t| j | j S )N)r rX r r r )rD r? r? r@ rX s zBufferedReader.tellc C sX |t krtd| j8 |dkr4|t| j| j 8 }t| ||}| |S Q R X d S )Nzinvalid whence valuer
) valid_seek_flagsr! r r r r r rU r )rD rV rW r? r? r@ rU s zBufferedReader.seek)N)N)r )r )r )r )rH rI rJ r' r ra r rr r rh r r r rX rU r? r? r? r@ r/ s
4
.r/ c @ s\ e Zd ZefddZdd Zdd Zddd Zd
d Zd d
Z dd Z
dddZ dd Z dS )r. c C sF | stdt| | |dkr,td|| _t | _t | _ d S )Nz "raw" argument must be writable.r zinvalid buffer size)
rc r+ r r r! r rq
_write_bufr _write_lock)rD r: r r? r? r@ r s zBufferedWriter.__init__c C s
| j S )N)r: rc )rD r? r? r@ rc s zBufferedWriter.writablec C s t |trtd| j | jr(tdt| j| jkr@| t| j}| j
| t| j| }t| j| jkry | W nl t k
r } zNt| j| jkrt| j| j }||8 }| jd | j | _t |j |j
|W d d }~X Y nX |S Q R X d S )Nz can't write str to binary streamzwrite to closed file)r r r r re r! r r r _flush_unlockedextendBlockingIOErrorerrnostrerror)rD r Zbeforer eZoverager? r? r@ r s(
"zBufferedWriter.writeNc C s8 | j ( | |d kr"| j }| j|S Q R X d S )N)r r r: rX rY )rD rV r? r? r@ rY s
zBufferedWriter.truncatec C s | j | W d Q R X d S )N)r r )rD r? r? r@ r[ s zBufferedWriter.flushc C s | j rtdxz| jry| j| j}W n tk
rD tdY nX |d kr\ttjdd|t | jksr|dk rzt
d| jd |= qW d S )Nzflush on closed filezHself.raw should implement RawIOBase: it should not raise BlockingIOErrorz)write could not complete without blockingr z*write() returned incorrect number of bytes) re r! r r: r r RuntimeErrorr ZEAGAINr r+ )rD rl r? r? r@ r s z BufferedWriter._flush_unlockedc C s t | t| j S )N)r rX r r )rD r? r? r@ rX s zBufferedWriter.tellr c C s8 |t krtd| j | t| ||S Q R X d S )Nzinvalid whence value)r r! r r r rU )rD rV rW r? r? r@ rU s
zBufferedWriter.seekc C sV | j | jd ks| jr d S W d Q R X z | W d | j | j W d Q R X X d S )N)r r: re r[ r2 )rD r? r? r@ r2 s zBufferedWriter.close)N)r )
rH rI rJ r' r rc r rY r[ r rX rU r2 r? r? r? r@ r. s
r. c @ s e Zd ZefddZd ddZdd Zdd Zd d d Zd d
dZ dd Z
dd Z dd Z dd Z
dd Zdd Zedd Zd S )!BufferedRWPairc C s< | std| s tdt||| _t||| _d S )Nz#"reader" argument must be readable.z#"writer" argument must be writable.)ra r+ rc r/ readerr. writer)rD r r r r? r? r@ r s zBufferedRWPair.__init__r c C s |d kr d}| j |S )Nr )r rr )rD rm r? r? r@ rr s zBufferedRWPair.readc C s | j |S )N)r r )rD r r? r? r@ r # s zBufferedRWPair.readintoc C s | j |S )N)r r )rD r r? r? r@ r & s zBufferedRWPair.writer c C s | j |S )N)r rh )rD rm r? r? r@ rh ) s zBufferedRWPair.peekc C s | j |S )N)r r )rD rm r? r? r@ r , s zBufferedRWPair.read1c C s | j |S )N)r r )rD r r? r? r@ r / s zBufferedRWPair.readinto1c C s
| j S )N)r ra )rD r? r? r@ ra 2 s zBufferedRWPair.readablec C s
| j S )N)r rc )rD r? r? r@ rc 5 s zBufferedRWPair.writablec C s
| j S )N)r r[ )rD r? r? r@ r[ 8 s zBufferedRWPair.flushc C s z| j W d | j X d S )N)r r2 r )rD r? r? r@ r2 ; s zBufferedRWPair.closec C s | j p| j S )N)r r& r )rD r? r? r@ r& A s zBufferedRWPair.isattyc C s | j jS )N)r re )rD r? r? r@ re D s zBufferedRWPair.closedN)r )r )r )rH rI rJ r' r rr r r rh r r ra rc r[ r2 r& r re r? r? r? r@ r s
r c @ sj e Zd ZefddZdddZdd Zdd d
Zdd d Zd
d Z dddZ
d ddZ dd Z dd Z
dS ) r- c C s( | t| || t| || d S )N)r` r/ r r. )rD r: r r? r? r@ r R s zBufferedRandom.__init__r c C s |t krtd| | jrJ| j | j| jt| j d W d Q R X | j||}| j | W d Q R X |dk rt
d|S )Nzinvalid whence valuer
r z seek() returned invalid position) r r! r[ r r r: rU r r r r+ )rD rV rW r? r? r@ rU W s $zBufferedRandom.seekc C s | j rt| S t| S d S )N)r r. rX r/ )rD r? r? r@ rX h s
zBufferedRandom.tellNc C s |d kr| }t| |S )N)rX r. rY )rD rV r? r? r@ rY n s zBufferedRandom.truncatec C s |d kr d}| t| |S )Nr )r[ r/ rr )rD rm r? r? r@ rr t s zBufferedRandom.readc C s | t| |S )N)r[ r/ r )rD r r? r? r@ r z s zBufferedRandom.readintoc C s | t| |S )N)r[ r/ rh )rD rm r? r? r@ rh ~ s zBufferedRandom.peekr c C s | t| |S )N)r[ r/ r )rD rm r? r? r@ r s zBufferedRandom.read1c C s | t| |S )N)r[ r/ r )rD r r? r? r@ r s zBufferedRandom.readinto1c C sF | j r:| j( | j| jt| j d | W d Q R X t| |S )Nr
) r r r: rU r r r r. r )rD r r? r? r@ r s
zBufferedRandom.write)r )N)N)r )r )rH rI rJ r' r rU rX rY rr r rh r r r r? r? r? r@ r- I s
r- c s e Zd ZdZdZdZdZdZdZdZ d0ddZ
dd Z d
d Z d d
Z
dd Zd1ddZd2ddZdd Zdd Zdd ZefddZd 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 d d| _ X t|tr s z"FileIO.__init__..r
r zKMust have exactly one of create/read/write/append mode and at most one plusr Tr
r r O_BINARYZ O_NOINHERIT O_CLOEXECz'Cannot use closefd=False with file namei z expected integer from openerzNegative file descriptorFr* )-_fd_closefdr r2 r floatr r r! r r sumcount_created _writableO_EXCLO_CREAT _readableO_TRUNC
_appendingO_APPENDO_RDWRO_RDONLYO_WRONLYgetattrrA r+ set_inheritabler( statS_ISDIRst_modeIsADirectoryErrorr ZEISDIRr r, _blksizer' _setmoder rS lseekr ZESPIPE) rD r3 r1 r8 r fdflagsZnoinherit_flagZowned_fdZfdfstatr r? r? r@ r s
$
zFileIO.__init__c C sB | j dkr>| jr>| js>dd l}|jd| f td| d | d S )Nr zunclosed file %rr )
stacklevelsource)r r re r" r# ResourceWarningr2 )rD r" r? r? r@ r] s
zFileIO.__del__c C s t d| jjd S )Nz cannot serialize '%s' object)r rR rH )rD r? r? r@ r s zFileIO.__getstate__c C sl d| j j| j jf }| jr"d| S y
| j}W n& tk
rR d|| j| j| jf 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>) rR rI rJ re rS r, r r1 r )rD
class_namerS r? r? r@ r s
zFileIO.__repr__c C s | j stdd S )NzFile not open for reading)r rP )rD r? r? r@ rb - s zFileIO._checkReadablec C s | j stdd S )NzFile not open for writing)r rP )rD r_ r? r? r@ rd 1 s zFileIO._checkWritablec C sP | | |d ks |dk r(| S yt| j|S tk
rJ d S X d S )Nr )rZ rb r r rr r r )rD rm r? r? r@ rr 5 s z FileIO.readc C s | | t}y6t| jdt}t| jj}||krH|| d }W n t k
r^ Y nX t
}xnt ||krt |}|t |t7 }|t | }yt
| j|}W n tk
r |rP d S X |sP ||7 }qhW t|S )Nr r
)rZ rb r' r r r r r( st_sizer+ rq r r rr r r )rD bufsizerV endr; rl r r? r? r@ r E s4 zFileIO.readallc C s4 t |d}| t|}t|}||d |< |S )Nr )r r rr r )rD r mr rl r? r? r@ r h s
zFileIO.readintoc C s8 | | yt| j|S tk
r2 d S X d S )N)rZ rd r r r r )rD r r? r? r@ r p s z FileIO.writec C s* t |trtd| t| j||S )Nzan integer is required)r r r rZ r r r )rD rV rW r? r? r@ rU ~ s
z FileIO.seekc C s | t| jdtS )Nr )rZ r r r r )rD r? r? r@ rX s z FileIO.tellc C s2 | | |d kr | }t| j| |S )N)rZ rd rX r ftruncater )rD rm r? r? r@ rY s zFileIO.truncatec s. | j s*z| jrt| j W d t X d S )N)re r r r2 r r )rD )rR r? r@ r2 s
z FileIO.closec C sF | | jd kr@y | W n tk
r8 d| _Y nX d| _| jS )NFT)rZ _seekablerX r+ )rD r? r? r@ r^ s
zFileIO.seekablec C s | | jS )N)rZ r )rD r? r? r@ ra s zFileIO.readablec C s | | jS )N)rZ r )rD r? r? r@ rc s zFileIO.writablec C s | | jS )N)rZ r )rD r? r? r@ r) s z
FileIO.filenoc C s | t| jS )N)rZ r r& r )rD r? r? r@ r& s z
FileIO.isattyc C s | j S )N)r )rD r? r? r@ r8 s zFileIO.closefdc C sJ | j r| jrdS dS n0| jr,| jr&dS dS n| jrB| jrd? Z#dRd@dAZ$dBdC Z%dSdDdEZ&dTdFdGZ'dHdI Z(dUdJdKZ)e dLdM Z*dS )Vr0 i NFc C s | | |d krvyt| }W n ttfk
r< Y nX |d krvy dd l}W n tk
rj d}Y n X |d}t |t
st d| t
|jsd}t|| |d krd}nt |t
st d| || _d| _d| _d | _| j | _| _t| jd | _| ||||| d S )
Nr asciiFzinvalid encoding: %rzG%r is not a text encoding; use codecs.open() to handle arbitrary codecsr zinvalid errors: %rr r )_check_newliner device_encodingr) r, rP locale ImportErrorgetpreferredencodingr r r! r lookup_is_text_encoding LookupErrorr _decoded_chars_decoded_chars_used _snapshotr> r^ r _tellingro
_has_read1
_configure) rD r> r5 r6 r7 r<
write_throughr r_ r? r? r@ r s:
zTextIOWrapper.__init__c C s> |d k r$t |ts$tdt|f |dkr:td|f d S )Nzillegal newline type: %r)Nr r r z
zillegal newline value: %r)r r r typer! )rD r7 r? r? r@ r
s z TextIOWrapper._check_newlinec C s || _ || _d | _d | _d| _| | _|d k| _|| _|dk| _|pHt j
| _ || _ || _
| jr| r| j }|dkry| d W n tk
r Y nX d S )Ng r r ) _encoding_errors_encoder_decoder _b2cratio_readuniversal_readtranslate_readnl_writetranslater linesep_writenl_line_buffering_write_throughr rc r> rX _get_encoderr r )rD r5 r6 r7 r< r positionr? r? r@ r s&
zTextIOWrapper._configurec C s d | jj| jj}y
| j}W n tk
r2 Y nX |d |7 }y
| 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 rR rI rJ rS r r1 r5 )rD r; rS r1 r? r? r@ r s
zTextIOWrapper.__repr__c C s | j S )N)r )rD r? r? r@ r5 s zTextIOWrapper.encodingc C s | j S )N)r )rD r? r? r@ r6
s zTextIOWrapper.errorsc C s | j S )N)r% )rD r? r? r@ r< s z TextIOWrapper.line_bufferingc C s | j S )N)r& )rD r? r? r@ r s zTextIOWrapper.write_throughc C s | j S )N)r )rD r? r? r@ r> s zTextIOWrapper.buffer)r5 r6 r7 r< r c C s | j d k r*|d k s"|d k s"|tk r*td|d krH|d krB| j}q^d}nt|ts^td| |d krn| j}nt|tstd| |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 zinvalid errors: %rzinvalid encoding: %r)r EllipsisrP r r r r r r! r
r< r r[ r )rD r5 r6 r7 r< r r? r? r@ reconfigure s2
zTextIOWrapper.reconfigurec C s | j rtd| jS )Nz I/O operation on closed file.)re r! r )rD r? r? r@ r^ C s zTextIOWrapper.seekablec C s
| j S )N)r> ra )rD r? r? r@ ra H s zTextIOWrapper.readablec C s
| j S )N)r> rc )rD r? r? r@ rc K s zTextIOWrapper.writablec C s | j | j| _d S )N)r> r[ r r )rD r? r? r@ r[ N s
zTextIOWrapper.flushc C s. | j d k r*| js*z | W d | j X d S )N)r> re r[ r2 )rD r? r? r@ r2 R s zTextIOWrapper.closec C s | j jS )N)r> re )rD r? r? r@ re Y s zTextIOWrapper.closedc C s | j jS )N)r> rS )rD r? r? r@ rS ] s zTextIOWrapper.namec C s
| j S )N)r> r) )rD r? r? r@ r) a s zTextIOWrapper.filenoc C s
| j S )N)r> r& )rD r? r? r@ r& d s zTextIOWrapper.isattyc C s | j rtdt|ts(td|jj t|}| js<| j oBd|k}|rf| jrf| j
dkrf| d| j
}| j pr|
}||}| j| | j r|sd|kr| | d d | _| jr| j |S )Nzwrite to closed filez can't write %s to text streamr r r )re r! r r r rR rH r r" r% r$ r r r' encoder> r r[ _set_decoded_charsr r r )rD r lengthZhaslfencoderr r? r? r@ r g s&
zTextIOWrapper.writec C s t | j}|| j| _| jS )N)r getincrementalencoderr r r )rD Z make_encoderr? r? r@ r' ~ s zTextIOWrapper._get_encoderc C s2 t | j}|| j}| jr(t|| j}|| _|S )N)r getincrementaldecoderr r r r r r )rD Z make_decoderr r? r? r@ _get_decoder s
zTextIOWrapper._get_decoderc C s || _ d| _d S )Nr )r r )rD charsr? r? r@ r, s z TextIOWrapper._set_decoded_charsc C sF | j }|d kr | j|d }n| j||| }| j t|7 _ |S )N)r r r )rD rl offsetr2 r? r? r@ _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)r AssertionError)rD rl r? r? r@ _rewind_decoded_chars s
z#TextIOWrapper._rewind_decoded_charsc C s | j d krtd| jr&| j \}}| jr<| j| j}n| j| j}| }| j ||}|
| |rt |t | j | _
nd| _
| jr||| f| _| S )Nz
no decoderg )r r! r r r r> r _CHUNK_SIZErr r r, r r r r )rD
dec_buffer dec_flags input_chunkeofZ
decoded_charsr? r? r@ _read_chunk s
zTextIOWrapper._read_chunkr c C s( ||d> B |d> B |d> B t |d> B S )N@ )r )rD r( r9
bytes_to_feedneed_eof
chars_to_skipr? r? r@ _pack_cookie s zTextIOWrapper._pack_cookiec C sF t |d\}}t |d\}}t |d\}}t |d\}}|||||fS )Nl )divmod)rD Zbigintrestr( r9 rA rB rC r? r? r@ _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 | }zt| j| }d}x|dkr"|d|f t ||d | } | |kr| \}
} |
s| }|| 8 }P |t |
8 }d}q||8 }|d }qW d}|d|f || } |}
|dkrX|
| |
S d}d}d}xt|t |D ]t}|d7 }|t ||||d 7 }| \}}|s||kr| |7 } ||8 }|dd }
}}||krtP qtW |t |jddd 7 }d}||k rtd
|
| |
|||S || X d S ) Nz!underlying stream is not seekablez(telling position disabled by next() callzpending decoded textr r
r r T)r z'can't reconstruct logical file position)r rP r r+ r[ r> rX r r r r5 r r rD r r r r r range)rD r( r r9 Z
next_inputrC Z saved_stateZ
skip_bytesZ skip_backrl r d start_posZ start_flagsZ bytes_fedrB Z
chars_decodedir8 r? r? r@ rX sv
zTextIOWrapper.tellc C s$ | |d kr| }| j|S )N)r[ rX r> rY )rD rV r? r? r@ rY A s zTextIOWrapper.truncatec C s* | j d krtd| | j}d | _|S )Nzbuffer is already detached)r> r! r[ r )rD r> r? r? r@ r G s
zTextIOWrapper.detachc s fdd} j rtd js(td|dkrL|dkr@tdd} }|dkr|dkrdtd jdd} d
d _ j
r j
|| |S |dkrtd |f |dk rtd |f |\}}}}} j| d
d _ |dkr( j
r( j
n@ j
s<|s<| rh j
pJ
_
j
d
|f |d
f _ | r j|}
j
|
| ||
f _ t j| k rtd| _|| |S )Nc sH y j p }W n tk
r& Y n X | dkr<|d n| d S )Nr )r r' r r r )r( r. )rD r? r@ _reset_encoderP s z*TextIOWrapper.seek.._reset_encoderztell on closed filez!underlying stream is not seekabler
r z#can't do nonzero cur-relative seeksr z#can't do nonzero end-relative seeksr zunsupported whence (%r)znegative seek position %rr z#can't restore logical file position)re r! r rP rX r[ r> rU r, r r r rG r1 r rr r r r r+ r ) rD ZcookierW rL r( rJ r9 rA rB rC r: r? )rD r@ rU O s\
zTextIOWrapper.seekc C s | |d krd}n4y
|j}W n" tk
rB t|dY nX | }| jpV| }|dk r| |j| j dd }|
d d | _ |S d}| |}x4t ||k r|s|
}|| |t | 7 }qW |S d S )Nr z is not an integerr T)r r F)rb rp r, r r r1 r4 r r> rr r, r r r< )rD rm rt r r; r; r? r? r@ rr s*
zTextIOWrapper.readc C s( d| _ | }|s$d | _| j| _ t|S )NF)r rv r r rx )rD ry r? r? r@ rz s zTextIOWrapper.__next__c C s | j rtd|d kr d}n4y
|j}W n" tk
rH t|dY nX | }| }d}| jsj| d }}xV| jr| d|}|dkr|d }P nt
|}n| j r>| d|}| d|}|dkr|dkrt
|}n
|d }P nP|dkr|d }P n:||k r|d }P n$||d kr2|d }P n
|d }P n&| | j }|dkrd|t
| j }P |dkrt
||kr|}P x|
r| jrP qW | jr|| 7 }qv| d d | _|S qvW |dkr||kr|}| t
|| |d | S )
Nzread from closed filer z is not an integerr r r
r r r )re r! rp r, r r4 r r1 r rj r r r! r< r r, r r6 ) rD rm rt ry startrV endposZnlposZcrposr? r? r@ rv sv
zTextIOWrapper.readlinec C s | j r| j jS d S )N)r r )rD r? r? r@ r
s zTextIOWrapper.newlines)NNNFF)NNNFF)N)r r r r )N)r )N)N)+rH rI rJ r7 r r r
r r r r5 r6 r< r r> r) r* r^ ra rc r[ r2 re rS r) r& r r' r1 r, r4 r6 r< rD rG rX rY r rU rr rz rv r r? r? r? r@ r0 sT
'
# '
*
c
K
]r0 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|tsNtdt |j
| | | d d S )Nzutf-8
surrogatepass)r5 r6 r7 Fz*initial_value must be str or None, not {0}r )
r rO r r r" r r r r r rH r rU )rD Z
initial_valuer7 )rR r? r@ r (
s
zStringIO.__init__c C sL | | jp| }| }| z|j| j ddS || X d S )NT)r ) r[ r r1 r r r r> r r )rD r Z old_stater? r? r@ r 8
s zStringIO.getvaluec C s
t | S )N)objectr )rD r? r? r@ r B
s zStringIO.__repr__c C s d S )Nr? )rD r? r? r@ r6 G
s zStringIO.errorsc C s d S )Nr? )rD r? r? r@ r5 K
s zStringIO.encodingc C s | d d S )Nr )rT )rD r? r? r@ r O
s zStringIO.detach)r r ) rH rI rJ r r r r r6 r5 r r r? r? )rR r@ rO !
s
rO )r
r NNNTN)2r abcr r r sys_threadr r platformZmsvcrtr r ior r r r r ro addr SEEK_DATAr' r rA rB rK rP r, r+ r! ABCMetarQ registerr _ior% r r r r/ r. r r- r r r r0 rO r? r? r? r@ sr
T
=
g i CiIJ Y@ U $