JezK
Edit File: _pyio.cpython-35.opt-2.pyc
���\ W � @ s[ d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z y d d l m Z Wn" e k r� d d l m Z Yn Xe j d d h k r� d d l m Z n d Z d d l Z d d l m Z m Z m Z m Z d d d h Z e e d � r'e j e j � e j e j � d d Z e Z d d d d d d d d d � Z Gd d � d � Z Gd d � d � Z y e j Z Wn+ e k r�Gd d � d e! e" � Z Yn XGd d � d d e j# �Z$ e j$ j% e$ � Gd d � d e$ � Z& e j& j% e& � d d l' m( Z( e& j% e( � Gd d � d e$ � Z) e j) j% e) � Gd d � d e) � Z* Gd d! � d! e) � Z+ Gd" d# � d# e* � Z, Gd$ d% � d% e* � Z- Gd& d' � d' e) � Z. Gd( d) � d) e- e, � Z/ Gd* d+ � d+ e& � Z( Gd, d- � d- e$ � Z0 e j0 j% e0 � Gd. d/ � d/ e j1 � Z2 Gd0 d1 � d1 e0 � Z3 Gd2 d3 � d3 e3 � Z4 d S)4� N)� allocate_lock�win32�cygwin)�setmode)�__all__�SEEK_SET�SEEK_CUR�SEEK_END� � � SEEK_HOLE� i �rTc C sS t | t t t f � s( t d | � � t | t � sG t d | � � t | t � sf t d | � � | d k r� t | t � r� t d | � � | d k r� t | t � r� t d | � � t | � } | t d � s� t | � t | � k rt d | � � d | k } d | k } d | k } d | k } d | k } d | k } d | k } d | k r�| st| st| r�t d � � d d l } | j d t d � d } | r�| r�t d � � | | | | d k r�t d � � | p�| p�| p�| st d � � | r#| d k r#t d � � | rA| d k rAt d � � | r_| d k r_t d � � t | | rqd ptd | r�d p�d | r�d p�d | r�d p�d | r�d p�d | d | �} | } ynd } | d k s�| d k r| j � rd! } d } | d k r]t } y t j | j � � j } Wn t t f k rJYn X| d k r]| } | d k rut d � � | d k r�| r�| St d � � | r�t | | � } nL | s�| s�| r�t | | � } n( | r�t | | � } n t d | � � | } | r | St | | | | | � } | } | | _ | SWn | j � � Yn Xd S)"Nzinvalid file: %rzinvalid mode: %rzinvalid buffering: %rzinvalid encoding: %rzinvalid errors: %rzaxrwb+tU�xr �w�a�+�t�b�Uz$can't use U and writing mode at oncer 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� �openerFzinvalid buffering sizez can't have unbuffered text I/Ozunknown mode: %r���)� isinstance�str�bytes�int� TypeError�set�len� ValueError�warnings�warn�DeprecationWarning�FileIO�isatty�DEFAULT_BUFFER_SIZE�os�fstat�fileno� st_blksize�OSError�AttributeError�BufferedRandom�BufferedWriter�BufferedReader� TextIOWrapper�mode�close)�filer1 � buffering�encoding�errors�newline�closefdr ZmodesZcreatingZreadingZwritingZ appendingZupdating�textZbinaryr! �raw�result�line_bufferingZbs�buffer� r> �5/opt/rh/rh-python35/root/usr/lib64/python3.5/_pyio.py�open) s� { ( ?$ r@ c @ s e Z d Z d d � Z d S)� DocDescriptorc C s d t j S)Nz\open(file, mode='r', buffering=-1, encoding=None, errors=None, newline=None, closefd=True) )r@ �__doc__)�self�obj�typr> r> r? �__get__� s zDocDescriptor.__get__N)�__name__� __module__� __qualname__rF r> r> r> r? rA � s rA c @ s% e Z d Z e � Z d d � Z d S)� OpenWrapperc O s t | | � S)N)r@ )�cls�args�kwargsr> r> r? �__new__ s zOpenWrapper.__new__N)rG rH rI rA rB rN r> r> r> r? rJ s rJ c @ s e Z d Z d S)�UnsupportedOperationN)rG rH rI r> r> r> r? rO s rO c @ sT e Z d Z d d � Z d d d � Z d d � Z d d d � Z d d � Z d Z d d � Z d d � Z d d � Z d d d � Z d d � Z d d d � Z d d � Z d d d � Z e d d � � Z d d d! � Z d" d# � Z d$ d% � Z d& d' � Z d( d) � Z d5 d+ d, � Z d- d. � Z d/ d0 � Z d d1 d2 � Z d3 d4 � Z d S)6�IOBasec C s t d | j j | f � � d S)Nz%s.%s() not supported)rO � __class__rG )rC �namer> r> r? � _unsupported> s zIOBase._unsupportedr c C s | j d � d S)N�seek)rS )rC �pos�whencer> r> r? rT E s z IOBase.seekc C s | j d d � S)Nr r )rT )rC r> r> r? �tellU s z IOBase.tellNc C s | j d � d S)N�truncate)rS )rC rU r> r> r? rX Y s zIOBase.truncatec C s | j � d S)N)� _checkClosed)rC r> r> r? �flushc s z IOBase.flushFc C s( | j s$ z | j � Wd d | _ Xd S)NT)�_IOBase__closedrZ )rC r> r> r? r2 m s z IOBase.closec C s y | j � Wn Yn Xd S)N)r2 )rC r> r> r? �__del__x s zIOBase.__del__c C s d S)NFr> )rC r> r> r? �seekable� s zIOBase.seekablec C s. | j � s* t | d k r! d n | � � d S)Nz File or stream is not seekable.)r] rO )rC �msgr> r> r? �_checkSeekable� s zIOBase._checkSeekablec C s d S)NFr> )rC r> r> r? �readable� s zIOBase.readablec C s. | j � s* t | d k r! d n | � � d S)Nz File or stream is not readable.)r` rO )rC r^ r> r> r? �_checkReadable� s zIOBase._checkReadablec C s d S)NFr> )rC r> r> r? �writable� s zIOBase.writablec C s. | j � s* t | d k r! d n | � � d S)Nz File or stream is not writable.)rb rO )rC r^ r> r> r? �_checkWritable� s zIOBase._checkWritablec C s | j S)N)r[ )rC r> r> r? �closed� s z IOBase.closedc C s+ | j r' t | d k r d n | � � d S)Nz I/O operation on closed file.)rd r )rC r^ r> r> r? rY � s zIOBase._checkClosedc C s | j � | S)N)rY )rC r> r> r? � __enter__� s zIOBase.__enter__c G s | j � d S)N)r2 )rC rL r> r> r? �__exit__� s zIOBase.__exit__c C s | j d � d S)Nr) )rS )rC r> r> r? r) � s z IOBase.filenoc C s | j � d S)NF)rY )rC r> r> r? r% � s z IOBase.isattyr c s� t � d � r' � � f d d � } n d d � } � d k rH d � n t � t � sc t d � � t � } xU � d k s� t | � � k r� � j | � � } | s� P| | 7} | j d � ro Pqo Wt | � S) N�peekc sW � j d � } | s d S| j d � d p5 t | � } � d k rS t | � � } | S)Nr s r )rg �findr �min)Z readahead�n)rC �sizer> r? � nreadahead� s z#IOBase.readline.<locals>.nreadaheadc S s d S)Nr r> r> r> r> r? rl � s r zsize must be an integerr s r ) �hasattrr r r � bytearrayr �read�endswithr )rC rk rl �resr r> )rC rk r? �readline� s ! zIOBase.readlinec C s | j � | S)N)rY )rC r> r> r? �__iter__ s zIOBase.__iter__c C s | j � } | s t � | S)N)rr � StopIteration)rC �liner> r> r? �__next__ s zIOBase.__next__c C sm | d k s | d k r" t | � Sd } g } x8 | D]0 } | j | � | t | � 7} | | k r5 Pq5 W| S)Nr )�list�appendr )rC Zhintrj �linesru r> r> r? � readlines s zIOBase.readlinesc C s, | j � x | D] } | j | � q Wd S)N)rY �write)rC ry ru r> r> r? � writelines! s zIOBase.writelinesr ) rG rH rI rS rT rW rX rZ r[ r2 r\ r] r_ r` ra rb rc �propertyrd rY re rf r) r% rr rs rv rz r| r> r> r> r? rP s2 # % rP � metaclassc @ sC e Z d Z d d d � Z d d � Z d d � Z d d � Z d S) � RawIOBaser c C sp | d k r d } | d k r( | j � St | j � � } | j | � } | d k rY d S| | d � =t | � S)Nr r r )�readallrn � __index__�readintor )rC rk r rj r> r> r? ro 7 s zRawIOBase.readc C sH t � } x$ | j t � } | s" P| | 7} q W| r@ t | � S| Sd S)N)rn ro r& r )rC rq �datar> r> r? r� H s zRawIOBase.readallc C s | j d � d S)Nr� )rS )rC r r> r> r? r� V s zRawIOBase.readintoc C s | j d � d S)Nr{ )rS )rC r r> r> r? r{ ^ s zRawIOBase.writeNr )rG rH rI ro r� r� r{ r> r> r> r? r ) s r )r$ c @ sj e Z d Z d d d � Z d d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d S)�BufferedIOBaseNc C s | j d � d S)Nro )rS )rC rk r> r> r? ro { s zBufferedIOBase.readc C s | j d � d S)N�read1)rS )rC rk r> r> r? r� � s zBufferedIOBase.read1c C s | j | d d �S)Nr� F)� _readinto)rC r r> r> r? r� � s zBufferedIOBase.readintoc C s | j | d d �S)Nr� T)r� )rC r r> r> r? � readinto1� s zBufferedIOBase.readinto1c C s} t | t � s t | � } | j d � } | rH | j t | � � } n | j t | � � } t | � } | | d | � <| S)N�B)r � memoryview�castr� r ro )rC r r� r� rj r> r> r? r� � s zBufferedIOBase._readintoc C s | j d � d S)Nr{ )rS )rC r r> r> r? r{ � s zBufferedIOBase.writec C s | j d � d S)N�detach)rS )rC r> r> r? r� � s zBufferedIOBase.detach) rG rH rI ro r� r� r� r� r{ r� r> r> r> r? r� j s r� c @ s e Z d Z d d � Z d d d � Z d d � Z d d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z e d d � � Z e d d � � Z e d d � � Z e d d � � Z d d � Z d! d" � Z d# d$ � Z d% d& � Z d S)'�_BufferedIOMixinc C s | | _ d S)N)�_raw)rC r: r> r> r? �__init__� s z_BufferedIOMixin.__init__r c C s1 | j j | | � } | d k r- t d � � | S)Nr z#seek() returned an invalid position)r: rT r+ )rC rU rV Z new_positionr> r> r? rT � s z_BufferedIOMixin.seekc C s+ | j j � } | d k r' t d � � | S)Nr z#tell() returned an invalid position)r: rW r+ )rC rU r> r> r? rW � s z_BufferedIOMixin.tellNc C s2 | j � | d k r" | j � } | j j | � S)N)rZ rW r: rX )rC rU r> r> r? rX � s z_BufferedIOMixin.truncatec C s& | j r t d � � | j j � d S)Nzflush of closed file)rd r r: rZ )rC r> r> r? rZ � s z_BufferedIOMixin.flushc C s< | j d k r8 | j r8 z | j � Wd | j j � Xd S)N)r: rd rZ r2 )rC r> r> r? r2 s z_BufferedIOMixin.closec C s; | j d k r t d � � | j � | j } d | _ | S)Nzraw stream already detached)r: r rZ r� )rC r: r> r> r? r� s z_BufferedIOMixin.detachc C s | j j � S)N)r: r] )rC r> r> r? r] s z_BufferedIOMixin.seekablec C s | j j � S)N)r: r` )rC r> r> r? r` s z_BufferedIOMixin.readablec C s | j j � S)N)r: rb )rC r> r> r? rb s z_BufferedIOMixin.writablec C s | j S)N)r� )rC r> r> r? r: s z_BufferedIOMixin.rawc C s | j j S)N)r: rd )rC r> r> r? rd s z_BufferedIOMixin.closedc C s | j j S)N)r: rR )rC r> r> r? rR $ s z_BufferedIOMixin.namec C s | j j S)N)r: r1 )rC r> r> r? r1 ( s z_BufferedIOMixin.modec C s t d j | j j � � � d S)Nz can not serialize a '{0}' object)r �formatrQ rG )rC r> r> r? � __getstate__, s z _BufferedIOMixin.__getstate__c C sa | j j } | j j } y | j } Wn" t k rI d j | | � SYn Xd j | | | � Sd S)Nz<{}.{}>z<{}.{} name={!r}>)rQ rH rI rR � Exceptionr� )rC �modnameZclsnamerR r> r> r? �__repr__0 s z_BufferedIOMixin.__repr__c C s | j j � S)N)r: r) )rC r> r> r? r) < s z_BufferedIOMixin.filenoc C s | j j � S)N)r: r% )rC r> r> r? r% ? s z_BufferedIOMixin.isatty)rG rH rI r� rT rW rX rZ r2 r� r] r` rb r} r: rd rR r1 r� r� r) r% r> r> r> r? r� � s$ r� c s� e Z d Z d d d � Z d d � Z d d � Z d d � Z � f d d � Z d d d � Z d d � Z d d � Z d d d � Z d d � Z d d d � Z d d � Z d d � Z d d � Z � S) �BytesIONc C s5 t � } | d k r | | 7} | | _ d | _ d S)Nr )rn �_buffer�_pos)rC Z initial_bytes�bufr> r> r? r� G s zBytesIO.__init__c C s" | j r t d � � | j j � S)Nz__getstate__ on closed file)rd r �__dict__�copy)rC r> r> r? r� N s zBytesIO.__getstate__c C s" | j r t d � � t | j � S)Nzgetvalue on closed file)rd r r r� )rC r> r> r? �getvalueS s zBytesIO.getvaluec C s" | j r t d � � t | j � S)Nzgetbuffer on closed file)rd r r� r� )rC r> r> r? � getbufferZ s zBytesIO.getbufferc s | j j � t � j � d S)N)r� �clear�superr2 )rC )rQ r> r? r2 a s z BytesIO.closec C s� | j r t d � � | d k r' d } | d k rB t | j � } t | j � | j k r^ d St t | j � | j | � } | j | j | � } | | _ t | � S)Nzread from closed filer r � r )rd r r r� r� ri r )rC rk Znewposr r> r> r? ro e s z BytesIO.readc C s | j | � S)N)ro )rC rk r> r> r? r� s s z BytesIO.read1c C s� | j r t d � � t | t � r0 t d � � t | � } | d k rL d S| j } | t | j � k r� d | t | j � } | j | 7_ | | j | | | � <| j | 7_ | S)Nzwrite to closed filez can't write str to binary streamr s )rd r r r r r r� r� )rC r rj rU Zpaddingr> r> r? r{ x s z BytesIO.writer c C s� | j r t d � � y | j Wn4 t k rV } z t d � | � WYd d } ~ Xn X| d k r� | d k r� t d | f � � | | _ nb | d k r� t d | j | � | _ n: | d k r� t d t | j � | � | _ n t d � � | j S)Nzseek on closed filezan integer is requiredr znegative seek position %rr r zunsupported whence value) rd r r� r, r r� �maxr r� )rC rU rV �errr> r> r? rT � s " " z BytesIO.seekc C s | j r t d � � | j S)Nztell on closed file)rd r r� )rC r> r> r? rW � s z BytesIO.tellc C s� | j r t d � � | d k r- | j } na y | j Wn4 t k rn } z t d � | � WYd d } ~ Xn X| d k r� t d | f � � | j | d � =| S)Nztruncate on closed filezan integer is requiredr z negative truncate position %r)rd r r� r� r, r r� )rC rU r� r> r> r? rX � s " zBytesIO.truncatec C s | j r t d � � d S)Nz I/O operation on closed file.T)rd r )rC r> r> r? r` � s zBytesIO.readablec C s | j r t d � � d S)Nz I/O operation on closed file.T)rd r )rC r> r> r? rb � s zBytesIO.writablec C s | j r t d � � d S)Nz I/O operation on closed file.T)rd r )rC r> r> r? r] � s zBytesIO.seekable)rG rH rI r� r� r� r� r2 ro r� r{ rT rW rX r` rb r] r> r> )rQ r? r� C s r� c @ s� e Z d Z e d d � Z d d � Z d d d � Z d d d � Z d d d � Z d d d � Z d d � Z d d � Z d d � Z d d d � Z d S)r/ c C sc | j � s t d � � t j | | � | d k r@ t d � � | | _ | j � t � | _ d S)Nz "raw" argument must be readable.r zinvalid buffer size) r` r+ r� r� r � buffer_size�_reset_read_buf�Lock� _read_lock)rC r: r� r> r> r? r� � s zBufferedReader.__init__c C s d | _ d | _ d S)Nr� r )� _read_buf� _read_pos)rC r> r> r? r� � s z BufferedReader._reset_read_bufNc C sF | d k r$ | d k r$ t d � � | j � | j | � SWd QRXd S)Nr z invalid number of bytes to readr )r r� �_read_unlocked)rC rk r> r> r? ro � s zBufferedReader.readc C s d } d } | j } | j } | d k s6 | d k r| j � t | j d � r� | j j � } | d k r� | | d � p� d S| | d � | S| | d � g } d } xC | j j � } | | k r� | } P| t | � 7} | j | � q� Wd j | � p| St | � | } | | k rB| j | 7_ | | | | � S| | d � g } t | j | � } xR | | k r�| j j | � } | | k r�| } P| t | � 7} | j | � qjWt | | � } d j | � } | | d � | _ d | _ | r | d | � S| S)Nr� r r� r )r� Nr ) r� r� r� rm r: r� ro r rx �joinr� r� ri ) rC rj Z nodata_valZ empty_valuesr� rU �chunkZchunksZ current_size�availZwanted�outr> r> r? r� � sN z BufferedReader._read_unlockedr c C s" | j � | j | � SWd QRXd S)N)r� �_peek_unlocked)rC rk r> r> r? rg s zBufferedReader.peekc C s� t | | j � } t | j � | j } | | k s@ | d k r� | j | } | j j | � } | r� | j | j d � | | _ d | _ | j | j d � S)Nr )ri r� r r� r� r: ro )rC rj ZwantZhaveZto_readZcurrentr> r> r? r� ( s z BufferedReader._peek_unlockedc C sp | d k r t d � � | d k r( d S| j �8 | j d � | j t | t | j � | j � � SWd QRXd S)Nr z(number of bytes to read must be positiver� r )r r� r� r� ri r r� r� )rC rk r> r> r? r� 3 s zBufferedReader.read1c C sh t | � d k r d St | t � s1 t | � } | j d � } d } | j �x | t | � k r\t t | j � | j t | � � } | r� | j | j | j | � | | | | � <| j | 7_ | | 7} | t | � k r� Pt | � | | j k r0| j j | | d � � } | s#P| | 7} n | o9| sL| j d � sLP| rS | rS PqS WWd QRX| S)Nr r� r ) r r r� r� r� ri r� r� r� r: r� r� )rC r� r� �writtenr� rj r> r> r? r� E s4 %+ zBufferedReader._readintoc C s! t j | � t | j � | j S)N)r� rW r r� r� )rC r> r> r? rW t s zBufferedReader.tellc C sv | t k r t d � � | j �N | d k rH | t | j � | j 8} t j | | | � } | j � | SWd QRXd S)Nzinvalid whence valuer ) �valid_seek_flagsr r� r r� r� r� rT r� )rC rU rV r> r> r? rT w s zBufferedReader.seek)rG rH rI r& r� r� ro r� rg r� r� r� rW rT r> r> r> r? r/ � s 4 / r/ c @ sm e Z d Z e d d � Z d d � Z d d d � Z d d � Z d d � Z d d � Z d d d � Z d S)r. c C se | j � s t d � � t j | | � | d k r@ t d � � | | _ t � | _ t � | _ d S)Nz "raw" argument must be writable.r zinvalid buffer size) rb r+ r� r� r r� rn � _write_bufr� � _write_lock)rC r: r� r> r> r? r� � s zBufferedWriter.__init__c C sT | j r t d � � t | t � r0 t d � � | j �t | j � | j k r\ | j � t | j � } | j j | � t | j � | } t | j � | j k rEy | j � Wn� t k rD} zn t | j � | j k r2t | j � | j } | | 8} | j d | j � | _ t | j | j | � � WYd d } ~ Xn X| SWd QRXd S)Nzwrite to closed filez can't write str to binary stream)rd r r r r r� r r� r� �_flush_unlocked�extend�BlockingIOError�errno�strerror)rC r Zbeforer� �eZoverager> r> r? r{ � s( +zBufferedWriter.writeNc C sJ | j �: | j � | d k r/ | j j � } | j j | � SWd QRXd S)N)r� r� r: rW rX )rC rU r> r> r? rX � s zBufferedWriter.truncatec C s | j � | j � Wd QRXd S)N)r� r� )rC r> r> r? rZ � s zBufferedWriter.flushc C s� | j r t d � � x� | j r� y | j j | j � } Wn t k rZ t d � � Yn X| d k r| t t j d d � � | t | j � k s� | d k r� t d � � | j d | � =q Wd S)Nzflush of closed filezHself.raw should implement RawIOBase: it should not raise BlockingIOErrorz)write could not complete without blockingr z*write() returned incorrect number of bytes) rd r r� r: r{ r� � RuntimeErrorr� ZEAGAINr r+ )rC rj r> r> r? r� � s ! z BufferedWriter._flush_unlockedc C s t j | � t | j � S)N)r� rW r r� )rC r> r> r? rW � s zBufferedWriter.tellr c C sJ | t k r t d � � | j �" | j � t j | | | � SWd QRXd S)Nzinvalid whence value)r� r r� r� r� rT )rC rU rV r> r> r? rT � s zBufferedWriter.seek) rG rH rI r& r� r{ rX rZ r� rW rT r> r> r> r? r. � s r. c @ s� e Z d Z e d d � Z d d d � Z d d � Z d d � Z d d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z e d d � � Z d S) �BufferedRWPairc C sX | j � s t d � � | j � s0 t d � � t | | � | _ t | | � | _ d S)Nz#"reader" argument must be readable.z#"writer" argument must be writable.)r` r+ rb r/ �readerr. �writer)rC r� r� r� r> r> r? r� � s zBufferedRWPair.__init__Nc C s" | d k r d } | j j | � S)Nr r )r� ro )rC rk r> r> r? ro � s zBufferedRWPair.readc C s | j j | � S)N)r� r� )rC r r> r> r? r� � s zBufferedRWPair.readintoc C s | j j | � S)N)r� r{ )rC r r> r> r? r{ � s zBufferedRWPair.writer c C s | j j | � S)N)r� rg )rC rk r> r> r? rg s zBufferedRWPair.peekc C s | j j | � S)N)r� r� )rC rk r> r> r? r� s zBufferedRWPair.read1c C s | j j | � S)N)r� r� )rC r r> r> r? r� s zBufferedRWPair.readinto1c C s | j j � S)N)r� r` )rC r> r> r? r` s zBufferedRWPair.readablec C s | j j � S)N)r� rb )rC r> r> r? rb s zBufferedRWPair.writablec C s | j j � S)N)r� rZ )rC r> r> r? rZ s zBufferedRWPair.flushc C s& z | j j � Wd | j j � Xd S)N)r� r2 r� )rC r> r> r? r2 s zBufferedRWPair.closec C s | j j � p | j j � S)N)r� r% r� )rC r> r> r? r% s zBufferedRWPair.isattyc C s | j j S)N)r� rd )rC r> r> r? rd s zBufferedRWPair.closed)rG rH rI r& r� ro r� r{ rg r� r� r` rb rZ r2 r% r} rd r> r> r> r? r� � s r� c @ s� e Z d Z e d d � Z d d d � Z d d � Z d d d � Z d d d � Z d d � Z d d d � Z d d � Z d d � Z d d � Z d S)r- c C s4 | j � t j | | | � t j | | | � d S)N)r_ r/ r� r. )rC r: r� r> r> r? r� * s zBufferedRandom.__init__r c C s� | t k r t d � � | j � | j r_ | j �( | j j | j t | j � d � Wd QRX| j j | | � } | j � | j � Wd QRX| d k r� t d � � | S)Nzinvalid whence valuer r z seek() returned invalid position) r� r rZ r� r� r: rT r� r r� r+ )rC rU rV r> r> r? rT / s * zBufferedRandom.seekc C s' | j r t j | � St j | � Sd S)N)r� r. rW r/ )rC r> r> r? rW @ s zBufferedRandom.tellNc C s( | d k r | j � } t j | | � S)N)rW r. rX )rC rU r> r> r? rX F s zBufferedRandom.truncatec C s, | d k r d } | j � t j | | � S)Nr r )rZ r/ ro )rC rk r> r> r? ro L s zBufferedRandom.readc C s | j � t j | | � S)N)rZ r/ r� )rC r r> r> r? r� R s zBufferedRandom.readintoc C s | j � t j | | � S)N)rZ r/ rg )rC rk r> r> r? rg V s zBufferedRandom.peekc C s | j � t j | | � S)N)rZ r/ r� )rC rk r> r> r? r� Z s zBufferedRandom.read1c C s | j � t j | | � S)N)rZ r/ r� )rC r r> r> r? r� ^ s zBufferedRandom.readinto1c C sW | j rG | j �2 | j j | j t | j � d � | j � Wd QRXt j | | � S)Nr ) r� r� r: rT r� r r� r. r{ )rC r r> r> r? r{ b s #zBufferedRandom.write)rG rH rI r& r� rT rW rX ro r� rg r� r� r{ r> r> r> r? r- ! s r- c s] e Z d Z d0 Z d Z d Z d Z d Z d Z d Z d d d d d � Z d d � Z d d � Z d d � Z d d � Z d d d � Z d d d � Z d d � Z d d � Z d d � Z e d d � Z d d � Z d d d � Z � f d d! � Z d" d# � Z d$ d% � Z d& d' � Z d( d) � Z d* d+ � Z e d, d- � � Z e d. d/ � � Z � S)1r$ r FNTr c C s | j d k r9 z | j r+ t j | j � Wd d | _ Xt | t � rT t d � � t | t � r� | } | d k r� t d � � n d } t | t � s� t d | f � � t | � t d � k s� t d | f � � t d d � | D� � d k s | j d � d k rt d � � d | k rHd | _ d | _ t j t j B} nt d | k rfd | _ d } nV d | k r�d | _ t j t j B} n. d | k r�d | _ d | _ t j t j B} d | k r�d | _ d | _ | j r�| j r�| t j O} n& | j r| t j O} n | t j O} | t t d d � O} t t d d � pYt t d d � } | | O} d } yp| d k r| s�t d � � | d k r�t j | | d � } nB | | | � } t | t � s�t d � � | d k r�t d � � | } | st j | d � | | _ t j | � } y7 t j | j � r]t t! j" t j# t! j" � | � � Wn t$ k rrYn Xt | d d � | _% | j% d k r�t& | _% t' r�t' | t j( � | | _) | j r�t j* | d t+ � Wn$ | d k r�t j | � � Yn X| | _ d S)Nr r z$integer argument expected, got floatznegative file descriptorzinvalid mode: %szxrwab+c s s | ] } | d k Vq d S)ZrwaxNr> )�.0�cr> r> r? � <genexpr>� s z"FileIO.__init__.<locals>.<genexpr>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* r r ),�_fd�_closefdr' r2 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�getattrr@ r+ �set_inheritabler( �stat�S_ISDIR�st_mode�IsADirectoryErrorr� ZEISDIRr� r, �_blksizer& �_setmoder� rR �lseekr ) rC r3 r1 r8 r �fd�flagsZnoinherit_flagZowned_fdZfdfstatr> r> r? r� t s� 4 zFileIO.__init__c C sY | j d k rU | j rU | j rU d d l } | j d | f t d d �| j � d S)Nr zunclosed file %r� stacklevelr )r� r� rd r! r" �ResourceWarningr2 )rC r! r> r> r? r\ � s " zFileIO.__del__c C s t d | j j � � d S)Nz cannot serialize '%s' object)r rQ rG )rC r> r> r? r� � s zFileIO.__getstate__c C s� d | j j | j j f } | j r- d | Sy | j } Wn/ t k rk d | | j | j | j f SYn Xd | | | j | j f Sd S)Nz%s.%sz <%s [closed]>z <%s fd=%d mode=%r closefd=%r>z <%s name=%r mode=%r closefd=%r>) rQ rH rI rd rR r, r� r1 r� )rC Z class_namerR r> r> r? r� � s zFileIO.__repr__c C s | j s t d � � d S)NzFile not open for reading)r� rO )rC r> r> r? ra s zFileIO._checkReadablec C s | j s t d � � d S)NzFile not open for writing)r� rO )rC r^ r> r> r? rc s zFileIO._checkWritablec C sj | j � | j � | d k s, | d k r6 | j � Sy t j | j | � SWn t k re d SYn Xd S)Nr )rY ra r� r' ro r� r� )rC rk r> r> r? ro s z FileIO.readc C s | j � | j � t } yK t j | j d t � } t j | j � j } | | k rd | | d } Wn t k ry Yn Xt � } x� t | � | k r� t | � } | t | t � 7} | t | � } y t j | j | � } Wn t k r� | r� Pd SYn X| sP| | 7} q� Wt | � S)Nr r )rY ra r& r' r� r� r r( �st_sizer+ rn r r� ro r� r )rC �bufsizerU �endr; rj r� r> r> r? r� s4 zFileIO.readallc C sJ t | � j d � } | j t | � � } t | � } | | d | � <| S)Nr� )r� r� ro r )rC r �mr� rj r> r> r? r� < s zFileIO.readintoc C sH | j � | j � y t j | j | � SWn t k rC d SYn Xd S)N)rY rc r' r{ r� r� )rC r r> r> r? r{ D s z FileIO.writec C s; t | t � r t d � � | j � t j | j | | � S)Nzan integer is required)r r� r rY r' r� r� )rC rU rV r> r> r? rT R s z FileIO.seekc C s | j � t j | j d t � S)Nr )rY r' r� r� r )rC r> r> r? rW b s z FileIO.tellc C sC | j � | j � | d k r, | j � } t j | j | � | S)N)rY rc rW r' � ftruncater� )rC rk r> r> r? rX i s zFileIO.truncatec s; | j s7 z | j r% t j | j � Wd t � j � Xd S)N)rd r� r' r2 r� r� )rC )rQ r> r? r2 v s z FileIO.closec C sU | j � | j d k rN y | j � Wn t k rD d | _ Yn Xd | _ | j S)NFT)rY � _seekablerW r+ )rC r> r> r? r] � s zFileIO.seekablec C s | j � | j S)N)rY r� )rC r> r> r? r` � s zFileIO.readablec C s | j � | j S)N)rY r� )rC r> r> r? rb � s zFileIO.writablec C s | j � | j S)N)rY r� )rC r> r> r? r) � s z FileIO.filenoc C s | j � t j | j � S)N)rY r' r% r� )rC r> r> r? r% � s z FileIO.isattyc C s | j S)N)r� )rC r> r> r? r8 � s zFileIO.closefdc C s_ | j r | j r d Sd Sn> | j r: | j r3 d Sd Sn! | j rW | j rP d Sd Sn d Sd S)Nzxb+Zxbzab+Zabzrb+�rb�wb)r� r� r� r� )rC r> r> r? r1 � s z FileIO.moder )!rG rH rI r� r� r� r� r� r� r� r� r\ r� r� ra rc ro r� r� r{ r rT rW rX r2 r] r` rb r) r% r} r8 r1 r> r> )rQ r? r$ k s8 u # r$ c @ s� e Z d Z d d d � Z d d � Z d d d � Z d d � Z d d � Z e d d � � Z e d d � � Z e d d � � Z d S)� TextIOBaser c C s | j d � d S)Nro )rS )rC rk r> r> r? ro � s zTextIOBase.readc C s | j d � d S)Nr{ )rS )rC �sr> r> r? r{ � s zTextIOBase.writeNc C s | j d � d S)NrX )rS )rC rU r> r> r? rX � s zTextIOBase.truncatec C s | j d � d S)Nrr )rS )rC r> r> r? rr � s zTextIOBase.readlinec C s | j d � d S)Nr� )rS )rC r> r> r? r� � s zTextIOBase.detachc C s d S)Nr> )rC r> r> r? r5 � s zTextIOBase.encodingc C s d S)Nr> )rC r> r> r? �newlines� s zTextIOBase.newlinesc C s d S)Nr> )rC r> r> r? r6 � s zTextIOBase.errorsr ) rG rH rI ro r{ rX rr r� r} r5 r� r6 r> r> r> r? r� � s r� c @ sv e Z d Z d d d � Z d d d � Z d d � Z d d � Z d d � Z d Z d Z d Z e d d � � Z d S)�IncrementalNewlineDecoder�strictc C s> t j j | d | �| | _ | | _ d | _ d | _ d S)Nr6 r F)�codecs�IncrementalDecoderr� � translate�decoder�seennl� pendingcr)rC r� r� r6 r> r> r? r� s z"IncrementalNewlineDecoder.__init__Fc C s+ | j d k r | } n | j j | d | �} | j rX | sE | rX d | } d | _ | j d � r� | r� | d d � } d | _ | j d � } | j d � | } | j d � | } | j | o� | j | o� | j B| o� | j BO_ | j r'| r| j d d � } | r'| j d d � } | S) N�final� Fr Tz � r ) r� �decoder� rp r� r� �_LF�_CR�_CRLFr� �replace)rC �inputr� �outputZcrlfZcrZlfr> r> r? r� s( + z IncrementalNewlineDecoder.decodec C sZ | j d k r d } d } n | j j � \ } } | d K} | j rP | d O} | | f S)Nr� r r )r� �getstater� )rC r� �flagr> r> r? r� / s z"IncrementalNewlineDecoder.getstatec C sL | \ } } t | d @� | _ | j d k rH | j j | | d ?f � d S)Nr )�boolr� r� �setstate)rC �stater� r� r> r> r? r� : s z"IncrementalNewlineDecoder.setstatec C s2 d | _ d | _ | j d k r. | j j � d S)Nr F)r� r� r� �reset)rC r> r> r? r� @ s z IncrementalNewlineDecoder.resetr r � c C s d | j S) Nr� r� � �r� r� �r� r �r� r �r� r� r )Nr� r� r r r r r )r� )rC r> r> r? r� J s z"IncrementalNewlineDecoder.newlinesN) rG rH rI r� r� r� r� r� r� r� r� r} r� r> r> r> r? r� s r� c @ s� e Z d Z d Z d d d d d d d � Z d d � Z e d d � � Z e d d � � Z e d d � � Z e d d � � Z d d � Z d d � Z d d � Z d d � Z d d � Z e d d � � Z e d d � � Z d d � Z d d! � Z d" d# � Z d$ d% � Z d& d' � Z d( d) � Z d d* d+ � Z d, d- � Z d. d/ � Z d0 d0 d0 d0 d1 d2 � Z d3 d4 � Z d5 d6 � Z d d7 d8 � Z d9 d: � Z d0 d; d< � Z d d= d> � Z! d? d@ � Z" d dA dB � Z# e dC dD � � Z$ d S)Er0 i NFc C s� | d k r5 t | t � r5 t d t | � f � � | d k rT t d | f � � | d k r� y t j | j � � } Wn t t f k r� Yn X| d k r� y d d l } Wn t k r� d } Yn X| j d � } t | t � s� t d | � � t j | � j s!d } t | | � � | d k r6d } n t | t � sUt d | � � | | _ | | _ | | _ | | _ | | _ | d k | _ | | _ | d k | _ | p�t j | _ d | _ d | _ d | _ d | _ d | _ | j j! � | _" | _# t$ | j d � | _% d | _& | j" r|| j' � r|| j j( � } | d k r|y | j) � j* d � Wn t k r{Yn Xd S)Nzillegal newline type: %rr r� r� � zillegal newline value: %rr �asciiFzinvalid encoding: %rzG%r is not a text encoding; use codecs.open() to handle arbitrary codecsr� zinvalid errors: %rr� g )Nr r� r� r )+r r r �typer r' �device_encodingr) r, rO �locale� ImportError�getpreferredencodingr� �lookup�_is_text_encoding� LookupErrorr� �_line_buffering� _encoding�_errors�_readuniversal�_readtranslate�_readnl�_writetranslate�linesep�_writenl�_encoder�_decoder�_decoded_chars�_decoded_chars_used� _snapshotr= r] r� �_tellingrm � _has_read1� _b2cratiorb rW � _get_encoderr� ) rC r= r5 r6 r7 r< Z write_throughr r^ �positionr> r> r? r� t s` zTextIOWrapper.__init__c C s� d j | j j | j j � } y | j } Wn t k r? Yn X| d j | � 7} y | j } Wn t k rt Yn X| d j | � 7} | d j | j � S)Nz<{}.{}z name={0!r}z mode={0!r}z encoding={0!r}>)r� rQ rH rI rR r� r1 r5 )rC r; rR r1 r> r> r? r� � s zTextIOWrapper.__repr__c C s | j S)N)r )rC r> r> r? r5 � s zTextIOWrapper.encodingc C s | j S)N)r )rC r> r> r? r6 � s zTextIOWrapper.errorsc C s | j S)N)r )rC r> r> r? r< � s z TextIOWrapper.line_bufferingc C s | j S)N)r� )rC r> r> r? r= � s zTextIOWrapper.bufferc C s | j r t d � � | j S)Nz I/O operation on closed file.)rd r r� )rC r> r> r? r] � s zTextIOWrapper.seekablec C s | j j � S)N)r= r` )rC r> r> r? r` � s zTextIOWrapper.readablec C s | j j � S)N)r= rb )rC r> r> r? rb � s zTextIOWrapper.writablec C s | j j � | j | _ d S)N)r= rZ r� r )rC r> r> r? rZ � s zTextIOWrapper.flushc C s< | j d k r8 | j r8 z | j � Wd | j j � Xd S)N)r= rd rZ r2 )rC r> r> r? r2 � s zTextIOWrapper.closec C s | j j S)N)r= rd )rC r> r> r? rd � s zTextIOWrapper.closedc C s | j j S)N)r= rR )rC r> r> r? rR � s zTextIOWrapper.namec C s | j j � S)N)r= r) )rC r> r> r? r) � s zTextIOWrapper.filenoc C s | j j � S)N)r= r% )rC r> r> r? r% � s zTextIOWrapper.isattyc C s | j r t d � � t | t � s: t d | j j � � t | � } | j sX | j oa d | k } | r� | j r� | j d k r� | j d | j � } | j p� | j � } | j | � } | j j | � | j r� | s� d | k r� | j � d | _ | j r| j j � | S)Nzwrite to closed filez can't write %s to text streamr� r� )rd r r r r rQ rG r r r r r� r r! �encoder= r{ rZ r r r� )rC r� ZlengthZhaslf�encoderr r> r> r? r{ � s$ zTextIOWrapper.writec C s+ t j | j � } | | j � | _ | j S)N)r� �getincrementalencoderr r r )rC Z make_encoderr> r> r? r! s zTextIOWrapper._get_encoderc C sI t j | j � } | | j � } | j r< t | | j � } | | _ | S)N)r� �getincrementaldecoderr r r r� r r )rC Z make_decoderr� r> r> r? � _get_decoder s zTextIOWrapper._get_decoderc C s | | _ d | _ d S)Nr )r r )rC �charsr> r> r? �_set_decoded_chars% s z TextIOWrapper._set_decoded_charsc C s[ | j } | d k r+ | j | d � } n | j | | | � } | j t | � 7_ | S)N)r r r )rC rj �offsetr( r> r> r? �_get_decoded_chars* s z TextIOWrapper._get_decoded_charsc C s. | j | k r t d � � | j | 8_ d S)Nz"rewind decoded_chars out of bounds)r �AssertionError)rC rj r> r> r? �_rewind_decoded_chars4 s z#TextIOWrapper._rewind_decoded_charsc C s� | j d k r t d � � | j r9 | j j � \ } } | j rZ | j j | j � } n | j j | j � } | } | j j | | � } | j | � | r� t | � t | j � | _ n d | _ | j r� | | | f | _ | S)Nz no decoderg )r r r r� r r= r� � _CHUNK_SIZEro r� r) r r r r )rC � dec_buffer� dec_flags� input_chunk�eofZ decoded_charsr> r> r? � _read_chunk: s zTextIOWrapper._read_chunkr c C s* | | d >B| d >B| d >Bt | � d >BS)N�@ � � � )r� )rC r" r0 � bytes_to_feed�need_eof� chars_to_skipr> r> r? � _pack_cookied s zTextIOWrapper._pack_cookiec C sg t | d � \ } } t | d � \ } } t | d � \ } } t | d � \ } } | | | | | f S)Nr r4 l l l l )�divmod)rC Zbigint�restr" r0 r8 r9 r: r> r> r? �_unpack_cookien s z TextIOWrapper._unpack_cookiec C s | j s t d � � | j s* t d � � | j � | j j � } | j } | d k sg | j d k r� | j r| t d � � | S| j \ } } | t | � 8} | j } | d k r� | j | | � S| j � } z t | j | � } d } x� | d k r�| j d | f � t | j | d | � � � } | | k r{| j � \ } } | sb| } | | 8} P| t | � 8} d } q� | | 8} | d } q� Wd } | j d | f � | | } | } | d k r�| j | | � Sd } d } d } x� t | t | � � D]� } | d 7} | t | j | | | d � � � 7} | j � \ } } | r�| | k r�| | 7} | | 8} | d d } } } | | k r Pq W| t | j d d d �� 7} d } | | k r�t d � � | j | | | | | � SWd | j | � Xd S) Nz!underlying stream is not seekablez(telling position disabled by next() callzpending decoded textr r r� r r� Tz'can't reconstruct logical file position)r� rO r r+ rZ r= rW r r r r, r r r; r� r r r� r� �range)rC r" r� r0 Z next_inputr: Z saved_stateZ skip_bytesZ skip_backrj r �d� start_posZ start_flagsZ bytes_fedr9 Z chars_decoded�ir/ r> r> r? rW u sv ' zTextIOWrapper.tellc C s2 | j � | d k r" | j � } | j j | � S)N)rZ rW r= rX )rC rU r> r> r? rX � s zTextIOWrapper.truncatec C s; | j d k r t d � � | j � | j } d | _ | S)Nzbuffer is already detached)r= r rZ r� )rC r= r> r> r? r� � s zTextIOWrapper.detachc sm � f d d � } � j r' t d � � � j s< t d � � | d k rr | d k r` t d � � d } � j � } | d k r� | d k r� t d � � � j � � j j d d � } � j d � d � _ � j r� � j j � | | � | S| d k rt d | f � � | d k r-t d | f � � � j � � j | � \ } } } } } � j j | � � j d � d � _ | d k r�� j r�� j j � nR � j s�| s�| r�� j p�� j � � _ � j j d | f � | d f � _ | r_� j j | � } � j � j j | | � � | | f � _ t � j � | k rVt d � � | � _ | | � | S)Nc sX y � j p � j � } Wn t k r- Yn' X| d k rJ | j d � n | j � d S)Nr )r r! r r� r� )r" r$ )rC r> r? �_reset_encoder� s z*TextIOWrapper.seek.<locals>._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)rd r r� rO rW rZ r= rT r) r r r� r> r' r� ro r� r r r+ r ) rC ZcookierV rC r" rA r0 r8 r9 r: r1 r> )rC r? rT � s\ zTextIOWrapper.seekc C s( | j � | d k r d } | j p. | j � } y | j Wn4 t k rr } z t d � | � WYd d } ~ Xn X| d k r� | j � | j | j j � d d �} | j d � d | _ | Sd } | j | � } xG t | � | k r | r | j � } | | j | t | � � 7} q� W| Sd S) Nr zan integer is requiredr r� Tr Fr )ra r r' r� r, r r+ r� r= ro r) r r r3 )rC rk r� r� r; r2 r> r> r? ro 1 s( " !zTextIOWrapper.readc C s: d | _ | j � } | s6 d | _ | j | _ t � | S)NF)r rr r r� rt )rC ru r> r> r? rv J s zTextIOWrapper.__next__c C sn | j r t d � � | d k r* d } n t | t � sE t d � � | j � } d } | j sj | j � d } } x�| j r� | j d | � } | d k r� | d } Pq�t | � } n� | j r}| j d | � } | j d | � } | d k r | d k rt | � } qz| d } Pq�| d k r7| d } Pq�| | k rQ| d } Pq�| | d k ro| d } Pq�| d } Pn2 | j | j � } | d k r�| t | j � } P| d k r�t | � | k r�| } Px | j � r�| j r�Pq�W| j r | | j � 7} qw | j d � d | _ | Sqw W| d k rI| | k rI| } | j t | � | � | d | � S) Nzread from closed filer zsize must be an integerr r� r� r r r r r r )rd r r r r r+ r r' r rh r r r r3 r r) r r- )rC rk ru �startrU �endposZnlposZcrposr> r> r? rr S sp zTextIOWrapper.readlinec C s | j r | j j Sd S)N)r r� )rC r> r> r? r� � s zTextIOWrapper.newlines)%rG rH rI r. r� r� r} r5 r6 r< r= r] r` rb rZ r2 rd rR r) r% r{ r! r' r) r+ r- r3 r; r> rW rX r� rT ro rv rr r� r> r> r> r? r0 W sF E * c K Xr0 c sp e Z d Z d d � f d d � Z d d � Z d d � Z e d d � � Z e d d � � Z d d � Z � S)�StringIOr r� c s� t t | � j t � d d d d d | �| d k r@ d | _ | d k r� t | t � sy t d j t | � j � � � | j | � | j d � d S) Nr5 zutf-8r6 � surrogatepassr7 Fz*initial_value must be str or None, not {0}r ) r� rF r� r� r r r r r� r rG r{ rT )rC Z initial_valuer7 )rQ r> r? r� � s zStringIO.__init__c C sj | j � | j p | j � } | j � } | j � z | j | j j � d d �SWd | j | � Xd S)Nr� T) rZ r r' r� r� r� r= r� r� )rC r� Z old_stater> r> r? r� � s zStringIO.getvaluec C s t j | � S)N)�objectr� )rC r> r> r? r� � s zStringIO.__repr__c C s d S)Nr> )rC r> r> r? r6 � s zStringIO.errorsc C s d S)Nr> )rC r> r> r? r5 � s zStringIO.encodingc C s | j d � d S)Nr� )rS )rC r> r> r? r� � s zStringIO.detach) rG rH rI r� r� r� r} r6 r5 r� r> r> )rQ r? rF � s rF )5r' �abcr� r� Zarrayr� �sys�_threadr r� r Z _dummy_thread�platformZmsvcrtr r� �ior r r r r� rm �addr � SEEK_DATAr& r� r@ rA rJ rO r, r r+ �ABCMetarP �registerr �_ior$ r� r� r� r/ r. r� r- r� r� r� r0 rF r> r> r> r? �<module> sj " � � < go~�WIJ� TAU� � [