X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.databoard%2Fsrc%2Forg%2Fsimantics%2Fdataboard%2Fserialization%2Fimpl%2FArraySerializer.java;h=e1038abad4e0f5436b91330887ed672083918043;hb=HEAD;hp=3831882dd7be895e962b59ce72bf21e1813b60f2;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/ArraySerializer.java b/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/ArraySerializer.java
index 3831882dd..e1038abad 100644
--- a/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/ArraySerializer.java
+++ b/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/ArraySerializer.java
@@ -1,245 +1,245 @@
-package org.simantics.databoard.serialization.impl;
-
-import gnu.trove.map.hash.TObjectIntHashMap;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-
-import org.simantics.databoard.binding.ArrayBinding;
-import org.simantics.databoard.binding.Binding;
-import org.simantics.databoard.binding.error.BindingException;
-import org.simantics.databoard.binding.impl.ArrayListBinding;
-import org.simantics.databoard.binding.util.IsReferableQuery;
-import org.simantics.databoard.binding.util.Result;
-import org.simantics.databoard.serialization.SerializationException;
-import org.simantics.databoard.serialization.Serializer;
-import org.simantics.databoard.serialization.Serializer.CompositeSerializer;
-import org.simantics.databoard.type.ArrayType;
-import org.simantics.databoard.util.Range;
-
-public class ArraySerializer extends CompositeSerializer {
-
-	Range length;
-	Integer fixedLength;
-	Integer fixedSize;
-	Integer fixedSizeOfComponent;
-	public Serializer componentSerializer;
-	boolean componentImmutable;
-	ArrayBinding binding;
-	DefaultValueIterator componentValueItr;
-	
-	/**
-	 * 
-	 * @param binding
-	 * @param componentSerializer (optional) can be set after
-	 */
-	public ArraySerializer(ArrayBinding binding, Serializer componentSerializer) {
-		super( IsReferableQuery.isReferable( binding.type() ) != Result.No );
-		ArrayType arrayType = (ArrayType) binding.type();
-		this.componentSerializer = componentSerializer;
-		this.binding = binding;
-		this.length = arrayType.getLength();
-		this.componentImmutable = binding.getComponentBinding().isImmutable();
-		this.componentValueItr = new DefaultValueIterator();
-		componentValueItr.binding = binding.componentBinding;
-	}
-	
-	@Override
-	public void finalizeConstruction() {
-		fixedSizeOfComponent = componentSerializer.getConstantSize();
-		if (fixedSizeOfComponent!=null && length!=null && length.getLower().equals(length.getUpper()) && length.getLower().getValue()!=null)
-		{
-			fixedLength = length.getLower().getValue().intValue();
-			fixedSize = fixedLength * fixedSizeOfComponent;
-		}		
-	}
-
-	@Override
-	public Object deserialize(DataInput in, List<Object> identities) throws IOException {
-		try {
-			int length = fixedLength != null ? fixedLength : in.readInt();	
-			if (length<0) throw new SerializationException("Cannot use negative array length");
-			assertRemainingBytes(in, ((long)length)*componentSerializer.getMinSize());			
-
-			ArrayList<Object> temp = new ArrayList<Object>(length);
-			for(int i=0;i<length;++i)
-				temp.add(componentSerializer.deserialize(in, identities));
-			return binding instanceof ArrayListBinding ? temp : binding.create(temp);
-		} catch (BindingException e) {
-			throw new IOException( e ); 
-		}
-	}
-	
-	public Object deserializeToTry(DataInput in, List<Object> identities, Object obj) throws IOException
-	{
-		try {
-			int length = fixedLength != null ? fixedLength : in.readInt();
-			if (length<0) throw new SerializationException("Cannot use negative array length");
-			assertRemainingBytes(in, ((long)length)*componentSerializer.getMinSize());			
-			
-			int oldLen = binding.size(obj);
-			
-			if (oldLen!=length) {
-				if ( binding.isResizable() ) {
-					binding.setSize(obj, length);
-				} else {
-					obj = binding.create(length, componentValueItr);
-					oldLen = length;
-				}
-			}
-			
-			if ( componentImmutable ) {
-				for(int i=0;i<length;i++) {
-					Object component = componentSerializer.deserialize(in, identities);
-					binding.set(obj, i, component);
-				}
-			} else {
-				for(int i=0;i<length;i++) {
-					Object component = binding.get(obj, i);
-					component = componentSerializer.deserializeToTry(in, identities, component);
-					binding.set(obj, i, component); 
-				}
-				if (oldLen>length) binding.setSize(obj, length);				
-			}
-			
-			return obj;
-		} catch (BindingException e) {
-			throw new IOException( e ); 
-		}
-		
-	}	
-
-	@Override
-	public void deserializeTo(DataInput in, List<Object> identities, Object obj) throws IOException {
-		try {
-			int length = fixedLength != null ? fixedLength : in.readInt();
-			if (length<0) throw new SerializationException("Cannot use negative array length");
-			assertRemainingBytes(in, ((long)length)*componentSerializer.getMinSize());			
-			
-			int oldLen = binding.size(obj);
-			
-			if (oldLen!=length) {
-				if ( binding.isResizable() ) {
-					binding.setSize(obj, length);
-				} else {
-					throw new IOException("Cannot resize array");
-				}
-			}
-			
-			if ( componentImmutable ) {
-				for(int i=0;i<length;i++) {
-					Object component = componentSerializer.deserialize(in, identities);
-					binding.set(obj, i, component);
-				}
-			} else {
-				for(int i=0;i<length;i++) {
-					Object component = binding.get(obj, i);
-					component = componentSerializer.deserializeToTry(in, identities, component);
-					binding.set(obj, i, component); 
-				}
-				if (oldLen>length) binding.setSize(obj, length);				
-			}
-		} catch (BindingException e) {
-			throw new IOException( e ); 
-		}		
-	}
-	
-	@Override
-	public void skip(DataInput in, List<Object> identities)
-	throws IOException {
-		if (fixedSize!=null) {
-			in.skipBytes(fixedSize);
-			return;
-		}
-		int length = fixedLength != null ? fixedLength : in.readInt();
-		
-		if (fixedSizeOfComponent!=null) {
-			// Skip all elements
-			in.skipBytes(length * fixedSizeOfComponent);
-		} else {
-			// Skip each element individualy
-			for(int i=0;i<length;++i)
-				componentSerializer.skip(in, identities);
-		}
-	}
-
-	@Override
-	public void serialize(DataOutput out, TObjectIntHashMap<Object> identities, Object obj) throws IOException {
-		try {
-			int length = binding.size(obj);
-			if (fixedLength==null) {
-				out.writeInt(length);
-			} else { 
-				if (length!=fixedLength)
-					throw new SerializationException("Unexpected array length "+length+", size is restricted to "+fixedLength);
-			}
-			
-			// Serialize elements
-			for(int i=0;i<length;++i)
-				componentSerializer.serialize(out, identities, binding.get(obj, i));
-		} catch (BindingException e) {
-			throw new IOException( e ); 
-		}
-	}
-
-	@Override
-	public Integer getConstantSize() {
-		return fixedSize;
-	}
-
-	@Override
-	public int getSize(Object obj, TObjectIntHashMap<Object> identities) throws IOException {
-		try {
-			if (fixedSize!=null) return fixedSize;
-			int length = binding.size(obj);
-			if (fixedSizeOfComponent!=null)
-				return 4 + fixedSizeOfComponent * length;
-			int result = 4;
-			for(int i=0;i<length;++i)
-				result += componentSerializer.getSize(binding.get(obj, i), identities);
-			return result;
-		} catch (BindingException e) {
-			throw new IOException( e ); 
-		}
-	}
-
-	@Override
-	public int getMinSize() {
-		return fixedSize != null ? fixedSize : 4;
-	}
-	
-}
-
-/**
- * Default value iterator iterates default values.
- * The iterator is infinite.
- * 
- * @author toni.kalajainen
- */
-class DefaultValueIterator implements Iterator<Object> {
-	
-	Binding binding;
-
-	@Override
-	public boolean hasNext() {
-		return true;
-	}
-
-	@Override
-	public Object next() {
-		try {
-			return binding.createDefault();
-		} catch (BindingException e) {
-			return null;
-		}
-	}
-
-	@Override
-	public void remove() {
-	}
-	
+package org.simantics.databoard.serialization.impl;
+
+import gnu.trove.map.hash.TObjectIntHashMap;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import org.simantics.databoard.binding.ArrayBinding;
+import org.simantics.databoard.binding.Binding;
+import org.simantics.databoard.binding.error.BindingException;
+import org.simantics.databoard.binding.impl.ArrayListBinding;
+import org.simantics.databoard.binding.util.IsReferableQuery;
+import org.simantics.databoard.binding.util.Result;
+import org.simantics.databoard.serialization.SerializationException;
+import org.simantics.databoard.serialization.Serializer;
+import org.simantics.databoard.serialization.Serializer.CompositeSerializer;
+import org.simantics.databoard.type.ArrayType;
+import org.simantics.databoard.util.Range;
+
+public class ArraySerializer extends CompositeSerializer {
+
+	Range length;
+	Integer fixedLength;
+	Integer fixedSize;
+	Integer fixedSizeOfComponent;
+	public Serializer componentSerializer;
+	boolean componentImmutable;
+	ArrayBinding binding;
+	DefaultValueIterator componentValueItr;
+	
+	/**
+	 * 
+	 * @param binding
+	 * @param componentSerializer (optional) can be set after
+	 */
+	public ArraySerializer(ArrayBinding binding, Serializer componentSerializer) {
+		super( IsReferableQuery.isReferable( binding.type() ) != Result.No );
+		ArrayType arrayType = (ArrayType) binding.type();
+		this.componentSerializer = componentSerializer;
+		this.binding = binding;
+		this.length = arrayType.getLength();
+		this.componentImmutable = binding.getComponentBinding().isImmutable();
+		this.componentValueItr = new DefaultValueIterator();
+		componentValueItr.binding = binding.componentBinding;
+	}
+	
+	@Override
+	public void finalizeConstruction() {
+		fixedSizeOfComponent = componentSerializer.getConstantSize();
+		if (fixedSizeOfComponent!=null && length!=null && length.getLower().equals(length.getUpper()) && length.getLower().getValue()!=null)
+		{
+			fixedLength = length.getLower().getValue().intValue();
+			fixedSize = fixedLength * fixedSizeOfComponent;
+		}		
+	}
+
+	@Override
+	public Object deserialize(DataInput in, List<Object> identities) throws IOException {
+		try {
+			int length = fixedLength != null ? fixedLength : in.readInt();	
+			if (length<0) throw new SerializationException("Cannot use negative array length");
+			assertRemainingBytes(in, ((long)length)*componentSerializer.getMinSize());			
+
+			ArrayList<Object> temp = new ArrayList<Object>(length);
+			for(int i=0;i<length;++i)
+				temp.add(componentSerializer.deserialize(in, identities));
+			return binding instanceof ArrayListBinding ? temp : binding.create(temp);
+		} catch (BindingException e) {
+			throw new IOException( e ); 
+		}
+	}
+	
+	public Object deserializeToTry(DataInput in, List<Object> identities, Object obj) throws IOException
+	{
+		try {
+			int length = fixedLength != null ? fixedLength : in.readInt();
+			if (length<0) throw new SerializationException("Cannot use negative array length");
+			assertRemainingBytes(in, ((long)length)*componentSerializer.getMinSize());			
+			
+			int oldLen = binding.size(obj);
+			
+			if (oldLen!=length) {
+				if ( binding.isResizable() ) {
+					binding.setSize(obj, length);
+				} else {
+					obj = binding.create(length, componentValueItr);
+					oldLen = length;
+				}
+			}
+			
+			if ( componentImmutable ) {
+				for(int i=0;i<length;i++) {
+					Object component = componentSerializer.deserialize(in, identities);
+					binding.set(obj, i, component);
+				}
+			} else {
+				for(int i=0;i<length;i++) {
+					Object component = binding.get(obj, i);
+					component = componentSerializer.deserializeToTry(in, identities, component);
+					binding.set(obj, i, component); 
+				}
+				if (oldLen>length) binding.setSize(obj, length);				
+			}
+			
+			return obj;
+		} catch (BindingException e) {
+			throw new IOException( e ); 
+		}
+		
+	}	
+
+	@Override
+	public void deserializeTo(DataInput in, List<Object> identities, Object obj) throws IOException {
+		try {
+			int length = fixedLength != null ? fixedLength : in.readInt();
+			if (length<0) throw new SerializationException("Cannot use negative array length");
+			assertRemainingBytes(in, ((long)length)*componentSerializer.getMinSize());			
+			
+			int oldLen = binding.size(obj);
+			
+			if (oldLen!=length) {
+				if ( binding.isResizable() ) {
+					binding.setSize(obj, length);
+				} else {
+					throw new IOException("Cannot resize array");
+				}
+			}
+			
+			if ( componentImmutable ) {
+				for(int i=0;i<length;i++) {
+					Object component = componentSerializer.deserialize(in, identities);
+					binding.set(obj, i, component);
+				}
+			} else {
+				for(int i=0;i<length;i++) {
+					Object component = binding.get(obj, i);
+					component = componentSerializer.deserializeToTry(in, identities, component);
+					binding.set(obj, i, component); 
+				}
+				if (oldLen>length) binding.setSize(obj, length);				
+			}
+		} catch (BindingException e) {
+			throw new IOException( e ); 
+		}		
+	}
+	
+	@Override
+	public void skip(DataInput in, List<Object> identities)
+	throws IOException {
+		if (fixedSize!=null) {
+			in.skipBytes(fixedSize);
+			return;
+		}
+		int length = fixedLength != null ? fixedLength : in.readInt();
+		
+		if (fixedSizeOfComponent!=null) {
+			// Skip all elements
+			in.skipBytes(length * fixedSizeOfComponent);
+		} else {
+			// Skip each element individualy
+			for(int i=0;i<length;++i)
+				componentSerializer.skip(in, identities);
+		}
+	}
+
+	@Override
+	public void serialize(DataOutput out, TObjectIntHashMap<Object> identities, Object obj) throws IOException {
+		try {
+			int length = binding.size(obj);
+			if (fixedLength==null) {
+				out.writeInt(length);
+			} else { 
+				if (length!=fixedLength)
+					throw new SerializationException("Unexpected array length "+length+", size is restricted to "+fixedLength);
+			}
+			
+			// Serialize elements
+			for(int i=0;i<length;++i)
+				componentSerializer.serialize(out, identities, binding.get(obj, i));
+		} catch (BindingException e) {
+			throw new IOException( e ); 
+		}
+	}
+
+	@Override
+	public Integer getConstantSize() {
+		return fixedSize;
+	}
+
+	@Override
+	public int getSize(Object obj, TObjectIntHashMap<Object> identities) throws IOException {
+		try {
+			if (fixedSize!=null) return fixedSize;
+			int length = binding.size(obj);
+			if (fixedSizeOfComponent!=null)
+				return 4 + fixedSizeOfComponent * length;
+			int result = 4;
+			for(int i=0;i<length;++i)
+				result += componentSerializer.getSize(binding.get(obj, i), identities);
+			return result;
+		} catch (BindingException e) {
+			throw new IOException( e ); 
+		}
+	}
+
+	@Override
+	public int getMinSize() {
+		return fixedSize != null ? fixedSize : 4;
+	}
+	
+}
+
+/**
+ * Default value iterator iterates default values.
+ * The iterator is infinite.
+ * 
+ * @author toni.kalajainen
+ */
+class DefaultValueIterator implements Iterator<Object> {
+	
+	Binding binding;
+
+	@Override
+	public boolean hasNext() {
+		return true;
+	}
+
+	@Override
+	public Object next() {
+		try {
+			return binding.createDefault();
+		} catch (BindingException e) {
+			return null;
+		}
+	}
+
+	@Override
+	public void remove() {
+	}
+	
 }
\ No newline at end of file