commit 64d3721fe15778c8243dabb839855e7b2308e5cf
author Madan Jampani <madan.jampani@gmail.com> Thu Feb 25 09:24:54 2016 -0800
committer Gerrit Code Review <gerrit@onlab.us> Thu Feb 25 20:52:42 2016 +0000
tree 2211d8d58818e8a9ac181060c26ed155113b6b19
parent 71cba685ffddc577156fa443390a357c155a60f7

Remove retry logic from NewDistributedLeadershipStore

Change-Id: I1eac3bda717ca227874ebac46fd5840247bfbe11

core/store/dist/src/main/java/org/onosproject/store/cluster/impl/NewDistributedLeadershipStore.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/NewDistributedLeadershipStore.java b/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/NewDistributedLeadershipStore.java
index 914da94..01f61c7 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/NewDistributedLeadershipStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/NewDistributedLeadershipStore.java
@@ -27,7 +27,6 @@
 import org.apache.felix.scr.annotations.Reference;
 import org.apache.felix.scr.annotations.ReferenceCardinality;
 import org.apache.felix.scr.annotations.Service;
-import org.onlab.util.Tools;
 import org.onosproject.cluster.ClusterService;
 import org.onosproject.cluster.Leadership;
 import org.onosproject.cluster.LeadershipEvent;
@@ -37,7 +36,6 @@
 import org.onosproject.event.Change;
 import org.onosproject.store.AbstractStore;
 import org.onosproject.store.service.LeaderElector;
-import org.onosproject.store.service.StorageException;
 import org.onosproject.store.service.StorageService;
 import org.slf4j.Logger;
 
@@ -66,9 +64,6 @@
     private LeaderElector leaderElector;
     private final Map<String, Leadership> leaderBoard = Maps.newConcurrentMap();
 
-    private static final int MAX_RETRIES = 10;
-    private static final int MAX_DELAY_MILLIS_BETWEEN_RETRIES = 100;
-
     private final Consumer<Change<Leadership>> leadershipChangeListener =
             change -> {
                 Leadership oldValue = change.oldValue();
@@ -109,21 +104,12 @@
 
     @Override
     public Leadership addRegistration(String topic) {
-        return Tools.retryable(() -> leaderElector.run(topic, localNodeId),
-                               StorageException.class,
-                               MAX_RETRIES,
-                               MAX_DELAY_MILLIS_BETWEEN_RETRIES).get();
+        return leaderElector.run(topic, localNodeId);
     }
 
     @Override
     public void removeRegistration(String topic) {
-        Tools.retryable(() -> {
-                            leaderElector.withdraw(topic);
-                            return null;
-                        },
-                        StorageException.class,
-                        MAX_RETRIES,
-                        MAX_DELAY_MILLIS_BETWEEN_RETRIES).get();
+        leaderElector.withdraw(topic);
     }
 
     @Override