X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fnode%2Futils%2Fstream%2FNormalizedNodeInputStreamReader.java;h=d5ac1580acc8dee0af2a9846586857859ac15f8d;hb=29ceb5385e45275a8125b73b1a2e5b9d0e369c02;hp=b042963f995accd80687d83d7714c553f185925c;hpb=5a0b7e550a7a484cee4693b63df0849111a8236a;p=controller.git diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeInputStreamReader.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeInputStreamReader.java index b042963f99..d5ac1580ac 100755 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeInputStreamReader.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeInputStreamReader.java @@ -57,8 +57,6 @@ public class NormalizedNodeInputStreamReader implements NormalizedNodeDataInput private static final Logger LOG = LoggerFactory.getLogger(NormalizedNodeInputStreamReader.class); - private static final String REVISION_ARG = "?revision="; - private final DataInput input; private final List codedStringMap = new ArrayList<>(); @@ -71,8 +69,6 @@ public class NormalizedNodeInputStreamReader implements NormalizedNodeDataInput @SuppressWarnings("rawtypes") private NormalizedNodeAttrBuilder> leafSetEntryBuilder; - private final StringBuilder reusableStringBuilder = new StringBuilder(50); - private boolean readSignatureMarker = true; NormalizedNodeInputStreamReader(final DataInput input, final boolean versionChecked) { @@ -238,18 +234,9 @@ public class NormalizedNodeInputStreamReader implements NormalizedNodeDataInput // Read in the same sequence of writing String localName = readCodedString(); String namespace = readCodedString(); - String revision = readCodedString(); - - String qname; - if (!Strings.isNullOrEmpty(revision)) { - qname = reusableStringBuilder.append('(').append(namespace).append(REVISION_ARG).append(revision) - .append(')').append(localName).toString(); - } else { - qname = reusableStringBuilder.append('(').append(namespace).append(')').append(localName).toString(); - } + String revision = Strings.emptyToNull(readCodedString()); - reusableStringBuilder.delete(0, reusableStringBuilder.length()); - return QNameFactory.create(qname); + return QNameFactory.create(new QNameFactory.Key(localName, namespace, revision)); }