from o2ims.service.watcher.pserver_if_watcher import PServerIfWatcher\r
from o2ims.adapter.clients.ocloud_sa_client import StxIfClient\r
\r
-from o2ims.service.watcher.pserver_port_watcher import PServerPortWatcher\r
-from o2ims.adapter.clients.ocloud_sa_client import StxPortClient\r
+from o2ims.service.watcher.pserver_port_watcher import PServerIfPortWatcher\r
+from o2ims.adapter.clients.ocloud_sa_client import StxIfPortClient\r
+\r
+from o2ims.service.watcher.pserver_eth_watcher import PServerEthWatcher\r
+from o2ims.adapter.clients.ocloud_sa_client import StxEthClient\r
\r
from o2common.helper import o2logging\r
logger = o2logging.get_logger(__name__)\r
super().__init__(worker_id)\r
self.args = args\r
self.bus = bootstrap.bootstrap()\r
- self.worker = PollWorker()\r
+ self.worker = PollWorker(bus=self.bus)\r
\r
def run(self):\r
try:\r
child_pserver.addchild(\r
PServerMemWatcher(StxMemClient(), self.bus))\r
child_pserver.addchild(\r
+ PServerEthWatcher(StxEthClient(), self.bus))\r
+ child_if = child_pserver.addchild(\r
PServerIfWatcher(StxIfClient(), self.bus))\r
- child_pserver.addchild(\r
- PServerPortWatcher(StxPortClient(), self.bus))\r
+ # child_if.addchild(\r
+ # PServerIfPortWatcher(StxIfPortClient(), self.bus))\r
\r
self.worker.add_watcher(root)\r
\r