--- /dev/null
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2013 Association for Decentralized Information Management\r
+ * in Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ * VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.objmap.graph.impl;\r
+\r
+\r
+import gnu.trove.map.hash.THashMap;\r
+\r
+import java.util.AbstractSet;\r
+import java.util.ArrayList;\r
+import java.util.Collection;\r
+import java.util.Iterator;\r
+import java.util.List;\r
+import java.util.Set;\r
+\r
+import org.apache.log4j.Logger;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.WriteGraph;\r
+import org.simantics.db.exception.DatabaseException;\r
+\r
+import org.simantics.objmap.backward.IBackwardMapping;\r
+import org.simantics.objmap.exceptions.MappingException;\r
+import org.simantics.objmap.forward.IForwardMapping;\r
+import org.simantics.objmap.graph.IMapping;\r
+import org.simantics.objmap.graph.IMappingListener;\r
+import org.simantics.objmap.graph.schema.ILinkType;\r
+import org.simantics.objmap.graph.schema.IMappingSchema;\r
+\r
+/**\r
+ * An implementation of IMapping. The class should not be created\r
+ * directly but using methods in Mappings.\r
+ * @see org.simantics.objmap.graph.Mappings\r
+ * @author Hannu Niemistö\r
+ */\r
+public class Mapping<Domain, Range> implements IMapping<Domain, Range> {\r
+\r
+ static Logger LOGGER = Logger.getLogger("org.simantics.objmap");\r
+ \r
+ \r
+ IMappingSchema<Domain, Range> schema;\r
+ \r
+ THashMap<Domain, Link<Domain,Range>> domain = new THashMap<Domain, Link<Domain,Range>>();\r
+ THashMap<Range, Link<Domain,Range>> range = new THashMap<Range, Link<Domain,Range>>();\r
+ ArrayList<IMappingListener> listeners = new ArrayList<IMappingListener>();\r
+\r
+ ArrayList<Link<Domain,Range>> modifiedDomainLinks = new ArrayList<Link<Domain,Range>>();\r
+ ArrayList<Link<Domain,Range>> modifiedRangeLinks = new ArrayList<Link<Domain,Range>>();\r
+\r
+ boolean disposed = false;\r
+ \r
+ boolean listensDomain; \r
+ \r
+ public Mapping(IMappingSchema<Domain, Range> schema, boolean listensDomain) {\r
+ this.schema = schema;\r
+ this.listensDomain = listensDomain;\r
+ }\r
+ \r
+ private void removeLink(Link<Domain,Range> link) {\r
+ if(link.domainModified)\r
+ modifiedDomainLinks.remove(link);\r
+ if(link.rangeModified)\r
+ modifiedRangeLinks.remove(link);\r
+ link.removed = true;\r
+ }\r
+ \r
+ private void createDomain(WriteGraph g, Link<Domain,Range> link) throws MappingException {\r
+ LOGGER.info(" createDomain for " + link.rangeElement);\r
+ ILinkType<Domain,Range> type = schema.linkTypeOfRangeElement(link.rangeElement);\r
+ Domain domainElement = type.createDomainElement(g, link.rangeElement);\r
+ link.type = type;\r
+ link.domainElement = domainElement;\r
+ domain.put(domainElement, link);\r
+ type.createDomain(g, new RangeToDomain(g), domainElement, link.rangeElement);\r
+ \r
+ // TODO Should we do this only if the mapping is listening?\r
+ domainModified(link);\r
+ }\r
+ \r
+ private void createRange(ReadGraph g, Link<Domain,Range> link) throws MappingException {\r
+ ILinkType<Domain,Range> type = schema.linkTypeOfDomainElement(g, link.domainElement); \r
+ Range rangeElement = type.createRangeElement(g, link.domainElement);\r
+ \r
+ link.type = type;\r
+ link.rangeElement = rangeElement;\r
+ range.put(rangeElement, link);\r
+ type.createRange(g, new DomainToRange(g), link.domainElement, rangeElement);\r
+ }\r
+ \r
+ Set<Domain> domainSet = new AbstractSet<Domain>() {\r
+\r
+ public boolean add(Domain e) {\r
+ if(domain.containsKey(e))\r
+ return false;\r
+ Link<Domain,Range> link = new Link<Domain,Range>(null, e, null);\r
+ domain.put(e, link);\r
+ modifiedDomainLinks.add(link);\r
+ return true;\r
+ }\r
+ \r
+ public boolean contains(Object o) {\r
+ return domain.contains(o);\r
+ }\r
+ \r
+ public boolean remove(Object o) {\r
+ Link<Domain,Range> link = domain.remove(o); \r
+ if(link == null)\r
+ return false;\r
+ removeLink(link);\r
+ if(link.rangeElement != null)\r
+ range.remove(link.rangeElement);\r
+ return true; \r
+ }\r
+ \r
+ @Override\r
+ public Iterator<Domain> iterator() {\r
+ // FIXME does not implement Iterator.remove correctly\r
+ return domain.keySet().iterator();\r
+ }\r
+\r
+ @Override\r
+ public int size() {\r
+ return domain.size();\r
+ }\r
+ \r
+ };\r
+ \r
+ Set<Range> rangeSet = new AbstractSet<Range>() {\r
+\r
+ public boolean add(Range e) {\r
+ if(range.containsKey(e))\r
+ return false;\r
+ Link<Domain,Range> link = new Link<Domain,Range>(null, null, e);\r
+ range.put(e, link);\r
+ modifiedRangeLinks.add(link);\r
+ return true;\r
+ }\r
+ \r
+ public boolean contains(Object o) {\r
+ return range.contains(o);\r
+ }\r
+ \r
+ public boolean remove(Object o) {\r
+ Link<Domain,Range> link = range.remove(o); \r
+ if(link == null)\r
+ return false;\r
+ removeLink(link);\r
+ if(link.domainElement != null)\r
+ domain.remove(link.domainElement);\r
+ return true;\r
+ }\r
+ \r
+ @Override\r
+ public Iterator<Range> iterator() {\r
+ // FIXME does not implement Iterator.remove correctly\r
+ return range.keySet().iterator();\r
+ }\r
+\r
+ @Override\r
+ public int size() {\r
+ return range.size();\r
+ }\r
+ \r
+ };\r
+ \r
+ class DomainToRange implements IForwardMapping<Domain, Range> {\r
+\r
+ ReadGraph g;\r
+ \r
+ public DomainToRange(ReadGraph g) {\r
+ this.g = g;\r
+ }\r
+\r
+ @Override\r
+ public Range get(Domain element) {\r
+ Link<Domain,Range> link = domain.get(element);\r
+ if (link != null)\r
+ return link.rangeElement;\r
+ return null;\r
+ \r
+ }\r
+ \r
+ @Override\r
+ public Range map(ReadGraph graph, Domain element)\r
+ throws MappingException {\r
+ Link<Domain,Range> link = domain.get(element);\r
+ if(link == null) {\r
+ link = new Link<Domain,Range>(null, element, null);\r
+ link.domainModified = true;\r
+ modifiedDomainLinks.add(link);\r
+ domain.put(element, link); \r
+ createRange(g, link); \r
+ }\r
+ else if(link.type == null) \r
+ createRange(g, link);\r
+ return link.rangeElement;\r
+ }\r
+ \r
+ @Override\r
+ public Set<Domain> getDomain() {\r
+ return domain.keySet();\r
+ }\r
+ \r
+ };\r
+ \r
+ class RangeToDomain extends DomainToRange implements IBackwardMapping<Domain, Range> {\r
+\r
+ WriteGraph g;\r
+ \r
+ public RangeToDomain(WriteGraph g) {\r
+ super(g);\r
+ this.g = g;\r
+ }\r
+ @Override\r
+ public Domain inverseGet(Range element) {\r
+ \r
+ Link<Domain,Range> link = range.get(element);\r
+ if(link != null)\r
+ return link.domainElement;\r
+ return null;\r
+ }\r
+ \r
+ @Override\r
+ public Domain inverseMap(WriteGraph graph, Range element)\r
+ throws MappingException {\r
+ Link<Domain,Range> link = range.get(element);\r
+ if(link == null) {\r
+ link = new Link<Domain,Range>(null, null, element);\r
+ link.rangeModified = true;\r
+ modifiedRangeLinks.add(link);\r
+ range.put(element, link);\r
+ createDomain(g, link); \r
+ }\r
+ else if(link.type == null)\r
+ createDomain(g, link);\r
+ return link.domainElement;\r
+ }\r
+ \r
+ \r
+ @Override\r
+ public Set<Range> getRange() {\r
+ return range.keySet();\r
+ }\r
+ };\r
+ \r
+ @Override\r
+ public Set<Domain> getDomain() {\r
+ return domainSet;\r
+ }\r
+ \r
+ @Override\r
+ public Set<Range> getRange() {\r
+ return rangeSet;\r
+ }\r
+ \r
+ \r
+ @Override\r
+ public synchronized Collection<Domain> updateDomain(WriteGraph g) throws MappingException {\r
+ LOGGER.info("Mapping.updateDomain");\r
+ RangeToDomain map = new RangeToDomain(g);\r
+ ArrayList<Domain> updated = new ArrayList<Domain>();\r
+ while(!modifiedRangeLinks.isEmpty()) {\r
+ LOGGER.info(" modifiedRangeLinks.size() = " + modifiedRangeLinks.size());\r
+ \r
+ Link<Domain,Range> link = modifiedRangeLinks.remove(modifiedRangeLinks.size()-1);\r
+ link.rangeModified = false;\r
+ /*if(link.domainModified) {\r
+ link.domainModified = false;\r
+ modifiedDomainLinks.remove(link);\r
+ }*/\r
+ \r
+ if(link.type == null) {\r
+ createDomain(g, link);\r
+ }\r
+ \r
+ if(link.type.updateDomain(g, map, link.domainElement, link.rangeElement))\r
+ updated.add(link.domainElement);\r
+ } \r
+ if (listensDomain)\r
+ updateRange(g); //FIXME: without this listening would stop. \r
+ return updated;\r
+ }\r
+ \r
+ @Override\r
+ public synchronized Collection<Range> updateRange(ReadGraph g) throws MappingException {\r
+ LOGGER.info("Mapping.updateRange");\r
+ DomainToRange map = new DomainToRange(g);\r
+ ArrayList<Range> updated = new ArrayList<Range>();\r
+ while(!modifiedDomainLinks.isEmpty()) { \r
+ LOGGER.info(" modifiedDomainLinks.size() = " + modifiedDomainLinks.size());\r
+ \r
+ Link<Domain,Range> link = modifiedDomainLinks.remove(modifiedDomainLinks.size()-1);\r
+ link.domainModified = false;\r
+ /*if(link.rangeModified) {\r
+ link.rangeModified = false;\r
+ modifiedRangeLinks.remove(link);\r
+ }*/\r
+ \r
+ if(link.type == null) {\r
+ createRange(g, link);\r
+ }\r
+ \r
+ if(listensDomain) {\r
+ RangeUpdateRequest<Domain,Range> request = new RangeUpdateRequest<Domain,Range>(link, map, this);\r
+ try {\r
+ g.syncRequest(request, request);\r
+ } catch (DatabaseException e) {\r
+ throw new MappingException(e);\r
+ }\r
+ // TODO check if really modified\r
+ updated.add(link.rangeElement);\r
+ }\r
+ else\r
+ if(link.type.updateRange(g, map, link.domainElement, link.rangeElement))\r
+ updated.add(link.rangeElement);\r
+ } \r
+ return updated;\r
+ }\r
+\r
+ @Override\r
+ public Range get(Domain domainElement) {\r
+ Link<Domain,Range> link = domain.get(domainElement);\r
+ if(link == null)\r
+ return null;\r
+ return link.rangeElement;\r
+ }\r
+\r
+ @Override\r
+ public Domain inverseGet(Range rangeElement) {\r
+ Link<Domain,Range> link = range.get(rangeElement);\r
+ if(link == null)\r
+ return null;\r
+ return link.domainElement;\r
+ }\r
+\r
+ @Override\r
+ public Domain inverseMap(WriteGraph g, Range rangeElement) throws MappingException {\r
+ getRange().add(rangeElement);\r
+ updateDomain(g);\r
+ return inverseGet(rangeElement);\r
+ }\r
+\r
+ @Override\r
+ public Range map(ReadGraph g, Domain domainElement) throws MappingException {\r
+ getDomain().add(domainElement);\r
+ updateRange(g);\r
+ return get(domainElement);\r
+ }\r
+\r
+ void domainModified(Link<Domain,Range> link) {\r
+ if(!link.domainModified) { \r
+ synchronized(modifiedDomainLinks) {\r
+ LOGGER.info(" domainModified for " + link.rangeElement);\r
+ link.domainModified = true;\r
+ modifiedDomainLinks.add(link);\r
+ if(modifiedDomainLinks.size() == 1) {\r
+ for(IMappingListener listener : listeners)\r
+ listener.domainModified();\r
+ }\r
+ }\r
+ }\r
+ }\r
+ \r
+ @Override\r
+ public void domainModified(Domain domainElement) {\r
+ Link<Domain,Range> link = domain.get(domainElement);\r
+ if(link != null)\r
+ domainModified(link);\r
+ }\r
+\r
+ void rangeModified(Link<Domain,Range> link) {\r
+ if(!link.rangeModified) {\r
+ synchronized(modifiedRangeLinks) {\r
+ link.rangeModified = true;\r
+ modifiedRangeLinks.add(link);\r
+ if(modifiedRangeLinks.size() == 1) {\r
+ for(IMappingListener listener : listeners)\r
+ listener.rangeModified();\r
+ }\r
+ }\r
+ }\r
+ }\r
+ \r
+ @Override\r
+ public void rangeModified(Range rangeElement) {\r
+ Link<Domain,Range> link = range.get(rangeElement);\r
+ if(link != null)\r
+ rangeModified(link);\r
+ }\r
+\r
+ @Override\r
+ public boolean isDomainModified() {\r
+ return !modifiedDomainLinks.isEmpty();\r
+ }\r
+\r
+ @Override\r
+ public boolean isRangeModified() {\r
+ return !modifiedRangeLinks.isEmpty();\r
+ }\r
+ \r
+ @Override\r
+ public Collection<Domain> getDomainModified() {\r
+ List<Domain> list = new ArrayList<Domain>(modifiedDomainLinks.size());\r
+ for (Link<Domain, Range> link : modifiedDomainLinks)\r
+ list.add(link.domainElement);\r
+ return list;\r
+ \r
+ }\r
+ \r
+ @Override\r
+ public Collection<Range> getRangeModified() {\r
+ List<Range> list = new ArrayList<Range>(modifiedRangeLinks.size());\r
+ for (Link<Domain, Range> link : modifiedRangeLinks)\r
+ list.add(link.rangeElement);\r
+ return list;\r
+ }\r
+\r
+ @Override\r
+ public void addMappingListener(IMappingListener listener) {\r
+ listeners.add(listener);\r
+ }\r
+\r
+ @Override\r
+ public void removeMappingListener(IMappingListener listener) {\r
+ listeners.remove(listener); \r
+ }\r
+\r
+ @Override\r
+ public Collection<Domain> getConflictingDomainElements() {\r
+ ArrayList<Domain> result = new ArrayList<Domain>();\r
+ if(modifiedDomainLinks.size() < modifiedRangeLinks.size()) {\r
+ for(Link<Domain,Range> link : modifiedDomainLinks)\r
+ if(link.rangeModified)\r
+ result.add(link.domainElement);\r
+ }\r
+ else {\r
+ for(Link<Domain,Range> link : modifiedRangeLinks)\r
+ if(link.domainModified)\r
+ result.add(link.domainElement);\r
+ }\r
+ return result;\r
+ }\r
+\r
+ @Override\r
+ public Collection<Range> getConflictingRangeElements() {\r
+ ArrayList<Range> result = new ArrayList<Range>();\r
+ if(modifiedDomainLinks.size() < modifiedRangeLinks.size()) {\r
+ for(Link<Domain,Range> link : modifiedDomainLinks)\r
+ if(link.rangeModified)\r
+ result.add(link.rangeElement);\r
+ }\r
+ else {\r
+ for(Link<Domain,Range> link : modifiedRangeLinks)\r
+ if(link.domainModified)\r
+ result.add(link.rangeElement);\r
+ }\r
+ return result;\r
+ }\r
+\r
+ @Override\r
+ public void dispose() {\r
+ disposed = true;\r
+ }\r
+ \r
+ public boolean isDisposed() {\r
+ return disposed;\r
+ }\r
+ \r
+}\r
Code Review / simantics / platform.git / blobdiff