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=9b2ce2b64d4fab9d71e5ac844983008ad8b85979;hb=a69604185f71923bdfc16d2d056490fff9a8d90e;hp=4e7216df88eac82e5ea4b4d875c29fc9f4b66a14;hpb=60fa71ddf45a8ffb37b69eb726305bdd0697185a;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 4e7216df88..9b2ce2b64d 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 @@ -58,8 +58,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 NormalizedNodeBuilder> leafSetEntryBuilder; - private final StringBuilder reusableStringBuilder = new StringBuilder(50); - private boolean readSignatureMarker = true; NormalizedNodeInputStreamReader(final DataInput input, final boolean versionChecked) { @@ -225,18 +221,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)); }