[CORD-1623] Fix DistributedMcastStore
Change-Id: I5db88a65aeed7ee46e69701d189c1c27c9eb4df0
diff --git a/core/store/dist/src/main/java/org/onosproject/store/mcast/impl/MulticastData.java b/core/store/dist/src/main/java/org/onosproject/store/mcast/impl/MulticastData.java
index 3dd8297..b1214830 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/mcast/impl/MulticastData.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/mcast/impl/MulticastData.java
@@ -20,6 +20,7 @@
import org.onosproject.net.ConnectPoint;
import java.util.Map;
+import java.util.Objects;
import java.util.Set;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
@@ -80,4 +81,24 @@
return new MulticastData();
}
+ @Override
+ public int hashCode() {
+ return Objects.hash(super.hashCode(), source, sinks, isEmpty);
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj) {
+ return true;
+ }
+ if (!(obj instanceof MulticastData)) {
+ return false;
+ }
+ final MulticastData other = (MulticastData) obj;
+
+ return super.equals(obj) &&
+ Objects.equals(source(), other.source()) &&
+ Objects.equals(sinks(), other.sinks()) &&
+ Objects.equals(isEmpty, other.isEmpty);
+ }
}