commit 21a7149c944b36a636cb7d4f833d719f5f736ad6
author Madan Jampani <madan@onlab.us> Thu Jun 16 16:53:04 2016 -0700
committer Gerrit Code Review <gerrit@onlab.us> Fri Jun 17 01:45:48 2016 +0000
tree b42bdea5c0bc92f64611605bc444a1d1f80a8d32
parent 984e2d8654030f4106acce56cac620e2c9358ae1

Retry queries when exception is StorageException.Unaavailable

Change-Id: I50537e18f09352ca35d039a341d6873f0ed44695

core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/OnosCopycatClient.java

diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/OnosCopycatClient.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/OnosCopycatClient.java
index a170afb..3a0ed32 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/OnosCopycatClient.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/OnosCopycatClient.java
@@ -55,7 +55,8 @@
             || e instanceof ClosedChannelException
             || e instanceof QueryException
             || e instanceof UnknownSessionException
-            || e instanceof ClosedSessionException;
+            || e instanceof ClosedSessionException
+            || e instanceof StorageException.Unavailable;
 
     OnosCopycatClient(CopycatClient client, int maxRetries, long delayBetweenRetriesMillis) {
         super(client);

core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java

diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java
index 92170d4..0c1d8a6 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java
@@ -225,6 +225,6 @@
                 throw new ResourceManagerException(e);
             }
         }
-        return new ResourceClient(new OnosCopycatClient(copycatClient, 2, 100));
+        return new ResourceClient(new OnosCopycatClient(copycatClient, 5, 100));
     }
 }