commit 149dd9fa5b41462a033c3a1f964b5d36aab6d085
author Andrea Campanella <andrea@opennetworking.org> Fri Apr 27 15:54:42 2018 +0200
committer Andrea Campanella <andrea@opennetworking.org> Wed May 09 19:17:47 2018 +0200
tree 9bfa6dacc048eace4b763b475cef1ae2ff8b242c
parent 4b5769a9e40a7ab84590ac7fa5d052823954d212

Moving Source from connect point to HostId in MulticastHandling

Change-Id: Ie8f678e150b7ee388680b8d8f27df0bce60ec01f

app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java

diff --git a/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java b/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
index 3b659bd..289778e 100644
--- a/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
+++ b/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
@@ -183,7 +183,9 @@
         // Get source, mcast group
         // FIXME To be addressed with multiple sources support
         final ConnectPoint source = mcastPrevUpdate.sources()
+                .values()
                 .stream()
+                .flatMap(Collection::stream)
                 .findFirst()
                 .orElse(null);
         IpAddress mcastIp = mcastPrevUpdate.route().group();