3 Z_]@s`ddlmZddlTddlmZddlmZddlm Z ddl Z Gdddej Z e Z Z[dS) )SSL)*) get_errno)greenio) trampolineNcsdeZdZdZdfdd ZddZddZdd d Zd dZeZ ddZ e Z ddZ ddZ ZS)GreenConnectionz5 Nonblocking wrapper for SSL.Connection objects. Ncs.|dk rtj||}n|}tt|j|dS)N)orig_SSL ConnectionsuperConnectionType__init__)selfctxsockfd) __class__>/tmp/pip-build-yz_zf6az/eventlet/eventlet/green/OpenSSL/SSL.pyr szGreenConnection.__init__c Cs|jr|jjSxny |jjStk rLt|jjd|jtjdYqt k rzt|jjd|jtjdYqXqWdS)z Perform an SSL handshake (usually called after renegotiate or one of set_accept_state or set_accept_state). This can raise the same exceptions as send and recv. T)readtimeout timeout_exc)writerrN) act_non_blockingr do_handshake WantReadErrorrfileno gettimeoutsocketrWantWriteError)r rrrrs    zGreenConnection.do_handshakecCs tddS)Nz Dup not supported on SSL sockets)NotImplementedError)r rrrdup*szGreenConnection.duprcCs tddS)Nz%Makefile not supported on SSL sockets)r)r modebufsizerrrmakefile-szGreenConnection.makefilecCs|jr|jj|Sxy |jj|Stk rPt|jjd|jtjdYqt k r~t|jjd|jtjdYqt k r}z"t |dkst |dkrdSWYdd}~XqXqWdS) zWorks like a blocking call to SSL_read(), whose behavior is described here: http://www.openssl.org/docs/ssl/SSL_read.htmlT)rrr)rrrr"rN) rrrrrrrrrrZ SysCallErrorr)r sizeerrrr0s$    zGreenConnection.readc Cs|sdS|jr|jj|Sxpy |jj|Stk rXt|jjd|jtjdYqt k rt|jjd|jtjdYqXqWdS)zWorks like a blocking call to SSL_write(), whose behavior is described here: http://www.openssl.org/docs/ssl/SSL_write.htmlrT)rrr)rrrN) rrrrrrrrrr)r datarrrrHs"    zGreenConnection.writecCs6|j|}x&|t|kr0||j||d7}q WdS)zSend "all" data on the connection. This calls send() repeatedly until all data is sent. If an error occurs, it's impossible to tell how much data has been sent. No return value.N)sendlen)r r*tailrrrsendall_s zGreenConnection.sendallc Cs|jr|jjSxny |jjStk rLt|jjd|jtjdYqt k rzt|jjd|jtjdYqXqWdS)NT)rrr)rrr) rrshutdownrrrrrrr)r rrrr/is    zGreenConnection.shutdown)Nr')r!r')__name__ __module__ __qualname____doc__r rr r%rrecvrr+r.r/ __classcell__rr)rrr s   r)ZOpenSSLrrZ OpenSSL.SSLZeventlet.supportrZeventletrZ eventlet.hubsrrZ GreenSocketrr r rrrrs    q