RustPython
diff --git a/‎Lib/test/_test_multiprocessing.py‎
Lines changed: 1 addition & 1 deletion b/‎Lib/test/_test_multiprocessing.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎Lib/test/test_ftplib.py‎
Lines changed: 2 additions & 22 deletions b/‎Lib/test/test_ftplib.py‎
Lines changed: 2 additions & 22 deletions
@@ -1459,7 +1459,7 @@ def _acquire_release(lock, timeout, l=None, n=1):
         for _ in range(n):
             lock.release()
 
-    @unittest.expectedFailureIf(sys.platform == "darwin", "TODO: RUSTPYTHON")
+    @unittest.skipIf(sys.platform == 'darwin', "TODO: RUSTPYTHON; flaky on darwin")
     def test_repr_rlock(self):
         if self.TYPE != 'processes':
             self.skipTest('test not appropriate for {}'.format(self.TYPE))
 
@@ -593,31 +593,24 @@ def test_quit(self):
     def test_abort(self):
         self.client.abort()
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_retrbinary(self):
         received = []
         self.client.retrbinary('retr', received.append)
         self.check_data(b''.join(received),
                         RETR_DATA.encode(self.client.encoding))
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_retrbinary_rest(self):
         for rest in (0, 10, 20):
             received = []
             self.client.retrbinary('retr', received.append, rest=rest)
             self.check_data(b''.join(received),
                             RETR_DATA[rest:].encode(self.client.encoding))
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_retrlines(self):
         received = []
         self.client.retrlines('retr', received.append)
         self.check_data(''.join(received), RETR_DATA.replace('\r\n', ''))
 
-    @unittest.skip('TODO: RUSTPYTHON; weird limiting to 8192, something w/ buffering?')
     def test_storbinary(self):
         f = io.BytesIO(RETR_DATA.encode(self.client.encoding))
         self.client.storbinary('stor', f)
@@ -629,8 +622,6 @@ def test_storbinary(self):
         self.client.storbinary('stor', f, callback=lambda x: flag.append(None))
         self.assertTrue(flag)
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # ssl_error.SSLWantReadError: The operation did not complete (read)
     def test_storbinary_rest(self):
         data = RETR_DATA.replace('\r\n', '\n').encode(self.client.encoding)
         f = io.BytesIO(data)
@@ -639,8 +630,6 @@ def test_storbinary_rest(self):
             self.client.storbinary('stor', f, rest=r)
             self.assertEqual(self.server.handler_instance.rest, str(r))
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # ssl_error.SSLWantReadError: The operation did not complete (read)
     def test_storlines(self):
         data = RETR_DATA.replace('\r\n', '\n').encode(self.client.encoding)
         f = io.BytesIO(data)
@@ -658,21 +647,15 @@ def test_storlines(self):
         with warnings_helper.check_warnings(('', BytesWarning), quiet=True):
             self.assertRaises(TypeError, self.client.storlines, 'stor foo', f)
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_nlst(self):
         self.client.nlst()
         self.assertEqual(self.client.nlst(), NLST_DATA.split('\r\n')[:-1])
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_dir(self):
         l = []
         self.client.dir(l.append)
         self.assertEqual(''.join(l), LIST_DATA.replace('\r\n', ''))
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_mlsd(self):
         list(self.client.mlsd())
         list(self.client.mlsd(path='/'))
@@ -859,8 +842,6 @@ def test_storlines_too_long(self):
         f = io.BytesIO(b'x' * self.client.maxline * 2)
         self.assertRaises(ftplib.Error, self.client.storlines, 'stor', f)
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # TimeoutError: The read operation timed out
     def test_encoding_param(self):
         encodings = ['latin-1', 'utf-8']
         for encoding in encodings:
@@ -922,6 +903,7 @@ def retr():
         retr()
 
 
+@unittest.skip("TODO: RUSTPYTHON; SSL + asyncore has problem")
 @skipUnless(ssl, "SSL not available")
 @requires_subprocess()
 class TestTLS_FTPClassMixin(TestFTPClass):
@@ -940,7 +922,7 @@ def setUp(self, encoding=DEFAULT_ENCODING):
 
 
 @skipUnless(ssl, "SSL not available")
-@unittest.skip("TODO: RUSTPYTHON; SSL + asyncore has problem on darwin")
+@unittest.skip("TODO: RUSTPYTHON; SSL + asyncore has problem")
 @requires_subprocess()
 class TestTLS_FTPClass(TestCase):
     """Specific TLS_FTP class tests."""
@@ -1025,8 +1007,6 @@ def test_context(self):
             self.assertIs(sock.context, ctx)
             self.assertIsInstance(sock, ssl.SSLSocket)
 
-    @unittest.skip('TODO: RUSTPYTHON')
-    # ssl_error.SSLWantReadError: The operation did not complete (read)
     def test_ccc(self):
         self.assertRaises(ValueError, self.client.ccc)
         self.client.login(secure=True)