remove a number of unused imports from tests
This commit is contained in:
@@ -22,10 +22,8 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|||||||
THE SOFTWARE.
|
THE SOFTWARE.
|
||||||
"""
|
"""
|
||||||
from greentest import tests
|
from greentest import tests
|
||||||
from eventlet import timer
|
|
||||||
from eventlet import coros, api
|
from eventlet import coros, api
|
||||||
|
|
||||||
import sys
|
|
||||||
|
|
||||||
class TestEvent(tests.TestCase):
|
class TestEvent(tests.TestCase):
|
||||||
mode = 'static'
|
mode = 'static'
|
||||||
|
@@ -22,8 +22,6 @@
|
|||||||
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||||
# THE SOFTWARE.
|
# THE SOFTWARE.
|
||||||
|
|
||||||
import os.path
|
|
||||||
|
|
||||||
from eventlet import api, coros
|
from eventlet import api, coros
|
||||||
from greentest import tests
|
from greentest import tests
|
||||||
from eventlet import db_pool
|
from eventlet import db_pool
|
||||||
|
@@ -22,7 +22,7 @@ THE SOFTWARE.
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
from greentest import tests
|
from greentest import tests
|
||||||
from eventlet import api, greenio, util
|
from eventlet import api
|
||||||
import socket
|
import socket
|
||||||
|
|
||||||
# TODO try and reuse unit tests from within Python itself
|
# TODO try and reuse unit tests from within Python itself
|
||||||
|
@@ -26,8 +26,6 @@ import cgi
|
|||||||
|
|
||||||
from eventlet import api
|
from eventlet import api
|
||||||
from eventlet import httpc
|
from eventlet import httpc
|
||||||
from eventlet import processes
|
|
||||||
from eventlet import util
|
|
||||||
from eventlet import wsgi
|
from eventlet import wsgi
|
||||||
|
|
||||||
import time
|
import time
|
||||||
|
@@ -33,8 +33,6 @@ try:
|
|||||||
except ImportError:
|
except ImportError:
|
||||||
from StringIO import StringIO
|
from StringIO import StringIO
|
||||||
|
|
||||||
from eventlet import greenio
|
|
||||||
|
|
||||||
|
|
||||||
util.wrap_socket_with_coroutine_socket()
|
util.wrap_socket_with_coroutine_socket()
|
||||||
|
|
||||||
|
@@ -22,14 +22,11 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|||||||
THE SOFTWARE.
|
THE SOFTWARE.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import sys
|
|
||||||
|
|
||||||
from eventlet import api
|
from eventlet import api
|
||||||
from eventlet import channel
|
from eventlet import channel
|
||||||
from eventlet import coros
|
from eventlet import coros
|
||||||
from eventlet import pools
|
from eventlet import pools
|
||||||
from greentest import tests
|
from greentest import tests
|
||||||
from eventlet import timer
|
|
||||||
|
|
||||||
class IntPool(pools.Pool):
|
class IntPool(pools.Pool):
|
||||||
def create(self):
|
def create(self):
|
||||||
|
@@ -24,7 +24,6 @@ THE SOFTWARE.
|
|||||||
import sys
|
import sys
|
||||||
|
|
||||||
from greentest import tests
|
from greentest import tests
|
||||||
from eventlet import api
|
|
||||||
from eventlet import processes
|
from eventlet import processes
|
||||||
|
|
||||||
class TestEchoPool(tests.TestCase):
|
class TestEchoPool(tests.TestCase):
|
||||||
|
@@ -1,4 +1,3 @@
|
|||||||
import sys
|
|
||||||
from eventlet import pool, coros, api
|
from eventlet import pool, coros, api
|
||||||
from greentest import LimitedTestCase
|
from greentest import LimitedTestCase
|
||||||
from unittest import main
|
from unittest import main
|
||||||
|
@@ -20,7 +20,7 @@
|
|||||||
# THE SOFTWARE.
|
# THE SOFTWARE.
|
||||||
|
|
||||||
from twisted.internet import reactor
|
from twisted.internet import reactor
|
||||||
from greentest import exit_unless_twisted, LimitedTestCase
|
from greentest import exit_unless_twisted
|
||||||
exit_unless_twisted()
|
exit_unless_twisted()
|
||||||
|
|
||||||
import unittest
|
import unittest
|
||||||
@@ -188,53 +188,6 @@ class TestGreenTransport_bufsize1(TestGreenTransport):
|
|||||||
# self.assertEqual('', self.conn.recv())
|
# self.assertEqual('', self.conn.recv())
|
||||||
#
|
#
|
||||||
|
|
||||||
# class TestHalfClose_TCP(LimitedTestCase):
|
|
||||||
#
|
|
||||||
# def _test_server(self, conn):
|
|
||||||
# conn.write('hello')
|
|
||||||
# conn.loseWriteConnection()
|
|
||||||
# self.assertRaises(pr.ConnectionDone, conn.write, 'hey')
|
|
||||||
# data = conn.read()
|
|
||||||
# self.assertEqual('bye', data)
|
|
||||||
# conn.loseConnection()
|
|
||||||
# self.assertRaises(ConnectionDone, conn._wait)
|
|
||||||
# self.check.append('server')
|
|
||||||
#
|
|
||||||
# def setUp(self):
|
|
||||||
# LimitedTestCase.setUp(self)
|
|
||||||
# self.factory = pr.SpawnFactory(self._test_server)
|
|
||||||
# self.port = reactor.listenTCP(0, self.factory)
|
|
||||||
# self.conn = pr.GreenClientCreator(reactor).connectTCP('localhost', self.port.getHost().port)
|
|
||||||
# self.port.stopListening()
|
|
||||||
# self.check = []
|
|
||||||
#
|
|
||||||
# def test(self):
|
|
||||||
# conn = self.conn
|
|
||||||
# data = conn.read()
|
|
||||||
# self.assertEqual('hello', data)
|
|
||||||
# conn.write('bye')
|
|
||||||
# conn.loseWriteConnection()
|
|
||||||
# self.assertRaises(pr.ConnectionDone, conn.write, 'hoy')
|
|
||||||
# self.factory.waitall()
|
|
||||||
# self.assertRaises(ConnectionDone, conn._wait)
|
|
||||||
# assert self.check == ['server']
|
|
||||||
#
|
|
||||||
# class TestHalfClose_TLS(TestHalfClose_TCP):
|
|
||||||
#
|
|
||||||
# def setUp(self):
|
|
||||||
# LimitedTestCase.setUp(self)
|
|
||||||
# from gnutls.crypto import X509PrivateKey, X509Certificate
|
|
||||||
# from gnutls.interfaces.twisted import X509Credentials
|
|
||||||
# cert = X509Certificate(open('gnutls_valid.crt').read())
|
|
||||||
# key = X509PrivateKey(open('gnutls_valid.key').read())
|
|
||||||
# server_credentials = X509Credentials(cert, key)
|
|
||||||
# self.factory = pr.SpawnFactory(self._test_server)
|
|
||||||
# self.port = reactor.listenTLS(0, self.factory, server_credentials)
|
|
||||||
# self.conn = pr.GreenClientCreator(reactor).connectTLS('localhost', self.port.getHost().port, X509Credentials())
|
|
||||||
# self.port.stopListening()
|
|
||||||
# self.check = []
|
|
||||||
#
|
|
||||||
|
|
||||||
if socket is not None:
|
if socket is not None:
|
||||||
|
|
||||||
class TestUnbufferedTransport_socketserver(TestUnbufferedTransport):
|
class TestUnbufferedTransport_socketserver(TestUnbufferedTransport):
|
||||||
|
@@ -17,11 +17,10 @@ See the License for the specific language governing permissions and
|
|||||||
limitations under the License.
|
limitations under the License.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import os, socket, time, threading
|
import time
|
||||||
from eventlet import coros, api, tpool
|
from eventlet import coros, api, tpool
|
||||||
from greentest import tests
|
from greentest import tests
|
||||||
|
|
||||||
from eventlet.tpool import erpc
|
|
||||||
from sys import stdout
|
from sys import stdout
|
||||||
|
|
||||||
import random
|
import random
|
||||||
|
@@ -28,7 +28,6 @@ import os
|
|||||||
from eventlet import api
|
from eventlet import api
|
||||||
from eventlet import wsgi
|
from eventlet import wsgi
|
||||||
from eventlet import processes
|
from eventlet import processes
|
||||||
from eventlet import util
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
from cStringIO import StringIO
|
from cStringIO import StringIO
|
||||||
|
Reference in New Issue
Block a user