VOL-1564: Incoporate Delete Flow Functionality and subsequent cleanup in stores
Change-Id: I429a380da3ed0c951cb5f01ee763eb318693d3b3
diff --git a/adaptercore/device_handler.go b/adaptercore/device_handler.go
index 99d0d01..20eb783 100644
--- a/adaptercore/device_handler.go
+++ b/adaptercore/device_handler.go
@@ -795,8 +795,13 @@
log.Debugw("In UpdateFlowsIncrementally", log.Fields{"deviceId": device.Id, "flows": flows, "groups": groups})
if flows != nil {
for _, flow := range flows.ToAdd.Items {
+ log.Debug("Adding flow", log.Fields{"deviceId": device.Id, "flowToAdd": flow})
dh.flowMgr.AddFlow(flow)
}
+ for _, flow := range flows.ToRemove.Items {
+ log.Debug("Removing flow", log.Fields{"deviceId": device.Id, "flowToRemove": flow})
+ dh.flowMgr.RemoveFlow(flow)
+ }
}
if groups != nil {
for _, flow := range flows.ToRemove.Items {