X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fnode%2FNormalizedNodeToNodeCodecTest.java;fp=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fnode%2FNormalizedNodeToNodeCodecTest.java;h=0000000000000000000000000000000000000000;hp=2521d997f5ffa4cc4a7c3e7357f7a52f78406cf2;hb=599f10fc4a52c41583b719582b6ff36a0d53ccae;hpb=a58c23b491f665e6d5449e97d430a7e15d1ecda6 diff --git a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/datastore/node/NormalizedNodeToNodeCodecTest.java b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/datastore/node/NormalizedNodeToNodeCodecTest.java deleted file mode 100644 index 2521d997f5..0000000000 --- a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/datastore/node/NormalizedNodeToNodeCodecTest.java +++ /dev/null @@ -1,141 +0,0 @@ -/* - * Copyright (c) 2014, 2015 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ - -package org.opendaylight.controller.cluster.datastore.node; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertTrue; - -import java.util.List; -import org.junit.Before; -import org.junit.Test; -import org.opendaylight.controller.cluster.datastore.node.utils.NormalizedNodeGetter; -import org.opendaylight.controller.cluster.datastore.node.utils.NormalizedNodeNavigator; -import org.opendaylight.controller.cluster.datastore.node.utils.PathUtils; -import org.opendaylight.controller.cluster.datastore.node.utils.serialization.NormalizedNodeSerializer; -import org.opendaylight.controller.cluster.datastore.util.TestModel; -import org.opendaylight.controller.protobuff.messages.common.NormalizedNodeMessages.Container; -import org.opendaylight.controller.protobuff.messages.common.NormalizedNodeMessages.Node; -import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode; -import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class NormalizedNodeToNodeCodecTest { - private static final Logger LOG = LoggerFactory.getLogger(NormalizedNodeToNodeCodecTest.class); - - private SchemaContext schemaContext; - - @Before - public void setUp() { - schemaContext = TestModel.createTestContext(); - assertNotNull("Schema context must not be null.", schemaContext); - } - - private static YangInstanceIdentifier instanceIdentifierFromString(String str) { - return PathUtils.toYangInstanceIdentifier(str); - } - - @Test - public void testNormalizeNodeAttributesToProtoBuffNode() { - final NormalizedNode documentOne = TestModel.createTestContainer(); - String id = "/(urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test?revision=2014-03-13)test" - + "/(urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test?revision=2014-03-13)outer-list" - + "/(urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test?revision=2014-03-13)outer-list[" - + "{(urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test?revision=2014-03-13)id=2}]" - + "/(urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test?revision=2014-03-13)id"; - - NormalizedNodeGetter normalizedNodeGetter = new NormalizedNodeGetter(id); - new NormalizedNodeNavigator(normalizedNodeGetter).navigate(PathUtils.toString(YangInstanceIdentifier.EMPTY), - documentOne); - - // Validate the value of id can be retrieved from the normalized node - NormalizedNode output = normalizedNodeGetter.getOutput(); - assertNotNull(output); - - NormalizedNodeToNodeCodec codec = new NormalizedNodeToNodeCodec(); - long start = System.currentTimeMillis(); - Container container = codec.encode(output); - long end = System.currentTimeMillis(); - - LOG.info("Time taken to encode: {}", end - start); - - assertNotNull(container); - - // Decode the normalized node from the ProtocolBuffer form - // first get the node representation of normalized node - final Node node = container.getNormalizedNode(); - - start = System.currentTimeMillis(); - NormalizedNode normalizedNode = codec.decode(node); - end = System.currentTimeMillis(); - - LOG.info("Time taken to decode: {}", end - start); - - assertEquals(normalizedNode.getValue().toString(), output.getValue().toString()); - } - - @Test - public void testThatANormalizedNodeToProtoBuffNodeEncodeDecode() throws Exception { - final NormalizedNode documentOne = TestModel.createTestContainer(); - - final NormalizedNodeToNodeCodec normalizedNodeToNodeCodec = new NormalizedNodeToNodeCodec(); - - Container container = normalizedNodeToNodeCodec.encode(documentOne); - - final NormalizedNode decode = normalizedNodeToNodeCodec.decode(container.getNormalizedNode()); - assertNotNull(decode); - - // let us ensure that the return decode normalized node encode returns - // same container - Container containerResult = normalizedNodeToNodeCodec.encode(decode); - - // check first level children are proper - List childrenResult = containerResult.getNormalizedNode().getChildList(); - List childrenOriginal = container.getNormalizedNode().getChildList(); - - LOG.info("\n-------------------------------------------------\n" + childrenOriginal - + "\n-------------------------------------------------\n" + childrenResult); - - boolean found; - for (Node resultChild : childrenResult) { - found = false; - for (Node originalChild : childrenOriginal) { - - YangInstanceIdentifier.PathArgument result = NormalizedNodeSerializer - .deSerialize(containerResult.getNormalizedNode(), resultChild.getPathArgument()); - - YangInstanceIdentifier.PathArgument original = NormalizedNodeSerializer - .deSerialize(container.getNormalizedNode(), originalChild.getPathArgument()); - - if (original.equals(result) && resultChild.getIntType() == resultChild.getIntType()) { - found = true; - break; - } - } - assertTrue(found); - } - - } - - @Test - public void addAugmentations() { - MapEntryNode uno = TestModel.createAugmentedListEntry(1, "Uno"); - - NormalizedNodeToNodeCodec codec = new NormalizedNodeToNodeCodec(); - - Container encode = codec.encode(uno); - - LOG.info(encode.getNormalizedNode().toString()); - - codec.decode(encode.getNormalizedNode()); - } -}