corrections wrt signals send to subprocesses in test

Author: d-w-moore

irods/test/data_obj_test.py

@@ -2951,9 +2951,9 @@ def test_replica_truncate__issue_534(self):
                     if data_objs.exists(data_path):
                         data_objs.unlink(data_path, force=True)
 
-    def test_reasonable_handling_of_parallel_download_threads_after_termination_signal__issue_722(self):
-        from test_parallel_put_sigint_response.py import test
-        test(self)
+    def test_handling_of_termination_signals_during_multithread_get__issue_722(self):
+        from irods.test.modules.test_signal_handling_in_multithread_get import test as test__issue_722
+        test__issue_722(self)
 
 if __name__ == "__main__":
     # let the tests find the parent irods lib

…les/test_parallel_put_sigint_response.py …st_signal_handling_in_multithread_get.pyirods/test/modules/test_parallel_put_sigint_response.py renamed to irods/test/modules/test_signal_handling_in_multithread_get.py irods/test/modules/test_parallel_put_sigint_response.py renamed to irods/test/modules/test_signal_handling_in_multithread_get.py

@@ -1,7 +1,7 @@
 
 import os
 import re
-from signal import SIGINT, SIGTERM
+import signal
 import subprocess
 import sys
 import tempfile
@@ -15,50 +15,58 @@
 OBJECT_NAME = 'data_get_issue__722'
 LOCAL_TEMPFILE_NAME = 'data_object_for_issue_722.dat'
 
-_clock_resolution = max(.01, *(time.clock_getres(getattr(time,symbol))
-                               for symbol in dir(time) if symbol.startswith('CLOCK_')))
+
+_clock_polling_interval = max(.01, time.clock_getres(time.CLOCK_BOOTTIME))
+
+
 def wait_till_true(function, timeout=None):
     start_time = time.clock_gettime_ns(time.CLOCK_BOOTTIME)
     while not (truth_value := function()):
         if timeout is not None and (time.clock_gettime_ns(time.CLOCK_BOOTTIME)-start_time)*1e-9 > timeout:
             break
-        time.sleep(_clock_resolution)
+        time.sleep(_clock_polling_interval)
     return truth_value
 
 
-def test(test_case, sigs = (SIGINT,SIGTERM)):
+def test(test_case, signal_names = ("SIGTERM",#"SIGINT" 
+            )):
     """Creates a child process executing a long get() and ensures the process can be
     terminated using SIGINT or SIGTERM.
     """
     program = os.path.join(test_modules.__path__[0], os.path.basename(__file__))
 
-    # Call into this same module as a command.  This will initiate another Python process that
-    # performs a lengthy data object "get" operation (see the main body of the script, below.)
-    process = subprocess.Popen([sys.executable, program],
-                               stderr=subprocess.PIPE,
-                               stdout=subprocess.PIPE,
-                               text = True)
-
-    # Wait for download process to reach the point of spawning data transfer threads.  In Python 3.9+ versions
-    # of the concurrent.futures module, these are nondaemon threads and will block the exit of the main thread
-    # unless measures are taken (#722).
-    localfile = process.stdout.readline().strip()
-    test_case.assertTrue(wait_till_true(lambda:os.path.exists(localfile) and os.stat(localfile).st_size > OBJECT_SIZE//2),
-               "Parallel download from data_objects.get() probably experienced a fatal error before spawning auxiliary data transfer threads."
-              )
-
-    for sig in sigs:
-        # Interrupt the sub-process with the given signal.
+    for signal_name in signal_names:
+        # Call into this same module as a command.  This will initiate another Python process that
+        # performs a lengthy data object "get" operation (see the main body of the script, below.)
+        process = subprocess.Popen([sys.executable, program],
+                                   stderr=subprocess.PIPE,
+                                   stdout=subprocess.PIPE,
+                                   text = True)
+
+        # Wait for download process to reach the point of spawning data transfer threads.  In Python 3.9+ versions
+        # of the concurrent.futures module, these are nondaemon threads and will block the exit of the main thread
+        # unless measures are taken (#722).
+        localfile = process.stdout.readline().strip()
+        test_case.assertTrue(wait_till_true(lambda:os.path.exists(localfile) and os.stat(localfile).st_size > OBJECT_SIZE//2),
+                   "Parallel download from data_objects.get() probably experienced a fatal error before spawning auxiliary data transfer threads."
+                  )
+
+        signal_message_info = f"While testing signal {signal_name}"
+        sig = getattr(signal, signal_name)
+
+        # Interrupt the subprocess with the given signal.
         process.send_signal(sig)
-        # Assert that this signal is what killed the sub-process, rather than a timed out process "wait" or a natural exit 
+        # Assert that this signal is what killed the subprocess, rather than a timed out process "wait" or a natural exit 
         # due to misproper or incomplete handling of the signal.
         try:
-            test_case.assertEqual(process.wait(timeout = 15), -sig)
+            test_case.assertEqual(process.wait(timeout = 15), -sig, "{signal_message_info}: unexpected subprocess return code.")
         except subprocess.TimeoutExpired as timeout_exc:
-            test_case.fail("Sub-process timed out before exit.  Non-daemon thread(s) probably prevented subprocess's main thread from exiting")
+            test_case.fail(f"{signal_message_info}:  subprocess timed out before terminating.  "
+                "Non-daemon thread(s) probably prevented subprocess's main thread from exiting.")
         # Assert that in the case of SIGINT, the process registered a KeyboardInterrupt.
-        if sig == SIGINT:
-            test_case.assertTrue(re.search('KeyboardInterrupt',process.stderr.read()))
+        if sig == signal.SIGINT:
+            test_case.assertTrue(re.search('KeyboardInterrupt', process.stderr.read()), 
+                "{signal_message_info}: Expected 'KeyboardInterrupt' in log output.")
 
 
 if __name__ == "__main__":