File: //opt/alt/python38/lib/python3.8/site-packages/pymysql/__pycache__/_socketio.cpython-38.opt-1.pyc
U
�
V� � @ sJ d Z ddlT ddlZddlZdgZejZejejfZG dd� dej �Z
dS )z}
SocketIO imported from socket module in Python 3.
Copyright (c) 2001-2013 Python Software Foundation; All Rights Reserved.
� )�*N�SocketIOc sp e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Z� fd d
�Z dd� Z
e dd� �Z e dd� �Z
dd� Z� ZS )r z�Raw I/O implementation for stream sockets.
This class supports the makefile() method on sockets. It provides
the raw I/O interface on top of a socket object.
c C sZ |dkrt d| ��tj�| � || _d|kr6|d7 }|| _d|k| _d|k| _d| _d S )N)�r�wZrw�rb�wbZrwbzinvalid mode: %r�br r F) �
ValueError�io� RawIOBase�__init__�_sock�_mode�_reading�_writing�_timeout_occurred)�selfZsock�mode� r �B/opt/alt/python38/lib/python3.8/site-packages/pymysql/_socketio.pyr ! s
zSocketIO.__init__c
C s� | � � | �� | jr td��z| j�|�W S tk
rH d| _� Y q tk
r� } z2|jd }|t krrW Y �q |t
kr�W Y �
dS � W 5 d}~X Y q X q dS )a3 Read up to len(b) bytes into the writable buffer *b* and return
the number of bytes read. If the socket is non-blocking and no bytes
are available, None is returned.
If *b* is non-empty, a 0 return value indicates that the connection
was shutdown at the other end.
z!cannot read from timed out objectTr N) � _checkClosed�_checkReadabler �IOErrorr
Z recv_into�timeout�error�args�EINTR�_blocking_errnos)r r �e�nr r r �readinto- s
zSocketIO.readintoc
C s` | � � | �� z| j�|�W S tk
rZ } z |jd tkrHW Y �
dS � W 5 d}~X Y nX dS )a Write the given bytes or bytearray object *b* to the socket
and return the number of bytes written. This can be less than
len(b) if not all data could be written. If the socket is
non-blocking and no bytes could be written None is returned.
r N)r �_checkWritabler
�sendr r r )r r r r r r �writeG s
zSocketIO.writec C s | j rtd��| jS )z2True if the SocketIO is open for reading.
� I/O operation on closed socket.)�closedr r �r r r r �readableW s zSocketIO.readablec C s | j rtd��| jS )z2True if the SocketIO is open for writing.
r$ )r% r r r& r r r �writable^ s zSocketIO.writablec s | j rtd��t� �� S )z2True if the SocketIO is open for seeking.
r$ )r% r �super�seekabler& �� __class__r r r* e s zSocketIO.seekablec C s | � � | j�� S )z=Return the file descriptor of the underlying socket.
)r r
�filenor& r r r r- l s zSocketIO.filenoc C s | j s| �� S dS d S )N���)r% r- r& r r r �namer s z
SocketIO.namec C s | j S )N)r r& r r r r y s z
SocketIO.modec C s* | j r
dS tj�| � | j�� d| _dS )z�Close the SocketIO object. This doesn't close the underlying
socket, except if all references to it have disappeared.
N)r% r
r �closer
Z_decref_socketiosr& r r r r0 } s
zSocketIO.close)�__name__�
__module__� __qualname__�__doc__r r r# r' r( r* r- �propertyr/ r r0 �
__classcell__r r r+ r r s
) r4 Zsocketr
�errno�__all__r ZEAGAINZ EWOULDBLOCKr r r r r r r �<module> s