X-Git-Url: https://review.fuel-infra.org/gitweb?a=blobdiff_plain;f=eventlet%2Feventlet%2Fgreen%2FOpenSSL%2FSSL.py;fp=eventlet%2Feventlet%2Fgreen%2FOpenSSL%2FSSL.py;h=0000000000000000000000000000000000000000;hb=358bd9258c2b6d2ee74de4dfd07a5123107abad4;hp=f534ceab4c06964e9ec6b678602d5f51e44ec087;hpb=376ff3bfe7071cc0793184a378c4e74508fb0d97;p=packages%2Ftrusty%2Fpython-eventlet.git

diff --git a/eventlet/eventlet/green/OpenSSL/SSL.py b/eventlet/eventlet/green/OpenSSL/SSL.py
deleted file mode 100644
index f534cea..0000000
--- a/eventlet/eventlet/green/OpenSSL/SSL.py
+++ /dev/null
@@ -1,124 +0,0 @@
-from OpenSSL import SSL as orig_SSL
-from OpenSSL.SSL import *
-from eventlet.support import get_errno
-from eventlet import greenio
-from eventlet.hubs import trampoline
-import socket
-
-
-class GreenConnection(greenio.GreenSocket):
-    """ Nonblocking wrapper for SSL.Connection objects.
-    """
-
-    def __init__(self, ctx, sock=None):
-        if sock is not None:
-            fd = orig_SSL.Connection(ctx, sock)
-        else:
-            # if we're given a Connection object directly, use it;
-            # this is used in the inherited accept() method
-            fd = ctx
-        super(ConnectionType, self).__init__(fd)
-
-    def do_handshake(self):
-        """ 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. """
-        if self.act_non_blocking:
-            return self.fd.do_handshake()
-        while True:
-            try:
-                return self.fd.do_handshake()
-            except WantReadError:
-                trampoline(self.fd.fileno(),
-                           read=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-            except WantWriteError:
-                trampoline(self.fd.fileno(),
-                           write=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-
-    def dup(self):
-        raise NotImplementedError("Dup not supported on SSL sockets")
-
-    def makefile(self, mode='r', bufsize=-1):
-        raise NotImplementedError("Makefile not supported on SSL sockets")
-
-    def read(self, size):
-        """Works like a blocking call to SSL_read(), whose behavior is
-        described here:  http://www.openssl.org/docs/ssl/SSL_read.html"""
-        if self.act_non_blocking:
-            return self.fd.read(size)
-        while True:
-            try:
-                return self.fd.read(size)
-            except WantReadError:
-                trampoline(self.fd.fileno(),
-                           read=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-            except WantWriteError:
-                trampoline(self.fd.fileno(),
-                           write=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-            except SysCallError as e:
-                if get_errno(e) == -1 or get_errno(e) > 0:
-                    return ''
-
-    recv = read
-
-    def write(self, data):
-        """Works like a blocking call to SSL_write(), whose behavior is
-        described here:  http://www.openssl.org/docs/ssl/SSL_write.html"""
-        if not data:
-            return 0  # calling SSL_write() with 0 bytes to be sent is undefined
-        if self.act_non_blocking:
-            return self.fd.write(data)
-        while True:
-            try:
-                return self.fd.write(data)
-            except WantReadError:
-                trampoline(self.fd.fileno(),
-                           read=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-            except WantWriteError:
-                trampoline(self.fd.fileno(),
-                           write=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-
-    send = write
-
-    def sendall(self, data):
-        """Send "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."""
-        tail = self.send(data)
-        while tail < len(data):
-            tail += self.send(data[tail:])
-
-    def shutdown(self):
-        if self.act_non_blocking:
-            return self.fd.shutdown()
-        while True:
-            try:
-                return self.fd.shutdown()
-            except WantReadError:
-                trampoline(self.fd.fileno(),
-                           read=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-            except WantWriteError:
-                trampoline(self.fd.fileno(),
-                           write=True,
-                           timeout=self.gettimeout(),
-                           timeout_exc=socket.timeout)
-
-Connection = ConnectionType = GreenConnection
-
-del greenio