X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=rwcm%2Fplugins%2Frwconman%2Frift%2Ftasklets%2Frwconmantasklet%2FRiftCA.py;h=0400a54a0eca2e63541da888ad36b526b31ad324;hb=refs%2Fchanges%2F90%2F390%2F1;hp=4a95a7da12788f84bba3824162afdad135f83c6d;hpb=6f07e6f33f751ab4ffe624f6037f887b243bece2;p=osm%2FSO.git diff --git a/rwcm/plugins/rwconman/rift/tasklets/rwconmantasklet/RiftCA.py b/rwcm/plugins/rwconman/rift/tasklets/rwconmantasklet/RiftCA.py index 4a95a7da..0400a54a 100644 --- a/rwcm/plugins/rwconman/rift/tasklets/rwconmantasklet/RiftCA.py +++ b/rwcm/plugins/rwconman/rift/tasklets/rwconmantasklet/RiftCA.py @@ -52,6 +52,28 @@ class RiftCAConfigPlugin(riftcm_config_plugin.RiftCMConfigPluginBase): def agent_type(self): return self._type + @property + def agent_data(self): + return dict( + type=self.agent_type, + name=self.name, + ) + + def vnfr(self, vnfr_id): + try: + vnfr = self._rift_vnfs[vnfr_id].vnfr + except KeyError: + self._log.debug("RiftCA: Did not find VNFR %s in Rift plugin", vnfr_id) + return None + + return vnfr + + def get_service_name(self, vnfr_id): + vnfr = self.vnfr(vnfr_id) + if vnfr: + return vnfr['name'] + return None + @asyncio.coroutine def notify_create_vlr(self, agent_nsr, agent_vnfr, vld, vlr): """