VOL-1494: Use core function to update state on all ports on a device
Change-Id: I7a09783b938bcce4100c4ff4588a18e910be4489
diff --git a/pyvoltha/adapters/kafka/core_proxy.py b/pyvoltha/adapters/kafka/core_proxy.py
index 58313e0..e99d00f 100644
--- a/pyvoltha/adapters/kafka/core_proxy.py
+++ b/pyvoltha/adapters/kafka/core_proxy.py
@@ -391,6 +391,30 @@
port=port)
returnValue(res)
+ @ContainerProxy.wrap_request(None)
+ @inlineCallbacks
+ def ports_state_update(self,
+ device_id,
+ oper_status):
+ log.debug("ports_state_update", device_id=device_id, oper_status=oper_status)
+ id = ID()
+ id.id = device_id
+ o_status = IntType()
+ o_status.val = oper_status
+
+ to_topic = self.get_core_topic(device_id)
+ reply_topic = self.get_adapter_topic()
+
+ # to_topic = createSubTopic(self.core_topic, device_id)
+ # reply_topic = createSubTopic(self.listening_topic, device_id)
+ res = yield self.invoke(rpc="PortsStateUpdate",
+ to_topic=to_topic,
+ reply_topic=reply_topic,
+ device_id=id,
+ oper_status=o_status)
+ log.debug("ports_state_update_response", device_id=device_id, oper_status=oper_status, response=res)
+ returnValue(res)
+
def port_removed(device_id, port):
raise NotImplementedError()