projects
/
osm
/
RO.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fixing RO Security Vulnerabilities
[osm/RO.git]
/
NG-RO
/
osm_ng_ro
/
vim_admin.py
diff --git
a/NG-RO/osm_ng_ro/vim_admin.py
b/NG-RO/osm_ng_ro/vim_admin.py
index
17bfb20
..
3350d43
100644
(file)
--- a/
NG-RO/osm_ng_ro/vim_admin.py
+++ b/
NG-RO/osm_ng_ro/vim_admin.py
@@
-19,15
+19,15
@@
It is based on asyncio.
It is in charge of load tasks assigned to VIMs that nobody is in chage of it
"""
It is in charge of load tasks assigned to VIMs that nobody is in chage of it
"""
-import logging
-import threading
import asyncio
from http import HTTPStatus
import asyncio
from http import HTTPStatus
+import logging
+import threading
+from time import time
-from osm_common import dbm
ongo, dbmemory, msglocal, msgkafka
+from osm_common import dbm
emory, dbmongo, msgkafka, msglocal
from osm_common.dbbase import DbException
from osm_common.msgbase import MsgException
from osm_common.dbbase import DbException
from osm_common.msgbase import MsgException
-from time import time
__author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
__author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
@@
-277,9
+277,10
@@
class VimAdminThread(threading.Thread):
try:
if not self.aiomain_task_kafka:
# await self.msg.aiowrite("admin", "echo", "dummy message", loop=self.loop)
try:
if not self.aiomain_task_kafka:
# await self.msg.aiowrite("admin", "echo", "dummy message", loop=self.loop)
- await self.msg.aiowrite(
- "vim_account", "echo", "dummy message", loop=self.loop
- )
+ for kafka_topic in self.kafka_topics:
+ await self.msg.aiowrite(
+ kafka_topic, "echo", "dummy message", loop=self.loop
+ )
kafka_working = True
self.logger.debug("Starting vim_account subscription task")
self.aiomain_task_kafka = asyncio.ensure_future(
kafka_working = True
self.logger.debug("Starting vim_account subscription task")
self.aiomain_task_kafka = asyncio.ensure_future(
@@
-333,7
+334,7
@@
class VimAdminThread(threading.Thread):
self.logger.error("renew_locks task exception: {}".format(exc))
self.aiomain_task_renew_lock = None
except asyncio.CancelledError:
self.logger.error("renew_locks task exception: {}".format(exc))
self.aiomain_task_renew_lock = None
except asyncio.CancelledError:
- pass
+ self.logger.exception("asyncio.CancelledError occured.")
except Exception as e:
if self.to_terminate:
except Exception as e:
if self.to_terminate: