VOL-1564: Incoporate Delete Flow Functionality and subsequent cleanup in stores
Change-Id: I429a380da3ed0c951cb5f01ee763eb318693d3b3
diff --git a/adaptercore/resourcemanager/resourcemanager.go b/adaptercore/resourcemanager/resourcemanager.go
index f87ffd1..524997a 100755
--- a/adaptercore/resourcemanager/resourcemanager.go
+++ b/adaptercore/resourcemanager/resourcemanager.go
@@ -623,6 +623,18 @@
}
func (RsrcMgr *OpenOltResourceMgr) FreeFlowID(IntfID uint32, ONUID uint32,
+ UNIID uint32, FlowId uint32) {
+ var IntfONUID string
+ var err error
+ IntfONUID = fmt.Sprintf("%d,%d,%d", IntfID, ONUID, UNIID)
+ err = RsrcMgr.ResourceMgrs[IntfID].UpdateFlowIDForOnu(IntfONUID, FlowId, false)
+ if err != nil {
+ log.Error("Failed to Update flow id infor for %s", IntfONUID)
+ }
+ RsrcMgr.ResourceMgrs[IntfID].RemoveFlowIDInfo(IntfONUID, FlowId)
+}
+
+func (RsrcMgr *OpenOltResourceMgr) FreeFlowIDs(IntfID uint32, ONUID uint32,
UNIID uint32, FlowID []uint32) {
/* Free flow id for a given interface, onu id and uni id.*/