projects
/
osm
/
LCM.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Modifications for test of feature 7953
[osm/LCM.git]
/
osm_lcm
/
lcm.py
diff --git
a/osm_lcm/lcm.py
b/osm_lcm/lcm.py
index
5b77c5c
..
6897a94
100644
(file)
--- a/
osm_lcm/lcm.py
+++ b/
osm_lcm/lcm.py
@@
-286,6
+286,10
@@
class Lcm:
except Exception as e:
self.logger.error("Cannot write into '{}' for healthcheck: {}".format(health_check_file, e))
return
except Exception as e:
self.logger.error("Cannot write into '{}' for healthcheck: {}".format(health_check_file, e))
return
+ elif topic == "pla":
+ if command == "placement":
+ self.ns.update_nsrs_with_pla_result(params)
+ return
elif topic == "k8scluster":
if command == "create" or command == "created":
k8scluster_id = params.get("_id")
elif topic == "k8scluster":
if command == "create" or command == "created":
k8scluster_id = params.get("_id")
@@
-463,7
+467,7
@@
class Lcm:
self.first_start = True
while self.consecutive_errors < 10:
try:
self.first_start = True
while self.consecutive_errors < 10:
try:
- topics = ("ns", "vim_account", "wim_account", "sdn", "nsi", "k8scluster", "k8srepo")
+ topics = ("ns", "vim_account", "wim_account", "sdn", "nsi", "k8scluster", "k8srepo"
, "pla"
)
topics_admin = ("admin", )
await asyncio.gather(
self.msg.aioread(topics, self.loop, self.kafka_read_callback),
topics_admin = ("admin", )
await asyncio.gather(
self.msg.aioread(topics, self.loop, self.kafka_read_callback),