--- /dev/null
+package org.simantics.databoard.serialization.impl;\r
+\r
+import java.io.DataInput;\r
+import java.io.DataOutput;\r
+import java.io.IOException;\r
+import java.util.List;\r
+\r
+import org.simantics.databoard.binding.ArrayBinding;\r
+import org.simantics.databoard.binding.error.BindingException;\r
+import org.simantics.databoard.serialization.SerializationException;\r
+import org.simantics.databoard.serialization.Serializer.NonRecursiveSerializer;\r
+import org.simantics.databoard.type.ArrayType;\r
+import org.simantics.databoard.util.Range;\r
+\r
+public class ByteArraySerializer extends NonRecursiveSerializer {\r
+\r
+ Range length;\r
+ Integer fixedLength, fixedSize;\r
+ \r
+ public ByteArraySerializer(ArrayBinding binding)\r
+ {\r
+ ArrayType arrayType = (ArrayType) binding.type();\r
+ this.length = arrayType.getLength();\r
+ if (length!=null && length.getLower().equals(length.getUpper()) && length.getLower().getValue()!=null)\r
+ {\r
+ fixedLength = length.getLower().getValue().intValue();\r
+ fixedSize = fixedLength * 1;\r
+ }\r
+ }\r
+ \r
+ @Override\r
+ public Object deserialize(DataInput in)\r
+ throws IOException \r
+ {\r
+ int length = fixedSize != null ? fixedLength : in.readInt();\r
+ if (length<0) throw new SerializationException("Cannot use negative array length");\r
+ assertRemainingBytes(in, length); \r
+ \r
+ byte[] array = new byte[length];\r
+ in.readFully(array);\r
+ return array;\r
+ }\r
+ \r
+ @Override\r
+ public void deserializeTo(DataInput in, Object obj) throws IOException {\r
+ try {\r
+ int length = fixedLength != null ? fixedLength : in.readInt(); \r
+ byte[] array = (byte[]) obj;\r
+ if (length!=array.length) throw new BindingException("primitive array is size immutable");\r
+ assertRemainingBytes(in, length); \r
+ in.readFully(array);\r
+ } catch (BindingException e) {\r
+ throw new IOException( e ); \r
+ }\r
+ }\r
+ \r
+ public Object deserializeToTry(DataInput in, List<Object> identities, Object obj) throws IOException\r
+ {\r
+ int length = fixedLength != null ? fixedLength : in.readInt();\r
+ byte[] array = (byte[]) obj;\r
+ if (length!=array.length) obj = new byte[ length ];\r
+ assertRemainingBytes(in, length); \r
+ in.readFully(array); \r
+ return array;\r
+ }\r
+\r
+ @Override\r
+ public void skip(DataInput in)\r
+ throws IOException {\r
+ int length = fixedSize != null ? fixedLength : in.readInt(); \r
+ in.skipBytes( length );\r
+ }\r
+ \r
+ @Override\r
+ public void serialize(DataOutput out, Object obj)\r
+ throws IOException \r
+ {\r
+ byte[] array = (byte[])obj;\r
+ if (fixedSize==null) \r
+ out.writeInt(array.length);\r
+ out.write(array);\r
+ }\r
+\r
+ @Override\r
+ public Integer getConstantSize() {\r
+ return fixedSize;\r
+ }\r
+\r
+ @Override\r
+ public int getSize(Object obj) {\r
+ if (fixedSize!=null) return fixedSize;\r
+ byte[] array = (byte[])obj; \r
+ return 4 + array.length;\r
+ }\r
+ \r
+ @Override\r
+ public int getMinSize() {\r
+ return fixedSize != null ? fixedSize : 4;\r
+ }\r
+ \r
+}
\ No newline at end of file