X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fentrypoints%2Fresource_watcher.py;h=38308ebb7e62893c9807968d2493fe04b1ca2b0f;hb=5bf7465e213fa92b6514446e353e6f2da436371f;hp=b7ad79947a4e663202d1787a9fc12fbfa9ba964e;hpb=f73c8e3b01b8f5b7438ba544870e06d8f30cdea0;p=pti%2Fo2.git

diff --git a/o2app/entrypoints/resource_watcher.py b/o2app/entrypoints/resource_watcher.py
index b7ad799..38308eb 100644
--- a/o2app/entrypoints/resource_watcher.py
+++ b/o2app/entrypoints/resource_watcher.py
@@ -37,8 +37,11 @@ from o2ims.adapter.clients.ocloud_sa_client import StxMemClient
 from o2ims.service.watcher.pserver_if_watcher import PServerIfWatcher
 from o2ims.adapter.clients.ocloud_sa_client import StxIfClient
 
-from o2ims.service.watcher.pserver_port_watcher import PServerPortWatcher
-from o2ims.adapter.clients.ocloud_sa_client import StxPortClient
+from o2ims.service.watcher.pserver_port_watcher import PServerIfPortWatcher
+from o2ims.adapter.clients.ocloud_sa_client import StxIfPortClient
+
+from o2ims.service.watcher.pserver_eth_watcher import PServerEthWatcher
+from o2ims.adapter.clients.ocloud_sa_client import StxEthClient
 
 from o2common.helper import o2logging
 logger = o2logging.get_logger(__name__)
@@ -51,7 +54,7 @@ class WatcherService(cotyledon.Service):
         super().__init__(worker_id)
         self.args = args
         self.bus = bootstrap.bootstrap()
-        self.worker = PollWorker()
+        self.worker = PollWorker(bus=self.bus)
 
     def run(self):
         try:
@@ -70,9 +73,11 @@ class WatcherService(cotyledon.Service):
             child_pserver.addchild(
                 PServerMemWatcher(StxMemClient(), self.bus))
             child_pserver.addchild(
+                PServerEthWatcher(StxEthClient(), self.bus))
+            child_if = child_pserver.addchild(
                 PServerIfWatcher(StxIfClient(), self.bus))
-            child_pserver.addchild(
-                PServerPortWatcher(StxPortClient(), self.bus))
+            # child_if.addchild(
+            #     PServerIfPortWatcher(StxIfPortClient(), self.bus))
 
             self.worker.add_watcher(root)