commit | b2cfa6ad75e5336c59545861a67123d60ada7f51 | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan@onlab.us> | Tue Jun 21 10:47:56 2016 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Thu Jun 23 08:41:46 2016 +0000 |
tree | 4c86798ddcb77e13efa4394fb0b4b823053202ea | |
parent | d721f295b7796051ddce0538562da93f60e0ebed [diff] |
Fail with StorageException.Unavailable only when client is CLOSED Change-Id: I5a7f7cdb78aee88662b421cbcc03ed3b39e1e7ab (cherry picked from commit 92ed7a17416759f63a05bd1a34e05d5215a68ee4)
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 3a0ed32..46b85b9 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
@@ -73,7 +73,7 @@ @Override public <T> CompletableFuture<T> submit(Query<T> query) { - if (state() == State.SUSPENDED || state() == State.CLOSED) { + if (state() == State.CLOSED) { return Tools.exceptionalFuture(new StorageException.Unavailable()); } CompletableFuture<T> future = new CompletableFuture<>();