| /******************************************************************************* |
| * Copyright (C) 2007 The University of Manchester |
| * |
| * Modifications to the initial code base are copyright of their |
| * respective authors, or their employers as appropriate. |
| * |
| * This program is free software; you can redistribute it and/or |
| * modify it under the terms of the GNU Lesser General Public License |
| * as published by the Free Software Foundation; either version 2.1 of |
| * the License, or (at your option) any later version. |
| * |
| * This program is distributed in the hope that it will be useful, but |
| * WITHOUT ANY WARRANTY; without even the implied warranty of |
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
| * Lesser General Public License for more details. |
| * |
| * You should have received a copy of the GNU Lesser General Public |
| * License along with this program; if not, write to the Free Software |
| * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 |
| ******************************************************************************/ |
| package net.sf.taverna.t2.workflowmodel.processor.iteration; |
| |
| import java.util.Map; |
| |
| import net.sf.taverna.t2.invocation.Completion; |
| import net.sf.taverna.t2.workflowmodel.processor.activity.Job; |
| |
| /** |
| * Acts as the input to a stage within the iteration strategy, passes all jobs |
| * straight through. NamedInputPortNode objects are, as the name suggests, |
| * named. These names correspond to the names of abstract input ports on the |
| * Processor object to which the iteration strategy belongs. |
| * |
| * @author Tom Oinn |
| * |
| */ |
| public class NamedInputPortNode extends AbstractIterationStrategyNode { |
| |
| private String portName; |
| |
| private int desiredCardinality; |
| |
| public NamedInputPortNode(String name, int cardinality) { |
| super(); |
| this.portName = name; |
| this.desiredCardinality = cardinality; |
| } |
| |
| /** |
| * If this node receives a job it will always be pushed without modification |
| * up to the parent |
| */ |
| public void receiveJob(int inputIndex, Job newJob) { |
| pushJob(newJob); |
| } |
| |
| /** |
| * Completion events are passed straight through the same as jobs |
| */ |
| public void receiveCompletion(int inputIndex, Completion completion) { |
| pushCompletion(completion); |
| } |
| |
| /** |
| * Each node maps to a single named input port within the processor |
| */ |
| public String getPortName() { |
| return this.portName; |
| } |
| |
| /** |
| * Each node defines the level of collection depth for that input port |
| */ |
| public int getCardinality() { |
| return this.desiredCardinality; |
| } |
| |
| /** |
| * These nodes correspond to inputs to the iteration strategy and are always |
| * leaf nodes as a result. |
| * |
| * @override |
| */ |
| @Override |
| public boolean isLeaf() { |
| return true; |
| } |
| |
| /** |
| * These nodes can never have children |
| * |
| * @override |
| */ |
| @Override |
| public boolean getAllowsChildren() { |
| return false; |
| } |
| |
| /** |
| * Iteration depth is the difference between the supplied input depth and |
| * the desired one. If the desired depth is greater then wrapping will |
| * happen and the iteration depth will be zero (rather than a negative!) |
| */ |
| public int getIterationDepth(Map<String, Integer> inputDepths) { |
| int myInputDepth = inputDepths.get(portName); |
| int depthMismatch = myInputDepth - desiredCardinality; |
| return (depthMismatch > 0 ? depthMismatch : 0); |
| } |
| |
| @Override |
| public String toString() { |
| return getClass().getSimpleName() + " " + getPortName() + "(" |
| + getCardinality() + ")"; |
| } |
| |
| } |