aboutsummaryrefslogtreecommitdiffstats
path: root/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade
diff options
context:
space:
mode:
authorebo <eliezio.oliveira@est.tech>2020-04-08 12:32:14 +0100
committerBartek Grzybowski <b.grzybowski@partner.samsung.com>2020-04-10 09:19:27 +0000
commit1402489faba6767edffc4909a2f95a13a2bbd6da (patch)
tree779c4fad1d6db05f5a0bac3ff299b74785deeb55 /test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade
parentae8d50ce126508c11667a85c4781a2c77cf2a814 (diff)
Update pnf-sw-upgrade module to latest engine v2.8.1
- Using loguru to follow new recommend standard - Renamed Yang model filename to comply with https://tools.ietf.org/html/rfc6020#section-5.2 - Renamed initialization data to reflect the target datastore Issue-ID: INT-1516 Signed-off-by: ebo <eliezio.oliveira@est.tech> Change-Id: Ifde9e832b6a308dc918e3a84e03bfd43ad0f9b63
Diffstat (limited to 'test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade')
-rw-r--r--test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/pnf-sw-upgrade.yang (renamed from test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/model.yang)0
-rw-r--r--test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/startup.xml (renamed from test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/data.xml)0
-rwxr-xr-xtest/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/subscriber.py23
3 files changed, 12 insertions, 11 deletions
diff --git a/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/model.yang b/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/pnf-sw-upgrade.yang
index 6d413065e..6d413065e 100644
--- a/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/model.yang
+++ b/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/pnf-sw-upgrade.yang
diff --git a/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/data.xml b/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/startup.xml
index 4f1e7bceb..4f1e7bceb 100644
--- a/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/data.xml
+++ b/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/startup.xml
diff --git a/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/subscriber.py b/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/subscriber.py
index 810fe453e..0786637b0 100755
--- a/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/subscriber.py
+++ b/test/mocks/netconf-pnp-simulator/modules/pnf-sw-upgrade/subscriber.py
@@ -27,6 +27,7 @@ from concurrent.futures import ThreadPoolExecutor
from threading import Timer
import sysrepo as sr
+from loguru import logger
YANG_MODULE_NAME = 'pnf-sw-upgrade'
@@ -117,13 +118,13 @@ def main():
try:
print_current_config(sess, YANG_MODULE_NAME)
except Exception as e:
- print(e)
+ logger.error(e)
sr.global_loop()
- print("Application exit requested, exiting.")
+ logger.info("Application exit requested, exiting.")
except Exception as e:
- print(e)
+ logger.error(e)
# Function to be called for subscribed client of given session whenever configuration changes.
@@ -138,7 +139,7 @@ def module_change_cb(sess, module_name, event, private_ctx):
break
handle_change(conn, change.oper(), change.old_val(), change.new_val())
except Exception as e:
- print(e)
+ logger.error(e)
return sr.SR_ERR_OK
@@ -150,10 +151,10 @@ def print_current_config(session, module_name):
values = session.get_items(select_xpath)
if values is not None:
- print("========== BEGIN CONFIG ==========")
+ logger.info("========== BEGIN CONFIG ==========")
for i in range(values.val_cnt()):
- print(values.val(i).to_string(), end='')
- print("=========== END CONFIG ===========")
+ logger.info(values.val(i).to_string().strip())
+ logger.info("=========== END CONFIG ===========")
def handle_change(conn, op, old_val, new_val):
@@ -161,7 +162,7 @@ def handle_change(conn, op, old_val, new_val):
Handle individual changes on the model.
"""
if op == sr.SR_OP_CREATED:
- print("CREATED: %s" % new_val.to_string())
+ logger.info("CREATED: %s" % new_val.to_string())
xpath = new_val.xpath()
last_node = xpath_ctx.last_node(xpath)
# Warning: 'key_value' modifies 'xpath'!
@@ -169,11 +170,11 @@ def handle_change(conn, op, old_val, new_val):
if key_id and last_node == 'action':
executor.submit(execute_action, conn, key_id, new_val.data().get_enum())
elif op == sr.SR_OP_DELETED:
- print("DELETED: %s" % old_val.to_string())
+ logger.info("DELETED: %s" % old_val.to_string())
elif op == sr.SR_OP_MODIFIED:
- print("MODIFIED: %s to %s" % (old_val.to_string(), new_val.to_string()))
+ logger.info("MODIFIED: %s to %s" % (old_val.to_string(), new_val.to_string()))
elif op == sr.SR_OP_MOVED:
- print("MOVED: %s after %s" % (new_val.xpath(), old_val.xpath()))
+ logger.info("MOVED: %s after %s" % (new_val.xpath(), old_val.xpath()))
def execute_action(conn, key_id, action):