Code Review
/
pti
/
o2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix INF-359 and INF-352 about the alarm event record
[pti/o2.git]
/
o2app
/
entrypoints
/
resource_watcher.py
diff --git
a/o2app/entrypoints/resource_watcher.py
b/o2app/entrypoints/resource_watcher.py
index
2e9e0c0
..
b557054
100644
(file)
--- a/
o2app/entrypoints/resource_watcher.py
+++ b/
o2app/entrypoints/resource_watcher.py
@@
-83,6
+83,8
@@
class WatcherService(cotyledon.Service):
child_respool = root.addchild(
ResourcePoolWatcher(StxResourcePoolClient(),
self.bus))
child_respool = root.addchild(
ResourcePoolWatcher(StxResourcePoolClient(),
self.bus))
+
+ # Add Aggregate watch
child_respool.addchild(
ComputeAggWatcher(ComputeAggClient(), self.bus))
child_respool.addchild(
child_respool.addchild(
ComputeAggWatcher(ComputeAggClient(), self.bus))
child_respool.addchild(
@@
-92,6
+94,7
@@
class WatcherService(cotyledon.Service):
child_respool.addchild(
UndefinedAggWatcher(UndefinedAggClient(), self.bus))
child_respool.addchild(
UndefinedAggWatcher(UndefinedAggClient(), self.bus))
+ # Add Resource watch
child_pserver = child_respool.addchild(
PServerWatcher(StxPserverClient(), self.bus))
child_pserver.addchild(
child_pserver = child_respool.addchild(
PServerWatcher(StxPserverClient(), self.bus))
child_pserver.addchild(
@@
-109,11
+112,10
@@
class WatcherService(cotyledon.Service):
child_pserver.addchild(
PServerAccWatcher(StxAccClient(), self.bus))
child_pserver.addchild(
PServerAccWatcher(StxAccClient(), self.bus))
- self.worker.add_watcher(root)
-
# Add Alarm watch
# Add Alarm watch
-
root = WatcherTree
(
+
child_respool.addchild
(
AlarmWatcher(StxAlarmClient(self.bus.uow), self.bus))
AlarmWatcher(StxAlarmClient(self.bus.uow), self.bus))
+
self.worker.add_watcher(root)
self.worker.start()
self.worker.add_watcher(root)
self.worker.start()