package org.opendaylight.controller.cluster.datastore.node.utils.stream;
-import java.io.ByteArrayInputStream;
+import com.google.common.io.ByteStreams;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import org.apache.commons.lang.SerializationUtils;
public void testNormalizedNodeStreaming() throws IOException {
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
- NormalizedNodeOutputStreamWriter writer = new NormalizedNodeOutputStreamWriter(byteArrayOutputStream);
+ NormalizedNodeOutputStreamWriter writer = new NormalizedNodeOutputStreamWriter(
+ ByteStreams.newDataOutput(byteArrayOutputStream));
NormalizedNode<?, ?> testContainer = createTestContainer();
writer.writeNormalizedNode(testContainer);
writer.writeNormalizedNode(toasterContainer);
NormalizedNodeInputStreamReader reader = new NormalizedNodeInputStreamReader(
- new ByteArrayInputStream(byteArrayOutputStream.toByteArray()));
+ ByteStreams.newDataInput(byteArrayOutputStream.toByteArray()));
NormalizedNode<?,?> node = reader.readNormalizedNode();
Assert.assertEquals(testContainer, node);
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
NormalizedNodeOutputStreamWriter writer =
- new NormalizedNodeOutputStreamWriter(byteArrayOutputStream);
+ new NormalizedNodeOutputStreamWriter(ByteStreams.newDataOutput(byteArrayOutputStream));
writer.writeYangInstanceIdentifier(path);
NormalizedNodeInputStreamReader reader = new NormalizedNodeInputStreamReader(
- new ByteArrayInputStream(byteArrayOutputStream.toByteArray()));
+ ByteStreams.newDataInput(byteArrayOutputStream.toByteArray()));
YangInstanceIdentifier newPath = reader.readYangInstanceIdentifier();
Assert.assertEquals(path, newPath);
public void testNormalizedNodeAndYangInstanceIdentifierStreaming() throws IOException {
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
- NormalizedNodeOutputStreamWriter writer = new NormalizedNodeOutputStreamWriter(byteArrayOutputStream);
+ NormalizedNodeOutputStreamWriter writer = new NormalizedNodeOutputStreamWriter(
+ ByteStreams.newDataOutput(byteArrayOutputStream));
NormalizedNode<?, ?> testContainer = TestModel.createBaseTestContainerBuilder().build();
writer.writeNormalizedNode(testContainer);
writer.writeYangInstanceIdentifier(path);
NormalizedNodeInputStreamReader reader = new NormalizedNodeInputStreamReader(
- new ByteArrayInputStream(byteArrayOutputStream.toByteArray()));
+ ByteStreams.newDataInput(byteArrayOutputStream.toByteArray()));
NormalizedNode<?,?> node = reader.readNormalizedNode();
Assert.assertEquals(testContainer, node);
TestModel.createBaseTestContainerBuilder().build()).getNormalizedNode().toByteArray();
NormalizedNodeInputStreamReader reader = new NormalizedNodeInputStreamReader(
- new ByteArrayInputStream(protobufBytes));
+ ByteStreams.newDataInput(protobufBytes));
reader.readNormalizedNode();
}
InstanceIdentifierUtils.toSerializable(path)).build().toByteArray();
NormalizedNodeInputStreamReader reader = new NormalizedNodeInputStreamReader(
- new ByteArrayInputStream(protobufBytes));
+ ByteStreams.newDataInput(protobufBytes));
reader.readYangInstanceIdentifier();
}
}
- private String largeString(int pow){
+ private static String largeString(final int pow){
String s = "X";
for(int i=0;i<pow;i++){
StringBuilder b = new StringBuilder();