commit | 2914e4e73c3e3ba38e9580c09da57ac5fbc0576d | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan@onlab.us> | Tue Sep 13 17:48:56 2016 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Wed Sep 14 19:05:18 2016 +0000 |
tree | 108d8083b0b542dd973229c0406087ce983d0bd8 | |
parent | a9e29550c05b4e465c8bb971ff88fffb5fb2f0bb [diff] [blame] |
StorageService API for creating AsyncDocumentTree primitive Change-Id: Ib7c3f19beb7b26a5b69161cf972c3c64d0be94b3
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java index efb32d7..b36906c 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java
@@ -29,6 +29,7 @@ import org.onosproject.store.service.AsyncConsistentMap; import org.onosproject.store.service.AsyncConsistentTreeMap; import org.onosproject.store.service.AsyncDistributedSet; +import org.onosproject.store.service.AsyncDocumentTree; import org.onosproject.store.service.AsyncLeaderElector; import org.onosproject.store.service.Serializer; import org.onosproject.store.service.WorkQueue; @@ -108,6 +109,11 @@ } @Override + public <V> AsyncDocumentTree<V> newAsyncDocumentTree(String name, Serializer serializer) { + return getCreator(name).newAsyncDocumentTree(name, serializer); + } + + @Override public Set<String> getAsyncConsistentMapNames() { return members.values() .stream()