Mark failing tests from test_threading

youknowone · youknowone · commit 714092d0c4c1 · 2022-08-23T05:01:32.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)
@@ -1657,6 +1664,8 @@ def check_interrupt_main_noerror(self, signum):
             # Restore original handler
             signal.signal(signum, handler)
 
+    # TODO: RUSTPYTHON
+    @unittest.expectedFailure
     def test_interrupt_main_subthread(self):
         # Calling start_new_thread with a function that executes interrupt_main
         # should raise KeyboardInterrupt upon completion.
@@ -1715,6 +1724,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 +1739,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 +1756,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
 
