PYTHON-2927 PYTHON-2937 Skip failing tests on PyPy (#753)

Cleanup test clients more eagerly.

(cherry picked from commit df6f649)

Author: ShaneHarvey

test/test_client.py

@@ -1657,6 +1657,7 @@ def test_direct_connection(self):
 
     @unittest.skipIf(sys.platform.startswith('java'),
                      'Jython does not support gc.get_objects')
+    @unittest.skipIf('PyPy' in sys.version, 'PYTHON-2927 fails often on PyPy')
     def test_continuous_network_errors(self):
         def server_description_count():
             i = 0

test/test_pooling.py

@@ -421,6 +421,7 @@ class TestPoolMaxSize(_TestPoolingBase):
     def test_max_pool_size(self):
         max_pool_size = 4
         c = rs_or_single_client(maxPoolSize=max_pool_size)
+        self.addCleanup(c.close)
         collection = c[DB].test
 
         # Need one document.
@@ -456,6 +457,7 @@ def f():
 
     def test_max_pool_size_none(self):
         c = rs_or_single_client(maxPoolSize=None)
+        self.addCleanup(c.close)
         collection = c[DB].test
 
         # Need one document.

test/test_read_write_concern_spec.py

@@ -52,6 +52,7 @@ def test_omit_default_read_write_concern(self):
         listener = EventListener()
         # Client with default readConcern and writeConcern
         client = rs_or_single_client(event_listeners=[listener])
+        self.addCleanup(client.close)
         collection = client.pymongo_test.collection
         # Prepare for tests of find() and aggregate().
         collection.insert_many([{} for _ in range(10)])
@@ -215,6 +216,7 @@ def test_error_includes_errInfo(self):
     def test_write_error_details_exposes_errinfo(self):
         listener = EventListener()
         client = rs_or_single_client(event_listeners=[listener])
+        self.addCleanup(client.close)
         db = client.errinfotest
         self.addCleanup(client.drop_database, "errinfotest")
         validator = {"x": {"$type": "string"}}

test/test_retryable_writes.py

@@ -531,6 +531,7 @@ def test_increment_transaction_id_without_sending_command(self):
         listener = OvertCommandListener()
         client = rs_or_single_client(
             retryWrites=True, event_listeners=[listener])
+        self.addCleanup(client.close)
         topology = client._topology
         select_server = topology.select_server
 

test/test_ssl.py

@@ -576,6 +576,7 @@ def test_mongodb_x509_auth(self):
             ssl=True,
             ssl_cert_reqs=ssl.CERT_NONE,
             ssl_certfile=CLIENT_PEM)
+        self.addCleanup(noauth.close)
 
         self.assertRaises(OperationFailure, noauth.pymongo_test.test.count)
 
@@ -587,6 +588,7 @@ def test_mongodb_x509_auth(self):
             ssl_cert_reqs=ssl.CERT_NONE,
             ssl_certfile=CLIENT_PEM,
             event_listeners=[listener])
+        self.addCleanup(auth.close)
 
         if client_context.version.at_least(3, 3, 12):
             # No error
@@ -609,6 +611,7 @@ def test_mongodb_x509_auth(self):
                              ssl=True,
                              ssl_cert_reqs=ssl.CERT_NONE,
                              ssl_certfile=CLIENT_PEM)
+        self.addCleanup(client.close)
         # No error
         client.pymongo_test.test.find_one()
 
@@ -617,6 +620,7 @@ def test_mongodb_x509_auth(self):
                              ssl=True,
                              ssl_cert_reqs=ssl.CERT_NONE,
                              ssl_certfile=CLIENT_PEM)
+        self.addCleanup(client.close)
         if client_context.version.at_least(3, 3, 12):
             # No error
             client.pymongo_test.test.find_one()
@@ -625,13 +629,16 @@ def test_mongodb_x509_auth(self):
             with self.assertRaises(ConfigurationError):
                 client.pymongo_test.test.find_one()
 
+        # No error
+        client.pymongo_test.test.find_one()
         # Auth should fail if username and certificate do not match
         uri = ('mongodb://%s@%s:%d/?authMechanism='
                'MONGODB-X509' % (
                    quote_plus("not the username"), host, port))
 
         bad_client = MongoClient(
             uri, ssl=True, ssl_cert_reqs="CERT_NONE", ssl_certfile=CLIENT_PEM)
+        self.addCleanup(bad_client.close)
 
         with self.assertRaises(OperationFailure):
             bad_client.pymongo_test.test.find_one()
@@ -643,6 +650,7 @@ def test_mongodb_x509_auth(self):
                 ssl=True,
                 ssl_cert_reqs=ssl.CERT_NONE,
                 ssl_certfile=CLIENT_PEM)
+        self.addCleanup(bad_client.close)
 
         with self.assertRaises(OperationFailure):
             bad_client.pymongo_test.test.find_one()

test/test_transactions.py

@@ -292,6 +292,9 @@ def gridfs_open_upload_stream(*args, **kwargs):
     @client_context.require_version_min(4, 2)
     @client_context.require_transactions
     def test_transaction_starts_with_batched_write(self):
+        if 'PyPy' in sys.version and client_context.tls:
+            self.skipTest('PYTHON-2937 PyPy is so slow sending large '
+                          'messages over TLS that this test fails')
         # Start a transaction with a batch of operations that needs to be
         # split.
         listener = OvertCommandListener()
@@ -301,7 +304,8 @@ def test_transaction_starts_with_batched_write(self):
         listener.reset()
         self.addCleanup(client.close)
         self.addCleanup(coll.drop)
-        ops = [InsertOne({'a': '1'*(10*1024*1024)}) for _ in range(10)]
+        large_str = '\0'*(10*1024*1024)
+        ops = [InsertOne({'a': large_str}) for _ in range(10)]
         with client.start_session() as session:
             with session.start_transaction():
                 coll.bulk_write(ops, session=session)