File: //usr/lib/python3.6/site-packages/pymysql/__pycache__/_socketio.cpython-36.pyc
3
B��Z� � @ 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 |d
krt d| ��tjj| � || _d|kr6|d7 }|| _d|k| _d|k| _d | _d S ) N�r�w�rw�rb�wb�rwbzinvalid mode: %r�bF)r r r r r r ) �
ValueError�io� RawIOBase�__init__�_sock�_mode�_reading�_writing�_timeout_occurred)�selfZsock�mode� r � /usr/lib/python3.6/_socketio.pyr ! s
zSocketIO.__init__c C s� | j � | j� | jr td��xpy | jj|�S tk
rH d| _� Y q tk
r� } z(|jd }|t krlw |t
krxdS � W Y dd}~X q X q W 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_intoZtimeout�error�args�EINTR�_blocking_errnos)r r
�e�nr r r �readinto- s"
zSocketIO.readintoc C sX | j � | j� y | jj|�S tk
rR } z|jd tkr@dS � W Y dd}~X 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.
z 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.
z I/O operation on closed socket.)r% r r )r r r r �writable^ s zSocketIO.writablec s | j rtd��t� j� S )z2True if the SocketIO is open for seeking.
z I/O operation on closed socket.)r% r �super�seekable)r )� __class__r r r) e s zSocketIO.seekablec C s | j � | jj� S )z=Return the file descriptor of the underlying socket.
)r r �fileno)r r r r r+ l s zSocketIO.filenoc C s | j s| j� 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 tjj| � | jj� 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_socketios)r r r r r/ } s
zSocketIO.close)�__name__�
__module__� __qualname__�__doc__r r! r$ r& r' r) r+ �propertyr. r r/ �
__classcell__r r )r* r r s ) r3 Zsocketr �errno�__all__r ZEAGAINZ EWOULDBLOCKr r
r r r r r �<module> s