o
0iq @ sr d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ej dv r+d dl
m Z ndZ d dl
Z
d dl
mZmZmZmZ h dZee drRee j ee j dZeZeed p^ejjZeZ d6d d Z e d7ddZ dd Z ze
j!Z!W n e"y e Z!Y nw dd Z#ze
j$Z$W n e"y G dd de%e&Z$Y nw 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.Z0G d&d' d'e.Z1G d(d) d)e-Z2G d*d+ d+e1e0Z3G d,d- d-e*Z,G d.d/ d/e(Z4e
j4)e4 G d0d1 d1ej5Z6G d2d3 d3e4Z7G d4d5 d5e7Z8dS )8 N)
allocate_lock> Zwin32cygwin)setmode)__all__SEEK_SETSEEK_CURSEEK_END> r SEEK_HOLEi Zgettotalrefcountr
c C s4 | d u rd} t jjrdd l}|dt|d | S )Nlocaler z"'encoding' argument not specified.r )sysflagswarn_default_encodingwarningswarnEncodingWarning)encoding
stacklevelr r ,/opt/alt/python310/lib64/python3.10/_pyio.py
text_encoding+ s
r rTc C sr t | ts t| } t | tttfstd| t |ts$td| t |ts/td| |d ur>t |ts>td| |d urMt |tsMtd| t|}|td s_t|t|kret d| d|v } d|v }
d |v } d
|v } d |v }
d |v }d
|v }d|v r| s| s| s|
rt ddd l
}| dt d d}
|r|rt d| |
| | dkrt d| s|
s| s| st d|r|d urt d|r|d urt d|r|d urt d|r|dkrdd l
}| dt
d t| | rdpd |
rdpd | rd pd | r
d
p d |
rd pd ||d }|}zd }|dks-|dk r1| r1d }d}|dk rVt}z
t| j}W n ttfyN Y nw |dkrV|}|dk r_t d |dkrn|rj|W S t d!|
rwt||}n | s| s| rt||}n|
rt||}nt d"| |}|r|W S t|}t|||||}|}||_|W 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
ValueErrorr r DeprecationWarningRuntimeWarningFileIOisattyDEFAULT_BUFFER_SIZEfstatfileno
st_blksizeOSErrorAttributeErrorBufferedRandomBufferedWriterBufferedReaderr
TextIOWrappermodeclose)filer= bufferingr errorsnewlineclosefdr$ ZmodesZcreatingZreadingZwritingZ appendingZupdatingtextZbinaryr rawresultline_bufferingZbsbufferr r r openH s
x
rI c C s" dd l }|dtd t| dS )Nr z(_pyio.open_code() may not be using hooksr
rb)r r r0 rI )pathr r r r _open_code_with_warning$ s
rL c C s0 | dkrdd l }|jdtdd tatS t| )N OpenWrapperr z+OpenWrapper is deprecated, use open insteadr
)r )r r r/ rI rM r8 )namer r r r __getattr__: s rO c @ s e Zd ZdS )UnsupportedOperationN)__name__
__module__ __qualname__r r r r rP O s rP c @ s e Zd Z dd Zd5ddZdd Zd6d d
Zd d Zd
Zdd Z dd Z
dd Z d6ddZ dd Z
d6ddZdd Zd6d d Zed d Zd6d d!Zd"d# Zd$d% Zd&d' Zd(d) Zd7d+d,Zd-d. Zd/d0 Zd6d1d2Zd3d4 Z dS )8IOBasec C s t d| jj|f )Nz%s.%s() not supported)rP __class__rQ )selfrN r r r _unsupportedu s
zIOBase._unsupportedr c C | d d S )NseekrW rV poswhencer r r rY | s
z IOBase.seekc C s | ddS Nr r )rY rV r r r tell z IOBase.tellNc C rX NtruncaterZ rV r\ r r r rc zIOBase.truncatec C | d S N _checkClosedr_ r r r flush s z IOBase.flushFc C s* | j sz
| W d| _ d S d| _ w d S )NT)_IOBase__closedrj r_ r r r r> s
z IOBase.closec C sV z| j }W n
ty Y d S w |rd S tr | d S z| W d S Y d S rg )closedr8 _IOBASE_EMITS_UNRAISABLEr> )rV rl r r r __del__ s
zIOBase.__del__c C dS NFr r_ r r r seekable s zIOBase.seekablec C $ | st|d u r
d|d S )Nz File or stream is not seekable.)rq rP rV msgr r r _checkSeekable zIOBase._checkSeekablec C ro rp r r_ r r r readable zIOBase.readablec C rr )Nz File or stream is not readable.)rw rP rs r r r _checkReadable rv zIOBase._checkReadablec C ro rp r r_ r r r writable rx zIOBase.writablec C rr )Nz File or stream is not writable.)rz rP rs r r r _checkWritable rv zIOBase._checkWritablec C | j S rg )rk r_ r r r rl s z
IOBase.closedc C s" | j rt|d u r d|d S N I/O operation on closed file.rl r. rs r r r ri s zIOBase._checkClosedc C s | | S rg rh r_ r r r __enter__ s zIOBase.__enter__c G rf rg )r> )rV argsr r r __exit__ ra zIOBase.__exit__c C rX )Nr5 rZ r_ r r r r5 z
IOBase.filenoc C s | dS rp rh r_ r r r r2 s z
IOBase.isattyr c s t dr fdd}ndd }d u rdnzj}W n ty, tdw | t }dk s=t|k rb | }|sJ t|S ||7 }|drX t|S dk s=t|k s=t|S ) Npeekc s> d} | s dS | dd pt| }dkr t|}|S )Nr
r )r findr- min)Z readaheadnrV sizer r
nreadahead0 s
z#IOBase.readline..nreadaheadc S s dS Nr r r r r r r 9 s r is not an integerr r ) hasattr __index__r8 r+ bytearrayr- readendswithr* )rV r r
size_indexresr! r r r readline$ s0
zIOBase.readlinec C s | | S rg rh r_ r r r __iter__N s zIOBase.__iter__c C s | }|st|S rg )r
StopIterationrV liner r r __next__R s zIOBase.__next__c C sT |d u s |dkr
t | S d}g }| D ]}|| |t|7 }||kr' |S q|S Nr )listappendr- )rV Zhintr linesr r r r readlinesX s
zIOBase.readlinesc C s" | |D ]}| | qd S rg )ri write)rV r r r r r
writelinesj s
zIOBase.writelinesr rg r ) rQ rR rS rW rY r` rc rj rk r> rn rq ru rw ry rz r{ propertyrl ri r r r5 r2 r r r r r r r r r rT S s8
*
rT ) metaclassc @ s0 e Zd Z d ddZdd Zdd Zdd Zd
S ) RawIOBaser c C sR |d u rd}|dk r| S t| }| |}|d u r d S ||d = t|S )Nr r )readallr r readintor* )rV r r! r r r r r s
zRawIOBase.readc C s4 t } | t}|s
n||7 }q|rt|S |S rg )r r r3 r* )rV r datar r r r s
zRawIOBase.readallc C rX )Nr rZ rV r! r r r r re zRawIOBase.readintoc C rX Nr rZ r r r r r re zRawIOBase.writeNr )rQ rR rS r r r r r r r r r w s
r )r1 c @ sJ e Zd Z dddZdddZdd Zdd Zd
d Zd d
Zdd Z dS )BufferedIOBaser c C rX Nr rZ r r r r r s zBufferedIOBase.readc C rX )Nread1rZ r r r r r s zBufferedIOBase.read1c C | j |ddS )NFr _readintor r r r r s zBufferedIOBase.readintoc C r )NTr r r r r r readinto1 zBufferedIOBase.readinto1c C sV t |ts t|}|d}|r| t|}n| t|}t|}||d |< |S NB)r%
memoryviewcastr r- r )rV r! r r r r r r r s
zBufferedIOBase._readintoc C rX r rZ r r r r r r zBufferedIOBase.writec C rX NdetachrZ r_ r r r r zBufferedIOBase.detachNr )
rQ rR rS r r r r r r r r r r r r s
r c @ s e Zd Z dd 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 rg _rawrV rE r r r __init__,
z_BufferedIOMixin.__init__r c C s" | j ||}|dk rtd|S )Nr z#seek() returned an invalid position)rE rY r7 )rV r\ r] Z new_positionr r r rY 1 s z_BufferedIOMixin.seekc C s | j }|dk r
td|S )Nr z#tell() returned an invalid position)rE r` r7 rd r r r r` 7 s
z_BufferedIOMixin.tellNc C s4 | | | |d u r| }| j|S rg )ri r{ rj r` rE rc rd r r r rc = s z_BufferedIOMixin.truncatec C s | j rtd| j d S )Nflush on closed file)rl r. rE rj r_ r r r rj N s z_BufferedIOMixin.flushc C > | j d ur| js z | W | j d S | j w d S d S rg )rE rl rj r> r_ r r r r> S s
z_BufferedIOMixin.closec C * | j d u r td| | j}d | _|S )Nzraw stream already detached)rE r. rj r r r r r r [
z_BufferedIOMixin.detachc C
| j S rg )rE rq r_ r r r rq e r z_BufferedIOMixin.seekablec C | j S rg r r_ r r r rE h z_BufferedIOMixin.rawc C | j jS rg )rE rl r_ r r r rl l z_BufferedIOMixin.closedc C r rg )rE rN r_ r r r rN p r z_BufferedIOMixin.namec C r rg )rE r= r_ r r r r= t r z_BufferedIOMixin.modec C t d| jjdNzcannot pickle z objectr+ rU rQ r_ r r r __getstate__x z _BufferedIOMixin.__getstate__c C sH | j j}| j j}z| j}W n ty d|| Y S w d|||S )Nz<{}.{}>z<{}.{} name={!r}>)rU rR rS rN r8 format)rV modnameZclsnamerN r r r __repr__{ s
z_BufferedIOMixin.__repr__c C r rg )rE r5 r_ r r r r5 r z_BufferedIOMixin.filenoc C r rg )rE r2 r_ r r r r2 r z_BufferedIOMixin.isattyr rg )rQ rR rS r rY r` rc rj r> r rq r rE rl rN r= r r r5 r2 r r r r r # s,
r c s e Zd Z dZd 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 ur ||7 }|| _d| _d S r )r _buffer_pos)rV Z
initial_bytesbufr r r r s
zBytesIO.__init__c C s | j rtd| j S )Nz__getstate__ on closed file)rl r. __dict__copyr_ r r r r s
zBytesIO.__getstate__c C | j rtdt| jS )Nzgetvalue on closed file)rl r. r* r r_ r r r getvalue
zBytesIO.getvaluec C r )Nzgetbuffer on closed file)rl r. r r r_ r r r getbuffer r zBytesIO.getbufferc s" | j d ur
| j t d S rg )r clearsuperr> r_ rU r r r> s
z
BytesIO.closer c C s | j rtd|d u rd}nz|j}W n ty! t|dw | }|dk r.t| j}t| j| jkr8dS tt| j| j| }| j| j| }|| _t |S )Nread from closed filer r r )
rl r. r r8 r+ r- r r r r* )rV r r Znewposr! r r r r s$
z BytesIO.readc C s | |S rg )r r r r r r s
z
BytesIO.read1c C s | j rtdt|trtdt| }|j}W d n1 s"w Y |dkr-dS | j}|t| j krGd|t| j }| j |7 _ || j ||| < | j|7 _|S )Nwrite to closed file can't write str to binary streamr )
rl r. r% r) r+ r nbytesr r- r )rV r! Zviewr r\ Zpaddingr r r r s
z
BytesIO.writer c C s | j rtdz|j}W n ty t|dw | }|dkr3|dk r-td|f || _| jS |dkrCtd| j| | _| jS |dkrUtdt| j| | _| jS td)Nzseek on closed filer r negative seek position %rr r
zunsupported whence value) rl r. r r8 r+ r maxr- r )rV r\ r] pos_indexr r r rY s(
z BytesIO.seekc C | j rtd| jS )Ntell on closed file)rl r. r r_ r r r r` z BytesIO.tellc C sr | j rtd|d u r| j}n"z|j}W n ty" t|dw | }|dk r1td|f | j|d = |S )Nztruncate on closed filer r z negative truncate position %r)rl r. r r r8 r+ r )rV r\ r r r r rc s
zBytesIO.truncatec C | j rtddS Nr~ Tr r_ r r r rw
zBytesIO.readablec C r r r r_ r r r rz r zBytesIO.writablec C r r r r_ r r r rq r zBytesIO.seekablerg r r )rQ rR rS r r r r r r> r r r rY r` rc rw rz rq
__classcell__r r r r r s"
r c @ sv e Zd Z efddZdd Zdd Zddd Zdd
d Zdd
dZ dddZ
d ddZ dd Z dd Z
dddZdS ) r; c C sH | s tdt| | |dkrtd|| _| t | _d S )Nz "raw" argument must be readable.r invalid buffer size) rw r7 r r r. buffer_size_reset_read_bufLock
_read_lockrV rE r r r r r ( s zBufferedReader.__init__c C r rg )rE rw r_ r r r rw 5 r zBufferedReader.readablec C s d| _ d| _d S )Nr r ) _read_buf _read_posr_ r r r r 8 s
z BufferedReader._reset_read_bufNc C sN |d ur
|dk r
t d| j
| |W d S 1 s w Y d S )Nr z invalid number of bytes to read)r. r _read_unlockedr r r r r < s $zBufferedReader.readc C s d}d}| j }| j}|d u s|dkr^| t| jdr5| j }|d u r-||d p,d S ||d | S ||d g}d} | j }||v rK|}n |t|7 }|| q?d |p]|S t|| } || krw| j|7 _|||| S ||d g}t
| j |}
| |k r| j|
}||v r|}n| t|7 } || | |k st || }d |} | |d | _ d| _| r| d | S |S )Nr )r Nr r r )
r r r r rE r r r- r joinr r r ) rV r Z
nodata_valZ empty_valuesr r\ chunkZchunksZ current_sizeavailZwantedoutr r r r I sR
z BufferedReader._read_unlockedr c C s6 | j
| |W d S 1 sw Y d S rg )r _peek_unlockedr r r r r } s $zBufferedReader.peekc C sr t || j}t| j| j }||k s|dkr1| j| }| j|}|r1| j| jd | | _d| _| j| jd S r )r r r- r r rE r )rV r ZwantZhaveZto_readZcurrentr r r r s
z BufferedReader._peek_unlockedr c C sl |dk r| j }|dkrdS | j | d | t|t| j| j W d S 1 s/w Y d S )Nr r r )r r r r r r- r r r r r r r s
$zBufferedReader.read1c C s| t |ts
t|}|jdkrdS |d}d}| j |t|k rtt| j| j t|}|rT| j| j| j| |||| < | j|7 _||7 }|t|krTn@t|| | j kro| j
||d }|sjn2||7 }n
|rs|sy| dsyn+|r~|r~n.|t|k s"W d |S W d |S W d |S W d |S W d |S W d |S 1 sw Y |S )Nr r r )
r% r r r r r- r r r r rE r r )rV r r writtenr r r r r r s^
zBufferedReader._readintoc C s t | t| j | j S rg )r r` r- r r r_ r r r r` s zBufferedReader.tellc C sp |t vrtd| j# |dkr|t| j| j 8 }t| ||}| |W d S 1 s1w Y d S )Ninvalid whence valuer ) valid_seek_flagsr. r r- r r r rY r r[ r r r rY s $zBufferedReader.seekrg r r )rQ rR rS r3 r rw r r r r r r r r` rY r r r r r; s
4
.r; c @ s^ e Zd Z efddZdd Zdd Zddd Zd
d Zd d
Z dd Z
dddZ dd Z dS )r: c C sF | stdt| | |dkrtd|| _t | _t | _ d S )Nz "raw" argument must be writable.r r )
rz r7 r r r. r r
_write_bufr _write_lockr r r r r s zBufferedWriter.__init__c C r rg )rE rz r_ r r r rz r zBufferedWriter.writablec C s t |tr td| ju | jrtdt| j| jkr | t| j}| j
| t| j| }t| j| jkrxz| W n7 t yw } z+t| j| jkrmt| j| j }||8 }| jd | j | _t |j |j
|W Y d }~nd }~ww |W d S 1 sw Y d S )Nr r )r% r) r+ r rl r. r- r r _flush_unlockedextendBlockingIOErrorerrnostrerror)rV r! Zbeforer eZoverager r r r s0
$zBufferedWriter.writeNc C sP | j | |d u r| j }| j|W d S 1 s!w Y d S rg )r r rE r` rc rd r r r rc s
$zBufferedWriter.truncatec C s4 | j
| W d d S 1 sw Y d S rg )r r r_ r r r rj s
"zBufferedWriter.flushc C s | j rtd| jrDz | j| j}W n ty tdw |d u r*ttjdd|t | jks5|dk r9t
d| jd |= | js
d S d 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) rl r. r rE r r RuntimeErrorr ZEAGAINr- r7 rV r r r r r s" z BufferedWriter._flush_unlockedc C s t | t| j S rg )r r` r- r r_ r r r r` . r zBufferedWriter.tellr c C sP |t vrtd| j | t| ||W d S 1 s!w Y d S )Nr )r r. r r r rY r[ r r r rY 1 s $zBufferedWriter.seekc C s | j | jd u s | jr W d d S W d n1 s w Y z | W | j | j W d d S 1 s>w Y d S | j
| j W d w 1 sXw Y w rg )r rE rl rj r> r_ r r r r> 8 s
* zBufferedWriter.closerg r )
rQ rR rS r3 r rz r rc rj r r` rY r> r r r r r: s
r: c @ s e Zd Z efddZd ddZdd Zdd Zd d d Zd d
dZ dd Z
dd Z dd Z dd Z
dd Zdd Zedd Zd S ) BufferedRWPairc C s> | s td| stdt||| _t||| _d S )Nz#"reader" argument must be readable.z#"writer" argument must be writable.)rw r7 rz r; readerr: writer)rV r r
r r r r r X s zBufferedRWPair.__init__r c C s |d u rd}| j |S Nr )r r r r r r r f s zBufferedRWPair.readc C | j |S rg )r r r r r r r k zBufferedRWPair.readintoc C r rg )r
r r r r r r n r zBufferedRWPair.writer c C r rg )r r r r r r r q r zBufferedRWPair.peekc C r rg )r r r r r r r t r zBufferedRWPair.read1c C r rg )r r r r r r r w r zBufferedRWPair.readinto1c C r rg )r rw r_ r r r rw z r zBufferedRWPair.readablec C r rg )r
rz r_ r r r rz } r zBufferedRWPair.writablec C r rg )r
rj r_ r r r rj r zBufferedRWPair.flushc C s( z
| j W | j d S | j w rg )r
r> r r_ r r r r> s zBufferedRWPair.closec C s | j p | j S rg )r r2 r
r_ r r r r2 r zBufferedRWPair.isattyc C r rg )r
rl r_ r r r rl r zBufferedRWPair.closedNr r )rQ rR rS r3 r r r r r r r rw rz rj r> r2 r rl r r r r r H s
r c @ sl e Zd Z efddZdddZdd Zdd d
Zdd d Zd
d Z dddZ
dddZ dd Z dd Z
dS )r9 c C s( | t| || t| || d S rg )ru r; r r: r r r r r s zBufferedRandom.__init__r c C s |t vrtd| | jr/| j | j| jt| j d W d n1 s*w Y | j||}| j | W d n1 sHw Y |dk rUt
d|S )Nr r r z seek() returned invalid position) r r. rj r r rE rY r r- r r7 r[ r r r rY s
zBufferedRandom.seekc C s | j rt| S t| S rg )r r: r` r; r_ r r r r` s
zBufferedRandom.tellNc C s |d u r| }t| |S rg )r` r: rc rd r r r rc s zBufferedRandom.truncatec C s |d u rd}| t| |S r )rj r; r r r r r r s zBufferedRandom.readc C | t| |S rg )rj r; r r r r r r zBufferedRandom.readintoc C r rg )rj r; r r r r r r r zBufferedRandom.peekr c C r rg )rj r; r r r r r r r zBufferedRandom.read1c C r rg )rj r; r r r r r r r zBufferedRandom.readinto1c C sZ | j r'| j | j| jt| j d | W d n1 s"w Y t| |S r ) r r rE rY r r- r r: r r r r r r s
zBufferedRandom.writer rg r )rQ rR rS r3 r rY r` rc r r r r r r r r r r r9 s
r9 c s e Zd ZdZdZdZdZdZdZdZ d0ddZ
dd Z d
d Z d d
Z
dd Zd1ddZd1ddZdd Zdd Zdd ZefddZd d Zd1d 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 )2r1 r FNTr c
C s0 | j dkrz| jrt| j W d| _ nd| _ w t|tr"tdt|tr2|}|dk r1tdnd}t|t s@td|f t
|t
dksOtd|f t dd |D d ksa| d
d kretd d |v rvd
| _
d
| _tjtjB }n(d|v rd
| _d}n d|v rd
| _tjtjB }nd|v rd
| _d
| _tjtjB }d
|v rd
| _d
| _| jr| jr|tjO }n| jr|tjO }n|tjO }|ttddO }ttddpttdd}||O }d }z|dk r|std|d u rt||d}n|||}t|tstd|dk r td|}|st|d || _t |} zt | j r2t t!j"t#t!j"|W n
t$y= Y nw t| dd| _%| j%d krNt&| _%t'rWt'|tj( || _)| jrz t*|dt+ W n ty }
z|
j!t!j,krx W Y d }
~
nd }
~
ww W n |d urt| || _ d S )Nr r z$integer argument expected, got floatznegative file descriptorzinvalid mode: %szxrwab+c s s | ]}|d v V qdS )ZrwaxNr ).0cr r r 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 descriptorFr6 )-_fd_closefdr' r> r% floatr+ r& r. r) r, sumcount_created _writableO_EXCLO_CREAT _readableO_TRUNC
_appendingO_APPENDO_RDWRO_RDONLYO_WRONLYgetattrrI r7 set_inheritabler4 statS_ISDIRst_modeIsADirectoryErrorr ZEISDIRr r8 _blksizer3 _setmoder rN lseekr ZESPIPE) rV r? r= rC r$ fdr Znoinherit_flagZowned_fdZfdfstatr r r r r s
$
zFileIO.__init__c C sN | j dkr!| jr#| js%dd l}|jd| f td| d | d S d S d S d S )Nr zunclosed file %rr
)r source)r r rl r r ResourceWarningr> )rV r r r r rn ] s zFileIO.__del__c C r r r r_ r r r r d r zFileIO.__getstate__c C sj d| j j| j jf }| jrd| S z| j}W n ty* d|| j| j| jf Y S w d||| j| jf S )Nz%s.%sz
<%s [closed]>z <%s fd=%d mode=%r closefd=%r>z <%s name=%r mode=%r closefd=%r>) rU rR rS rl rN r8 r r= r )rV
class_namerN r r r r g s
zFileIO.__repr__c C | j stdd S )NzFile not open for reading)r! rP r_ r r r ry u zFileIO._checkReadablec C r5 )NzFile not open for writing)r rP rs r r r r{ y r6 zFileIO._checkWritablec C sP | | |d u s|dk r| S zt| j|W S ty' Y d S w r )ri ry r r' r r r r r r r r } s z FileIO.readc C s | | t}zt| jdt}t| jj}||kr%|| d }W n t y/ Y nw t
} t ||krEt |}|t |t7 }|t | }z t
| j|}W n tye |rbY t|S Y d S w |sm t|S ||7 }q4r^ )ri ry r3 r' r0 r r r4 st_sizer7 r r- r r r r* )rV bufsizer\ endrF r r r r r r s@ zFileIO.readallc C s6 t |d}| t|}t|}||d |< |S r )r r r r- )rV r! mr r r r r r s zFileIO.readintoc C s8 | | zt| j|W S ty Y d S w rg )ri r{ r' r r r r r r r r s z FileIO.writec C s, t |tr
td| t| j||S )Nzan integer is required)r% r r+ ri r' r0 r r[ r r r rY s
z FileIO.seekc C s | t| jdtS r )ri r' r0 r r r_ r r r r` s z FileIO.tellc C s4 | | |d u r| }t| j| |S rg )ri r{ r` r' ftruncater r r r r rc s zFileIO.truncatec sL | j s$z| jrt| j W t d S W t d S t w d S rg )rl r r' r> r r r_ r r r r> s z FileIO.closec C sJ | | jd u r"z| W n ty d| _Y | jS w d| _| jS )NFT)ri _seekabler` r7 r_ r r r rq s
zFileIO.seekablec C | | jS rg )ri r! r_ r r r rw zFileIO.readablec C r= rg )ri r r_ r r r rz r> zFileIO.writablec C r= rg )ri r r_ r r r r5
r> z
FileIO.filenoc C s | t| jS rg )ri r' r2 r r_ r r r r2 s z
FileIO.isattyc C r| rg )r r_ r r r rC s zFileIO.closefdc C sB | j r | jr dS dS | jr| jrdS dS | jr | jr dS dS dS )Nzxb+Zxbzab+Zabzrb+rJ wb)r r! r# r r_ r r r r= s z FileIO.mode)r TNrg )"rQ rR rS r r r! r r# r< r r rn r r ry r{ r r r r r rY r` rc r> rq rw rz r5 r2 r rC r= r r r r r r1 s>
y
#
r1 c @ s^ e Zd Z dddZdd ZdddZd d
Zd d Zed
d Z edd Z
edd Z dS )
TextIOBaser c C rX r rZ r r r r r : s zTextIOBase.readc C rX r rZ )rV sr r r r D zTextIOBase.writeNc C rX rb rZ rd r r r rc H rB zTextIOBase.truncatec C rX )Nr rZ r_ r r r r L r zTextIOBase.readlinec C rX r rZ r_ r r r r S r zTextIOBase.detachc C d S rg r r_ r r r r \ s zTextIOBase.encodingc C rC rg r r_ r r r newlinesa s zTextIOBase.newlinesc C rC rg r r_ r r r rA k s zTextIOBase.errorsr rg ) rQ rR rS r r rc r r r r rD rA r r r r r@ 2 s
r@ c @ sR e Zd Z dddZdddZdd Zd d
Zd d Zd
ZdZ dZ
e dd Z dS )IncrementalNewlineDecoderstrictc C s, t jj| |d || _|| _d| _d| _d S )N)rA r F)codecsIncrementalDecoderr translatedecoderseennl pendingcr)rV rJ rI rA r r r r | s
z"IncrementalNewlineDecoder.__init__Fc C s | j d u r|}n| j j||d}| jr |s|r d| }d| _|dr.|s.|d d }d| _|d}|d| }|d| }| j|oH| j|oL| jB |oQ| jB O _| j rh|r`|
dd}|rh|
dd}|S )Nfinal
Fr T
) rJ decoderL r r rK _LF_CR_CRLFrI replace)rV inputrN outputZcrlfZcrZlfr r r rR s*
z IncrementalNewlineDecoder.decodec C s@ | j d u r
d}d}n| j \}}|dK }| jr |dO }||fS )Nr r r )rJ getstaterL )rV r flagr r r rY s
z"IncrementalNewlineDecoder.getstatec C s< |\}}t |d@ | _| jd ur | j||d? f d S d S r )boolrL rJ setstate)rV stater rZ r r r r\ s
z"IncrementalNewlineDecoder.setstatec C s( d| _ d| _| jd ur| j d S d S )Nr F)rK rL rJ resetr_ r r r r^ s
z IncrementalNewlineDecoder.resetr r
c C s
d| j S )N)NrQ rO )rO rQ rP )rQ rP )rO rP )rO rQ rP )rK r_ r r r rD s z"IncrementalNewlineDecoder.newlinesN)rF )F)
rQ rR rS r rR rY r\ r^ rS rT rU r rD r r r r rE u s
rE c @ s e Zd Z dZdZ dNddZdd Z dNdd Zd
d Ze d d
Z
e dd Z e dd Z e dd Z
e dd ZddedddddZdd 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 dOd3d4Z d5d6 Z d7d8 Z 9 9dPd:d;Z!dd? Z#dOd@dAZ$dBdC Z%dQdDdEZ&dOdFdGZ'dHdI Z(dOdJdKZ)e dLdM Z*dS )Rr< i NFc C s0 | | t|}|dkr$z t| pd}W n ttfy# Y nw |dkr?zdd l}W n ty9 d}Y nw | d}t
|t sJt d| t
|jsXd}t|| |d u r_d}nt
|t sjt d| trqt
| || _d | _d| _d | _| j | _| _t| jd
| _ | ||||| d S ) Nr r utf-8Fr zG%r is not a text encoding; use codecs.open() to handle arbitrary codecsrF r r# r ) _check_newliner r' device_encodingr5 r8 rP r ImportErrorZgetpreferredencodingr% r) r. rG lookup_is_text_encoding LookupError
_CHECK_ERRORS lookup_errorr _decoded_chars_decoded_chars_used _snapshotrH rq r< _tellingr
_has_read1
_configure) rV rH r rA rB rG
write_throughr rt r r r r sF
zTextIOWrapper.__init__c C s> |d urt |tstdt|f |dvr td|f d S )Nzillegal newline type: %r)Nr# rQ rO rP zillegal newline value: %r)r% r) r+ typer. )rV rB r r r ra s
z TextIOWrapper._check_newlinec C s || _ || _d | _d | _d| _| | _|d u | _|| _|dk| _|p$t j
| _ || _ || _
| jrQ| rS| j }|dkrUz
| d W d S tyP Y d S w d S d S d S )N r# r ) _encoding_errors_encoder_decoder _b2cratio_readuniversal_readtranslate_readnl_writetranslater' linesep_writenl_line_buffering_write_throughr< rz rH r` _get_encoderr\ rf )rV r rA rB rG ro positionr r r rn s,
zTextIOWrapper._configurec C s| d | jj| jj}z| j}W n ty Y nw |d |7 }z| j}W n ty. Y nw |d |7 }|d | j S )Nz<{}.{}z name={0!r}z mode={0!r}z encoding={0!r}>)r rU rR rS rN r8 r= r )rV rF rN r= r r r r B s
zTextIOWrapper.__repr__c C r rg )rr r_ r r r r S r zTextIOWrapper.encodingc C r rg )rs r_ r r r rA W r zTextIOWrapper.errorsc C r rg )r} r_ r r r rG [ r z TextIOWrapper.line_bufferingc C r rg )r~ r_ r r r ro _ r zTextIOWrapper.write_throughc C r rg )r r_ r r r rH c r zTextIOWrapper.buffer)r rA rB rG ro c C s | j d ur|d us|d us|turtd|d u r%|d u r"| j}nd}n t|ts0td| |d u r8| j}n t|tsCtd| |tu rJ| j}| | |d u rV| j
}|d u r]| j }| |
||||| d S )NzPIt is not possible to set the encoding or newline of stream after the first readrF r r )ru EllipsisrP rs r% r) r+ rr ry ra rG ro rj rn )rV r rA rB rG ro r r r reconfigureg s8
zTextIOWrapper.reconfigurec C r r} )rl r. r< r_ r r r rq r zTextIOWrapper.seekablec C r rg )rH rw r_ r r r rw r zTextIOWrapper.readablec C r rg )rH rz r_ r r r rz r zTextIOWrapper.writablec C s | j | j| _d S rg )rH rj r< rl r_ r r r rj s
zTextIOWrapper.flushc C r rg )rH rl rj r> r_ r r r r> s
zTextIOWrapper.closec C r rg )rH rl r_ r r r rl r zTextIOWrapper.closedc C r rg )rH rN r_ r r r rN r zTextIOWrapper.namec C r rg )rH r5 r_ r r r r5 r zTextIOWrapper.filenoc C r rg )rH r2 r_ r r r r2 r zTextIOWrapper.isattyc C s | j rtdt|tstd|jj t|}| js | j o"d|v }|r4| jr4| j
dkr4| d| j
}| j p:|
}||}| j| | j rS|sOd|v rS| | d d | _| jrc| j |S )Nr z can't write %s to text streamrQ rO r# )rl r. r% r) r+ rU rQ r- rz r} r| rV rt r encoderH r rj _set_decoded_charsrk ru r^ )rV rA ZlengthZhaslfencoderr! r r r r s*
zTextIOWrapper.writec C s t | j}|| j| _| jS rg )rG getincrementalencoderrr rs rt )rV Z make_encoderr r r r s zTextIOWrapper._get_encoderc C s2 t | j}|| j}| jrt|| j}|| _|S rg )rG getincrementaldecoderrr rs rw rE rx ru )rV Z make_decoderrJ r r r _get_decoder s
zTextIOWrapper._get_decoderc C s || _ d| _d S r )ri rj )rV charsr r r r s
z TextIOWrapper._set_decoded_charsc C sH | j }|d u r| j|d }n | j||| }| j t|7 _ |S rg )rj ri r- )rV r offsetr r r r _get_decoded_chars s z TextIOWrapper._get_decoded_charsc C s& | j |k r
td| j |8 _ d S )Nz"rewind decoded_chars out of bounds)rj AssertionErrorr
r r r _rewind_decoded_chars s
z#TextIOWrapper._rewind_decoded_charsc C s | j d u r
td| jr| j \}}| jr | j| j}n| j| j}| }| j ||}|
| |rBt |t | j | _
nd| _
| jrO||| f| _| S )Nz
no decoderrq )ru r. rl rY rm rH r _CHUNK_SIZEr rR r r- ri rv rk )rV
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[ )rV r r
bytes_to_feedneed_eof
chars_to_skipr r r _pack_cookie s
zTextIOWrapper._pack_cookiec C sJ t |d\}}t |d\}}t |d\}}t |d\}}|||t||fS )Nl )divmodr[ )rV Zbigintrestr r r r r r r r _unpack_cookie$ s
z TextIOWrapper._unpack_cookiec C s> | j std| jstd| | j }| j}|d u s#| jd u r,| j r*t
d|S | j\}}|t |8 }| j }|dkrD|
||S | }zt| j| }d}|dkr|d|f t ||d | } | |kr| \}
} |
s{| }|| 8 }n |t |
8 }d}n||8 }|d }|dksVd}|d|f || } |}
|dkr|
| |
W || S d}d}d}t|t |D ]7}|d7 }|t ||||d 7 }| \}}|s||kr| |7 } ||8 }|dd}
}}||kr nq|t |jdd d
7 }d }||k r
td |
| |
|||W || S || w ) N!underlying stream is not seekablez(telling position disabled by next() callzpending decoded textr r r r
FTrM z'can't reconstruct logical file position)r< rP rl r7 rj rH r` ru rk ri r r- rj r rY r& rv r\ rR range)rV r rJ r Z
next_inputr Z saved_stateZ
skip_bytesZ skip_backr r! d start_posZ start_flagsZ bytes_fedr Z
chars_decodedir r r r r` + s~
zTextIOWrapper.tellc C s$ | |d u r | }| j|S rg )rj r` rH rc rd r r r rc s zTextIOWrapper.truncatec C r )Nzbuffer is already detached)rH r. rj r )rV rH r r r r r zTextIOWrapper.detachc s fdd} j r
td jstd|tkr'|dkr tdd} }n-|tkrT|dkr3td j d|}
d d _ j rN j
|| |S |dkr_td |f |dk rjtd
|f |\}}}}} j |
d d _ |dkr j r j
n j s|s| r j p _ j d |f |d f _ | rԈ j|}
j |
| ||
f _ t j| k rtd | _|| |S )
Nc sL z j p }W n
ty Y d S w | dkr |d d S | d S r )rt r rf r\ r^ )r r r_ r r _reset_encoder s z*TextIOWrapper.seek.._reset_encoderr r 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)rl r. r< rP r r` r rj rH rY r rk ru r^ r r r\ r rR r- ri r7 rj ) rV Zcookier] r r r r r r r r r r_ r rY s`
zTextIOWrapper.seekc C s | |d u r d}nz|j}W n ty t|dw | }| jp(| }|dk rE| |j| j dd }|
d d | _ |S d}| |}t ||k rl|sl|
}|| |t | 7 }t ||k rl|rT|S )Nr r r TrM r# F)ry r r8 r+ ru r r rR rH r r rk r- r )rV r r rJ rF r r r r r s0
zTextIOWrapper.readc C s( d| _ | }|sd | _| j| _ t|S rp )rl r rk r< r r r r r r
s zTextIOWrapper.__next__c C s | j rtd|d u rd}nz|j}W n ty! t|dw | }| }d}| js2| d }} | jrN| d|}|dkrI|d }nt
|}nU| j r| d|}| d|}|dkro|dkrjt
|}n9|d }nb|dkrx|d }nY||k r|d }nP||d kr|d }nE|d }n@| | j }|dkr|t
| j }n.|dkrt
||kr|}n!|
r| jrn|
s| jr|| 7 }n
| d
d | _|S q7|dkr||kr|}| t
|| |d | S ) Nr r r r TrQ r rO r
r# )rl r. r r8 r+ r ru r rx r r- rw ry r ri r rk r ) rV r r r startr\ endposZnlposZcrposr r r r
s|
@ zTextIOWrapper.readlinec C s | j r| j jS d S rg )ru rD r_ r r r rD i
s zTextIOWrapper.newlines)NNNFFrg )r r Fr r )+rQ rR rS r r r ra rn r r r rA rG ro rH r r rq rw rz rj r> rl rN r5 r2 r r r r r r r r r r` rc r rY r r r rD r r r r r< sp
-
$
)
*
c
K
]r< c sP e Zd Z d fdd Zdd Zdd Zed d
Zed d Zd
d Z Z
S )StringIOr# rQ c sj t t| jt dd|d |d u rd| _|d ur3t|ts'tdt |j
| | | d d S d S )Nr`
surrogatepass)r rA rB Fz*initial_value must be str or None, not {0}r )
r r r r rz r% r) r+ r rp rQ r rY )rV Z
initial_valuerB r r r r u
s
zStringIO.__init__c C sT | | jp
| }| }| z|j| j ddW || S || w )NTrM ) rj ru r rY r^ rR rH r r\ )rV rJ Z old_stater r r r
s zStringIO.getvaluec C s
t | S rg )objectr r_ r r r r
s
zStringIO.__repr__c C d S rg r r_ r r r rA
zStringIO.errorsc C r rg r r_ r r r r
r zStringIO.encodingc C s | d d S r rZ r_ r r r r
s zStringIO.detach)r# rQ ) rQ rR rS r r r r rA r r r r r r r r n
s
r )r
)r r NNNTN)9r' abcrG r r* r
_threadr r platformZmsvcrtr r/ ior r r r r r addr SEEK_DATAr3 r r dev_moderm rg r staticmethodrI rL open_coder8 rO rP r7 r. ABCMetarT registerr _ior1 r r r r; r: r r9 r@ rH rE r< r r r r r s
\
# =
gk CiIJ Y @U )