X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.databoard%2Fsrc%2Forg%2Fsimantics%2Fdataboard%2Faccessor%2Fbinary%2FBinaryByte.java;h=eb8b5039f3cb002c61ea51287d2ff779cc26f20f;hb=e81aaf01a022b7f9fd54924f843a8f8594682126;hp=e83a9a25301793f9cd219cb40016828af2a989f3;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.databoard/src/org/simantics/databoard/accessor/binary/BinaryByte.java b/bundles/org.simantics.databoard/src/org/simantics/databoard/accessor/binary/BinaryByte.java index e83a9a253..eb8b5039f 100644 --- a/bundles/org.simantics.databoard/src/org/simantics/databoard/accessor/binary/BinaryByte.java +++ b/bundles/org.simantics.databoard/src/org/simantics/databoard/accessor/binary/BinaryByte.java @@ -1,36 +1,36 @@ -/******************************************************************************* - * Copyright (c) 2010 Association for Decentralized Information Management in - * Industry THTH ry. - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * which accompanies this distribution, and is available at - * http://www.eclipse.org/legal/epl-v10.html - * - * Contributors: - * VTT Technical Research Centre of Finland - initial API and implementation - *******************************************************************************/ +/******************************************************************************* + * Copyright (c) 2010 Association for Decentralized Information Management in + * Industry THTH ry. + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * which accompanies this distribution, and is available at + * http://www.eclipse.org/legal/epl-v10.html + * + * Contributors: + * VTT Technical Research Centre of Finland - initial API and implementation + *******************************************************************************/ package org.simantics.databoard.accessor.binary; -import java.io.IOException; - -import org.simantics.databoard.Bindings; -import org.simantics.databoard.accessor.Accessor; -import org.simantics.databoard.accessor.ByteAccessor; -import org.simantics.databoard.accessor.error.AccessorConstructionException; -import org.simantics.databoard.accessor.error.AccessorException; -import org.simantics.databoard.accessor.error.ReferenceException; -import org.simantics.databoard.accessor.event.Event; -import org.simantics.databoard.accessor.event.ValueAssigned; -import org.simantics.databoard.accessor.file.FileByteAccessor; -import org.simantics.databoard.accessor.impl.AccessorParams; -import org.simantics.databoard.accessor.impl.ListenerEntry; -import org.simantics.databoard.accessor.interestset.ByteInterestSet; -import org.simantics.databoard.accessor.reference.ChildReference; -import org.simantics.databoard.binding.Binding; -import org.simantics.databoard.binding.ByteBinding; -import org.simantics.databoard.binding.error.BindingException; -import org.simantics.databoard.type.ByteType; -import org.simantics.databoard.util.binary.Blob; +import java.io.IOException; + +import org.simantics.databoard.Bindings; +import org.simantics.databoard.accessor.Accessor; +import org.simantics.databoard.accessor.ByteAccessor; +import org.simantics.databoard.accessor.error.AccessorConstructionException; +import org.simantics.databoard.accessor.error.AccessorException; +import org.simantics.databoard.accessor.error.ReferenceException; +import org.simantics.databoard.accessor.event.Event; +import org.simantics.databoard.accessor.event.ValueAssigned; +import org.simantics.databoard.accessor.file.FileByteAccessor; +import org.simantics.databoard.accessor.impl.AccessorParams; +import org.simantics.databoard.accessor.impl.ListenerEntry; +import org.simantics.databoard.accessor.interestset.ByteInterestSet; +import org.simantics.databoard.accessor.reference.ChildReference; +import org.simantics.databoard.binding.Binding; +import org.simantics.databoard.binding.ByteBinding; +import org.simantics.databoard.binding.error.BindingException; +import org.simantics.databoard.type.ByteType; +import org.simantics.databoard.util.binary.Blob; public class BinaryByte extends BinaryObject implements ByteAccessor, FileByteAccessor { @@ -50,29 +50,29 @@ public class BinaryByte extends BinaryObject implements ByteAccessor, FileByteAc } @Override - public byte getValue() throws AccessorException { - assert b.isOpen(); + public byte getValue() throws AccessorException { + assert b.isOpen(); readLock(); try { b.position(0L); return b.readByte(); } catch (IOException e) { throw new AccessorException(e); - } finally { - readUnlock(); + } finally { + readUnlock(); } } @Override Event applyLocal(Event e, boolean makeRollback) throws AccessorException { - Event rollback = makeRollback ? new ValueAssigned( Bindings.BYTE, getValue() ) : null; - if (e instanceof ValueAssigned) { - ValueAssigned va = (ValueAssigned) e; - if (va.newValue == null) throw new AccessorException("Byte value expected, got null"); - setValueNoflush(va.newValue.getBinding(), va.newValue.getValue()); - return rollback; - } else { - throw new AccessorException("Cannot apply "+e.getClass().getName()+" to Byte"); + Event rollback = makeRollback ? new ValueAssigned( Bindings.BYTE, getValue() ) : null; + if (e instanceof ValueAssigned) { + ValueAssigned va = (ValueAssigned) e; + if (va.newValue == null) throw new AccessorException("Byte value expected, got null"); + setValueNoflush(va.newValue.getBinding(), va.newValue.getValue()); + return rollback; + } else { + throw new AccessorException("Cannot apply "+e.getClass().getName()+" to Byte"); } } @@ -85,7 +85,7 @@ public class BinaryByte extends BinaryObject implements ByteAccessor, FileByteAc } @Override - public Object getValue(Binding binding) throws AccessorException { + public Object getValue(Binding binding) throws AccessorException { try { ByteBinding bb = (ByteBinding) binding; byte v = getValue(); @@ -95,8 +95,8 @@ public class BinaryByte extends BinaryObject implements ByteAccessor, FileByteAc } } - public void setValueNoflush(byte newValue) throws AccessorException { - assert b.isOpen(); + public void setValueNoflush(byte newValue) throws AccessorException { + assert b.isOpen(); writeLock(); try { // Set value @@ -116,21 +116,21 @@ public class BinaryByte extends BinaryObject implements ByteAccessor, FileByteAc } catch (IOException e) { throw new AccessorException(e); - } finally { - writeUnlock(); + } finally { + writeUnlock(); } } @Override - public void setValue(byte newValue) throws AccessorException { - assert b.isOpen(); + public void setValue(byte newValue) throws AccessorException { + assert b.isOpen(); writeLock(); try { setValueNoflush(newValue); b.flush(); } catch (IOException e) { throw new AccessorException(e); - } finally { - writeUnlock(); + } finally { + writeUnlock(); } }