commit 89470f1d99c29655546d4e177605fea8f235bf54
author helenyrwu <helenwu@college.harvard.edu> Fri Aug 12 13:18:10 2016 -0700
committer Helen Wu <helen@onlab.us> Thu Aug 18 16:56:47 2016 +0000
tree 4df2ff26e57f22947f57e89654da6826135bda78
parent 06e890869d52fee79dd8fad6701ab1ee4ea41a65

Group event indicating failover of previously used live port

Change-Id: I32749b38d5e4fab93fa97bbf6587bd0dc91db88c

core/store/dist/src/main/java/org/onosproject/store/group/impl/DistributedGroupStore.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/group/impl/DistributedGroupStore.java b/core/store/dist/src/main/java/org/onosproject/store/group/impl/DistributedGroupStore.java
index afdec73..1f9387e 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/group/impl/DistributedGroupStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/group/impl/DistributedGroupStore.java
@@ -1312,6 +1312,17 @@
         }
     }
 
+    @Override
+    public void notifyOfFailovers(Collection<Group> failoverGroups) {
+        List<GroupEvent> failoverEvents = new ArrayList<>();
+        failoverGroups.forEach(group -> {
+            if (group.type() == Group.Type.FAILOVER) {
+                failoverEvents.add(new GroupEvent(GroupEvent.Type.GROUP_BUCKET_FAILOVER, group));
+            }
+        });
+        notifyDelegate(failoverEvents);
+    }
+
     private void garbageCollect(DeviceId deviceId,
                                 Set<Group> southboundGroupEntries,
                                 Set<StoredGroupEntry> storedGroupEntries) {