Send FlowEntryId notifications for every Flow Entry that is not updated
in the switch (after it is written to the database).
diff --git a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
index ba46ebd..4230e43 100644
--- a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
+++ b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
@@ -823,8 +823,13 @@
} while (retry);
if (enableOnrc2014MeasurementsFlows) {
- // Send the notification
- datagridService.notificationSendFlowIdAdded(flowPath.flowId());
+ // Send the notifications
+ for (FlowEntry flowEntry : flowPath.flowEntries()) {
+ if (flowEntry.flowEntrySwitchState() ==
+ FlowEntrySwitchState.FE_SWITCH_NOT_UPDATED) {
+ datagridService.notificationSendFlowEntryIdAdded(flowEntry.flowEntryId(), flowEntry.dpid());
+ }
+ }
}
}
}