commit | e14a09c5dcca8cfc5e1b70ff6ff24437b42db007 | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan.jampani@gmail.com> | Thu Feb 11 10:43:21 2016 -0800 |
committer | Gerrit Code Review <gerrit@onlab.us> | Thu Feb 11 19:15:31 2016 +0000 |
tree | da309eaf1ffb2485043e29eab636b921d34063fa | |
parent | 826990b08dc1316526216a01bc483085d11ac210 [diff] [blame] |
Implementation for StorageAdmin and PartitionAdmin APIs Change-Id: I48cbfae6f410425294196884cdb2ce4705fa2c3d
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionServer.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionServer.java index 6ffc677..0dad15a 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionServer.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionServer.java
@@ -34,6 +34,7 @@ import java.util.function.Supplier; import org.onosproject.cluster.NodeId; +import org.onosproject.store.service.PartitionInfo; import com.google.common.collect.ImmutableSet; import com.google.common.collect.Sets; @@ -124,4 +125,16 @@ public boolean isClosed() { return server.isClosed(); } + + /** + * Returns the partition information. + * @return partition info + */ + public PartitionInfo info() { + return new StoragePartitionDetails(partition.getId(), + server.cluster().members(), + server.cluster().members(), + server.cluster().leader(), + server.cluster().term()).toPartitionInfo(); + } }