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%2FLithiumNormalizedNodeInputStreamReader.java;h=ae8738e60f2d02ae82a797be6e26403f1976200b;hb=2d72ea2f5f6860a8e2bb2ae12212ac35b0cd8b99;hp=573e4ed2faf3f131bbaf6729a1197e94c70f936d;hpb=1f6d9ca454e9594030ffe52271ef050f56ba33e7;p=controller.git diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/LithiumNormalizedNodeInputStreamReader.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/LithiumNormalizedNodeInputStreamReader.java index 573e4ed2fa..ae8738e60f 100755 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/LithiumNormalizedNodeInputStreamReader.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/LithiumNormalizedNodeInputStreamReader.java @@ -215,11 +215,10 @@ class LithiumNormalizedNodeInputStreamReader extends ForwardingDataInput impleme String namespace = readCodedString(); String revision = Strings.emptyToNull(readCodedString()); - return QNameFactory.create(new QNameFactory.Key(localName, namespace, revision)); + return QNameFactory.create(localName, namespace, revision); } - - private String readCodedString() throws IOException { + final String readCodedString() throws IOException { final byte valueType = input.readByte(); switch (valueType) { case TokenTypes.IS_NULL_VALUE: @@ -254,8 +253,7 @@ class LithiumNormalizedNodeInputStreamReader extends ForwardingDataInput impleme return new AugmentationIdentifier(readQNameSet()); } - private NodeIdentifier readNodeIdentifier() throws IOException { - // FIXME: we should have a cache for these, too + NodeIdentifier readNodeIdentifier() throws IOException { return new NodeIdentifier(readQName()); }