diff options
author | Alex Shatov <alexs@att.com> | 2018-04-27 11:53:55 -0400 |
---|---|---|
committer | Alex Shatov <alexs@att.com> | 2018-04-27 11:53:55 -0400 |
commit | 50bed534083c96cbf1f8fa4e220cb2b00dff9621 (patch) | |
tree | 8abb64c6e6bbbf7a7a2f7d9bf12cfb9b4e166f2e /tests/test_step_timer.py | |
parent | 3365431059e2de5977dae447f34a2d42dd2b039b (diff) |
2.4.2 policy-handler - fixed race on step-timer
- fixed the bug of unpredictably stopping of the periodic catch-up
step-timer due to thread race condition in policy-handler
= added critical sections under the reentrant lock on every group
of local var change in step-timer
- added more stats for healthcheck to track each type of
job-operation separately
= that helps narrowing down identifying the potential problems
- unit test coverage 76%
Change-Id: I92ddf6c92a3d225d9b87427e3edfb7f80669501a
Signed-off-by: Alex Shatov <alexs@att.com>
Issue-ID: DCAEGEN2-472
Diffstat (limited to 'tests/test_step_timer.py')
-rw-r--r-- | tests/test_step_timer.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/tests/test_step_timer.py b/tests/test_step_timer.py index fe2d1c1..a116f8c 100644 --- a/tests/test_step_timer.py +++ b/tests/test_step_timer.py @@ -20,7 +20,6 @@ import json import logging -import sys import time from datetime import datetime @@ -29,6 +28,7 @@ from policyhandler.step_timer import StepTimer Config.load_from_file() + class MockTimer(object): """testing step_timer""" logger = logging.getLogger("policy_handler.unit_test.step_timer") @@ -131,9 +131,10 @@ class MockTimer(object): str(self.status_ts), str(self.exe_ts) ) if self.step_timer: - return "{0}: {1}".format(status, self.step_timer.get_status()) + return "{0}: {1}".format(status, self.step_timer.get_timer_status()) return status + def test_step_timer(): """test step_timer""" MockTimer.logger.info("============ test_step_timer =========") @@ -161,6 +162,7 @@ def test_step_timer(): time.sleep(3 * step_timer.interval) step_timer.verify_last_event() + def test_interrupt_step_timer(): """test step_timer""" MockTimer.logger.info("============ test_interrupt_step_timer =========") |