fix tests not to use gevent.spawn_link*

greentest/test__examples.py

@@ -187,9 +187,10 @@ class Test_echoserver(BaseTestServer):
             self.assertEqual(received, message)
             conn._sock.settimeout(0.1)
             self.assertRaises(socket.timeout, conn.read, 1)
-        client1 = gevent.spawn_link_exception(test_client, 'hello\r\n')
-        client2 = gevent.spawn_link_exception(test_client, 'world\r\n')
-        gevent.joinall([client1, client2])
+        client1 = gevent.spawn(test_client, 'hello\r\n')
+        client2 = gevent.spawn(test_client, 'world\r\n')
+        gevent.joinall([client1, client2], raise_error=True)
+
 
 
 class TestAllTested(unittest.TestCase):

greentest/test__greenlet.py

@@ -488,7 +488,7 @@ class TestStuff(greentest.TestCase):
                 e.set_exception(sys.exc_info()[1])
                 gevent.sleep(0)
 
-        p = gevent.spawn_link(func)
+        p = gevent.Greenlet.spawn_link(func)
         try:
             try:
                 e.wait()

greentest/test__server.py

@@ -225,7 +225,7 @@ class TestDefaultSpawn(TestCase):
         self._test_invalid_callback()
 
     def _test_serve_forever(self):
-        g = gevent.spawn_link_exception(self.server.serve_forever)
+        g = gevent.spawn(self.server.serve_forever)
         try:
             gevent.sleep(0.01)
             self.assertRequestSucceeded()
@@ -234,6 +234,7 @@ class TestDefaultSpawn(TestCase):
             self.assertConnectionRefused()
         finally:
             g.kill()
+            g.get()
 
     def test_serve_forever(self):
         self.server = self.ServerSubClass(('127.0.0.1', 0))

greentest/test__socket.py

@@ -27,17 +27,18 @@ class TestTCP(greentest.TestCase):
             (client, addr) = self.listener.accept()
             # start reading, then, while reading, start writing. the reader should not hang forever
             N = 100000  # must be a big enough number so that sendall calls trampoline
-            sender = gevent.spawn_link_exception(client.sendall, 't' * N)
+            sender = gevent.spawn(client.sendall, 't' * N)
             result = client.recv(1000)
             assert result == 'hello world', result
-            sender.join(0.2)
+            sender.join(timeout=0.2)
             sender.kill()
+            sender.get()
 
         #print '%s: client' % getcurrent()
 
-        server_proc = gevent.spawn_link_exception(server)
+        server_proc = gevent.spawn(server)
         client = self.create_connection()
-        client_reader = gevent.spawn_link_exception(client.makefile().read)
+        client_reader = gevent.spawn(client.makefile().read)
         gevent.sleep(0.001)
         client.send('hello world')
 
@@ -50,7 +51,7 @@ class TestTCP(greentest.TestCase):
         client_reader.get()
 
     def test_recv_timeout(self):
-        acceptor = gevent.spawn_link_exception(self.listener.accept)
+        acceptor = gevent.spawn(self.listener.accept)
         try:
             client = self.create_connection()
             client.settimeout(0.1)
@@ -65,7 +66,7 @@ class TestTCP(greentest.TestCase):
             acceptor.get()
 
     def test_sendall_timeout(self):
-        acceptor = gevent.spawn_link_exception(self.listener.accept)
+        acceptor = gevent.spawn(self.listener.accept)
         try:
             client = self.create_connection()
             client.settimeout(0.1)