Don't ignore anymore Flow Entries Events originated by this instance.
This was an optimization that was added in the original implementation.
Now we need the FlowEventHandler to process events for Flow Entries
that were added/modified by other internal modules (e.g., the FlowPusher)
so it can track when a FlowPath has been pushed into all switches.
diff --git a/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java b/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java
index d48e896..6483121 100644
--- a/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java
+++ b/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java
@@ -171,12 +171,6 @@
* @param event the notification event for the entry.
*/
public void entryAdded(EntryEvent<Long, byte[]> event) {
- //
- // NOTE: Ignore Flow Entries Events originated by this instance
- //
- if (event.getMember().localMember())
- return;
-
byte[] valueBytes = (byte[])event.getValue();
//
@@ -195,12 +189,6 @@
* @param event the notification event for the entry.
*/
public void entryRemoved(EntryEvent<Long, byte[]> event) {
- //
- // NOTE: Ignore Flow Entries Events originated by this instance
- //
- if (event.getMember().localMember())
- return;
-
byte[] valueBytes = (byte[])event.getValue();
//
@@ -219,12 +207,6 @@
* @param event the notification event for the entry.
*/
public void entryUpdated(EntryEvent<Long, byte[]> event) {
- //
- // NOTE: Ignore Flow Entries Events originated by this instance
- //
- if (event.getMember().localMember())
- return;
-
byte[] valueBytes = (byte[])event.getValue();
//