3  (ƒhÑã@sJdZddlTddlZddlZdgZejZejejfZGdd„dej ƒZ dS)z} SocketIO imported from socket module in Python 3. Copyright (c) 2001-2013 Python Software Foundation; All Rights Reserved. é)Ú*NÚSocketIOcspeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Z‡fd d „Z dd„Z e dd„ƒZ e dd„ƒZ dd„Z‡ZS)rz¬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. cCsZ|d krtd|ƒ‚tjj|ƒ||_d|kr6|d7}||_d|k|_d|k|_d |_dS) NÚrÚwÚrwÚrbÚwbÚrwbzinvalid mode: %rÚbF)rrrrrr ) Ú ValueErrorÚioÚ RawIOBaseÚ__init__Ú_sockÚ_modeÚ_readingÚ_writingÚ_timeout_occurred)ÚselfÚsockÚmode©rú6/tmp/pip-install-q3hcpn_q/PyMySQL/pymysql/_socketio.pyr!s    zSocketIO.__init__cCs”|jƒ|jƒ|jrtdƒ‚xpy |jj|ƒStk rHd|_‚Yq tk rŠ}z(|jd}|t krlw |t krxdS‚WYdd}~Xq Xq WdS)a3Read 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 objectTrN) Ú _checkClosedÚ_checkReadablerÚIOErrorrÚ recv_intoÚtimeoutÚerrorÚargsÚEINTRÚ_blocking_errnos)rr ÚeÚnrrrÚreadinto-s"  zSocketIO.readintocCsX|jƒ|jƒy |jj|ƒStk rR}z|jdtkr@dS‚WYdd}~XnXdS)aWrite 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. rN)rÚ_checkWritablerÚsendrrr!)rr r"rrrÚwriteGs zSocketIO.writecCs|jrtdƒ‚|jS)z2True if the SocketIO is open for reading. zI/O operation on closed socket.)Úclosedr r)rrrrÚreadableWszSocketIO.readablecCs|jrtdƒ‚|jS)z2True if the SocketIO is open for writing. zI/O operation on closed socket.)r(r r)rrrrÚwritable^szSocketIO.writablecs|jrtdƒ‚tƒjƒS)z2True if the SocketIO is open for seeking. zI/O operation on closed socket.)r(r ÚsuperÚseekable)r)Ú __class__rrr,eszSocketIO.seekablecCs|jƒ|jjƒS)z=Return the file descriptor of the underlying socket. )rrÚfileno)rrrrr.lszSocketIO.filenocCs|js|jƒSdSdS)Nééÿÿÿÿ)r(r.)rrrrÚnamersz SocketIO.namecCs|jS)N)r)rrrrrysz SocketIO.modecCs*|jr dStjj|ƒ|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Ú_decref_socketios)rrrrr2}s   zSocketIO.close)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr$r'r)r*r,r.Úpropertyr1rr2Ú __classcell__rr)r-rrs     ) r7Úsocketr ÚerrnoÚ__all__r ÚEAGAINÚ EWOULDBLOCKr!r rrrrrÚs