+/*
+ * 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.utils.serialization;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import com.google.common.base.Optional;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.ExpectedException;
import org.opendaylight.controller.cluster.datastore.util.TestModel;
import org.opendaylight.controller.protobuff.messages.common.NormalizedNodeMessages;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
+import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
+import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
+import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class NormalizedNodeSerializerTest {
+ private static final Logger LOG = LoggerFactory.getLogger(NormalizedNodeSerializerTest.class);
@Rule
public ExpectedException expectedException = ExpectedException.none();
@Test
- public void testSerializeDeSerialize(){
+ public void testSerializeDeSerialize() {
// This test basically serializes and deSerializes a largish document
// which contains most of the types of nodes that go into a normalized
NormalizedNodeMessages.Node expected = NormalizedNodeSerializer
.serialize(expectedNode);
- System.out.println("Serialize Time = " + (System.nanoTime() - start)/1000000);
+ LOG.info("Serialize Time = {}", (System.nanoTime() - start) / 1000000);
- System.out.println("Serialized Size = " + expected.getSerializedSize());
+ LOG.info("Serialized Size = {}", expected.getSerializedSize());
- System.out.println(expected.toString());
+ LOG.info(expected.toString());
start = System.nanoTime();
- NormalizedNode actualNode =
+ NormalizedNode<?, ?> actualNode =
NormalizedNodeSerializer.deSerialize(expected);
- System.out.println("DeSerialize Time = " + (System.nanoTime() - start)/1000000);
+ LOG.info("DeSerialize Time = {}", (System.nanoTime() - start) / 1000000);
// Compare the original normalized node to the normalized node that was
// created by serializing the original node and deSerializing it back.
assertEquals(expectedNode, actualNode);
+ byte[] binaryData = new byte[5];
+ for (byte i = 0; i < 5; i++) {
+ binaryData[i] = i;
+ }
+
+ ContainerNode node1 = TestModel.createBaseTestContainerBuilder()
+ .withChild(ImmutableNodes.leafNode(TestModel.SOME_BINARY_DATA_QNAME, binaryData))
+ .build();
+
+ NormalizedNodeMessages.Node serializedNode1 = NormalizedNodeSerializer
+ .serialize(node1);
+
+ ContainerNode node2 =
+ (ContainerNode) NormalizedNodeSerializer.deSerialize(serializedNode1);
+
+
+ // FIXME: This will not work due to BUG 2326. Once that is fixed we can uncomment this assertion
+ // assertEquals(node1, node2);
+
+ Optional<DataContainerChild<? extends YangInstanceIdentifier.PathArgument, ?>> child =
+ node2.getChild(new YangInstanceIdentifier.NodeIdentifier(TestModel.SOME_BINARY_DATA_QNAME));
+
+ Object value = child.get().getValue();
+
+ assertTrue("value should be of type byte[]", value instanceof byte[]);
+
+ byte[] bytesValue = (byte[]) value;
+
+ for (byte i = 0; i < 5; i++) {
+ assertEquals(i, bytesValue[i]);
+ }
+
}
@Test(expected = NullPointerException.class)
- public void testSerializeNullNormalizedNode(){
+ public void testSerializeNullNormalizedNode() {
assertNotNull(NormalizedNodeSerializer.serialize(null));
}
@Test
- public void testDeSerializeNullProtocolBufferNode(){
+ public void testDeSerializeNullProtocolBufferNode() {
expectedException.expect(NullPointerException.class);
expectedException.expectMessage("node should not be null");
}
@Test
- public void testDeSerializePathArgumentNullNode(){
+ public void testDeSerializePathArgumentNullNode() {
expectedException.expect(NullPointerException.class);
expectedException.expectMessage("node should not be null");
}
@Test
- public void testDeSerializePathArgumentNullPathArgument(){
+ public void testDeSerializePathArgumentNullPathArgument() {
expectedException.expect(NullPointerException.class);
expectedException.expectMessage("pathArgument should not be null");
}
@Test
- public void testDeSerializePathArgument(){
+ public void testDeSerializePathArgument() {
NormalizedNodeMessages.Node.Builder nodeBuilder = NormalizedNodeMessages.Node.newBuilder();
pathBuilder.setIntType(PathArgumentType.NODE_IDENTIFIER.ordinal());
- NormalizedNodeMessages.QName.Builder qNameBuilder = NormalizedNodeMessages.QName.newBuilder();
- qNameBuilder.setNamespace(1);
- qNameBuilder.setRevision(4);
- qNameBuilder.setLocalName(8);
+ NormalizedNodeMessages.QName.Builder qnameBuilder = NormalizedNodeMessages.QName.newBuilder();
+ qnameBuilder.setNamespace(1);
+ qnameBuilder.setRevision(4);
+ qnameBuilder.setLocalName(8);
- pathBuilder.setNodeType(qNameBuilder);
+ pathBuilder.setNodeType(qnameBuilder);
YangInstanceIdentifier.PathArgument pathArgument =
NormalizedNodeSerializer
assertNotNull(pathArgument);
- assertEquals("urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test", pathArgument.getNodeType().getNamespace().toString());
+ assertEquals("urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom:store:test",
+ pathArgument.getNodeType().getNamespace().toString());
assertEquals("2014-03-13", pathArgument.getNodeType().getFormattedRevision());
assertEquals("capability", pathArgument.getNodeType().getLocalName());
}
-
-
}
Code Review / controller.git / blobdiff