U
e5dk @ 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 dree j ee j d ZeZeed
pejjZd6ddZ dd Z z
e
j Z W n e k
r e Z Y nX G dd dZ G dd dZ!z
e
j"Z"W n( e k
rD G dd de#e$Z"Y nX G dd dej%dZ&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 d1ej3Z4G d2d3 d3e2Z5G d4d5 d5e5Z6dS )7 N)
allocate_lock> win32cygwin)setmode)__all__SEEK_SETSEEK_CURSEEK_END SEEK_HOLEi ZgettotalrefcountrTc C s 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 d|r|dkrdd l
}| dt
d t| | rdpd |
r"dp$d | r2d p4d | rBd
pDd |
rRd pTd ||d }|}z$d }|dks|dk r| rd }d}|dk rt}zt| j}W n ttfk
r Y nX |dkr|}|dk rt d |dkr|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: %rinvalid encoding: %rinvalid 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 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)
isinstanceintosfspathstrbytes TypeErrorsetlen
ValueErrorwarningswarnDeprecationWarningRuntimeWarningFileIOisattyDEFAULT_BUFFER_SIZEfstatfileno
st_blksizeOSErrorAttributeErrorBufferedRandomBufferedWriterBufferedReader
TextIOWrappermodeclose)filer4 bufferingencodingerrorsnewlineclosefdr ZmodesZcreatingZreadingZwritingZ appendingZupdatingtextZbinaryr$ rawresultline_bufferingZbsbuffer rA /usr/lib64/python3.8/_pyio.pyopen) s {
rC c C s dd l }|dtd t| dS )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 ZdddZdS )
DocDescriptorNc C s
dt j S )Nz\open(file, mode='r', buffering=-1, encoding=None, errors=None, newline=None, closefd=True)
)rC __doc__)selfobjtyprA 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 )clsargskwargsrA 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 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 Zd d} | sdS | dd p&t| }dkr:t|}|S )Nr
r )r{ findr" min)Z readaheadnrI sizerA rB
nreadahead s
z#IOBase.readline..nreadaheadc S s dS Nr
rA rA rA rA rB r s r is not an integerr r| ) hasattr __index__r/ r bytearrayr" readendswithr )rI r r
size_indexresr 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
StopIterationrI linerA rA rB __next__9 s zIOBase.__next__c C sP |d ks|dkrt | S d}g }| D ]&}|| |t|7 }||kr$ qLq$|S Nr )listappendr" )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 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 )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 ZdddZdddZdd 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 )Nread1r\ r rA rA rB r s zBufferedIOBase.read1c C s | j |ddS )NFr _readintor rA rA rB r s zBufferedIOBase.readintoc C s | j |ddS )NTr r r rA rA rB readinto1 s zBufferedIOBase.readinto1c C sV t |tst|}|d}|r0| t|}n| t|}t|}||d |< |S NB)r
memoryviewcastr 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 Ndetachr\ 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#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 rQ _rawrI 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 )Nflush 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| jjdd S Nzcannot pickle z objectr 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 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 r )r _buffer_pos)rI Z
initial_bytesbufrA 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 rtdt| jS )Nzgetvalue on closed file)rj r# r r ra rA rA rB getvalue s zBytesIO.getvaluec C s | j rtdt| jS )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 clearsuperr5 ra rX rA rB r5 s
z
BytesIO.closer c C s | j rtd|d kr d}n4z
|j}W n" tk
rH t|dY nX | }|dk rbt| j}t| j| jkrvdS tt| j| j| }| j| j| }|| _t |S )Nread 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 rtdt|tr tdt| }|j}W 5 Q R X |dkrFdS | j}|t| j krzd|t| j }| j |7 _ || j ||| < | j|7 _|S )Nwrite 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 rtdz
|j}W n" tk
r: t|dY nX | }|dkrh|dk r`td|f || _nD|dkrtd| j| | _n(|dkrtdt| 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 )Ntell 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|dY 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 rtddS Nrw Trx ra rA rA rB rr s zBytesIO.readablec C s | j rtddS r rx ra rA rA rB rt s zBytesIO.writablec C s | j rtddS 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 ZefddZdd Zdd Zddd Zdd
d Zd d
dZ d ddZ
d ddZ dd Z dd Z
d ddZdS ) r2 c C sF | stdt| | |dkr,td|| _| t | _d S )Nz "raw" argument must be readable.r invalid buffer size) rr r. r r r# buffer_size_reset_read_bufLock
_read_lockrI 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| jdrj| 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|
}||kr.|}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_sizeavailZwantedoutrA 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 | j4 | 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 |tst|}|jdkr dS |d}d}| j |t|k rtt| j| j t|}|r| j| j| j| |||| < | j|7 _||7 }|t|krqt|| | j kr| j
||d }|sq||7 }n|r|s| dsq|r6|r6qq6W 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| jD |dkr4|t| j| j 8 }t| ||}| |W 5 Q R S Q R X d S )Ninvalid 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 ZefddZdd Zdd Zddd Zd
d Zd d
Z dd Z
dddZ dd Z dS )r1 c C sF | stdt| | |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 |trtd| j | jr(tdt| j| jkr@| t| j}| j
| t| j| }t| j| jkrz | W nl t k
r } zNt| j| jkrt| 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_unlockedextendBlockingIOErrorerrnostrerror)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| jrz| j| j}W n tk
rB tdY nX |d krZttjdd|t | jksp|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 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.)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 ZefddZdddZdd Zdd d
Zdd d Zd
d Z dddZ
d ddZ 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 rt
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 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 5 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 r5 r floatr r r# r r! sumcount_created _writableO_EXCLO_CREAT _readableO_TRUNC
_appendingO_APPENDO_RDWRO_RDONLYO_WRONLYgetattrrC r. set_inheritabler+ statS_ISDIRst_modeIsADirectoryErrorr ZEISDIRr r/ _blksizer* _setmoder rY lseekr ZESPIPE) rI r6 r4 r; r fdflagsZnoinherit_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 )
stacklevelsource)r r rj r$ r% ResourceWarningr5 )rI r$ rA rA rB rl A s zFileIO.__del__c C s t d| jjdd 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 stdd S )NzFile not open for reading)r rV ra rA rA rB rs Y s zFileIO._checkReadablec C s | j stdd 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| jj}||krH|| d }W n t k
r^ Y nX t
}t ||krt |}|t |t7 }|t | }zt
| j|}W n tk
r |rY qY d S X |sq||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 |trtd| 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| jdtS 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| jS 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| jrd? Z#dRd@dAZ$dBdC Z%dSdDdEZ&dTdFdGZ'dHdI Z(dUdJdKZ)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
st d| t
|jsd}t|| |d krd}nt |t
st 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 |ts$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 }|dkrz| 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|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 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 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 )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 ZlengthZhaslfencoderr 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 ||}|
| |rt |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_chunkeofZ
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_feedneed_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 ZbigintrestrX 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 | }zt| j| }d}|dkr"|d|f t ||d | } | |kr| \}
} |
s| }|| 8 }q4|t |
8 }d}q||8 }|d }qd}|d|f || } |}
|dkrZ|
| |
W S d}d}d}t|t |D ]x}|d7 }|t ||||d 7 }| \}}|s||kr| |7 } ||8 }|dd }
}}||krt qqt|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_decodedirg 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@tdd} }nZ|tkr|dkrftd j d|}
d d _ j r j
|| |S |dkrtd |f |dk rtd
|f |\}}}}} j |
d d _ |dkr* j r* j
n@ j s>|s>| rj j pL _ j d |f |d f _ | r j|}
j |
| ||
f _ t j| k rtd | _|| |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.._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|dY 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|dY nX | }| }d}| jsj| d }}| jr| d|}|dkr|d }qnt
|}n| j rF| d|}| d|}|dkr|dkrt
|}n |d }qnX|dkr|d }qn@||k r |d }qn(||d kr8|d }qn |d }qn(| | j }|dkrn|t
| j }q|dkrt
||kr|}q|
r| jrqq| jr|| 7 }qr| d d | _|S qr|dkr||kr|}| 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|tsNtdt |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 ddW 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 s
[
$ =
g h CiIJ Y@ U $