Changeset 1170 for DCWoRMS/branches/coolemall/src/simulator
- Timestamp:
- 08/02/13 09:09:28 (12 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/simulator/workload/WorkloadLoader.java
r1164 r1170 17 17 import javax.xml.xpath.XPathExpressionException; 18 18 19 20 19 import org.apache.commons.logging.Log; 21 20 import org.apache.commons.logging.LogFactory; 22 21 import org.exolab.castor.xml.MarshalException; 23 22 import org.exolab.castor.xml.ValidationException; 24 import org.qcg.broker.schemas.jobdesc.ParentType;25 import org.qcg.broker.schemas.jobdesc.ResourceConsumptionProfileType;26 import org.qcg.broker.schemas.jobdesc.Task;27 import org.qcg.broker.schemas.jobdesc.Workflow;28 import org.qcg.broker.schemas.jobdesc.types.TaskStatesName;29 30 import dcworms.schedframe.scheduling.utils.JobDescription;31 import dcworms.schedframe.scheduling.utils.TaskDescription;32 33 23 34 24 import simulator.utils.XsltTransformations; … … 37 27 import simulator.workload.reader.archive.QcgWAJobReader; 38 28 import simulator.workload.reader.archive.WAFields; 29 import simulator.workload.reader.archive.WAParser; 39 30 import simulator.workload.reader.archive.WAReader; 40 import simulator.workload.reader.archive.WAParser;41 31 import simulator.workload.reader.archive.gwf.GWFFields; 42 32 import simulator.workload.reader.archive.swf.SWFFields; 43 33 import simulator.workload.reader.xmlJob.XMLJobReader; 34 import dcworms.schedframe.scheduling.utils.JobDescription; 35 import dcworms.schedframe.scheduling.utils.TaskDescription; 44 36 45 37 /** … … 221 213 222 214 while((jobDesc = this.waReader.readRaw()) != null){ 223 /*QcgWAJobReader qcgReader = (QcgWAJobReader)waReader;215 QcgWAJobReader qcgReader = (QcgWAJobReader)waReader; 224 216 if(!applicationProfilesMap.isEmpty()) 225 jobDesc = qcgReader.mergeSwfAndXmlProfile(applicationProfilesMap, jobDesc); */217 jobDesc = qcgReader.mergeSwfAndXmlProfile(applicationProfilesMap, jobDesc); 226 218 job = createJobDescription(jobDesc, puSpeed); 227 if(job!= null && !applicationProfilesMap.isEmpty()){219 /*if(job!= null && !applicationProfilesMap.isEmpty()){ 228 220 for(int i = 0; i < job.getDescription().getTaskCount(); i++){ 229 221 try { … … 243 235 } 244 236 } 245 237 */ 246 238 if(job != null) 247 239 this.jobsMap.put(job.getJobId(), job);
Note: See TracChangeset
for help on using the changeset viewer.