tests: clean out unittest.main()
This commit is contained in:
@@ -1,5 +1,4 @@
|
|||||||
import time
|
import time
|
||||||
import unittest
|
|
||||||
|
|
||||||
import eventlet
|
import eventlet
|
||||||
from eventlet import semaphore
|
from eventlet import semaphore
|
||||||
@@ -62,7 +61,3 @@ def test_semaphore_contention():
|
|||||||
t2.kill()
|
t2.kill()
|
||||||
|
|
||||||
assert abs(counts[0] - counts[1]) < int(min(counts) * 0.1), counts
|
assert abs(counts[0] - counts[1]) < int(min(counts) * 0.1), counts
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
unittest.main()
|
|
||||||
|
@@ -1,4 +1,3 @@
|
|||||||
import unittest
|
|
||||||
from eventlet import spawn, sleep, with_timeout
|
from eventlet import spawn, sleep, with_timeout
|
||||||
from eventlet.event import Event
|
from eventlet.event import Event
|
||||||
import eventlet
|
import eventlet
|
||||||
@@ -39,7 +38,3 @@ class TestEvent(LimitedTestCase):
|
|||||||
X = object()
|
X = object()
|
||||||
result = with_timeout(DELAY, event2.wait, timeout_value=X)
|
result = with_timeout(DELAY, event2.wait, timeout_value=X)
|
||||||
assert result is X, 'Nobody sent anything to event2 yet it received %r' % (result, )
|
assert result is X, 'Nobody sent anything to event2 yet it received %r' % (result, )
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
unittest.main()
|
|
||||||
|
@@ -2,10 +2,8 @@
|
|||||||
To do that spawn a green server and then access it using a green socket.
|
To do that spawn a green server and then access it using a green socket.
|
||||||
If either operation blocked the whole script would block and timeout.
|
If either operation blocked the whole script would block and timeout.
|
||||||
"""
|
"""
|
||||||
import unittest
|
import eventlet
|
||||||
|
|
||||||
from eventlet.green import BaseHTTPServer
|
from eventlet.green import BaseHTTPServer
|
||||||
from eventlet import spawn, kill
|
|
||||||
from eventlet.support import six
|
from eventlet.support import six
|
||||||
|
|
||||||
if six.PY2:
|
if six.PY2:
|
||||||
@@ -34,27 +32,20 @@ def start_http_server():
|
|||||||
# the send() for the response blocks (or at least appeared to be)
|
# the send() for the response blocks (or at least appeared to be)
|
||||||
httpd.request_count += 1
|
httpd.request_count += 1
|
||||||
httpd.handle_request()
|
httpd.handle_request()
|
||||||
return spawn(serve), httpd, sa[1]
|
return eventlet.spawn(serve), httpd, sa[1]
|
||||||
|
|
||||||
|
|
||||||
class TestGreenness(unittest.TestCase):
|
def test_urllib():
|
||||||
|
gthread, server, port = start_http_server()
|
||||||
|
|
||||||
def setUp(self):
|
|
||||||
self.gthread, self.server, self.port = start_http_server()
|
|
||||||
# print('Spawned the server')
|
|
||||||
|
|
||||||
def tearDown(self):
|
|
||||||
self.server.server_close()
|
|
||||||
kill(self.gthread)
|
|
||||||
|
|
||||||
def test_urllib(self):
|
|
||||||
self.assertEqual(self.server.request_count, 0)
|
|
||||||
try:
|
try:
|
||||||
urlopen('http://127.0.0.1:%s' % self.port)
|
assert server.request_count == 0
|
||||||
|
try:
|
||||||
|
urlopen('http://127.0.0.1:{0}'.format(port))
|
||||||
assert False, 'should not get there'
|
assert False, 'should not get there'
|
||||||
except HTTPError as ex:
|
except HTTPError as ex:
|
||||||
assert ex.code == 501, repr(ex)
|
assert ex.code == 501, repr(ex)
|
||||||
self.assertEqual(self.server.request_count, 1)
|
assert server.request_count == 1
|
||||||
|
finally:
|
||||||
if __name__ == '__main__':
|
server.server_close()
|
||||||
unittest.main()
|
eventlet.kill(gthread)
|
||||||
|
@@ -3,7 +3,6 @@ are not leaked by the hub.
|
|||||||
"""
|
"""
|
||||||
import gc
|
import gc
|
||||||
from pprint import pformat
|
from pprint import pformat
|
||||||
import unittest
|
|
||||||
import weakref
|
import weakref
|
||||||
|
|
||||||
from eventlet.support import clear_sys_exc_info
|
from eventlet.support import clear_sys_exc_info
|
||||||
@@ -86,7 +85,3 @@ def test_clean_exit():
|
|||||||
def test_timeout_exit():
|
def test_timeout_exit():
|
||||||
run_and_check(False)
|
run_and_check(False)
|
||||||
run_and_check(False)
|
run_and_check(False)
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
unittest.main()
|
|
||||||
|
@@ -60,7 +60,3 @@ def test_create_connection_refused():
|
|||||||
except socket.error as ex:
|
except socket.error as ex:
|
||||||
errno = ex.errno
|
errno = ex.errno
|
||||||
assert errno in [111, 61, 10061], 'Expected socket.error ECONNREFUSED, got {0}'.format(errno)
|
assert errno in [111, 61, 10061], 'Expected socket.error ECONNREFUSED, got {0}'.format(errno)
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
unittest.main()
|
|
||||||
|
@@ -8,7 +8,6 @@ import socket
|
|||||||
import sys
|
import sys
|
||||||
import tempfile
|
import tempfile
|
||||||
import traceback
|
import traceback
|
||||||
import unittest
|
|
||||||
|
|
||||||
import eventlet
|
import eventlet
|
||||||
from eventlet import debug
|
from eventlet import debug
|
||||||
@@ -1787,7 +1786,3 @@ class TestChunkedInput(_TestBase):
|
|||||||
signal.signal(signal.SIGALRM, signal.SIG_DFL)
|
signal.signal(signal.SIGALRM, signal.SIG_DFL)
|
||||||
|
|
||||||
assert not got_signal, "caught alarm signal. infinite loop detected."
|
assert not got_signal, "caught alarm signal. infinite loop detected."
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
unittest.main()
|
|
||||||
|
Reference in New Issue
Block a user