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 /policyhandler/policy_receiver.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 'policyhandler/policy_receiver.py')
| -rw-r--r-- | policyhandler/policy_receiver.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/policyhandler/policy_receiver.py b/policyhandler/policy_receiver.py index 843dbd8..751bea8 100644 --- a/policyhandler/policy_receiver.py +++ b/policyhandler/policy_receiver.py @@ -136,8 +136,9 @@ class _PolicyReceiver(Thread): ) return - audit = Audit(req_message="policy-notification - updated[{0}], removed[{1}]" \ - .format(len(policies_updated), len(policies_removed))) + audit = Audit(job_name="policy_update", + req_message="policy-notification - updated[{0}], removed[{1}]" + .format(len(policies_updated), len(policies_removed))) audit.retry_get_config = True self._policy_updater.enqueue(audit, policies_updated, policies_removed) |