Dan Smith created GEODE-2130:
--------------------------------
Summary: Serialized data generated by DataSerializer.writeObject
depends on the type of OutputStream
Key: GEODE-2130
URL: https://issues.apache.org/jira/browse/GEODE-2130
Project: Geode
Issue Type: Bug
Components: serialization
Reporter: Dan Smith
I hit this with a simple test using DataSerializer to write and read a java
Serializable object.
The problem I'm seeing is that there is a difference in the serialized form of
an object depending on whether DataSerializer is passed an ObjectInputStream or
just a DataInputStream.
With ObjectInputStream DataSerializer.writeObject just calls writeObject on the
underlying ObjectInputStream. With DataInputStream, DataSerializer constructs a
new ObjectInputStream.
The problem is that the constructor for ObjectInputStream actually writes two
shorts to the stream. So the serialized form may or may not include those two
shorts.
DataSerializer.writeObject expects to read those two shorts, because it
constructs a DSObjectInputStream unless the input is already a
DSObjectInputStream.
Because of that, just writing and reading an object and result in an
EOFException:
{noformat}
java.io.EOFException
at
java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2353)
at
java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2822)
at
java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804)
at java.io.ObjectInputStream.<init>(ObjectInputStream.java:301)
at
org.apache.geode.internal.InternalDataSerializer$DSObjectInputStream.<init>(InternalDataSerializer.java:3583)
at
org.apache.geode.internal.InternalDataSerializer.basicReadObject(InternalDataSerializer.java:2988)
at org.apache.geode.DataSerializer.readObject(DataSerializer.java:3281)
at DataSerializerJUnitTest.test(DataSerializerJUnitTest.java:20)
{noformat}
Here's a simple test of this issue:
{code}
import org.apache.geode.DataSerializer;
import org.junit.Test;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.Serializable;
public class DataSerializerJUnitTest {
@Test
public void test() throws IOException, ClassNotFoundException {
final ByteArrayOutputStream byteArrayOutputStream = new
ByteArrayOutputStream();
ObjectOutputStream out = new ObjectOutputStream(byteArrayOutputStream);
DataSerializer.writeObject(new MyObject(), out);
out.close();
ObjectInputStream in = new ObjectInputStream(new
ByteArrayInputStream(byteArrayOutputStream.toByteArray()));
final Object object = DataSerializer.readObject(in);
}
private static class MyObject implements Serializable {
}
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
