[Swift-commit] r2185 - trunk/src/org/griphyn/vdl/karajan

[noreply at svn.ci.uchicago.edu]

Author: benc
Date: 2008-08-08 10:08:00 -0500 (Fri, 08 Aug 2008)
New Revision: 2185

Modified:
   trunk/src/org/griphyn/vdl/karajan/VDSTaskTransformer.java
Log:
remove constructor and associated methods that were not used and were dependent on VDS precompiled code

Modified: trunk/src/org/griphyn/vdl/karajan/VDSTaskTransformer.java
===================================================================
--- trunk/src/org/griphyn/vdl/karajan/VDSTaskTransformer.java	2008-08-08 15:04:15 UTC (rev 2184)
+++ trunk/src/org/griphyn/vdl/karajan/VDSTaskTransformer.java	2008-08-08 15:08:00 UTC (rev 2185)
@@ -21,7 +21,6 @@
 import org.globus.cog.karajan.util.Contact;
 import org.globus.cog.karajan.workflow.KarajanRuntimeException;
 import org.griphyn.common.catalog.TransformationCatalogEntry;
-import org.griphyn.common.catalog.transformation.Mapper;
 import org.griphyn.common.classes.TCType;
 import org.griphyn.vdl.util.FQN;
 
@@ -32,10 +31,6 @@
 	private Scheduler scheduler;
 	private Set checkedTRs;
 
-	public VDSTaskTransformer(Mapper tcmapper) {
-		this.impl = new MapperTransformer(tcmapper);
-	}
-
 	public VDSTaskTransformer(TCCache tc) {
 		this.impl = new TCTransformer(tc);
 	}
@@ -130,37 +125,6 @@
 		protected abstract void applyTCEntry(Task task, Contact[] contacts);
 	}
 
-	public static class MapperTransformer extends AbstractTransformer {
-		private Mapper tcmapper;
-
-		public MapperTransformer(Mapper tcmapper) {
-			this.tcmapper = tcmapper;
-		}
-
-		protected void applyTCEntry(Task task, Contact[] contacts) {
-			JobSpecification spec = (JobSpecification) task.getSpecification();
-			BoundContact bc = (BoundContact) contacts[0];
-			List l = new LinkedList();
-			l.add(bc.getHost());
-			TransformationCatalogEntry tce;
-			Map siteMap = tcmapper.getSiteMap(null, spec.getExecutable(), null, l);
-			if (siteMap == null) {
-				return;
-			}
-			Object e = siteMap.get(bc.getHost());
-			if (e instanceof List) {
-				tce = (TransformationCatalogEntry) ((List) e).get(0);
-			}
-			else if (e instanceof TransformationCatalogEntry) {
-				tce = (TransformationCatalogEntry) e;
-			}
-			else {
-				throw new KarajanRuntimeException("Invalid object in transformation catalog: " + e);
-			}
-			spec.setExecutable(tce.getPhysicalTransformation());
-		}
-	}
-
 	public static class TCTransformer extends AbstractTransformer {
 		private TCCache tc;
 		private Set warnset = new HashSet();