-
Notifications
You must be signed in to change notification settings - Fork 379
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Terminate analyzer invocation once a timeout passes to prevent hanging
- Loading branch information
1 parent
de66e70
commit 3528366
Showing
8 changed files
with
253 additions
and
13 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,87 @@ | ||
| # ----------------------------------------------------------------------------- | ||
| # The CodeChecker Infrastructure | ||
| # This file is distributed under the University of Illinois Open Source | ||
| # License. See LICENSE.TXT for details. | ||
| # ----------------------------------------------------------------------------- | ||
|
|
||
| """ | ||
| Test if the subprocess timeout watcher works properly. | ||
| """ | ||
|
|
||
| import signal | ||
| import subprocess | ||
| import unittest | ||
|
|
||
| import psutil | ||
|
|
||
| from libcodechecker.util import setup_process_timeout | ||
|
|
||
|
|
||
| class subprocess_timeoutTest(unittest.TestCase): | ||
| """ | ||
| Test the process timeout watcher functionality. | ||
| """ | ||
|
|
||
| def testTimeoutWithProcessFinishing(self): | ||
| """ | ||
| Test if process timeout watcher recognises if a process ended | ||
| gracefully before the timeout expired. | ||
| """ | ||
| # Create a process that executes quickly. | ||
| proc = subprocess.Popen(['echo', 'This process executes quickly!'], | ||
| stdout=subprocess.PIPE, | ||
| stderr=subprocess.PIPE) | ||
| print("Started `echo` with PID {0}".format(proc.pid)) | ||
|
|
||
| future = setup_process_timeout(proc, 5, signal.SIGKILL) | ||
|
|
||
| # Simulate waiting for the process. | ||
| proc.wait() | ||
|
|
||
| # Execution reaches this spot, the process exited, one way or another. | ||
| killed = future() | ||
| self.assertFalse(killed, | ||
| "Process timeout watcher said it killed the " | ||
| "process, but it should have exited long beforehand.") | ||
|
|
||
| def testTimeoutWithLongRunning(self): | ||
| """ | ||
| Test if process timeout watcher kills the process that runs too long, | ||
| and properly reports that it was killed. | ||
| """ | ||
| # Create a process that runs infinitely. | ||
| proc = subprocess.Popen(['yes'], | ||
| stdout=subprocess.PIPE, | ||
| stderr=subprocess.PIPE) | ||
| print("Started `yes` with PID {0}".format(proc.pid)) | ||
|
|
||
| future = setup_process_timeout(proc, 5, signal.SIGKILL) | ||
|
|
||
| # Simulate waiting for the process. | ||
| proc.wait() | ||
|
|
||
| # Execution reaches this spot, which means the process was killed. | ||
| # (Or it ran way too long and the OS killed it. Usually tests run | ||
| # quick enough this isn't the case...) | ||
| killed = future() | ||
| self.assertTrue(killed, | ||
| "Process timeout watcher said it did not kill the " | ||
| "process, but it should have.") | ||
|
|
||
| with self.assertRaises(psutil.NoSuchProcess): | ||
| # Try to fetch the process from the system. It shouldn't exist. | ||
| osproc = psutil.Process(proc.pid) | ||
|
|
||
| # There can be rare cases that the OS so quickly recycles the PID. | ||
| if osproc.exe() != 'yes': | ||
| # (Let's just say it's very, very, VERY rare that it recycles | ||
| # the PID to another execution of 'yes'...) | ||
|
|
||
| # If the process exists but it isn't the process we started, | ||
| # it's the same as if it doesn't existed. | ||
| raise psutil.NoSuchProcess(proc.pid) | ||
|
|
||
| # NOTE: This assertion is only viable on Unix systems! | ||
| self.assertEquals(proc.returncode, -signal.SIGKILL, | ||
| "`yes` died in a way that it wasn't the process " | ||
| "timeout watcher killing it.") |