module eventlet.common moved to eventlet.support
This commit is contained in:
@@ -6,8 +6,7 @@ import linecache
|
||||
import inspect
|
||||
import warnings
|
||||
|
||||
from eventlet.common import BaseException
|
||||
from eventlet.support import greenlets as greenlet
|
||||
from eventlet.support import greenlets as greenlet, BaseException
|
||||
from eventlet import hubs
|
||||
from eventlet import greenthread
|
||||
from eventlet import debug
|
||||
|
||||
@@ -5,8 +5,7 @@ from code import InteractiveConsole
|
||||
|
||||
import eventlet
|
||||
from eventlet import hubs
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import greenlets
|
||||
from eventlet.support import greenlets, get_errno
|
||||
#FIXME no testcases for bckdor module
|
||||
|
||||
try:
|
||||
|
||||
@@ -1,36 +0,0 @@
|
||||
import sys
|
||||
def get_errno(exc):
|
||||
""" Get the error code out of socket.error objects.
|
||||
socket.error in <2.5 does not have errno attribute
|
||||
socket.error in 3.x does not allow indexing access
|
||||
e.args[0] works for all.
|
||||
There are cases when args[0] is not errno.
|
||||
i.e. http://bugs.python.org/issue6471
|
||||
Maybe there are cases when errno is set, but it is not the first argument?
|
||||
"""
|
||||
|
||||
try:
|
||||
if exc.errno is not None: return exc.errno
|
||||
except AttributeError:
|
||||
pass
|
||||
try:
|
||||
return exc.args[0]
|
||||
except IndexError:
|
||||
return None
|
||||
|
||||
if sys.version_info[0]<3:
|
||||
from sys import exc_clear as clear_sys_exc_info
|
||||
else:
|
||||
def clear_sys_exc_info():
|
||||
"""No-op In py3k.
|
||||
Exception information is not visible outside of except statements.
|
||||
sys.exc_clear became obsolete and removed."""
|
||||
pass
|
||||
|
||||
if sys.version_info[0]==2 and sys.version_info[1]<5:
|
||||
class BaseException: # pylint: disable-msg=W0622
|
||||
# not subclassing from object() intentionally, because in
|
||||
# that case "raise Timeout" fails with TypeError.
|
||||
pass
|
||||
else:
|
||||
from __builtin__ import BaseException
|
||||
@@ -1,6 +1,6 @@
|
||||
from OpenSSL import SSL as orig_SSL
|
||||
from OpenSSL.SSL import *
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
from eventlet import greenio
|
||||
from eventlet.hubs import trampoline
|
||||
import socket
|
||||
|
||||
@@ -3,7 +3,7 @@ import errno
|
||||
socket = __import__("socket")
|
||||
|
||||
from eventlet import greenio
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
from eventlet import greenthread
|
||||
from eventlet import hubs
|
||||
|
||||
|
||||
@@ -6,7 +6,7 @@ for attr in dir(__ssl):
|
||||
import errno
|
||||
time = __import__('time')
|
||||
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
from eventlet.hubs import trampoline
|
||||
from eventlet.greenio import set_nonblocking, GreenSocket, SOCKET_CLOSED, CONNECT_ERR, CONNECT_SUCCESS
|
||||
orig_socket = __import__('socket')
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
from eventlet.hubs import trampoline
|
||||
BUFFER_SIZE = 4096
|
||||
|
||||
|
||||
@@ -2,8 +2,7 @@ import heapq
|
||||
import sys
|
||||
import traceback
|
||||
|
||||
from eventlet.common import clear_sys_exc_info
|
||||
from eventlet.support import greenlets as greenlet
|
||||
from eventlet.support import greenlets as greenlet, clear_sys_exc_info
|
||||
from eventlet.hubs import timer
|
||||
from eventlet import patcher
|
||||
time = patcher.original('time')
|
||||
|
||||
@@ -5,7 +5,7 @@ select = patcher.original('select')
|
||||
time = patcher.original('time')
|
||||
sleep = time.sleep
|
||||
|
||||
from eventlet.common import get_errno, clear_sys_exc_info
|
||||
from eventlet.support import get_errno, clear_sys_exc_info
|
||||
from eventlet.hubs.hub import BaseHub, READ, WRITE
|
||||
|
||||
EXC_MASK = select.POLLERR | select.POLLHUP
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
import sys
|
||||
import errno
|
||||
from eventlet import patcher
|
||||
from eventlet.common import get_errno, clear_sys_exc_info
|
||||
from eventlet.support import get_errno, clear_sys_exc_info
|
||||
select = patcher.original('select')
|
||||
time = patcher.original('time')
|
||||
|
||||
|
||||
@@ -0,0 +1,36 @@
|
||||
import sys
|
||||
def get_errno(exc):
|
||||
""" Get the error code out of socket.error objects.
|
||||
socket.error in <2.5 does not have errno attribute
|
||||
socket.error in 3.x does not allow indexing access
|
||||
e.args[0] works for all.
|
||||
There are cases when args[0] is not errno.
|
||||
i.e. http://bugs.python.org/issue6471
|
||||
Maybe there are cases when errno is set, but it is not the first argument?
|
||||
"""
|
||||
|
||||
try:
|
||||
if exc.errno is not None: return exc.errno
|
||||
except AttributeError:
|
||||
pass
|
||||
try:
|
||||
return exc.args[0]
|
||||
except IndexError:
|
||||
return None
|
||||
|
||||
if sys.version_info[0]<3:
|
||||
from sys import exc_clear as clear_sys_exc_info
|
||||
else:
|
||||
def clear_sys_exc_info():
|
||||
"""No-op In py3k.
|
||||
Exception information is not visible outside of except statements.
|
||||
sys.exc_clear became obsolete and removed."""
|
||||
pass
|
||||
|
||||
if sys.version_info[0]==2 and sys.version_info[1]<5:
|
||||
class BaseException: # pylint: disable-msg=W0622
|
||||
# not subclassing from object() intentionally, because in
|
||||
# that case "raise Timeout" fails with TypeError.
|
||||
pass
|
||||
else:
|
||||
from __builtin__ import BaseException
|
||||
|
||||
@@ -20,8 +20,7 @@
|
||||
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||
# THE SOFTWARE.from eventlet.support import greenlets as greenlet
|
||||
|
||||
from eventlet.common import BaseException
|
||||
from eventlet.support import greenlets as greenlet
|
||||
from eventlet.support import greenlets as greenlet, BaseException
|
||||
from eventlet.hubs import get_hub
|
||||
|
||||
__all__ = ['Timeout',
|
||||
|
||||
@@ -10,7 +10,7 @@ from eventlet.green import socket
|
||||
from eventlet.green import BaseHTTPServer
|
||||
from eventlet import greenpool
|
||||
from eventlet import greenio
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
|
||||
DEFAULT_MAX_SIMULTANEOUS_REQUESTS = 1024
|
||||
DEFAULT_MAX_HTTP_VERSION = 'HTTP/1.1'
|
||||
|
||||
@@ -3,7 +3,7 @@ from tests import LimitedTestCase, skip_with_pyevent, main, skipped, s2b
|
||||
from eventlet import event
|
||||
from eventlet import greenio
|
||||
from eventlet import debug
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
from eventlet.green import socket
|
||||
from eventlet.green import time
|
||||
from eventlet.green.socket import GreenSSLObject
|
||||
|
||||
@@ -4,7 +4,7 @@ are not leaked by the hub.
|
||||
import sys
|
||||
import unittest
|
||||
from pprint import pformat
|
||||
from eventlet.common import clear_sys_exc_info
|
||||
from eventlet.support import clear_sys_exc_info
|
||||
from eventlet.green import socket
|
||||
from eventlet.green.thread import start_new_thread
|
||||
from eventlet.green.time import sleep
|
||||
|
||||
@@ -14,7 +14,7 @@ from eventlet import greenio
|
||||
from eventlet.green import socket as greensocket
|
||||
from eventlet import wsgi
|
||||
from eventlet import processes
|
||||
from eventlet.common import get_errno
|
||||
from eventlet.support import get_errno
|
||||
|
||||
from tests import find_command
|
||||
|
||||
|
||||
Reference in New Issue
Block a user