summaryrefslogtreecommitdiffstats
path: root/policyhandler/policy_receiver.py
diff options
context:
space:
mode:
Diffstat (limited to 'policyhandler/policy_receiver.py')
-rw-r--r--policyhandler/policy_receiver.py15
1 files changed, 10 insertions, 5 deletions
diff --git a/policyhandler/policy_receiver.py b/policyhandler/policy_receiver.py
index d949c4b..091c2c3 100644
--- a/policyhandler/policy_receiver.py
+++ b/policyhandler/policy_receiver.py
@@ -1,5 +1,5 @@
# ================================================================================
-# Copyright (c) 2018-2019 AT&T Intellectual Property. All rights reserved.
+# Copyright (c) 2018-2020 AT&T Intellectual Property. All rights reserved.
# ================================================================================
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
@@ -24,13 +24,15 @@ on receiving the policy-notifications, the policy-receiver
passes the notifications to policy-updater
"""
+from .config import Config
from .service_activator import ServiceActivator
+
class PolicyReceiver(object):
"""
policy-receiver - static singleton wrapper around two threads
policy_updater - master thread for all scheduled actions
- policy_listener - listens to policy-engine through web-socket
+ policy_listener - listens to policy-engine through DMaaP MR or web-socket
"""
_policy_updater = None
_policy_listener = None
@@ -47,9 +49,9 @@ class PolicyReceiver(object):
def _close_listener(audit):
"""stop the notification-handler"""
if PolicyReceiver._policy_listener:
- policy_receiver = PolicyReceiver._policy_listener
+ policy_listener = PolicyReceiver._policy_listener
PolicyReceiver._policy_listener = None
- policy_receiver.shutdown(audit)
+ policy_listener.shutdown(audit)
@staticmethod
def shutdown(audit):
@@ -98,4 +100,7 @@ class PolicyReceiver(object):
PolicyReceiver._policy_updater.start()
- PolicyReceiver.catch_up(audit)
+ if Config.is_pdp_api_default():
+ audit.audit_done(result="will catch_up after draining the policy-update queue")
+ else:
+ PolicyReceiver.catch_up(audit)