X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.objmap2%2Fsrc%2Forg%2Fsimantics%2Fobjmap%2Fgraph%2Frules%2FMappedElementsRule.java;h=fcc62d7b5444e925ad451124eb14bd67c9b02caf;hb=HEAD;hp=202c9abc1f2195a7cc717048accb6a520f87efca;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.objmap2/src/org/simantics/objmap/graph/rules/MappedElementsRule.java b/bundles/org.simantics.objmap2/src/org/simantics/objmap/graph/rules/MappedElementsRule.java index 202c9abc1..fcc62d7b5 100644 --- a/bundles/org.simantics.objmap2/src/org/simantics/objmap/graph/rules/MappedElementsRule.java +++ b/bundles/org.simantics.objmap2/src/org/simantics/objmap/graph/rules/MappedElementsRule.java @@ -1,82 +1,97 @@ -/******************************************************************************* - * Copyright (c) 2007, 2013 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.objmap.graph.rules; - -import java.util.ArrayList; -import java.util.Collection; - -import org.apache.log4j.Logger; -import org.simantics.db.ReadGraph; -import org.simantics.db.WriteGraph; -import org.simantics.objmap.backward.IBackwardMapping; -import org.simantics.objmap.bidirectional.IBidirectionalMappingRule; -import org.simantics.objmap.exceptions.MappingException; -import org.simantics.objmap.forward.IForwardMapping; -import org.simantics.objmap.graph.rules.domain.IDomainAccessor; -import org.simantics.objmap.graph.rules.range.IRangeAccessor; - - -/** - * A rule that synchronizes collection of elements between - * domain and range accessors. Elements are mapped from - * between domain and range during the synchronization. - * @author Hannu Niemistö - */ -public class MappedElementsRule implements IBidirectionalMappingRule { - - static Logger LOGGER = Logger.getLogger("org.simantics.objmap"); - - IDomainAccessor> domainAccessor; - IRangeAccessor> rangeAccessor; - - public MappedElementsRule(IDomainAccessor> domainAccessor, - IRangeAccessor> rangeAccessor) { - this.domainAccessor = domainAccessor; - this.rangeAccessor = rangeAccessor; - } - - @Override - public boolean updateDomain(WriteGraph g, IBackwardMapping map, - Domain domainElement, Range rangeElement) - throws MappingException { - LOGGER.info(" MappedElementsRule.updateDomain"); - // Snapshot the accessed range value for concurrency safety. - // NOTE: still assumes that the accessed collection is concurrent or - // synchronized for toArray to be atomic. - Collection value = rangeAccessor.get(rangeElement); - Object[] rangeSnapshot = value.toArray(); - ArrayList mappedValue = new ArrayList(rangeSnapshot.length); - for (Object obj : rangeSnapshot) - mappedValue.add(map.inverseMap(g, (Range)obj));//map.inverseGet((Range)obj)); - return domainAccessor.set(g, domainElement, mappedValue); - } - - @Override - public boolean updateRange(ReadGraph g, IForwardMapping map, - Domain domainElement, Range rangeElement) - throws MappingException { - LOGGER.info(" MappedElementsRule.updateRange"); - Collection value = domainAccessor.get(g, domainElement); - ArrayList mappedValue = new ArrayList(value.size()); - for(Domain r : value) - mappedValue.add(map.map(g, r));//map.get(r)); - return rangeAccessor.set(rangeElement, mappedValue); - } - - public void createDomain(WriteGraph g, IBackwardMapping map, Domain domainElement, Range rangeElement) throws MappingException { - updateDomain(g, map, domainElement, rangeElement); - }; - - public void createRange(ReadGraph g, IForwardMapping map, Domain domainElement, Range rangeElement) throws MappingException { - updateRange(g, map, domainElement, rangeElement); - }; -} +/******************************************************************************* + * Copyright (c) 2007, 2013 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.objmap.graph.rules; + +import java.util.ArrayList; +import java.util.Collection; +import java.util.Objects; + +import org.simantics.db.ReadGraph; +import org.simantics.db.WriteGraph; +import org.simantics.objmap.backward.IBackwardMapping; +import org.simantics.objmap.bidirectional.IBidirectionalMappingRule; +import org.simantics.objmap.exceptions.MappingException; +import org.simantics.objmap.forward.IForwardMapping; +import org.simantics.objmap.graph.rules.domain.IDomainAccessor; +import org.simantics.objmap.graph.rules.range.IRangeAccessor; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + + +/** + * A rule that synchronizes collection of elements between + * domain and range accessors. Elements are mapped from + * between domain and range during the synchronization. + * @author Hannu Niemistö + */ +public class MappedElementsRule implements IBidirectionalMappingRule { + + static final Logger LOGGER = LoggerFactory.getLogger(MappedElementsRule.class); + + IDomainAccessor> domainAccessor; + IRangeAccessor> rangeAccessor; + + public MappedElementsRule(IDomainAccessor> domainAccessor, + IRangeAccessor> rangeAccessor) { + this.domainAccessor = domainAccessor; + this.rangeAccessor = rangeAccessor; + } + + @Override + public boolean updateDomain(WriteGraph g, IBackwardMapping map, + Domain domainElement, Range rangeElement) + throws MappingException { + LOGGER.trace(" MappedElementsRule.updateDomain"); + // Snapshot the accessed range value for concurrency safety. + // NOTE: still assumes that the accessed collection is concurrent or + // synchronized for toArray to be atomic. + Collection value = rangeAccessor.get(rangeElement); + Object[] rangeSnapshot = value.toArray(); + ArrayList mappedValue = new ArrayList(rangeSnapshot.length); + for (Object obj : rangeSnapshot) + mappedValue.add(map.inverseMap(g, (Range)obj));//map.inverseGet((Range)obj)); + return domainAccessor.set(g, domainElement, mappedValue); + } + + @Override + public boolean updateRange(ReadGraph g, IForwardMapping map, + Domain domainElement, Range rangeElement) + throws MappingException { + LOGGER.trace(" MappedElementsRule.updateRange"); + ArrayList mappedValue = getMappedValue(g, map, domainElement); + return rangeAccessor.set(rangeElement, mappedValue); + } + + @Override + public boolean checkChanges(ReadGraph g, IForwardMapping map, Domain domainElement, Range rangeElement) throws MappingException { + LOGGER.trace(" MappedElementsRule.updateRange"); + ArrayList mappedValue = getMappedValue(g, map, domainElement); + return !Objects.equals(mappedValue, rangeAccessor.get(rangeElement)); + } + + private ArrayList getMappedValue(ReadGraph g, IForwardMapping map, Domain domainElement) + throws MappingException { + Collection value = domainAccessor.get(g, domainElement); + ArrayList mappedValue = new ArrayList(value.size()); + for(Domain r : value) + mappedValue.add(map.map(g, r));//map.get(r)); + return mappedValue; + } + + public void createDomain(WriteGraph g, IBackwardMapping map, Domain domainElement, Range rangeElement) throws MappingException { + updateDomain(g, map, domainElement, rangeElement); + }; + + public void createRange(ReadGraph g, IForwardMapping map, Domain domainElement, Range rangeElement) throws MappingException { + updateRange(g, map, domainElement, rangeElement); + }; +}