From 3bdc0a1b97ad5d2d22610347d41ba0d735282a50 Mon Sep 17 00:00:00 2001 From: velandy Date: Wed, 2 Aug 2017 15:26:35 -0400 Subject: [PATCH] Bug 196 SO+UI container memory leak Signed-off-by: velandy --- .../rift/tasklets/rwnsmtasklet/publisher.py | 22 +++++++++---------- 1 file changed, 10 insertions(+), 12 deletions(-) diff --git a/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py b/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py index 6c4b1237..bff6d49c 100644 --- a/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py +++ b/rwlaunchpad/plugins/rwnsm/rift/tasklets/rwnsmtasklet/publisher.py @@ -1,4 +1,4 @@ -# +# # Copyright 2016 RIFT.IO Inc # # Licensed under the Apache License, Version 2.0 (the "License"); @@ -62,7 +62,7 @@ class NsrOpDataDtsHandler(object): Create an NS record in DTS with the path and message """ self._log.debug("Creating NSR xact = %s, %s:%s", xact, path, msg) - self.regh.create_element(path, msg) + self.regh.create_element(path, msg, xact=xact) self._log.debug("Created NSR xact = %s, %s:%s", xact, path, msg) @asyncio.coroutine @@ -71,7 +71,7 @@ class NsrOpDataDtsHandler(object): Update an NS record in DTS with the path and message """ self._log.debug("Updating NSR xact = %s, %s:%s regh = %s", xact, path, msg, self.regh) - self.regh.update_element(path, msg, flags) + self.regh.update_element(path, msg, flags, xact=xact) self._log.debug("Updated NSR xact = %s, %s:%s", xact, path, msg) @asyncio.coroutine @@ -80,11 +80,10 @@ class NsrOpDataDtsHandler(object): Update an NS record in DTS with the path and message """ self._log.debug("Deleting NSR xact:%s, path:%s", xact, path) - self.regh.delete_element(path) + self.regh.delete_element(path, xact=xact) self._log.debug("Deleted NSR xact:%s, path:%s", xact, path) - class VnfrPublisherDtsHandler(object): """ Registers 'D,/vnfr:vnfr-catalog/vnfr:vnfr' DTS""" XPATH = "D,/vnfr:vnfr-catalog/vnfr:vnfr" @@ -134,7 +133,7 @@ class VnfrPublisherDtsHandler(object): """ self._log.debug("Creating VNFR xact = %s, %s:%s", xact, path, msg) - self.regh.create_element(path, msg) + self.regh.create_element(path, msg, xact=xact) self._log.debug("Created VNFR xact = %s, %s:%s", xact, path, msg) @@ -145,7 +144,7 @@ class VnfrPublisherDtsHandler(object): """ self._log.debug("Updating VNFR xact = %s, %s:%s", xact, path, msg) - self.regh.update_element(path, msg) + self.regh.update_element(path, msg, xact=xact) self._log.debug("Updated VNFR xact = %s, %s:%s", xact, path, msg) @@ -155,7 +154,7 @@ class VnfrPublisherDtsHandler(object): Delete a VNFR record in DTS with path and message """ self._log.debug("Deleting VNFR xact = %s, %s", xact, path) - self.regh.delete_element(path) + self.regh.delete_element(path, xact=xact) self._log.debug("Deleted VNFR xact = %s, %s", xact, path) @@ -208,7 +207,7 @@ class VlrPublisherDtsHandler(object): """ self._log.debug("Creating VLR xact = %s, %s:%s", xact, path, msg) - self.regh.create_element(path, msg) + self.regh.create_element(path, msg, xact=xact) self._log.debug("Created VLR xact = %s, %s:%s", xact, path, msg) @@ -219,7 +218,7 @@ class VlrPublisherDtsHandler(object): """ self._log.debug("Updating VLR xact = %s, %s:%s", xact, path, msg) - self.regh.update_element(path, msg) + self.regh.update_element(path, msg, xact=xact) self._log.debug("Updated VLR xact = %s, %s:%s", xact, path, msg) @@ -229,7 +228,7 @@ class VlrPublisherDtsHandler(object): Delete a VLR record in DTS with path and message """ self._log.debug("Deleting VLR xact = %s, %s", xact, path) - self.regh.delete_element(path) + self.regh.delete_element(path, xact=xact) self._log.debug("Deleted VLR xact = %s, %s", xact, path) @@ -286,4 +285,3 @@ class VnfdPublisher(object): update, vnfd ) - -- 2.25.1