Strong timeout handle. Do not produce fake positive scenarios

(cherry picked from commit 41b65a2)

Author: penguinolog

exec_helpers/subprocess_runner.py

@@ -148,31 +148,15 @@ def close_streams() -> None:
 
         try:
             exit_code = async_result.interface.wait(timeout=timeout)  # Wait real timeout here
-        except subprocess.TimeoutExpired:
-            exit_code = async_result.interface.poll()  # Update exit code
-
-        # Process closed?
-        if exit_code is not None:
             concurrent.futures.wait([stdout_future, stderr_future], timeout=0.1)  # Minimal timeout to complete polling
             result.exit_code = exit_code
-            close_streams()
             return result
-        # Kill not ended process and wait for close
-        try:
+        except subprocess.TimeoutExpired:
             # kill -9 for all subprocesses
             _subprocess_helpers.kill_proc_tree(async_result.interface.pid)
-            async_result.interface.kill()  # kill -9
-            # Force stop cycle if no exit code after kill
-        except OSError:
             exit_code = async_result.interface.poll()
-            if exit_code is not None and exit_code not in {-9, -15}:  # Nothing to kill
-                self.logger.warning(
-                    "{!s} has been completed just after timeout: please validate timeout.".format(command)
-                )
-                concurrent.futures.wait([stdout_future, stderr_future], timeout=0.1)
-                result.exit_code = exit_code
-                return result
-            raise  # Some other error
+            if exit_code is None:
+                async_result.interface.kill()  # kill -9
         finally:
             stdout_future.cancel()
             stderr_future.cancel()

test/test_subprocess_special.py

@@ -76,13 +76,10 @@ def read_stream(stream: FakeFileStream):
     "no_stdout": dict(),
     "IOError_on_stdout_read": dict(stdout=(b" \n", b"2\n", IOError())),
     "TimeoutError": dict(
-        ec=(timeout_expired_exc,), poll=(None, None, None,), stdout=(), expect_exc=exec_helpers.ExecHelperTimeoutError
-    ),
-    "TimeoutError_closed": dict(
-        ec=(timeout_expired_exc, 0), poll=(None, 0), stdout=(b" \n", b"2\n", b"3\n", b" \n"), kill=(OSError(),)
+        ec=(timeout_expired_exc,), poll=(None,), stdout=(), expect_exc=exec_helpers.ExecHelperTimeoutError
     ),
     "TimeoutError_no_kill": dict(
-        ec=(timeout_expired_exc,), poll=(None, None, None,), stdout=(), kill=(OSError(),), expect_exc=OSError
+        ec=(timeout_expired_exc,), poll=(None,), stdout=(), kill=(OSError(),), expect_exc=OSError
     ),
     "stdin_closed_PIPE_windows": dict(stdout=(b" \n", b"2\n", b"3\n", b" \n"), stdin="Warning", write=einval_exc),
     "stdin_broken_PIPE": dict(stdout=(b" \n", b"2\n", b"3\n", b" \n"), stdin="Warning", write=epipe_exc),
@@ -113,7 +110,6 @@ def pytest_generate_tests(metafunc):
                 "no_stdout",
                 "IOError_on_stdout_read",
                 "TimeoutError",
-                "TimeoutError_closed",
                 "TimeoutError_no_kill",
                 "stdin_closed_PIPE_windows",
                 "stdin_broken_PIPE",