X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.databoard%2Fsrc%2Forg%2Fsimantics%2Fdataboard%2Fserialization%2Fimpl%2FUTF8StringSerializer.java;h=20dc08c91db76ef2498db65a7c7e38af001d83e1;hb=HEAD;hp=11b938571444184b0212420c059d5d0bd213cf77;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/UTF8StringSerializer.java b/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/UTF8StringSerializer.java index 11b938571..20dc08c91 100644 --- a/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/UTF8StringSerializer.java +++ b/bundles/org.simantics.databoard/src/org/simantics/databoard/serialization/impl/UTF8StringSerializer.java @@ -1,91 +1,91 @@ -package org.simantics.databoard.serialization.impl; - -import java.io.DataInput; -import java.io.DataOutput; -import java.io.IOException; - -import org.simantics.databoard.binding.StringBinding; -import org.simantics.databoard.binding.error.BindingException; -import org.simantics.databoard.serialization.Serializer.NonRecursiveSerializer; -import org.simantics.databoard.util.binary.Endian; -import org.simantics.databoard.util.binary.UTF8; - -/** - * Serializes Strings to UTF8 strings - * - * @author Toni Kalajainen - */ -public class UTF8StringSerializer extends NonRecursiveSerializer { - - - StringBinding binding; - - public UTF8StringSerializer(StringBinding binding) { - this.binding = binding; - } - - @Override - public Object deserialize(DataInput in) throws IOException { - try { - int length = Endian.readDynamicUInt32(in); - assertRemainingBytes(in, length); - String str = UTF8.readUTF(in, length); - return binding.create(str); - } catch (BindingException e) { - throw new IOException( e ); - } - } - - @Override - public void deserializeTo(DataInput in, Object obj) throws IOException { - try { - int length = Endian.readDynamicUInt32(in); - assertRemainingBytes(in, length); - String str = UTF8.readUTF(in, length); - binding.setValue(obj, str); - } catch (BindingException e) { - throw new IOException( e ); - } - } - - @Override - public void skip(DataInput in) throws IOException { - int length = Endian.readDynamicUInt32(in); - in.skipBytes(length); - } - - @Override - public void serialize(DataOutput out, Object obj) throws IOException { - try { - byte[] bytes = binding.getValue(obj).getBytes(UTF8.CHARSET); - Endian.writeDynamicUInt32(out, bytes.length); - out.write(bytes); - } catch (BindingException e) { - throw new IOException( e ); - } - } - - @Override - public Integer getConstantSize() { - return null; - } - - @Override - public int getSize(Object obj) throws IOException { - try { - String string = binding.getValue(obj); - int stringByteLength = UTF8.getUTF8EncodingByteLength( string ); - int lengthLength = Endian.getDynamicUInt32Length( stringByteLength ); - return lengthLength + stringByteLength; - } catch (BindingException e) { - throw new IOException( e ); - } - } - - @Override - public int getMinSize() { - return 1; - } - -} - +package org.simantics.databoard.serialization.impl; + +import java.io.DataInput; +import java.io.DataOutput; +import java.io.IOException; + +import org.simantics.databoard.binding.StringBinding; +import org.simantics.databoard.binding.error.BindingException; +import org.simantics.databoard.serialization.Serializer.NonRecursiveSerializer; +import org.simantics.databoard.util.binary.Endian; +import org.simantics.databoard.util.binary.UTF8; + +/** + * Serializes Strings to UTF8 strings + * + * @author Toni Kalajainen + */ +public class UTF8StringSerializer extends NonRecursiveSerializer { + + + StringBinding binding; + + public UTF8StringSerializer(StringBinding binding) { + this.binding = binding; + } + + @Override + public Object deserialize(DataInput in) throws IOException { + try { + int length = Endian.readDynamicUInt32(in); + assertRemainingBytes(in, length); + String str = UTF8.readUTF(in, length); + return binding.create(str); + } catch (BindingException e) { + throw new IOException( e ); + } + } + + @Override + public void deserializeTo(DataInput in, Object obj) throws IOException { + try { + int length = Endian.readDynamicUInt32(in); + assertRemainingBytes(in, length); + String str = UTF8.readUTF(in, length); + binding.setValue(obj, str); + } catch (BindingException e) { + throw new IOException( e ); + } + } + + @Override + public void skip(DataInput in) throws IOException { + int length = Endian.readDynamicUInt32(in); + in.skipBytes(length); + } + + @Override + public void serialize(DataOutput out, Object obj) throws IOException { + try { + byte[] bytes = binding.getValue(obj).getBytes(UTF8.CHARSET); + Endian.writeDynamicUInt32(out, bytes.length); + out.write(bytes); + } catch (BindingException e) { + throw new IOException( e ); + } + } + + @Override + public Integer getConstantSize() { + return null; + } + + @Override + public int getSize(Object obj) throws IOException { + try { + String string = binding.getValue(obj); + int stringByteLength = UTF8.getUTF8EncodingByteLength( string ); + int lengthLength = Endian.getDynamicUInt32Length( stringByteLength ); + return lengthLength + stringByteLength; + } catch (BindingException e) { + throw new IOException( e ); + } + } + + @Override + public int getMinSize() { + return 1; + } + +} +