Committed by
Gerrit Code Review
Retry queries when exception is StorageException.Unaavailable
Change-Id: I50537e18f09352ca35d039a341d6873f0ed44695
Showing
2 changed files
with
3 additions
and
2 deletions
... | @@ -55,7 +55,8 @@ public class OnosCopycatClient extends DelegatingCopycatClient { | ... | @@ -55,7 +55,8 @@ public class OnosCopycatClient extends DelegatingCopycatClient { |
55 | || e instanceof ClosedChannelException | 55 | || e instanceof ClosedChannelException |
56 | || e instanceof QueryException | 56 | || e instanceof QueryException |
57 | || e instanceof UnknownSessionException | 57 | || e instanceof UnknownSessionException |
58 | - || e instanceof ClosedSessionException; | 58 | + || e instanceof ClosedSessionException |
59 | + || e instanceof StorageException.Unavailable; | ||
59 | 60 | ||
60 | OnosCopycatClient(CopycatClient client, int maxRetries, long delayBetweenRetriesMillis) { | 61 | OnosCopycatClient(CopycatClient client, int maxRetries, long delayBetweenRetriesMillis) { |
61 | super(client); | 62 | super(client); | ... | ... |
... | @@ -225,6 +225,6 @@ public class StoragePartitionClient implements DistributedPrimitiveCreator, Mana | ... | @@ -225,6 +225,6 @@ public class StoragePartitionClient implements DistributedPrimitiveCreator, Mana |
225 | throw new ResourceManagerException(e); | 225 | throw new ResourceManagerException(e); |
226 | } | 226 | } |
227 | } | 227 | } |
228 | - return new ResourceClient(new OnosCopycatClient(copycatClient, 2, 100)); | 228 | + return new ResourceClient(new OnosCopycatClient(copycatClient, 5, 100)); |
229 | } | 229 | } |
230 | } | 230 | } | ... | ... |
-
Please register or login to post a comment