Mark failing tests from test_threading

youknowone · youknowone · commit 4c4dfc0c037b · 2022-08-23T05:28:38.000+09:00
diff --git a/Lib/test/test_threadedtempfile.py b/Lib/test/test_threadedtempfile.py
@@ -21,6 +21,8 @@
 import threading
 from traceback import print_exc
 
+import sys  # XXX: RUSTPYTHON
+
 
 NUM_THREADS = 20
 FILES_PER_THREAD = 50
diff --git a/Lib/test/test_threading.py b/Lib/test/test_threading.py
@@ -880,6 +880,8 @@ def test_shutdown_locks(self):
                 # Daemon threads must never add it to _shutdown_locks.
                 self.assertNotIn(tstate_lock, threading._shutdown_locks)
 
+    # TODO: RUSTPYTHON
+    @unittest.expectedFailure
     def test_locals_at_exit(self):
         # bpo-19466: thread locals must not be deleted before destructors
         # are called
@@ -1599,6 +1601,11 @@ def test_release_save_unacquired(self):
 class EventTests(lock_tests.EventTests):
     eventtype = staticmethod(threading.Event)
 
+    # TODO: RUSTPYTHON
+    @unittest.expectedFailure
+    def test_reset_internal_locks():  # TODO: RUSTPYTHON; remove this when done
+        super().test_reset_internal_locks()
+
 class ConditionAsRLockTests(lock_tests.RLockTests):
     # Condition uses an RLock by default and exports its API.
     locktype = staticmethod(threading.Condition)
@@ -1715,6 +1722,8 @@ def worker(started, cont, interrupted):
 
 class AtexitTests(unittest.TestCase):
 
+    # TODO: RUSTPYTHON
+    @unittest.expectedFailure
     def test_atexit_output(self):
         rc, out, err = assert_python_ok("-c", """if True:
             import threading
@@ -1728,6 +1737,8 @@ def run_last():
         self.assertFalse(err)
         self.assertEqual(out.strip(), b'parrot')
 
+    # TODO: RUSTPYTHON
+    @unittest.expectedFailure
     def test_atexit_called_once(self):
         rc, out, err = assert_python_ok("-c", """if True:
             import threading
@@ -1743,6 +1754,8 @@ def test_atexit_called_once(self):
 
         self.assertFalse(err)
 
+    # TODO: RUSTPYTHON
+    @unittest.expectedFailure
     def test_atexit_after_shutdown(self):
         # The only way to do this is by registering an atexit within
         # an atexit, which is intended to raise an exception.
diff --git a/Lib/test/test_threading_local.py b/Lib/test/test_threading_local.py
@@ -110,8 +110,6 @@ def f():
 
         self.assertTrue(passed)
 
-    # TODO: RUSTPYTHON, __new__ vs __init__ cooperation
-    @unittest.expectedFailure
     def test_arguments(self):
         # Issue 1522237
         class MyLocal(self._local):
@@ -202,6 +200,12 @@ class X:
 class ThreadLocalTest(unittest.TestCase, BaseLocalTest):
     _local = _thread._local
 
+    # TODO: RUSTPYTHON, __new__ vs __init__ cooperation
+    @unittest.expectedFailure
+    def test_arguments():
+        super().test_arguments()
+
+
 class PyThreadingLocalTest(unittest.TestCase, BaseLocalTest):
     _local = _threading_local.local
 
