CURRENT PATH:
/
usr
/
lib64
/
python3.9
/
__pycache__
/
[ ⬅ KEMBALI ]
|
[ HOME ]
Upload File:
Upload Ke Sini
Dir Baru
File Baru
Editing:
_pyio.cpython-39.opt-2.pyc
a �DOg�l � @ sv d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ej dv rTd dl m Z ndZ d dl Z d dl mZmZmZmZ h d�Zee d�r�e�e j� e�e j� dZeZeed �p�ejjZeZ d5d d�Z dd� Z z e j Z W n e � y� e Z Y n0 G dd� d�Z!G dd� d�Z"z e j#Z#W n& e �yB G dd� de$e%�Z#Y n0 G dd� dej&d�Z'e j'�(e'� G dd� de'�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-�Z0G d'd(� d(e,�Z1G d)d*� d*e0e/�Z2G d+d,� d,e)�Z+G d-d.� d.e'�Z3e j3�(e3� G d/d0� d0ej4�Z5G d1d2� d2e3�Z6G d3d4� d4e6�Z7dS )6� N)� allocate_lock> �cygwin�win32)�setmode)�__all__�SEEK_SET�SEEK_CUR�SEEK_END> r � � � SEEK_HOLEi Zgettotalrefcount�r���Tc C s� t | t�st�| �} t | tttf�s0td| ��t |t�sFtd| ��t |t�s\td| ��|d urzt |t�sztd| ��|d ur�t |t�s�td| ��t|�}|td� s�t|�t|�kr�t d| ��d|v } d|v } d |v } d |v } d |v } d |v }d |v }d|v �rD| �s"| �s"| �s"| �r*t d��dd l }|� dt d� d} |�rX|�rXt d��| | | | dk�rvt d��| �s�| �s�| �s�| �s�t d��|�r�|d u�r�t d��|�r�|d u�r�t d��|�r�|d u�r�t d��|�r|dk�rdd l }|� dt d� t| | �rd�pd | �r"d�p$d | �r2d �p4d | �rBd �pDd | �rRd �pTd ||d �}|}�z"d }|dk�s�|dk �r�|�� �r�d }d}|dk �r�t}zt�|�� �j}W n ttf�y� Y n0 |dk�r�|}|dk �r�t d ��|dk�r |�r|W S t d!��| �r t||�}n<| �s0| �s0| �r<t||�}n | �rNt||�}n t d"| ��|}|�rj|W S t|||||�}|}||_|W S |�� � Y n0 d S )#Nzinvalid file: %rzinvalid mode: %rzinvalid buffering: %r�invalid encoding: %r�invalid errors: %rzaxrwb+tU�xr �w�a�+�t�b�Uz4mode U cannot be combined with 'x', 'w', 'a', or '+'r z'U' mode is deprecatedr Tz'can't have text and binary mode at oncer z)can't have read/write/append mode at oncez/must have exactly one of read/write/append modez-binary mode doesn't take an encoding argumentz+binary mode doesn't take an errors argumentz+binary mode doesn't take a newline argumentzaline buffering (buffering=1) isn't supported in binary mode, the default buffer size will be used� )�openerFr zinvalid buffering sizez can't have unbuffered text I/Ozunknown mode: %r) � isinstance�int�os�fspath�str�bytes� TypeError�set�len� ValueError�warnings�warn�DeprecationWarning�RuntimeWarning�FileIO�isatty�DEFAULT_BUFFER_SIZE�fstat�fileno� st_blksize�OSError�AttributeError�BufferedRandom�BufferedWriter�BufferedReader� TextIOWrapper�mode�close)�filer4 � buffering�encoding�errors�newline�closefdr ZmodesZcreating�reading�writingZ appendingZupdating�text�binaryr$ �raw�result�line_buffering�bs�buffer� rE � /usr/lib64/python3.9/_pyio.py�open+ s� { � ������ rG c C s dd l }|�dtd� t| d�S )Nr z(_pyio.open_code() may not be using hooksr �rb)r$ r% r' rG )�pathr$ rE rE rF �_open_code_with_warning s �rJ c @ s e Zd Zddd�ZdS )� DocDescriptorNc C s dt j S )Nz\open(file, mode='r', buffering=-1, encoding=None, errors=None, newline=None, closefd=True) )rG �__doc__)�self�obj�typrE rE rF �__get__ s ��zDocDescriptor.__get__)N)�__name__� __module__� __qualname__rP rE rE rE rF rK s rK c @ s e Zd Ze� Zdd� ZdS )� OpenWrapperc O s t |i |��S �N)rG )�cls�args�kwargsrE rE rF �__new__. s zOpenWrapper.__new__N)rQ rR rS rK rL rY rE rE rE rF rT $ s rT c @ s e Zd ZdS )�UnsupportedOperationN)rQ rR rS rE rE rE rF rZ 7 s rZ c @ s� e Zd Zdd� Zd5dd�Zdd� Zd6d d �Zd d � Zd Zdd� Z dd� Z dd� Z d7dd�Z dd� Z d8dd�Zdd� Zd9d d �Zed d � �Zd:d d!�Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd;d+d,�Zd-d.� Zd/d0� Zd<d1d2�Zd3d4� Z dS )=�IOBasec C s t d| jj|f ��d S )Nz%s.%s() not supported)rZ � __class__rQ )rM �namerE rE rF � _unsupported] s �zIOBase._unsupportedr c C s | � d� d S )N�seek�r^ �rM �pos�whencerE rE rF r_ d s z IOBase.seekc C s | � dd�S �Nr r )r_ �rM rE rE rF �tellt s z IOBase.tellNc C s | � d� d S �N�truncater` �rM rb rE rE rF rh x s zIOBase.truncatec C s | � � d S rU �� _checkClosedre rE rE rF �flush� s z IOBase.flushFc C s& | j s"z| �� W d| _ nd| _ 0 d S )NT)�_IOBase__closedrl re rE rE rF r5 � s z IOBase.closec C sT z | j }W n ty Y d S 0 |r(d S tr6| �� nz | �� W n Y n0 d S rU )�closedr/ �_IOBASE_EMITS_UNRAISABLEr5 )rM rn rE rE rF �__del__� s zIOBase.__del__c C s dS �NFrE re rE rE rF �seekable� s zIOBase.seekablec C s | � � s t|d u rdn|��d S )Nz File or stream is not seekable.)rr rZ �rM �msgrE rE rF �_checkSeekable� s ��zIOBase._checkSeekablec C s dS rq rE re rE rE rF �readable� s zIOBase.readablec C s | � � s t|d u rdn|��d S )Nz File or stream is not readable.)rv rZ rs rE rE rF �_checkReadable� s ��zIOBase._checkReadablec C s dS rq rE re rE rE rF �writable� s zIOBase.writablec C s | � � s t|d u rdn|��d S )Nz File or stream is not writable.)rx rZ rs rE rE rF �_checkWritable� s ��zIOBase._checkWritablec C s | j S rU )rm re rE rE rF rn � s z IOBase.closedc C s | j rt|d u rdn|��d S �N� I/O operation on closed file.�rn r# rs rE rE rF rk � s ��zIOBase._checkClosedc C s | � � | S rU rj re rE rE rF � __enter__� s zIOBase.__enter__c G s | � � d S rU )r5 )rM rW rE rE rF �__exit__� s zIOBase.__exit__c C s | � d� d S )Nr, r` re rE rE rF r, � s z IOBase.filenoc C s | � � dS rq rj re rE rE rF r) s z IOBase.isattyr c s� t � d�r� �fdd�}ndd� }�d u r0d�n2z �j}W n tyZ t��d���Y n0 |� �t� }�dk s|t|��k r�� �|� �}|s�q�||7 }|�d�rhq�qht|�S ) N�peekc s> � � d�} | sdS | �d�d p&t| �}�dkr:t|��}|S )Nr � r )r �findr" �min)Z readahead�n�rM �sizerE rF � nreadahead s z#IOBase.readline.<locals>.nreadaheadc S s dS �Nr rE rE rE rE rF r� ! s r � is not an integerr r� ) �hasattr� __index__r/ r � bytearrayr" �read�endswithr )rM r� r� � size_index�resr rE r� rF �readline s& zIOBase.readlinec C s | � � | S rU rj re rE rE rF �__iter__6 s zIOBase.__iter__c C s | � � }|st�|S rU )r� � StopIteration�rM �linerE rE rF �__next__: s zIOBase.__next__c C sP |d u s|dkrt | �S d}g }| D ]&}|�|� |t|�7 }||kr$ qLq$|S �Nr )�list�appendr" )rM �hintr� �linesr� rE rE rF � readlines@ s zIOBase.readlinesc C s | � � |D ]}| �|� q d S rU )rk �write)rM r� r� rE rE rF � writelinesR s zIOBase.writelines)r )N)N)N)N)N)r )N) rQ rR rS r^ r_ rf rh rl rm r5 rp rr ru rv rw rx ry �propertyrn rk r} r~ r, r) r� r� r� r� r� rE rE rE rF r[ ; s4 " * r[ )� metaclassc @ s. e Zd Zd dd�Zdd� Zdd� Zdd � Zd S ) � RawIOBaser c C sP |d u r d}|dk r | � � S t|�� �}| �|�}|d u r>d S ||d �= t|�S )Nr r )�readallr� r� �readintor )rM r� r r� rE rE rF r� m s zRawIOBase.readc C s4 t � }| �t�}|sq ||7 }q|r,t|�S |S d S rU )r� r� r* r )rM r� �datarE rE rF r� ~ s zRawIOBase.readallc C s | � d� d S )Nr� r` �rM r rE rE rF r� � s zRawIOBase.readintoc C s | � d� d S �Nr� r` r� rE rE rF r� � s zRawIOBase.writeN)r )rQ rR rS r� r� r� r� rE rE rE rF r� _ s r� )r( c @ sH e Zd Zddd�Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dS )�BufferedIOBaser c C s | � d� d S �Nr� r` r� rE rE rF r� � s zBufferedIOBase.readc C s | � d� d S )N�read1r` r� rE rE rF r� � s zBufferedIOBase.read1c C s | j |dd�S )NF�r� �� _readintor� rE rE rF r� � s zBufferedIOBase.readintoc C s | j |dd�S )NTr� r� r� rE rE rF � readinto1� s zBufferedIOBase.readinto1c C sV t |t�st|�}|�d�}|r0| �t|��}n| �t|��}t|�}||d |�< |S �N�B)r � memoryview�castr� r" r� )rM r r� r� r� rE rE rF r� � s zBufferedIOBase._readintoc C s | � d� d S r� r` r� rE rE rF r� � s zBufferedIOBase.writec C s | � d� d S �N�detachr` re rE rE rF r� � s zBufferedIOBase.detachN)r )r ) rQ rR rS r� r� r� r� r� r� r� rE rE rE rF r� � s r� c @ s� e Zd Zdd� Zd#dd�Zdd� Zd$d d �Zd d � Zd d� Zdd� Z dd� Z e dd� �Z e dd� �Z e dd� �Ze dd� �Zdd � Zd d � Zd d � Zd!d"� ZdS )%�_BufferedIOMixinc C s || _ d S rU ��_raw�rM r@ rE rE rF �__init__ s z_BufferedIOMixin.__init__r c C s" | j �||�}|dk r td��|S )Nr z#seek() returned an invalid position)r@ r_ r. )rM rb rc Z new_positionrE rE rF r_ s z_BufferedIOMixin.seekc C s | j �� }|dk rtd��|S )Nr z#tell() returned an invalid position)r@ rf r. ri rE rE rF rf s z_BufferedIOMixin.tellNc C s4 | � � | �� | �� |d u r(| �� }| j�|�S rU )rk ry rl rf r@ rh ri rE rE rF rh % s z_BufferedIOMixin.truncatec C s | j rtd��| j�� d S )N�flush on closed file)rn r# r@ rl re rE rE rF rl 6 s z_BufferedIOMixin.flushc C s8 | j d ur4| js4z| �� W | j �� n | j �� 0 d S rU )r@ rn rl r5 re rE rE rF r5 ; s z_BufferedIOMixin.closec C s* | j d u rtd��| �� | j}d | _|S )Nzraw stream already detached)r@ r# rl r� r� rE rE rF r� C s z_BufferedIOMixin.detachc C s | j �� S rU )r@ rr re rE rE rF rr M s z_BufferedIOMixin.seekablec C s | j S rU r� re rE rE rF r@ P s z_BufferedIOMixin.rawc C s | j jS rU )r@ rn re rE rE rF rn T s z_BufferedIOMixin.closedc C s | j jS rU )r@ r] re rE rE rF r] X s z_BufferedIOMixin.namec C s | j jS rU )r@ r4 re rE rE rF r4 \ s z_BufferedIOMixin.modec C s t d| jj�d���d S �Nzcannot pickle z object�r r\ rQ re rE rE rF � __getstate__` s z _BufferedIOMixin.__getstate__c C sL | j j}| j j}z | j}W n ty8 d�||� Y S 0 d�|||�S d S )Nz<{}.{}>z<{}.{} name={!r}>)r\ rR rS r] r/ �format)rM �modnameZclsnamer] rE rE rF �__repr__c s z_BufferedIOMixin.__repr__c C s | j �� S rU )r@ r, re rE rE rF r, o s z_BufferedIOMixin.filenoc C s | j �� S rU )r@ r) re rE rE rF r) r s z_BufferedIOMixin.isatty)r )N)rQ rR rS r� r_ rf rh rl r5 r� rr r� r@ rn r] r4 r� r� r, r) rE rE rE rF r� s( r� c s� e Zd ZdZd dd�Zdd� Zdd� Zdd � Z� fd d �Zd!d d�Z d"dd�Z dd� Z d#dd�Z dd� Z d$dd�Zdd� Zd d � Zd d � Z� ZS )%�BytesIONc C s& t � }|d ur||7 }|| _d| _d S r� )r� �_buffer�_pos)rM Z initial_bytes�bufrE rE rF r� ~ s zBytesIO.__init__c C s | j rtd��| j�� S )Nz__getstate__ on closed file)rn r# �__dict__�copyre rE rE rF r� � s zBytesIO.__getstate__c C s | j rtd��t| j�S )Nzgetvalue on closed file)rn r# r r� re rE rE rF �getvalue� s zBytesIO.getvaluec C s | j rtd��t| j�S )Nzgetbuffer on closed file)rn r# r� r� re rE rE rF � getbuffer� s zBytesIO.getbufferc s" | j d ur| j �� t� �� d S rU )r� �clear�superr5 re �r\ rE rF r5 � s z BytesIO.closer c C s� | j rtd��|d u r d}n2z |j}W n tyF t|�d���Y n0 |� }|dk r`t| j�}t| j�| jkrtdS tt| j�| j| �}| j| j|� }|| _t |�S )N�read from closed filer r� r � ) rn r# r� r/ r r" r� r� r� r )rM r� r� Znewposr rE rE rF r� � s" z BytesIO.readc C s | � |�S rU )r� r� rE rE rF r� � s z BytesIO.read1c C s� | j rtd��t|t�r td��t|��}|j}W d � n1 sD0 Y |dkrZdS | j}|t| j �kr�d|t| j � }| j |7 _ || j ||| �< | j|7 _|S )N�write to closed file� can't write str to binary streamr � ) rn r# r r r r� �nbytesr� r" r� )rM r �viewr� rb ZpaddingrE rE rF r� � s $z BytesIO.writer c C s� | j rtd��z |j}W n ty8 t|�d���Y n0 |� }|dkrf|dk r^td|f ��|| _nD|dkr�td| j| �| _n(|dkr�tdt| j�| �| _ntd��| jS )Nzseek on closed filer� r �negative seek position %rr r zunsupported whence value) rn r# r� r/ r r� �maxr" r� )rM rb rc � pos_indexrE rE rF r_ � s" z BytesIO.seekc C s | j rtd��| jS )N�tell on closed file)rn r# r� re rE rE rF rf � s z BytesIO.tellc C sv | j rtd��|d u r | j}nHz |j}W n tyH t|�d���Y n0 |� }|dk rftd|f ��| j|d �= |S )Nztruncate on closed filer� r z negative truncate position %r)rn r# r� r� r/ r r� )rM rb r� rE rE rF rh � s zBytesIO.truncatec C s | j rtd��dS �Nr{ Tr| re rE rE rF rv � s zBytesIO.readablec C s | j rtd��dS r� r| re rE rE rF rx � s zBytesIO.writablec C s | j rtd��dS r� r| re rE rE rF rr � s zBytesIO.seekable)N)r )r )r )N)rQ rR rS r� r� r� r� r� r5 r� r� r� r_ rf rh rv rx rr � __classcell__rE rE r� rF r� v s r� c @ st e Zd Zefdd�Zdd� Zdd� Zddd �Zdd d �Zd d d�Z d dd�Z d dd�Z dd� Z dd� Z d dd�ZdS ) r2 c C sF |� � std��t�| |� |dkr,td��|| _| �� t� | _d S )Nz "raw" argument must be readable.r �invalid buffer size) rv r. r� r� r# � buffer_size�_reset_read_buf�Lock� _read_lock�rM r@ r� rE rE rF r� s zBufferedReader.__init__c C s | j �� S rU )r@ rv re rE rE rF rv s zBufferedReader.readablec C s d| _ d| _d S )Nr� r )� _read_buf� _read_posre rE rE rF r� s z BufferedReader._reset_read_bufNc C sL |d ur|dk rt d��| j� | �|�W d � S 1 s>0 Y d S )Nr z invalid number of bytes to read)r# r� �_read_unlockedr� rE rE rF r� $ s zBufferedReader.readc C s� d}d}| j }| j}|d u s$|dkr�| �� t| jd�rj| j�� }|d u rZ||d � pXd S ||d � | S ||d � g}d}| j�� }||v r�|}q�|t|�7 }|�|� q|d� |�p�|S t|�| } || kr�| j|7 _|||| � S ||d � g}t | j |�} | |k �rH| j�| �}||v �r.|}�qH| t|�7 } |�|� �qt || �}d� |�} | |d � | _ d| _| �r�| d |� S |S )Nr� )r� Nr r� r ) r� r� r� r� r@ r� r� r" r� �joinr� r� r� ) rM r� Z nodata_valZ empty_valuesr� rb �chunk�chunksZ current_size�availZwanted�outrE rE rF r� 1 sL z BufferedReader._read_unlockedr c C s4 | j � | �|�W d � S 1 s&0 Y d S rU )r� �_peek_unlockedr� rE rE rF r e 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� )rM r� ZwantZhaveZto_read�currentrE rE rF r� o s z BufferedReader._peek_unlockedr c C sj |dk r| j }|dkrdS | j�6 | �d� | �t|t| j�| j ��W d � S 1 s\0 Y d S )Nr r� r )r� r� r� r� r� r" r� r� r� rE rE rF r� z s �zBufferedReader.read1c C s t |t�st|�}|jdkr dS |�d�}d}| j�� |t|�k r�tt| j�| j t|��}|r�| j| j| j| � |||| �< | j|7 _||7 }|t|�kr�q�t|�| | j kr�| j � ||d � �}|s�q�||7 }n|r�|s�| � d�s�q�|r6|r6q�q6W d � n1 �s0 Y |S )Nr r� r ) r r� r� r� r� r" r� r� r� r� r@ r� r� )rM r� r� �writtenr� r� rE rE rF r� � s6 � $zBufferedReader._readintoc C s t �| �t| j� | j S rU )r� rf r" r� r� re rE rE rF rf � s zBufferedReader.tellc C sp |t vrtd��| j�F |dkr4|t| j�| j 8 }t�| ||�}| �� |W d � S 1 sb0 Y d S )N�invalid whence valuer ) �valid_seek_flagsr# r� r" r� r� r� r_ r� ra rE rE rF r_ � s zBufferedReader.seek)N)N)r )r )r )r )rQ rR rS r* r� rv r� r� r� r r� r� r� rf r_ rE rE rE rF r2 s 4 .r2 c @ s\ e Zd Zefdd�Zdd� Zdd� Zddd �Zd d � Zd d � Z dd� Z ddd�Z dd� Z dS )r1 c C sF |� � std��t�| |� |dkr,td��|| _t� | _t� | _ d S )Nz "raw" argument must be writable.r r� ) rx r. r� r� r# r� r� � _write_bufr� � _write_lockr� rE rE rF r� � s zBufferedWriter.__init__c C s | j �� S rU )r@ rx re rE rE rF rx � s zBufferedWriter.writablec C s t |t�rtd��| j�� | jr(td��t| j�| jkr@| � � t| j�}| j� |� t| j�| }t| j�| jkr�z | � � W nn t y� } zVt| j�| jkr�t| j�| j }||8 }| jd | j� | _t |j |j |��W Y d }~n d }~0 0 |W d � S 1 �s 0 Y d S )Nr� r� )r r r r� rn r# r" r� r� �_flush_unlocked�extend�BlockingIOError�errno�strerror)rM r �beforer� �eZoveragerE rE rF r� � s( &zBufferedWriter.writeNc C sP | j �6 | �� |d u r"| j�� }| j�|�W d � S 1 sB0 Y d S rU )r� r� r@ rf rh ri rE rE rF rh � s zBufferedWriter.truncatec C s2 | j � | �� W d � n1 s$0 Y d S rU )r� r� re rE rE rF rl s zBufferedWriter.flushc C s� | j rtd��| jr�z| j�| j�}W n ty@ td��Y n0 |d u rXttjdd��|t | j�ksn|dk rvt 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) rn r# r� r@ r� r� � RuntimeErrorr� �EAGAINr" r. �rM r� rE rE rF r� s �z BufferedWriter._flush_unlockedc C s t �| �t| j� S rU )r� rf r" r� re rE rE rF rf s zBufferedWriter.tellr c C sP |t vrtd��| j�& | �� t�| ||�W d � S 1 sB0 Y d S )Nr� )r� r# r� r� r� r_ ra rE rE rF r_ s zBufferedWriter.seekc C s� | j �0 | jd u s| jr(W d � d S W d � n1 s<0 Y z<| �� W | j � | j�� W d � q�1 sx0 Y n2| j � | j�� W d � n1 s�0 Y 0 d S rU )r� r@ rn rl r5 re rE rE rF r5 s . *�zBufferedWriter.close)N)r ) rQ rR rS r* r� rx r� rh rl r� rf r_ r5 rE rE rE rF r1 � s r1 c @ s� e Zd Zefdd�Zd dd�Zdd� Zdd � Zd d d �Zd d d�Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zedd � �Zd S )!�BufferedRWPairc C s< |� � std��|�� s td��t||�| _t||�| _d S )Nz#"reader" argument must be readable.z#"writer" argument must be writable.)rv r. rx r2 �readerr1 �writer)rM r� r� r� rE rE rF r� @ s zBufferedRWPair.__init__r c C s |d u r d}| j �|�S �Nr )r� r� r� rE rE rF r� N s zBufferedRWPair.readc C s | j �|�S rU )r� r� r� rE rE rF r� S s zBufferedRWPair.readintoc C s | j �|�S rU )r� r� r� rE rE rF r� V s zBufferedRWPair.writer c C s | j �|�S rU )r� r r� rE rE rF r Y s zBufferedRWPair.peekc C s | j �|�S rU )r� r� r� rE rE rF r� \ s zBufferedRWPair.read1c C s | j �|�S rU )r� r� r� rE rE rF r� _ s zBufferedRWPair.readinto1c C s | j �� S rU )r� rv re rE rE rF rv b s zBufferedRWPair.readablec C s | j �� S rU )r� rx re rE rE rF rx e s zBufferedRWPair.writablec C s | j �� S rU )r� rl re rE rE rF rl h s zBufferedRWPair.flushc C s* z| j �� W | j�� n | j�� 0 d S rU )r� r5 r� re rE rE rF r5 k s zBufferedRWPair.closec C s | j �� p| j�� S rU )r� r) r� re rE rE rF r) q s zBufferedRWPair.isattyc C s | j jS rU )r� rn re rE rE rF rn t s zBufferedRWPair.closedN)r )r )r )rQ rR rS r* r� r� r� r� r r� r� rv rx rl r5 r) r� rn rE rE rE rF r� 0 s r� c @ sj e Zd Zefdd�Zddd�Zdd� Zdd d �Zdd d �Zd d� Z ddd�Z d dd�Z dd� Z dd� Z dS ) r0 c C s( |� � t�| ||� t�| ||� d S rU )ru r2 r� r1 r� rE rE rF r� � s zBufferedRandom.__init__r c C s� |t vrtd��| �� | jr^| j�* | j�| jt| j� d� W d � n1 sT0 Y | j�||�}| j� | � � W d � n1 s�0 Y |dk r�t d��|S )Nr� r r z seek() returned invalid position) r� r# rl r� r� r@ r_ r� r" r� r. ra rE rE rF r_ � s 8&zBufferedRandom.seekc C s | j rt�| �S t�| �S d S rU )r� r1 rf r2 re rE rE rF rf � s zBufferedRandom.tellNc C s |d u r| � � }t�| |�S rU )rf r1 rh ri rE rE rF rh � s zBufferedRandom.truncatec C s |d u r d}| � � t�| |�S r� )rl r2 r� r� rE rE rF r� � s zBufferedRandom.readc C s | � � t�| |�S rU )rl r2 r� r� rE rE rF r� � s zBufferedRandom.readintoc C s | � � t�| |�S rU )rl r2 r r� rE rE rF r � s zBufferedRandom.peekr c C s | � � t�| |�S rU )rl r2 r� r� rE rE rF r� � s zBufferedRandom.read1c C s | � � t�| |�S rU )rl r2 r� r� rE rE rF r� � s zBufferedRandom.readinto1c C sZ | j rN| j�2 | j�| jt| j � d� | �� W d � n1 sD0 Y t�| |�S r� ) r� r� r@ r_ r� r" r� r1 r� r� rE rE rF r� � s &zBufferedRandom.write)r )N)N)r )r )rQ rR rS r* r� r_ rf rh r� r� r r� r� r� rE rE rE rF r0 y s r0 c s� e Zd ZdZdZdZdZdZdZdZ d0dd�Z dd � Z d d � Z d d � Z dd� Zd1dd�Zd2dd�Zdd� Zdd� Zdd� Zefdd�Zd d � Zd3d d �Z� fd d!�Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z e d,d-� �Z e d.d/� �Z � Z!S )4r( r FNTr c C sH | j dkr0z | jr t�| j � W d| _ nd| _ 0 t|t�rBtd��t|t�rb|}|dk rftd��nd}t|t �s~td|f ��t |�t d�ks�td|f ��t dd� |D ��d ks�|� d �d kr�td ��d |v r�d | _ d | _tjtjB }nTd|v r�d | _d}n@d|v �r d | _tjtjB }n"d|v �r>d | _d | _tjtjB }d |v �rTd | _d | _| j�rp| j�rp|tjO }n | j�r�|tjO }n |tjO }|ttdd�O }ttdd��p�ttdd�}||O }d }�zT|dk �r@|�s�td��|d u �r�t�||d�}n0|||�}t|t��std��|dk �r*td��|}|�s@t�|d� || _t� |�} z(t � | j ��rvt t!j"t�#t!j"�|��W n t$�y� Y n0 t| dd�| _%| j%d k�r�t&| _%t'�r�t'|tj(� || _)| j�rzt�*|dt+� W n6 t�y } z | j!t!j,k�r� W Y d } ~ n d } ~ 0 0 W n" |d u�r6t�|� � Y n0 || _ d S )Nr r z$integer argument expected, got floatznegative file descriptorzinvalid mode: %szxrwab+c s s | ]}|d v V qdS )ZrwaxNrE )�.0�crE rE rF � <genexpr>� r� z"FileIO.__init__.<locals>.<genexpr>r r zKMust have exactly one of create/read/write/append mode and at most one plusr Tr r r �O_BINARYZ O_NOINHERIT� O_CLOEXECz'Cannot use closefd=False with file namei� z expected integer from openerzNegative file descriptorFr- )-�_fd�_closefdr r5 r �floatr r r# r r! �sum�count�_created� _writable�O_EXCL�O_CREAT� _readable�O_TRUNC� _appending�O_APPEND�O_RDWR�O_RDONLY�O_WRONLY�getattrrG r. �set_inheritabler+ �stat�S_ISDIR�st_mode�IsADirectoryErrorr� ZEISDIRr� r/ �_blksizer* �_setmoder� r] �lseekr ZESPIPE) rM r6 r4 r; r �fd�flagsZnoinherit_flagZowned_fdZfdfstatr� rE rE rF r� � s� $ � � zFileIO.__init__c C sB | j dkr>| jr>| js>dd l}|jd| f td| d� | �� d S )Nr zunclosed file %rr )� stacklevel�source)r� r rn r$ r% �ResourceWarningr5 )rM r$ rE rE rF rp E s �zFileIO.__del__c C s t d| jj�d���d S r� r� re rE rE rF r� L s zFileIO.__getstate__c C sn d| j j| j jf }| jr"d| S z | j}W n( tyT d|| j| j| jf Y S 0 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>) r\ rR rS rn r] r/ r� r4 r )rM � class_namer] rE rE rF r� O s � � �zFileIO.__repr__c C s | j std��d S )NzFile not open for reading)r rZ re rE rE rF rw ] s zFileIO._checkReadablec C s | j std��d S )NzFile not open for writing)r rZ rs rE rE rF ry a s zFileIO._checkWritablec C sR | � � | �� |d u s |dk r(| �� S zt�| j|�W S tyL Y d S 0 d S r� )rk rw r� r r� r� r� r� rE rE rF r� e s z FileIO.readc C s� | � � | �� t}z6t�| jdt�}t�| j�j}||krH|| d }W n t y\ Y n0 t � }t |�|kr�t |�}|t |t�7 }|t |� }zt� | j|�}W n ty� |r�Y q�Y d S 0 |s�q�||7 }qdt|�S rd )rk rw r* r r r� r r+ �st_sizer. r� r" r� r� r� r )rM �bufsizerb �endrA r� r� rE rE rF r� u s2 zFileIO.readallc C s4 t |��d�}| �t|��}t|�}||d |�< |S r� )r� r� r� r" )rM r �mr� r� rE rE rF r� � s zFileIO.readintoc C s: | � � | �� zt�| j|�W S ty4 Y d S 0 d S rU )rk ry r r� r� r� r� rE rE rF r� � s z FileIO.writec C s* t |t�rtd��| �� t�| j||�S )Nzan integer is required)r r r rk r r r� ra rE rE rF r_ � s z FileIO.seekc C s | � � t�| jdt�S r� )rk r r r� r re rE rE rF rf � s z FileIO.tellc C s2 | � � | �� |d u r | �� }t�| j|� |S rU )rk ry rf r � ftruncater� r� rE rE rF rh � s zFileIO.truncatec s8 | j s4z | jrt�| j� W t� �� n t� �� 0 d S rU )rn r r r5 r� r� re r� rE rF r5 � s z FileIO.closec C sD | � � | jd u r>z | �� W n ty6 d| _Y n0 d| _| jS )NFT)rk � _seekablerf r. re rE rE rF rr � s zFileIO.seekablec C s | � � | jS rU )rk r re rE rE rF rv � s zFileIO.readablec C s | � � | jS rU )rk r re rE rE rF rx � s zFileIO.writablec C s | � � | jS rU )rk r� re rE rE rF r, � s z FileIO.filenoc C s | � � t�| j�S rU )rk r r) r� re rE rE rF r) � s z FileIO.isattyc C s | j S rU )r re rE rE rF r; � s zFileIO.closefdc C sJ | j r| jrdS dS n0| jr,| jr&dS dS n| jrB| jr<dS dS ndS d S )Nzxb+�xbzab+�abzrb+rH �wb)r r r r re rE rE rF r4 s z FileIO.mode)r TN)N)N)N)"rQ rR rS r� r r r r r# r r� rp r� r� rw ry r� r� r� r� r r_ rf rh r5 rr rv rx r, r) r� r; r4 r� rE rE r� rF r( � s< y # r( c @ s\ e Zd Zddd�Zdd� Zddd�Zd d � Zd d � Zed d� �Z edd� �Z edd� �Z dS )� TextIOBaser c C s | � d� d S r� r` r� rE rE rF r� " s zTextIOBase.readc C s | � d� d S r� r` )rM �srE rE rF r� , s zTextIOBase.writeNc C s | � d� d S rg r` ri rE rE rF rh 0 s zTextIOBase.truncatec C s | � d� d S )Nr� r` re rE rE rF r� 4 s zTextIOBase.readlinec C s | � d� d S r� r` re rE rE rF r� ; s zTextIOBase.detachc C s d S rU rE re rE rE rF r8 D s zTextIOBase.encodingc C s d S rU rE re rE rE rF �newlinesI s zTextIOBase.newlinesc C s d S rU rE re rE rE rF r9 S s zTextIOBase.errors)r )N) rQ rR rS r� r� rh r� r� r� r8 r) r9 rE rE rE rF r' s r' c @ sP e Zd Zddd�Zddd�Zdd� Zd d � Zd d � Zd ZdZ dZ e dd� �Z dS )�IncrementalNewlineDecoder�strictc C s, t jj| |d� || _|| _d| _d| _d S )N)r9 r F)�codecs�IncrementalDecoderr� � translate�decoder�seennl� pendingcr)rM r/ r. r9 rE rE rF r� d s z"IncrementalNewlineDecoder.__init__Fc C s� | j d u r|}n| j j||d�}| jr<|s.|r<d| }d| _|�d�r\|s\|d d� }d| _|�d�}|�d�| }|�d�| }| j|o�| j|o�| jB |o�| jB O _| j r�|r�|� dd�}|r�|� dd�}|S )N��final� Fr T� � ) r/ �decoder1 r� r r0 �_LF�_CR�_CRLFr. �replace)rM �inputr3 �outputZcrlfZcrZlfrE rE rF r7 k s* � z IncrementalNewlineDecoder.decodec C s@ | j d u rd}d}n| j �� \}}|dK }| jr8|dO }||fS )Nr� r r )r/ �getstater1 )rM r� �flagrE rE rF r> � s z"IncrementalNewlineDecoder.getstatec C s8 |\}}t |d@ �| _| jd ur4| j�||d? f� d S r� )�boolr1 r/ �setstate)rM �stater� r? rE rE rF rA � s z"IncrementalNewlineDecoder.setstatec C s$ d| _ d| _| jd ur | j�� d S )Nr F)r0 r1 r/ �resetre rE rE rF rC � s z IncrementalNewlineDecoder.resetr r � c C s d| j S )N)Nr6 r4 )r4 r6 r5 )r6 r5 )r4 r5 )r4 r6 r5 )r0 re rE rE rF r) � s �z"IncrementalNewlineDecoder.newlinesN)r+ )F) rQ rR rS r� r7 r> rA rC r8 r9 r: r� r) rE rE rE rF r* ] s r* c @ sr e Zd ZdZdZdNdd�Zdd� ZdOdd �Zd d � Ze d d � �Z e dd� �Z e dd� �Z e dd� �Z e dd� �Zddeddd�dd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Ze d#d$� �Ze d%d&� �Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z d1d2� Z dPd3d4�Z d5d6� Z d7d8� Z dQd:d;�Z!d<d=� Z"d>d?� Z#dRd@dA�Z$dBdC� Z%dSdDdE�Z&dTdFdG�Z'dHdI� Z(dUdJdK�Z)e dLdM� �Z*dS )Vr3 i NFc C s$ | � |� |d u rrzt�|�� �}W n ttfy: Y n0 |d u rrz dd l}W n tyf d}Y n 0 |�d�}t |t �s�t d| ��t � |�js�d}t|| ��|d u r�d}n$t |t �s�t d| ��tr�t �|� || _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/ rZ �locale� ImportError�getpreferredencodingr r r# r, �lookup�_is_text_encoding� LookupError� _CHECK_ERRORS� lookup_errorr� �_decoded_chars�_decoded_chars_used� _snapshotrD rr r# �_tellingr� � _has_read1� _configure) rM rD r8 r9 r: rB � write_throughrH rt rE rE rF r� � s@ �zTextIOWrapper.__init__c C s> |d ur$t |t�s$tdt|�f ��|dvr:td|f ��d S )Nzillegal newline type: %r)Nr r6 r4 r5 zillegal newline value: %r)r r r �typer# )rM r: rE rE rF rF � s z TextIOWrapper._check_newlinec C s� || _ || _d | _d | _d| _| | _|d u | _|| _|dk| _|pHt j | _ || _ || _ | jr�| �� r�| j�� }|dkr�z| �� �d� W n ty� Y n0 d S )N� r r )� _encoding�_errors�_encoder�_decoder� _b2cratio�_readuniversal�_readtranslate�_readnl�_writetranslater �linesep�_writenl�_line_buffering�_write_throughr# rx rD rf � _get_encoderrA rM )rM r8 r9 r: rB rV �positionrE rE rF rU s& zTextIOWrapper._configurec C s| d� | jj| jj�}z | j}W n ty0 Y n0 |d� |�7 }z | j}W n ty\ Y n0 |d� |�7 }|d� | j� S )Nz<{}.{}z name={0!r}z mode={0!r}z encoding={0!r}>)r� r\ rR rS r] r/ r4 r8 )rM rA r] r4 rE rE rF r� ' s � zTextIOWrapper.__repr__c C s | j S rU )rY re rE rE rF r8 8 s zTextIOWrapper.encodingc C s | j S rU )rZ re rE rE rF r9 < s zTextIOWrapper.errorsc C s | j S rU )rd re rE rE rF rB @ s z TextIOWrapper.line_bufferingc C s | j S rU )re re rE rE rF rV D s zTextIOWrapper.write_throughc C s | j S rU )r� re rE rE rF rD H s zTextIOWrapper.buffer)r8 r9 r: rB rV c C s� | j d ur*|d us"|d us"|tur*td��|d u rH|d u rB| j}q^d}nt|t�s^td| ��|d u rn| j}nt|t�s�td| ��|tu r�| j}| � |� |d u r�| j }|d u r�| j }| � � | � |||||� d S )NzPIt is not possible to set the encoding or newline of stream after the first readr+ r r )r\ �EllipsisrZ rZ r r r rY r` rF rB rV rl rU )rM r8 r9 r: rB rV rE rE rF � reconfigureL s> ���� �zTextIOWrapper.reconfigurec C s | j rtd��| jS rz )rn r# r# re rE rE rF rr u s zTextIOWrapper.seekablec C s | j �� S rU )rD rv re rE rE rF rv z s zTextIOWrapper.readablec C s | j �� S rU )rD rx re rE rE rF rx } s zTextIOWrapper.writablec C s | j �� | j| _d S rU )rD rl r# rS re rE rE rF rl � s zTextIOWrapper.flushc C s8 | j d ur4| js4z| �� W | j �� n | j �� 0 d S rU )rD rn rl r5 re rE rE rF r5 � s zTextIOWrapper.closec C s | j jS rU )rD rn re rE rE rF rn � s zTextIOWrapper.closedc C s | j jS rU )rD r] re rE rE rF r] � s zTextIOWrapper.namec C s | j �� S rU )rD r, re rE rE rF r, � s zTextIOWrapper.filenoc C s | j �� S rU )rD r) re rE rE rF r) � s zTextIOWrapper.isattyc C s� | j rtd��t|t�s(td|jj ��t|�}| js<| j oBd|v }|rf| jrf| j dkrf|� d| j �}| j pr| � � }|�|�}| j�|� | j r�|s�d|v r�| �� | �d� d | _| jr�| j�� |S )Nr� z can't write %s to text streamr6 r4 r )rn r# r r r r\ rQ r" ra rd rc r; r[ rf �encoderD r� rl �_set_decoded_charsrR r\ rC )rM r( �lengthZhaslf�encoderr rE rE rF r� � s( � zTextIOWrapper.writec C s t �| j�}|| j�| _| jS rU )r, �getincrementalencoderrY rZ r[ )rM Z make_encoderrE rE rF rf � s zTextIOWrapper._get_encoderc C s2 t �| j�}|| j�}| jr(t|| j�}|| _|S rU )r, �getincrementaldecoderrY rZ r^ r* r_ r\ )rM Z make_decoderr/ rE rE rF � _get_decoder� s zTextIOWrapper._get_decoderc C s || _ d| _d S r� )rP rQ )rM �charsrE rE rF rk � s z TextIOWrapper._set_decoded_charsc C sF | j }|d u r | j|d � }n| j||| � }| j t|�7 _ |S rU )rQ rP r" )rM r� �offsetrq rE rE rF �_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)rQ �AssertionErrorr� rE rE rF �_rewind_decoded_chars� s z#TextIOWrapper._rewind_decoded_charsc C s� | j d u rtd��| jr&| j �� \}}| jr<| j�| j�}n| j�| j�}| }| j � ||�}| � |� |r�t |�t | j � | _ nd| _ | jr�||| f| _| S )Nz no decoderrX )r\ r# rS r> rT rD r� � _CHUNK_SIZEr� r7 rk r" rP r] rR )rM � dec_buffer� dec_flags� input_chunk�eofZ decoded_charsrE rE rF � _read_chunk� s zTextIOWrapper._read_chunkr c C s( ||d> B |d> B |d> B t |�d> B S )N�@ � � � )r@ )rM rg rx � bytes_to_feed�need_eof� chars_to_skiprE rE rF � _pack_cookie� s � �zTextIOWrapper._pack_cookiec C sJ t |d�\}}t |d�\}}t |d�\}}t |d�\}}|||t|�|fS )Nl )�divmodr@ )rM Zbigint�restrg rx r� r� r� rE rE rF �_unpack_cookie s z TextIOWrapper._unpack_cookiec C sP | j std��| js td��| �� | j�� }| j}|d u sF| jd u rX| j rTt d��|S | j\}}|t |�8 }| j }|dkr�| � ||�S |�� }�z�t| j| �}d}|dk�r"|�d|f� t |�|d |� ��} | |k�r|�� \} } | s�| }|| 8 }�q4|t | �8 }d}q�||8 }|d }q�d}|�d|f� || } |} |dk�rb| � | | �W |�|� S d}d}d}t|t |��D ]x}|d7 }|t |�|||d � ��7 }|�� \}}|�s�||k�r�| |7 } ||8 }|dd } }}||k�r| �q"�q||t |jdd d ��7 }d }||k �r"td ��| � | | |||�W |�|� S |�|� 0 d S ) N�!underlying stream is not seekablez(telling position disabled by next() callzpending decoded textr r r� r FTr2 z'can't reconstruct logical file position)r# rZ rS r. rl rD rf r\ rR rP rt r" rQ r� r> r r] rA r7 �range)rM rg r/ rx Z next_inputr� � saved_stateZ skip_bytesZ skip_backr� r �d� start_posZ start_flagsZ bytes_fedr� Z chars_decoded�irw rE rE rF rf s� � � �zTextIOWrapper.tellc C s$ | � � |d u r| �� }| j�|�S rU )rl rf rD rh ri rE rE rF rh s s zTextIOWrapper.truncatec C s* | j d u rtd��| �� | j}d | _|S )Nzbuffer is already detached)rD r# rl r� )rM rD rE rE rF r� y s zTextIOWrapper.detachc s� � fdd�}� j rtd��� js(td��|tkrN|dkr@td��d}� �� }nZ|tkr�|dkrftd��� �� � j� d|�}� � d� d � _ � j r�� j � � ||� |S |dkr�td |f ��|dk r�td |f ��� �� � �|�\}}}}} � j� |� � � d� d � _ |dk�r*� j �r*� j � � n@� j �s>|�s>| �rj� j �pL� �� � _ � j �d |f� |d f� _ | �r�� j�|�} � � � j �| |�� || f� _ t� j�| k �r�td ��| � _||� |S ) Nc sF z� j p� �� }W n ty$ Y n 0 | dkr:|�d� n|�� d S r� )r[ rf rM rA rC )rg rm re rE rF �_reset_encoder� s z*TextIOWrapper.seek.<locals>._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)rn r# r# rZ r rf r rl rD r_ rk rR r\ rC r� rp rA r� r7 r" rP r. rQ ) rM Zcookierc r� rg r� rx r� r� r� ry rE re rF r_ � s` � � zTextIOWrapper.seekc C s� | � � |d u rd}n2z |j}W n ty@ t|�d���Y n0 |� }| jpT| �� }|dk r�| �� |j| j� � dd� }| � d� d | _ |S d}| �|�}t |�|k r�|s�| � � }|| �|t |� �7 }q�|S d S )Nr r� r Tr2 r F)rw r� r/ r r\ rp rs r7 rD r� rk rR r" r{ )rM r� r� r/ rA rz rE rE rF r� � s, � zTextIOWrapper.readc C s( d| _ | �� }|s$d | _| j| _ t�|S rq )rS r� rR r# r� r� rE rE rF r� � s zTextIOWrapper.__next__c C s | j rtd��|d u r d}n2z |j}W n tyF t|�d���Y n0 |� }| �� }d}| jsh| �� d }}| jr�|� d|�}|dkr�|d }�q�nt |�}n�| j �rD|� d|�}|� d|�}|dkr�|dkr�t |�}n |d }�q�nX|dk�r|d }�q�n@||k �r|d }�q�n(||d k�r6|d }�q�n |d }�q�n(|� | j �}|dk�rl|t | j � }�q�|dk�r�t |�|k�r�|}�q�| � � �r�| j�r��q��q�| j�r�|| �� 7 }qp| �d � d | _|S qp|dk�r�||k�r�|}| �t |�| � |d |� S ) Nr� r r� r r6 r r4 r r )rn r# r� r/ r rs r\ rp r_ r� r" r^ r` r{ rP rk rR ru ) rM r� r� r� �startrb �endposZnlposZcrposrE rE rF r� � st zTextIOWrapper.readlinec C s | j r| j jS d S rU )r\ r) re rE rE rF r) N s zTextIOWrapper.newlines)NNNFF)NNNFF)N)r r Fr )N)r )N)N)+rQ rR rS rv r� r� rF rU r� r� r8 r9 rB rV rD rh ri rr rv rx rl r5 rn r] r, r) r� rf rp rk rs ru r{ r� r� rf rh r� r_ r� r� r� r) rE rE rE rF r3 � sl � * � $ � ) * � c K ]r3 c sN e Zd Zd� fdd� Zdd� Zdd� Zed d � �Zed d � �Zd d� Z � Z S )�StringIOr r6 c sf t t| �jt� dd|d� |d u r(d| _|d urbt|t�sNtd�t |�j ���| � |� | � d� d S )Nzutf-8� surrogatepass)r8 r9 r: Fz*initial_value must be str or None, not {0}r ) r� r� r� r� ra r r r r� rW rQ r� r_ )rM Z initial_valuer: r� rE rF r� Z s � � zStringIO.__init__c C sX | � � | jp| �� }|�� }|�� z |j| j�� dd�W |�|� S |�|� 0 d S )NTr2 ) rl r\ rp r> rC r7 rD r� rA )rM r/ Z old_staterE rE rF r� j s �zStringIO.getvaluec C s t �| �S rU )�objectr� re rE rE rF r� t s zStringIO.__repr__c C s d S rU rE re rE rE rF r9 y s zStringIO.errorsc C s d S rU rE re rE rE rF r8 } s zStringIO.encodingc C s | � d� d S r� r` re rE rE rF r� � s zStringIO.detach)r r6 ) rQ rR rS r� r� r� r� r9 r8 r� r� rE rE r� rF r� S s r� )r r NNNTN)8r �abcr, r� r �sys�_threadr r� �platform�msvcrtr r �ior r r r r� r� �addr � SEEK_DATAr* r� r �dev_modero rN rG rJ � open_coder/ rK rT rZ r. r# �ABCMetar[ �registerr� �_ior( r� r� r� r2 r1 r� r0 r' r- r* r3 r� rE rE rE rF �<module> s� � [ # = g k CiIJ Y@ U &
SIMPAN
[ BATAL ]