commit 7f72c3f3540859c9c5f58b0b3f7927e9fd1336b5
author Madan Jampani <madan@onlab.us> Sun Mar 01 17:34:59 2015 -0800
committer Madan Jampani <madan@onlab.us> Mon Mar 02 19:37:15 2015 +0000
tree 6eb5b58177827243af94d8578db0ebe279a46eb4
parent dd6479f2ace1654d277eaf7104b9a04f13e1c5c6

Enabled leadership service implementation based on consistent map + added precondition checks to partitioned database.

Change-Id: Ia76f8479d9113e7ad67e583e4ca157e62a1cabc7

core/store/dist/src/main/java/org/onosproject/store/intent/impl/PartitionManager.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/intent/impl/PartitionManager.java b/core/store/dist/src/main/java/org/onosproject/store/intent/impl/PartitionManager.java
index d913a38..e2e6322 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/intent/impl/PartitionManager.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/intent/impl/PartitionManager.java
@@ -33,6 +33,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.google.common.base.Objects;
+
 import java.util.List;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
@@ -169,7 +171,7 @@
         public void event(LeadershipEvent event) {
             Leadership leadership = event.subject();
 
-            if (leadership.leader().equals(clusterService.getLocalNode().id()) &&
+            if (Objects.equal(leadership.leader(), clusterService.getLocalNode().id()) &&
                     leadership.topic().startsWith(ELECTION_PREFIX)) {
 
                 // See if we need to let some partitions go