You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directmemory.apache.org by no...@apache.org on 2012/11/02 20:49:40 UTC
svn commit: r1405128 [1/2] - in
/directmemory/lightning/trunk/lightning-core/src:
main/java/org/apache/directmemory/lightning/
main/java/org/apache/directmemory/lightning/io/
test/java/org/apache/directmemory/lightning/
test/java/org/apache/directmemor...
Author: noctarius
Date: Fri Nov 2 19:49:39 2012
New Revision: 1405128
URL: http://svn.apache.org/viewvc?rev=1405128&view=rev
Log:
Changed unittests according to the new Source / Target interfaces and introduced a reworked version of SerializerInputStream / SerializerOutputStream
Added:
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerInputStream.java
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerOutputStream.java
Modified:
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Source.java
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Target.java
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferSource.java
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferTarget.java
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/InputStreamSource.java
directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/OutputStreamTarget.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/Benchmark.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/ComplexClassHierarchyTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/GenericTypedTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/PropertyFinderTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/WhatShouldItLookLike.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ArrayMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigDecimalMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigIntegerMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BooleanMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ByteMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/CharacterMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/DoubleMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/FloatMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/IntegerMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ListMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/LongMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/MapMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/SetMarshallerTestCase.java
directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ShortMarshallerTestCase.java
Modified: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Source.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Source.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Source.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Source.java Fri Nov 2 19:49:39 2012
@@ -28,9 +28,6 @@ public interface Source
long readableBytes();
- boolean readBoolean()
- throws IOException;
-
int readBytes( byte[] bytes )
throws IOException;
Modified: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Target.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Target.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Target.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/Target.java Fri Nov 2 19:49:39 2012
@@ -28,9 +28,6 @@ public interface Target
long writtenBytes();
- void writeBoolean( boolean value )
- throws IOException;
-
void writeBytes( byte[] bytes )
throws IOException;
Modified: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferSource.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferSource.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferSource.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferSource.java Fri Nov 2 19:49:39 2012
@@ -31,13 +31,6 @@ public class ByteBufferSource
}
@Override
- public boolean readBoolean()
- throws IOException
- {
- return readByte() == 1 ? true : false;
- }
-
- @Override
public int readBytes( byte[] bytes )
throws IOException
{
Modified: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferTarget.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferTarget.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferTarget.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/ByteBufferTarget.java Fri Nov 2 19:49:39 2012
@@ -30,13 +30,6 @@ public class ByteBufferTarget
}
@Override
- public void writeBoolean( boolean value )
- throws IOException
- {
- writeByte( (byte) ( value ? 1 : 0 ) );
- }
-
- @Override
public void writeBytes( byte[] bytes )
throws IOException
{
Modified: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/InputStreamSource.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/InputStreamSource.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/InputStreamSource.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/InputStreamSource.java Fri Nov 2 19:49:39 2012
@@ -65,13 +65,6 @@ public class InputStreamSource
}
@Override
- public boolean readBoolean()
- throws IOException
- {
- return readByte() == 1 ? true : false;
- }
-
- @Override
public int readBytes( byte[] bytes )
throws IOException
{
Modified: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/OutputStreamTarget.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/OutputStreamTarget.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/OutputStreamTarget.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/OutputStreamTarget.java Fri Nov 2 19:49:39 2012
@@ -41,13 +41,6 @@ public class OutputStreamTarget
}
@Override
- public void writeBoolean( boolean value )
- throws IOException
- {
- writeByte( (byte) ( value ? 1 : 0 ) );
- }
-
- @Override
public void writeBytes( byte[] bytes )
throws IOException
{
Added: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerInputStream.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerInputStream.java?rev=1405128&view=auto
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerInputStream.java (added)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerInputStream.java Fri Nov 2 19:49:39 2012
@@ -0,0 +1,178 @@
+package org.apache.directmemory.lightning.io;
+
+import java.io.IOException;
+import java.io.ObjectInput;
+
+import org.apache.directmemory.lightning.Serializer;
+import org.apache.directmemory.lightning.Source;
+
+public class SerializerInputStream
+ implements ObjectInput
+{
+
+ private final Serializer serializer;
+
+ private final Source source;
+
+ public SerializerInputStream( Serializer serializer, Source source )
+ {
+ this.serializer = serializer;
+ this.source = source;
+ }
+
+ @Override
+ public void readFully( byte[] b )
+ throws IOException
+ {
+ readFully( b, 0, b.length );
+ }
+
+ @Override
+ public void readFully( byte[] b, int off, int len )
+ throws IOException
+ {
+ source.readBytes( b, off, len );
+ }
+
+ @Override
+ public int skipBytes( int n )
+ throws IOException
+ {
+ throw new UnsupportedOperationException( "skipBytes is not implemented in the underlying Source type" );
+ }
+
+ @Override
+ public boolean readBoolean()
+ throws IOException
+ {
+ return source.readBoolean();
+ }
+
+ @Override
+ public byte readByte()
+ throws IOException
+ {
+ return source.readByte();
+ }
+
+ @Override
+ public int readUnsignedByte()
+ throws IOException
+ {
+ return source.readUnsignedByte();
+ }
+
+ @Override
+ public short readShort()
+ throws IOException
+ {
+ return source.readShort();
+ }
+
+ @Override
+ public int readUnsignedShort()
+ throws IOException
+ {
+ return (char) ( ( ( source.readByte() & 0x000000FF ) << 8 ) | ( source.readByte() & 0x000000FF ) );
+ }
+
+ @Override
+ public char readChar()
+ throws IOException
+ {
+ return source.readChar();
+ }
+
+ @Override
+ public int readInt()
+ throws IOException
+ {
+ return source.readInt();
+ }
+
+ @Override
+ public long readLong()
+ throws IOException
+ {
+ return source.readLong();
+ }
+
+ @Override
+ public float readFloat()
+ throws IOException
+ {
+ return source.readFloat();
+ }
+
+ @Override
+ public double readDouble()
+ throws IOException
+ {
+ return source.readDouble();
+ }
+
+ @Override
+ public String readLine()
+ throws IOException
+ {
+ return readUTF();
+ }
+
+ @Override
+ public String readUTF()
+ throws IOException
+ {
+ return source.readString();
+ }
+
+ @Override
+ public Object readObject()
+ throws ClassNotFoundException, IOException
+ {
+ return serializer.deserialize( source );
+ }
+
+ @Override
+ public int read()
+ throws IOException
+ {
+ return 0;
+ }
+
+ @Override
+ public int read( byte[] b )
+ throws IOException
+ {
+ // TODO Auto-generated method stub
+ return 0;
+ }
+
+ @Override
+ public int read( byte[] b, int off, int len )
+ throws IOException
+ {
+ return source.readByte();
+ }
+
+ @Override
+ public long skip( long n )
+ throws IOException
+ {
+ throw new UnsupportedOperationException( "skip is not implemented in the underlying Source type" );
+ }
+
+ @Override
+ public int available()
+ throws IOException
+ {
+ return (int) source.readableBytes();
+ }
+
+ @Override
+ public void close()
+ throws IOException
+ {
+ // nothing to implement here
+ }
+
+}
Added: directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerOutputStream.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerOutputStream.java?rev=1405128&view=auto
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerOutputStream.java (added)
+++ directmemory/lightning/trunk/lightning-core/src/main/java/org/apache/directmemory/lightning/io/SerializerOutputStream.java Fri Nov 2 19:49:39 2012
@@ -0,0 +1,146 @@
+package org.apache.directmemory.lightning.io;
+
+import java.io.IOException;
+import java.io.ObjectOutput;
+
+import org.apache.directmemory.lightning.Serializer;
+import org.apache.directmemory.lightning.Target;
+
+public class SerializerOutputStream
+ implements ObjectOutput
+{
+
+ private final Serializer serializer;
+
+ private final Target target;
+
+ public SerializerOutputStream( Serializer serializer, Target target )
+ {
+ this.serializer = serializer;
+ this.target = target;
+ }
+
+ @Override
+ public void write( int b )
+ throws IOException
+ {
+ target.writeByte( (byte) b );
+ }
+
+ @Override
+ public void writeBoolean( boolean v )
+ throws IOException
+ {
+ target.writeBoolean( v );
+ }
+
+ @Override
+ public void writeByte( int v )
+ throws IOException
+ {
+ target.writeByte( (byte) v );
+ }
+
+ @Override
+ public void writeShort( int v )
+ throws IOException
+ {
+ target.writeShort( (short) v );
+ }
+
+ @Override
+ public void writeChar( int v )
+ throws IOException
+ {
+ target.writeChar( (char) v );
+ }
+
+ @Override
+ public void writeInt( int v )
+ throws IOException
+ {
+ target.writeInt( v );
+ }
+
+ @Override
+ public void writeLong( long v )
+ throws IOException
+ {
+ target.writeLong( v );
+ }
+
+ @Override
+ public void writeFloat( float v )
+ throws IOException
+ {
+ target.writeFloat( v );
+ }
+
+ @Override
+ public void writeDouble( double v )
+ throws IOException
+ {
+ target.writeDouble( v );
+ }
+
+ @Override
+ public void writeBytes( String s )
+ throws IOException
+ {
+ target.writeString( s );
+ }
+
+ @Override
+ public void writeChars( String s )
+ throws IOException
+ {
+ char[] chars = s.toCharArray();
+ for ( int i = 0; i < chars.length; i++ )
+ {
+ target.writeChar( chars[i] );
+ }
+ }
+
+ @Override
+ public void writeUTF( String s )
+ throws IOException
+ {
+ target.writeString( s );
+ }
+
+ @Override
+ public void writeObject( Object obj )
+ throws IOException
+ {
+ serializer.serialize( obj, target );
+ }
+
+ @Override
+ public void write( byte[] b )
+ throws IOException
+ {
+ write( b, 0, b.length );
+ }
+
+ @Override
+ public void write( byte[] b, int off, int len )
+ throws IOException
+ {
+ target.writeBytes( b, off, len );
+ }
+
+ @Override
+ public void flush()
+ throws IOException
+ {
+ // nothing to implement here
+ }
+
+ @Override
+ public void close()
+ throws IOException
+ {
+ // nothing to implement here
+ }
+
+}
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/Benchmark.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/Benchmark.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/Benchmark.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/Benchmark.java Fri Nov 2 19:49:39 2012
@@ -23,8 +23,6 @@ import static org.junit.Assert.assertNot
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
-import java.io.DataInput;
-import java.io.DataOutput;
import java.io.File;
import java.io.IOException;
import java.io.ObjectInputStream;
@@ -33,11 +31,10 @@ import java.io.Serializable;
import java.util.Random;
import java.util.concurrent.TimeUnit;
-import org.apache.directmemory.lightning.Lightning;
-import org.apache.directmemory.lightning.SerializationContext;
-import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractObjectMarshaller;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.io.SerializerInputStream;
import org.apache.directmemory.lightning.io.SerializerOutputStream;
import org.apache.directmemory.lightning.metadata.Attribute;
@@ -67,7 +64,8 @@ public class Benchmark
for ( int i = 0; i < WARMUP_ROUNDS; i++ )
{
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Foo foo = buildRandomFoo();
out.writeObject( foo );
@@ -92,7 +90,8 @@ public class Benchmark
long startTime = System.nanoTime();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( foo );
time += System.nanoTime() - startTime;
@@ -126,7 +125,8 @@ public class Benchmark
for ( int i = 0; i < WARMUP_ROUNDS; i++ )
{
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Foo foo = buildRandomFoo();
out.writeObject( foo );
@@ -136,7 +136,8 @@ public class Benchmark
size = baos.toByteArray().length;
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( foo, value );
@@ -156,12 +157,14 @@ public class Benchmark
Foo foo = buildRandomFoo();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( foo );
long startTime = System.nanoTime();
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
time += System.nanoTime() - startTime;
assertNotNull( value );
@@ -480,14 +483,14 @@ public class Benchmark
}
@Override
- public void marshall( Object value, PropertyDescriptor propertyDescriptor, DataOutput dataOutput,
+ public void marshall( Object value, PropertyDescriptor propertyDescriptor, Target target,
SerializationContext serializationContext )
throws IOException
{
}
@Override
- public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, DataInput dataInput,
+ public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, Source source,
SerializationContext serializationContext )
throws IOException
{
@@ -507,14 +510,14 @@ public class Benchmark
}
@Override
- public void marshall( Object value, PropertyDescriptor propertyDescriptor, DataOutput dataOutput,
+ public void marshall( Object value, PropertyDescriptor propertyDescriptor, Target target,
SerializationContext serializationContext )
throws IOException
{
}
@Override
- public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, DataInput dataInput,
+ public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, Source source,
SerializationContext serializationContext )
throws IOException
{
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/ComplexClassHierarchyTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/ComplexClassHierarchyTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/ComplexClassHierarchyTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/ComplexClassHierarchyTestCase.java Fri Nov 2 19:49:39 2012
@@ -25,10 +25,10 @@ import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
-import org.apache.directmemory.lightning.Lightning;
-import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.io.SerializerInputStream;
import org.apache.directmemory.lightning.io.SerializerOutputStream;
import org.apache.directmemory.lightning.metadata.Attribute;
@@ -57,7 +57,8 @@ public class ComplexClassHierarchyTestCa
foo.setName( "SomeName" );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( foo );
assertNotNull( baos );
@@ -65,7 +66,8 @@ public class ComplexClassHierarchyTestCa
assertNotNull( baos.toByteArray() );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( foo, value );
@@ -94,7 +96,8 @@ public class ComplexClassHierarchyTestCa
complex.setBar( Bar.SomeOtherValue );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( complex );
assertNotNull( baos );
@@ -102,7 +105,8 @@ public class ComplexClassHierarchyTestCa
assertNotNull( baos.toByteArray() );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( complex, value );
@@ -131,7 +135,8 @@ public class ComplexClassHierarchyTestCa
complex.setBar( Bar.SomeOtherValue );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( complex );
assertNotNull( baos );
@@ -139,7 +144,8 @@ public class ComplexClassHierarchyTestCa
assertNotNull( baos.toByteArray() );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( complex, value );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/GenericTypedTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/GenericTypedTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/GenericTypedTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/GenericTypedTestCase.java Fri Nov 2 19:49:39 2012
@@ -27,9 +27,9 @@ import java.io.File;
import java.io.PrintStream;
import java.util.List;
-import org.apache.directmemory.lightning.Lightning;
-import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.io.SerializerInputStream;
import org.apache.directmemory.lightning.io.SerializerOutputStream;
import org.apache.directmemory.lightning.logging.LogLevel;
@@ -60,7 +60,8 @@ public class GenericTypedTestCase
// foo.setName("SomeName");
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( foo );
assertNotNull( baos );
@@ -68,7 +69,8 @@ public class GenericTypedTestCase
assertNotNull( baos.toByteArray() );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( foo, value );
@@ -97,7 +99,8 @@ public class GenericTypedTestCase
complex.setBar( Bar.SomeOtherValue );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( complex );
assertNotNull( baos );
@@ -105,7 +108,8 @@ public class GenericTypedTestCase
assertNotNull( baos.toByteArray() );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( complex, value );
@@ -134,7 +138,8 @@ public class GenericTypedTestCase
complex.setBar( Bar.SomeOtherValue );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( complex );
assertNotNull( baos );
@@ -142,7 +147,8 @@ public class GenericTypedTestCase
assertNotNull( baos.toByteArray() );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
assertNotNull( value );
assertEquals( complex, value );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/PropertyFinderTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/PropertyFinderTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/PropertyFinderTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/PropertyFinderTestCase.java Fri Nov 2 19:49:39 2012
@@ -25,10 +25,10 @@ import static org.junit.Assert.assertNul
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
-import org.apache.directmemory.lightning.Lightning;
-import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.ClassDescriptorAwareSerializer;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.io.SerializerInputStream;
import org.apache.directmemory.lightning.io.SerializerOutputStream;
import org.apache.directmemory.lightning.metadata.Attribute;
@@ -60,7 +60,8 @@ public class PropertyFinderTestCase
assertEquals( 2, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Standard standard = new Standard();
standard.setValue1( "Foo" );
@@ -68,7 +69,8 @@ public class PropertyFinderTestCase
out.writeObject( standard );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Standard result = (Standard) in.readObject();
@@ -96,7 +98,8 @@ public class PropertyFinderTestCase
assertEquals( 2, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Standard standard = new Standard();
standard.setValue1( "Foo" );
@@ -104,7 +107,8 @@ public class PropertyFinderTestCase
out.writeObject( standard );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Standard result = (Standard) in.readObject();
@@ -132,7 +136,8 @@ public class PropertyFinderTestCase
assertEquals( 2, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Standard standard = new Standard();
standard.setValue1( "Foo" );
@@ -140,7 +145,8 @@ public class PropertyFinderTestCase
out.writeObject( standard );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Standard result = (Standard) in.readObject();
@@ -168,7 +174,8 @@ public class PropertyFinderTestCase
assertEquals( 1, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Standard standard = new Standard();
standard.setValue1( "Foo" );
@@ -176,7 +183,8 @@ public class PropertyFinderTestCase
out.writeObject( standard );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Standard result = (Standard) in.readObject();
@@ -205,7 +213,8 @@ public class PropertyFinderTestCase
assertEquals( 2, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Inherted inherted = new Inherted();
inherted.setValue1( "Foo" );
@@ -215,7 +224,8 @@ public class PropertyFinderTestCase
out.writeObject( inherted );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Inherted result = (Inherted) in.readObject();
@@ -246,7 +256,8 @@ public class PropertyFinderTestCase
assertEquals( 4, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Inherted inherted = new Inherted();
inherted.setValue1( "Foo" );
@@ -256,7 +267,8 @@ public class PropertyFinderTestCase
out.writeObject( inherted );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Standard result = (Standard) in.readObject();
@@ -284,13 +296,15 @@ public class PropertyFinderTestCase
assertEquals( 3, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
Composed composed = new Composed( "Foo", 123, "Bar" );
out.writeObject( composed );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Composed result = (Composed) in.readObject();
@@ -318,7 +332,8 @@ public class PropertyFinderTestCase
assertEquals( 3, classDescriptor.getPropertyDescriptors().size() );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
ComposedInherted composedInherted = new ComposedInherted();
composedInherted.setValue1( "Foo" );
@@ -327,7 +342,8 @@ public class PropertyFinderTestCase
out.writeObject( composedInherted );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
ComposedInherted result = (ComposedInherted) in.readObject();
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/WhatShouldItLookLike.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/WhatShouldItLookLike.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/WhatShouldItLookLike.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/WhatShouldItLookLike.java Fri Nov 2 19:49:39 2012
@@ -20,8 +20,6 @@ package org.apache.directmemory.lightnin
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
-import java.io.DataInput;
-import java.io.DataOutput;
import java.io.IOException;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
@@ -29,16 +27,13 @@ import java.lang.reflect.Type;
import java.util.Arrays;
import java.util.List;
-import org.apache.directmemory.lightning.Lightning;
-import org.apache.directmemory.lightning.MarshallerContext;
-import org.apache.directmemory.lightning.MarshallerStrategy;
-import org.apache.directmemory.lightning.SerializationContext;
-import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractObjectMarshaller;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.configuration.TypeIntrospector;
import org.apache.directmemory.lightning.generator.PropertyDescriptorFactory;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.io.SerializerInputStream;
import org.apache.directmemory.lightning.io.SerializerOutputStream;
import org.apache.directmemory.lightning.metadata.ClassDefinitionContainer;
@@ -48,6 +43,7 @@ public class WhatShouldItLookLike
{
public static void main( String[] args )
+ throws IOException, ClassNotFoundException
{
Serializer serializer2 =
Lightning.newBuilder().logger( new DebugLogger() ).serializerDefinitions( new ExampleSerializerDefinition() ).build();
@@ -72,7 +68,8 @@ public class WhatShouldItLookLike
foo.someOther = 123;
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( foo );
System.out.println( foo );
@@ -80,7 +77,8 @@ public class WhatShouldItLookLike
System.out.println( Arrays.toString( data ) );
ByteArrayInputStream bais = new ByteArrayInputStream( data );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
Object value = in.readObject();
System.out.println( value );
}
@@ -254,14 +252,14 @@ public class WhatShouldItLookLike
}
@Override
- public void marshall( Object value, PropertyDescriptor propertyDescriptor, DataOutput dataOutput,
+ public void marshall( Object value, PropertyDescriptor propertyDescriptor, Target target,
SerializationContext serializationContext )
throws IOException
{
}
@Override
- public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, DataInput dataInput,
+ public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, Source source,
SerializationContext serializationContext )
throws IOException
{
@@ -281,14 +279,14 @@ public class WhatShouldItLookLike
}
@Override
- public void marshall( Object value, PropertyDescriptor propertyDescriptor, DataOutput dataOutput,
+ public void marshall( Object value, PropertyDescriptor propertyDescriptor, Target target,
SerializationContext serializationContext )
throws IOException
{
}
@Override
- public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, DataInput dataInput,
+ public <V> V unmarshall( V value, PropertyDescriptor propertyDescriptor, Source source,
SerializationContext serializationContext )
throws IOException
{
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ArrayMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ArrayMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ArrayMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ArrayMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -30,6 +30,8 @@ import java.util.Random;
import org.apache.directmemory.lightning.Lightning;
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.io.SerializerInputStream;
import org.apache.directmemory.lightning.io.SerializerOutputStream;
import org.apache.directmemory.lightning.metadata.Attribute;
@@ -68,12 +70,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
BooleanArray result = (BooleanArray) in.readObject();
@@ -107,12 +111,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
ByteArray result = (ByteArray) in.readObject();
@@ -146,12 +152,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
CharArray result = (CharArray) in.readObject();
@@ -185,12 +193,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
ShortArray result = (ShortArray) in.readObject();
@@ -224,12 +234,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
IntArray result = (IntArray) in.readObject();
@@ -263,12 +275,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
LongArray result = (LongArray) in.readObject();
@@ -302,12 +316,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
FloatArray result = (FloatArray) in.readObject();
@@ -341,12 +357,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
DoubleArray result = (DoubleArray) in.readObject();
@@ -380,12 +398,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
ObjectArray result = (ObjectArray) in.readObject();
@@ -430,12 +450,14 @@ public class ArrayMarshallerTestCase
}, test.array );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- SerializerOutputStream out = new SerializerOutputStream( baos, serializer );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ SerializerOutputStream out = new SerializerOutputStream( serializer, target );
out.writeObject( test );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- SerializerInputStream in = new SerializerInputStream( bais, serializer );
+ InputStreamSource source = new InputStreamSource( bais );
+ SerializerInputStream in = new SerializerInputStream( serializer, source );
DeepObjectArray result = (DeepObjectArray) in.readObject();
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigDecimalMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigDecimalMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigDecimalMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigDecimalMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -31,6 +31,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -61,10 +63,12 @@ public class BigDecimalMarshallerTestCas
value.setValue3( BigDecimal.valueOf( random.nextLong() ).subtract( BigDecimal.valueOf( random.nextLong() ) ) );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -75,10 +79,12 @@ public class BigDecimalMarshallerTestCas
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -89,10 +95,12 @@ public class BigDecimalMarshallerTestCas
value.setValue3( BigDecimal.valueOf( random.nextLong() ).add( BigDecimal.valueOf( random.nextLong() ) ) );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigIntegerMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigIntegerMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigIntegerMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BigIntegerMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -31,6 +31,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -61,10 +63,12 @@ public class BigIntegerMarshallerTestCas
value.setValue3( BigInteger.valueOf( random.nextLong() ).subtract( BigInteger.valueOf( random.nextLong() ) ) );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -75,10 +79,12 @@ public class BigIntegerMarshallerTestCas
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -89,10 +95,12 @@ public class BigIntegerMarshallerTestCas
value.setValue3( BigInteger.valueOf( random.nextLong() ).add( BigInteger.valueOf( random.nextLong() ) ) );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BooleanMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BooleanMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BooleanMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/BooleanMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -29,6 +29,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -56,10 +58,12 @@ public class BooleanMarshallerTestCase
value.setValue2( false );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -69,10 +73,12 @@ public class BooleanMarshallerTestCase
value.setValue2( true );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -100,10 +106,12 @@ public class BooleanMarshallerTestCase
value.setValue3( false );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -114,10 +122,12 @@ public class BooleanMarshallerTestCase
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -128,10 +138,12 @@ public class BooleanMarshallerTestCase
value.setValue3( false );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ByteMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ByteMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ByteMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/ByteMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -29,6 +29,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -56,10 +58,12 @@ public class ByteMarshallerTestCase
value.setValue2( Byte.MAX_VALUE );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -69,10 +73,12 @@ public class ByteMarshallerTestCase
value.setValue2( (byte) 20 );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -100,10 +106,12 @@ public class ByteMarshallerTestCase
value.setValue3( (byte) 34 );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -114,10 +122,12 @@ public class ByteMarshallerTestCase
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -128,10 +138,12 @@ public class ByteMarshallerTestCase
value.setValue3( Byte.MAX_VALUE );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/CharacterMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/CharacterMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/CharacterMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/CharacterMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -29,6 +29,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -56,10 +58,12 @@ public class CharacterMarshallerTestCase
value.setValue2( Character.MAX_VALUE );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -69,10 +73,12 @@ public class CharacterMarshallerTestCase
value.setValue2( (char) 20 );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -100,10 +106,12 @@ public class CharacterMarshallerTestCase
value.setValue3( (char) 34 );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -114,10 +122,12 @@ public class CharacterMarshallerTestCase
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -128,10 +138,12 @@ public class CharacterMarshallerTestCase
value.setValue3( Character.MAX_VALUE );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/DoubleMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/DoubleMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/DoubleMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/DoubleMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -29,6 +29,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -56,10 +58,12 @@ public class DoubleMarshallerTestCase
value.setValue2( Double.MAX_VALUE );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -69,10 +73,12 @@ public class DoubleMarshallerTestCase
value.setValue2( 20 );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -100,10 +106,12 @@ public class DoubleMarshallerTestCase
value.setValue3( 34D );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -114,10 +122,12 @@ public class DoubleMarshallerTestCase
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -128,10 +138,12 @@ public class DoubleMarshallerTestCase
value.setValue3( Double.MAX_VALUE );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/FloatMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/FloatMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/FloatMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/FloatMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -29,6 +29,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -56,10 +58,12 @@ public class FloatMarshallerTestCase
value.setValue2( Float.MAX_VALUE );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -69,10 +73,12 @@ public class FloatMarshallerTestCase
value.setValue2( 20 );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -100,10 +106,12 @@ public class FloatMarshallerTestCase
value.setValue3( 34F );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -114,10 +122,12 @@ public class FloatMarshallerTestCase
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -128,10 +138,12 @@ public class FloatMarshallerTestCase
value.setValue3( Float.MAX_VALUE );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
Modified: directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/IntegerMarshallerTestCase.java
URL: http://svn.apache.org/viewvc/directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/IntegerMarshallerTestCase.java?rev=1405128&r1=1405127&r2=1405128&view=diff
==============================================================================
--- directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/IntegerMarshallerTestCase.java (original)
+++ directmemory/lightning/trunk/lightning-core/src/test/java/org/apache/directmemory/lightning/internal/marshaller/IntegerMarshallerTestCase.java Fri Nov 2 19:49:39 2012
@@ -29,6 +29,8 @@ import org.apache.directmemory.lightning
import org.apache.directmemory.lightning.Serializer;
import org.apache.directmemory.lightning.base.AbstractSerializerDefinition;
import org.apache.directmemory.lightning.internal.util.DebugLogger;
+import org.apache.directmemory.lightning.io.InputStreamSource;
+import org.apache.directmemory.lightning.io.OutputStreamTarget;
import org.apache.directmemory.lightning.metadata.Attribute;
import org.junit.Test;
@@ -56,10 +58,12 @@ public class IntegerMarshallerTestCase
value.setValue2( Integer.MAX_VALUE );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -69,10 +73,12 @@ public class IntegerMarshallerTestCase
value.setValue2( (short) 20 );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -100,10 +106,12 @@ public class IntegerMarshallerTestCase
value.setValue3( 34 );
ByteArrayOutputStream baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ OutputStreamTarget target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
ByteArrayInputStream bais = new ByteArrayInputStream( baos.toByteArray() );
- Object result = serializer.deserialize( bais );
+ InputStreamSource source = new InputStreamSource( bais );
+ Object result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -114,10 +122,12 @@ public class IntegerMarshallerTestCase
value.setValue3( null );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );
@@ -128,10 +138,12 @@ public class IntegerMarshallerTestCase
value.setValue3( Integer.MAX_VALUE );
baos = new ByteArrayOutputStream();
- serializer.serialize( value, baos );
+ target = new OutputStreamTarget( baos );
+ serializer.serialize( value, target );
bais = new ByteArrayInputStream( baos.toByteArray() );
- result = serializer.deserialize( bais );
+ source = new InputStreamSource( bais );
+ result = serializer.deserialize( source );
assertNotNull( result );
assertEquals( value, result );