X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fidentifiers%2FShardIdentifier.java;h=e8824fbe11b1378774b644310d3878414b17d5a5;hb=81674d6fd50b419b868d0851062e23f34b34557d;hp=d65af61ba3f8a957b6f67bdc355035fa93297431;hpb=c66e710cd61119c4779784571e59cdc3b490673f;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/ShardIdentifier.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/ShardIdentifier.java index d65af61ba3..e8824fbe11 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/ShardIdentifier.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/ShardIdentifier.java @@ -9,40 +9,49 @@ package org.opendaylight.controller.cluster.datastore.identifiers; import com.google.common.base.Preconditions; - import java.util.regex.Matcher; import java.util.regex.Pattern; +import org.opendaylight.controller.cluster.access.concepts.MemberName; public class ShardIdentifier { + // This pattern needs to remain in sync with toString(), which produces + // strings with corresponding to "%s-shard-%s-%s" + private static final Pattern PATTERN = Pattern.compile("(\\S+)-shard-(\\S+)-(\\S+)"); + private final String shardName; - private final String memberName; + private final MemberName memberName; private final String type; + private final String fullName; - //format and pattern should be in sync - private final String format = "%s-shard-%s-%s"; - private static final Pattern pattern = Pattern.compile("(\\S+)-shard-(\\S+)-(\\S+)"); + private ShardIdentifier(String shardName, MemberName memberName, String type) { + this.shardName = Preconditions.checkNotNull(shardName, "shardName should not be null"); + this.memberName = Preconditions.checkNotNull(memberName, "memberName should not be null"); + this.type = Preconditions.checkNotNull(type, "type should not be null"); + + fullName = memberName.getName() + "-shard-" + shardName + "-" + type; + } - public ShardIdentifier(String shardName, String memberName, String type) { + public static ShardIdentifier create(final String shardName, final MemberName memberName, final String type) { + return new ShardIdentifier(shardName, memberName, type); + } - Preconditions.checkNotNull(shardName, "shardName should not be null"); - Preconditions.checkNotNull(memberName, "memberName should not be null"); - Preconditions.checkNotNull(type, "type should not be null"); + public static ShardIdentifier fromShardIdString(final String shardIdString) { + final Matcher matcher = PATTERN.matcher(shardIdString); + Preconditions.checkArgument(matcher.matches(), "Invalid shard id \"%s\"", shardIdString); - this.shardName = shardName; - this.memberName = memberName; - this.type = type; + return new ShardIdentifier(matcher.group(2), MemberName.forName(matcher.group(1)), matcher.group(3)); } @Override - public boolean equals(Object o) { - if (this == o) { + public boolean equals(Object obj) { + if (this == obj) { return true; } - if (o == null || getClass() != o.getClass()) { + if (obj == null || getClass() != obj.getClass()) { return false; } - ShardIdentifier that = (ShardIdentifier) o; + ShardIdentifier that = (ShardIdentifier) obj; if (!memberName.equals(that.memberName)) { return false; @@ -65,25 +74,17 @@ public class ShardIdentifier { return result; } - @Override public String toString() { - //ensure the output of toString matches the pattern above - return new StringBuilder(memberName) - .append("-shard-") - .append(shardName) - .append("-") - .append(type) - .toString(); - } - - public static Builder builder(){ - return new Builder(); + @Override + public String toString() { + // ensure the output of toString matches the pattern above + return fullName; } public String getShardName() { return shardName; } - public String getMemberName() { + public MemberName getMemberName() { return memberName; } @@ -93,33 +94,33 @@ public class ShardIdentifier { public static class Builder { private String shardName; - private String memberName; + private MemberName memberName; private String type; - public ShardIdentifier build(){ + public ShardIdentifier build() { return new ShardIdentifier(shardName, memberName, type); } - public Builder shardName(String shardName){ - this.shardName = shardName; + public Builder shardName(String newShardName) { + this.shardName = newShardName; return this; } - public Builder memberName(String memberName){ - this.memberName = memberName; + public Builder memberName(MemberName newMemberName) { + this.memberName = newMemberName; return this; } - public Builder type(String type){ - this.type = type; + public Builder type(String newType) { + this.type = newType; return this; } - public Builder fromShardIdString(String shardId){ - Matcher matcher = pattern.matcher(shardId); + public Builder fromShardIdString(String shardId) { + Matcher matcher = PATTERN.matcher(shardId); if (matcher.matches()) { - memberName = matcher.group(1); + memberName = MemberName.forName(matcher.group(1)); shardName = matcher.group(2); type = matcher.group(3); }