Fix test_socket by properly wrapping socketpair and fromfd in the eventlet.green.socket module.

This commit is contained in:
donovan
2009-03-28 17:49:16 -05:00
parent 41d3298eb7
commit 9ba293115d
2 changed files with 11 additions and 10 deletions

View File

@@ -5,6 +5,7 @@ _fileobject = __socket._fileobject
from eventlet.api import get_hub
from eventlet.greenio import GreenSocket as socket, GreenSSL as _GreenSSL
from eventlet.greenio import socketpair, fromfd
def fromfd(*args):
return socket(__socket.fromfd(*args))
@@ -33,16 +34,6 @@ def _gethostbyname_tpool(name):
# XXX there're few more blocking functions in socket
# XXX having a hub-independent way to access thread pool would be nice
def socketpair(family=None, type=SOCK_STREAM, proto=0):
if family is None:
try:
family = AF_UNIX
except AttributeError:
family = AF_INET
a, b = __socket.socketpair(family, type, proto)
return socket(a), socket(b)
_GLOBAL_DEFAULT_TIMEOUT = object()

View File

@@ -547,3 +547,13 @@ class GreenSSL(GreenSocket):
def issuer(self):
return self.fd.issuer()
def socketpair(*args):
one, two = socket.socketpair(*args)
return GreenSocket(one), GreenSocket(two)
def fromfd(*args):
return GreenSocket(socket.fromfd(*args))