VOL-1489: Can now recieve flows incrementally
core can now deliver incremental flow updates
to the handler and flow mgr. successfully call openolt/bal
flow add for eap, dhcp, and lldp. BAL complains still about
downstream eap flow. likely due to ID problems.
Calculation of uni_id, onu_id needs additional
info from the decomposer.
Change-Id: Ic347e71501e6cf2bb0e93d42eaf0b6c709238fbd
diff --git a/python/adapters/openolt/openolt_resource_manager.py b/python/adapters/openolt/openolt_resource_manager.py
index 121f193..c0ccb14 100644
--- a/python/adapters/openolt/openolt_resource_manager.py
+++ b/python/adapters/openolt/openolt_resource_manager.py
@@ -143,12 +143,15 @@
def get_flow_id(self, pon_intf_id, onu_id, uni_id, flow_store_cookie,
flow_category=None):
pon_intf_onu_id = (pon_intf_id, onu_id, uni_id)
+ self.log.debug("get-flow-id", pon_intf_onu_id=pon_intf_onu_id)
try:
flow_ids = self.resource_mgrs[pon_intf_id]. \
get_current_flow_ids_for_onu(pon_intf_onu_id)
+ self.log.debug("get-current-flow-ids-for-onu", flow_ids=flow_ids)
if flow_ids is not None:
for flow_id in flow_ids:
flows = self.get_flow_id_info(pon_intf_id, onu_id, uni_id, flow_id)
+ self.log.debug("get-flow-id-info", flows=flows)
assert (isinstance(flows, list))
for flow in flows:
@@ -168,6 +171,7 @@
pon_intf_onu_id, flow_id
)
+ self.log.debug("return-flow-id", flow_id=flow_id)
return flow_id
def get_flow_id_info(self, pon_intf_id, onu_id, uni_id, flow_id):